Sha256: db27a1c79153a91338ce8e5ae8bcc05584a0218fa43e47000e11c41247435c63
Contents?: true
Size: 1.76 KB
Versions: 9
Compression:
Stored size: 1.76 KB
Contents
module Backburner
class Hooks
class << self
# Triggers all method hooks that match the given event type with specified arguments.
#
# @example
# invoke_hook_events(:before_enqueue, 'some', 'args')
# invoke_hook_events(:after_perform, 5)
#
def invoke_hook_events(job, event, *args)
res = find_hook_events(job, event).map { |e| job.send(e, *args) }
return false if res.any? { |result| result == false }
res
end
# Triggers all method hooks that match given around event type. Used for 'around' hooks
# that stack over the original task cumulatively onto one another.
#
# The final block will be the one that actually invokes the
# original task after calling all other around blocks.
#
# @example
# around_hook_events(:around_perform) { job.perform }
#
def around_hook_events(job, event, *args, &block)
raise "Please pass a block to hook events!" unless block_given?
around_hooks = find_hook_events(job, event).reverse
aggregate_filter = Proc.new { |&blk| blk.call }
around_hooks.each do |ah|
prior_around_filter = aggregate_filter
aggregate_filter = Proc.new do |&blk|
job.method(ah).call(*args) do
prior_around_filter.call(&blk)
end
end
end
aggregate_filter.call(&block)
end
protected
# Returns all methods that match given hook type
#
# @example
# find_hook_events(:before_enqueue)
# # => ['before_enqueue_foo', 'before_enqueue_bar']
#
def find_hook_events(job, event)
(job.methods - Object.methods).grep(/^#{event}/).sort
end
end
end # Hooks
end # Backburner
Version data entries
9 entries across 9 versions & 1 rubygems