Contents

module BridgeCache::Jobs
  class ImportData < ActiveJob::Base
    include BridgeCache::Utils::WorkerHelper
    queue_as :default

    def perform(account_settings, chain = [])
      account_settings = account_settings.with_indifferent_access
      remote_data = BridgeBlueprint::RemoteData.new(account_settings[:url], account_settings[:api_key], account_settings[:api_secret])
      Dir.mktmpdir do |dir|
        path = "#{dir}/data_dump"
        remote_data.store_file(path)
        import = BridgeBlueprint::DataDump.new(path)
        models = account_settings[:models] || BridgeCache.resolved_models(account_settings[:is_subaccount])
        models.each do |model|
          ids = []
          ids << BridgeCache::Plugins::CSVDump.bulk_import(import, model)
          BridgeCache::Jobs::CleanupJob.set(queue: queue_name).perform_later(model, ids)
        end
      end
      BridgeCache::Utils::WorkerHelper.invoke_next(chain)
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
bridge_cache-0.3.19	app/lib/bridge_cache/jobs/import_data.rb
bridge_cache-0.3.17	app/lib/bridge_cache/jobs/import_data.rb
bridge_cache-0.3.16	app/lib/bridge_cache/jobs/import_data.rb
bridge_cache-0.3.15	app/lib/bridge_cache/jobs/import_data.rb
bridge_cache-0.3.14	app/lib/bridge_cache/jobs/import_data.rb