app/models/import/workbench.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

class Import::Workbench < Import::Base
  after_commit :launch_worker, :on => :create

  def launch_worker
    unless Import::Gtfs.accept_file?(file.path)
      WorkbenchImportWorker.perform_async(id)
    else
      import_gtfs
    end
  end

  # def main_resource
  #   @resource ||= resources.find_or_create_by(name: self.name, resource_type: "workbench_import")
  # end

  def import_gtfs
    update_column :status, 'running'
    update_column :started_at, Time.now

    Import::Gtfs.create! parent_type: self.class.name, parent_id: self.id, workbench: workbench, file: File.new(file.path), name: "Import GTFS", creator: "Web service"

    # update_column :status, 'successful'
    # update_column :ended_at, Time.now
  rescue Exception => e
    Rails.logger.error "Error while processing GTFS file: #{e}"

    update_column :status, 'failed'
    update_column :ended_at, Time.now
  end
end