Class: BridgeCache::Jobs::ImportCheck

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

Instance Method Summary collapse

Methods included from Utils::WorkerHelper

invoke_next

Instance Method Details

#max_import_attempts ⇒ Object 



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

def max_import_attempts
  ENV.fetch('BRIDGE_CACHE_MAX_IMPORT_ATTEMPTS', 30)
end

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



17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'app/lib/bridge_cache/jobs/import_check.rb', line 17

def perform(, attempts, chain = [], retries = 0)
  @account_settings = .with_indifferent_access

  if attempts > max_import_attempts
    Rails.logger.fatal("Bridge data dump failed to download after #{(max_import_attempts * 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

    raise 'Bridge data dump download failed' if retries < 1

    BridgeCache::Jobs::ImportStart.set(queue: queue_name).perform_later(@account_settings, chain, retries - 1)
  end
end

#remote_data ⇒ Object 



12
13
14
15
 
# File 'app/lib/bridge_cache/jobs/import_check.rb', line 12

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