Sha256: d600d385b712558fc67c572d7f2c322c7510248b3576b1094767017cc73714b9
Contents?: true
Size: 1.35 KB
Versions: 8
Compression:
Stored size: 1.35 KB
Contents
# frozen_string_literal: true
module Bulkrax
class ImporterJob < ApplicationJob
queue_as :import
def perform(importer_id, only_updates_since_last_import = false)
importer = Importer.find(importer_id)
importer.current_run
unzip_imported_file(importer.parser)
import(importer, only_updates_since_last_import)
update_current_run_counters(importer)
schedule(importer) if importer.schedulable?
rescue ::CSV::MalformedCSVError => e
importer.set_status_info(e)
end
def import(importer, only_updates_since_last_import)
importer.only_updates = only_updates_since_last_import || false
return unless importer.valid_import?
importer.import_objects
end
def unzip_imported_file(parser)
return unless parser.file? && parser.zip?
parser.unzip(parser.parser_fields['import_file_path'])
end
def update_current_run_counters(importer)
importer.current_run.total_work_entries = importer.limit || importer.parser.works_total
importer.current_run.total_collection_entries = importer.parser.collections_total
importer.current_run.total_file_set_entries = importer.parser.file_sets_total
importer.current_run.save!
end
def schedule(importer)
ImporterJob.set(wait_until: importer.next_import_at).perform_later(importer.id, true)
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems