Sha256: 3ff8fc4f3114ea28d17e8f1fcc27a454a7b825fd8838ac170d1f8aa37da5bd27
Contents?: true
Size: 1.59 KB
Versions: 8
Compression:
Stored size: 1.59 KB
Contents
module Reactor::Publishable
extend ActiveSupport::Concern
included do
after_commit :schedule_events, if: :persisted?
after_commit :reschedule_events, if: :persisted?, on: :update
end
def publish(name, data = {})
Reactor::Event.publish(name, data.merge(actor: self) )
end
module ClassMethods
def publishes(name, data = {})
events[name] = data
end
def events
@events ||= {}
end
end
private
def schedule_events
self.class.events.each do |name, data|
event = data.merge(
actor: ( data[:actor] ? send(data[:actor]) : self ),
target: ( data[:target] ? self : nil),
at: ( data[:at] ? send(data[:at]) : nil)
).except(:watch, :if)
need_to_fire = case (ifarg = data[:if])
when Proc
instance_exec(&ifarg)
when Symbol
send(ifarg)
else
transaction_include_action?(:create)
end
Reactor::Event.publish name, event if need_to_fire
end
end
def reschedule_events
self.class.events.each do |name, data|
attr_changed_method = data[:watch] || data[:at]
if data[:at] && previous_changes[attr_changed_method]
Reactor::Event.reschedule name,
data.merge(
at: send(data[:at]),
actor: ( data[:actor] ? send(data[:actor]) : self ),
target: ( data[:target] ? self : nil),
was: previous_changes[data[:at]].try(:first) || send("#{data[:at]}_was"))
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems