Class: BridgeCache::Jobs::ImportCheck

Inherits:

ActiveJob::Base

• Object
• ActiveJob::Base
• BridgeCache::Jobs::ImportCheck

Includes:

Utils::WorkerHelper

Defined in:

app/lib/bridge_cache/jobs/import_check.rb

Constant Summary

ATTEMPTS_THRESHOLD =

30

Instance Method Summary

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

Methods included from Utils::WorkerHelper

invoke_next

Instance Method Details

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

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

def perform(account_settings, attempts, chain = [])
  account_settings = account_settings.with_indifferent_access
  remote_data = BridgeBlueprint::RemoteData.new(account_settings[:url], account_settings[:api_key], account_settings[:api_secret])
  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
    raise 'Bridge data dump download failed'
  end
end