Contents

# frozen_string_literal: true

module Bulkrax
  module ImporterExporterBehavior
    extend ActiveSupport::Concern

    def parser
      @parser ||= parser_class.new(self)
    end

    def parser_class
      self.parser_klass.constantize
    end

    def last_imported_at
      @last_imported_at ||= self.importer_runs.last&.created_at
    end

    def next_import_at
      (last_imported_at || Time.current) + frequency.to_seconds if schedulable? && last_imported_at.present?
    end

    def increment_counters(index, collection = false)
      # Only set the totals if they were not set on initialization
      if collection
        current_run.total_collection_entries = index + 1 unless parser.collections_total.positive?
      else
        current_run.total_work_entries = index + 1 unless limit.to_i.positive? || parser.total.positive?
      end
      current_run.enqueued_records = index + 1
      current_run.save!
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
bulkrax-1.0.2	app/models/concerns/bulkrax/importer_exporter_behavior.rb
bulkrax-1.0.1	app/models/concerns/bulkrax/importer_exporter_behavior.rb
bulkrax-1.0.0	app/models/concerns/bulkrax/importer_exporter_behavior.rb