Class: BridgeCache::Jobs::ImportCheck

Inherits:
ActiveJob::Base
  • Object
show all
Includes:
Utils::WorkerHelper
Defined in:
app/lib/bridge_cache/jobs/import_check.rb

Constant Summary collapse

ATTEMPTS_THRESHOLD = 
30

Instance Method Summary collapse

Methods included from Utils::WorkerHelper

invoke_next

Instance Method Details

#perform(account_settings, attempts, chain = [], retries = 0) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'app/lib/bridge_cache/jobs/import_check.rb', line 12

def perform(, attempts, chain = [], retries = 0)
  @account_settings = .with_indifferent_access
  if attempts > ATTEMPTS_THRESHOLD
    Rails.logger.fatal("Bridge data dump failed to download after #{(ATTEMPTS_THRESHOLD * 30) / 60} minutes")
  elsif remote_data.status == BridgeBlueprint::Constants::STATUS_COMPLETE
    BridgeCache::Jobs::ImportData.set(queue: queue_name).perform_later(@account_settings, chain)
  elsif remote_data.status == BridgeBlueprint::Constants::STATUS_PENDING
    BridgeCache::Jobs::ImportCheck.set(queue: queue_name, wait: 30.seconds).perform_later(@account_settings, attempts + 1, chain)
  elsif remote_data.status == BridgeBlueprint::Constants::STATUS_FAILED || remote_data.status == BridgeBlueprint::Constants::STATUS_NOT_FOUND
    if retries < 1
      raise 'Bridge data dump download failed'
    else
      BridgeCache::Jobs::ImportStart.set(queue: queue_name).perform_later(@account_settings, chain, retries - 1)
    end
  end
end

#remote_data ⇒ Object 



8
9
10
 
# File 'app/lib/bridge_cache/jobs/import_check.rb', line 8

def remote_data
  @remote_data ||= BridgeBlueprint::RemoteData.new(@account_settings[:url], @account_settings[:api_key], @account_settings[:api_secret])
end