Contents

class BatchCreateJob < ActiveJob::Base
  queue_as :ingest

  before_enqueue do |job|
    log = job.arguments.last
    log.pending_job(self)
  end

  # This copies metadata from the passed in attribute to all of the works that
  # are members of the given upload set
  # @param [User] user
  # @param [Array<String>] titles
  # @param [Array<String>] resource_types
  # @param [Array<Sufia::UploadedFile>] uploaded_files
  # @param [Hash] attributes attributes to apply to all works
  # @param [BatchCreateOperation] log
  def perform(user, titles, resource_types, uploaded_files, attributes, log)
    log.performing!

    titles ||= {}
    resource_types ||= {}

    create(user, titles, resource_types, uploaded_files, attributes, log)
  end

  private

    def create(user, titles, resource_types, uploaded_files, attributes, log)
      uploaded_files.each do |upload_id|
        title = [titles[upload_id]] if titles[upload_id]
        resource_type = [resource_types[upload_id]] if resource_types[upload_id]
        attributes = attributes.merge(uploaded_files: [upload_id],
                                      title: title,
                                      resource_type: resource_type)
        model = model_to_create(attributes)
        child_log = CurationConcerns::Operation.create!(user: user,
                                                        operation_type: "Create Work",
                                                        parent: log)
        CreateWorkJob.perform_later(user, model, attributes, child_log)
      end
    end

    # Override this method if you have a different rubric for choosing the model
    # @param [Hash] attributes
    # @return String the model to create
    def model_to_create(attributes)
      Sufia.config.model_to_create.call(attributes)
    end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
sufia-7.2.0	app/jobs/batch_create_job.rb
sufia-7.1.0	app/jobs/batch_create_job.rb
sufia-7.0.0	app/jobs/batch_create_job.rb
sufia-7.0.0.rc2	app/jobs/batch_create_job.rb
sufia-7.0.0.rc1	app/jobs/batch_create_job.rb