Contents

module Ddr::Batch
  class ProcessBatchObject

    attr_reader :batch_object_id, :operator

    def initialize(batch_object_id:, operator:)
      @batch_object_id = batch_object_id
      @operator = operator
    end

    def execute
      ActiveSupport::Notifications.instrument("handled.batchobject.batch.ddr",
                                              batch_object_id: batch_object_id) do |payload|
        batch_object = BatchObject.find(batch_object_id)
        # Validate batch object
        errors = batch_object.validate
        # Process batch object or record validation errors
        if errors.empty?
          process(batch_object, operator)
        else
          record_errors(batch_object, errors)
        end
        # return true if batch_object was processed; otherwise, false
        batch_object.processed? ? true : false
      end
    end

    def process(batch_object, operator)
      batch_object.update!(validated: true)
      batch_object.process(operator)
      batch_object.update!(processed: true)
      results_message = batch_object.results_message
      Ddr::Batch::BatchObjectMessage.create!(batch_object: batch_object,
                                             level: results_message.level,
                                             message: results_message.message)
    end

    def record_errors(batch_object, errors)
      errors.each do |error|
        Ddr::Batch::BatchObjectMessage.create!(batch_object: batch_object,
                                               level: Logger::ERROR,
                                               message: error)
      end
    end
  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version	Path
ddr-batch-1.7.2	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.7.1	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.7.0	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.6.1	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.6.0	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.6.0.rc1	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.5.1	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.5.0	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.5.0.rc1	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.4.1	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.4.0	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.4.0.rc1	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.3.0	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.3.0.rc1	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.2.0	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.2.0.rc6	app/services/ddr/batch/process_batch_object.rb
ddr-batch-1.2.0.rc5	app/services/ddr/batch/process_batch_object.rb