Class: Workarea::FlowIo::ProcessImport

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::CallbacksWorker, Sidekiq::Worker
Defined in:
app/workers/workarea/flow_io/process_import.rb

Overview

Reads the CSV stored in a ‘Workarea::FlowIo::Import`, and processes each row with `FlatFileItem.import`

Instance Method Summary collapse

Instance Method Details

#perform(id) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'app/workers/workarea/flow_io/process_import.rb', line 13

def perform(id)
  import = Import.find(id)

  import.update!(started_at: Time.current)

  experiences = FlowIo.client.experiences.get(FlowIo.organization_id)

  CSV.foreach(import.file_path, headers: true) do |row|
    ImportedItem.process(row, experiences)
  end

  import.update!(completed_at: Time.current)
end