require 'sidekiq/extensions/generic_proxy' module Sidekiq module Extensions ## # Adds 'delay', 'delay_for' and `delay_until` methods to ActionMailer to offload arbitrary email # delivery to Sidekiq. Example: # # UserMailer.delay.send_welcome_email(new_user) # UserMailer.delay_for(5.days).send_welcome_email(new_user) # UserMailer.delay_until(5.days.from_now).send_welcome_email(new_user) class DelayedMailer include Sidekiq::Worker def perform(yml) (target, method_name, args) = YAML.load(yml) msg = target.public_send(method_name, *args) # The email method can return nil, which causes ActionMailer to return # an undeliverable empty message. if msg deliver(msg) else raise "#{target.name}##{method_name} returned an undeliverable mail object" end end private def deliver(msg) if msg.respond_to?(:deliver_now) ActiveSupport::Deprecation.warn('`ActionMailer.delay.method` is deprecated. Use `ActionMailer.method.deliver_later` instead and configure ActiveJob to use Sidekiq.') # Rails 4.2/5.0 msg.deliver_now else # Rails 3.2/4.0/4.1 msg.deliver end end end module ActionMailer def sidekiq_delay(options={}) Proxy.new(DelayedMailer, self, options) end def sidekiq_delay_for(interval, options={}) Proxy.new(DelayedMailer, self, options.merge('at' => Time.now.to_f + interval.to_f)) end def sidekiq_delay_until(timestamp, options={}) Proxy.new(DelayedMailer, self, options.merge('at' => timestamp.to_f)) end alias_method :delay, :sidekiq_delay alias_method :delay_for, :sidekiq_delay_for alias_method :delay_until, :sidekiq_delay_until end end end