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

#perform(bridge_base_url, bridge_api_key, bridge_api_secret, models, chain = []) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
 
# File 'app/lib/bridge_cache/jobs/import_check.rb', line 6

def perform(bridge_base_url, bridge_api_key, bridge_api_secret, models, chain = [])
  remote_data = BridgeBlueprint::RemoteData.new(bridge_base_url, bridge_api_key, bridge_api_secret)
  if remote_data.status == BridgeBlueprint::Constants::STATUS_COMPLETE
    BridgeCache::Jobs::ImportData.set(queue: self.queue_name).perform_later(bridge_base_url, bridge_api_key, bridge_api_secret, models, chain)
  elsif remote_data.status == BridgeBlueprint::Constants::STATUS_PENDING
    BridgeCache::Jobs::ImportCheck.set(queue: self.queue_name, wait: 30.seconds).perform_later(bridge_base_url, bridge_api_key, bridge_api_secret, models, 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