Contents

# frozen_string_literal: true

require "active_record"
require "global_id"

module AcidicJob
  class Staged < ActiveRecord::Base
    self.table_name = "staged_acidic_jobs"

    include GlobalID::Identification

    validates :adapter, presence: true
    validates :job_name, presence: true
    validates :job_args, presence: true

    serialize :job_args

    after_create_commit :enqueue_job

    private

    # rubocop:disable Metrics/AbcSize, Metrics/MethodLength
    def enqueue_job
      gid = { "staged_job_gid" => to_global_id.to_s }

      if job_args.is_a?(Hash) && job_args.key?("arguments")
        job_args["arguments"].concat([gid])
      else
        job_args.concat([gid])
      end

      case adapter
      when "activejob"
        job = ActiveJob::Base.deserialize(job_args)
        job.enqueue
      when "sidekiq"
        Sidekiq::Client.push(
          "class" => job_name,
          "args" => job_args
        )
      else
        raise UnknownJobAdapter.new(adapter: adapter)
      end

      # NOTE: record will be deleted after the job has successfully been performed
      true
    end
    # rubocop:enable Metrics/AbcSize, Metrics/MethodLength
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
acidic_job-0.7.7	lib/acidic_job/staged.rb
acidic_job-0.7.6	lib/acidic_job/staged.rb
acidic_job-0.7.5	lib/acidic_job/staged.rb
acidic_job-0.7.4	lib/acidic_job/staged.rb
acidic_job-0.7.3	lib/acidic_job/staged.rb
acidic_job-0.7.2	lib/acidic_job/staged.rb
acidic_job-0.7.1	lib/acidic_job/staged.rb
acidic_job-0.7.0	lib/acidic_job/staged.rb