Contents

# frozen_string_literal: true

require "active_support/callbacks"

# Following approach used by ActiveJob
# https://github.com/rails/rails/blob/93c9534c9871d4adad4bc33b5edc355672b59c61/activejob/lib/active_job/callbacks.rb
module SidekiqCallbacks
  extend ActiveSupport::Concern

  def self.prepended(base)
    base.include(ActiveSupport::Callbacks)

    # Check to see if we already have any callbacks for :perform
    # Prevents overwriting callbacks if we already included this module (and defined callbacks)
    base.define_callbacks :perform unless base.respond_to?(:_perform_callbacks) && base._perform_callbacks.present?

    class << base
      prepend ClassMethods
    end
  end

  def perform(*args)
    if respond_to?(:run_callbacks)
      run_callbacks :perform do
        super(*args)
      end
    else
      super(*args)
    end
  end

  module ClassMethods
    def around_perform(*filters, &blk)
      set_callback(:perform, :around, *filters, &blk)
    end

    def before_perform(*filters, &blk)
      set_callback(:perform, :before, *filters, &blk)
    end

    def after_perform(*filters, &blk)
      set_callback(:perform, :after, *filters, &blk)
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

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