Contents

require 'active_support/core_ext/module/aliasing'

module Delayed
  class DelayProxy < Delayed::Compatibility.proxy_object_class
    def initialize(payload_class, target, options)
      @payload_class = payload_class
      @target = target
      @options = options
    end

    def method_missing(method, *args)
      Job.enqueue({:payload_object => @payload_class.new(@target, method.to_sym, args)}.merge(@options))
    end
  end

  module MessageSending
    def delay(options = {})
      DelayProxy.new(PerformableMethod, self, options)
    end
    alias_method :__delay__, :delay

    def send_later(method, *args)
      warn '[DEPRECATION] `object.send_later(:method)` is deprecated. Use `object.delay.method'
      __delay__.__send__(method, *args)
    end

    def send_at(time, method, *args)
      warn '[DEPRECATION] `object.send_at(time, :method)` is deprecated. Use `object.delay(:run_at => time).method'
      __delay__(:run_at => time).__send__(method, *args)
    end

    module ClassMethods
      def handle_asynchronously(method, opts = {})
        aliased_method, punctuation = method.to_s.sub(/([?!=])$/, ''), $1 # rubocop:disable PerlBackrefs
        with_method, without_method = "#{aliased_method}_with_delay#{punctuation}", "#{aliased_method}_without_delay#{punctuation}"
        define_method(with_method) do |*args|
          curr_opts = opts.clone
          curr_opts.each_key do |key|
            next unless (val = curr_opts[key]).is_a?(Proc)
            curr_opts[key] = if val.arity == 1
              val.call(self)
            else
              val.call
            end
          end
          delay(curr_opts).__send__(without_method, *args)
        end
        alias_method_chain method, :delay
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 2 rubygems

Version	Path
delayed_job_tgmerritt-4.0.7	lib/delayed/message_sending.rb
delayed_job-4.0.6	lib/delayed/message_sending.rb
delayed_job-4.0.5	lib/delayed/message_sending.rb
delayed_job-4.0.4	lib/delayed/message_sending.rb
delayed_job-4.0.3	lib/delayed/message_sending.rb