Sha256: d0f8c37048e75f7682747f60ba9a0935e020d5e69e9ce69c786e535eb5241243
Contents?: true
Size: 1.68 KB
Versions: 10
Compression:
Stored size: 1.68 KB
Contents
if defined?(Delayed)
module StateManager
# Adds support for a :delay property on event definitions. Events with a
# delay set will be automatically sent after the delay. If the state is
# changed such that the event is no longer available before the delay is
# reached, it will be canceled.
module DelayedJob
class DelayedEvent < Struct.new(:path, :event, :state_manager)
def perform
return unless state_manager.respond_to_event?(event[:name]) &&
state_manager.in_state?(path)
state_manager.send_event! event[:name]
end
end
module State
def delayed_events
self.class.specification.events.reject{|name,event|!event[:delay]}
end
def entered
delayed_events.each do |name, event|
delay = if event[:delay].is_a? Proc
instance_exec(&event[:delay])
elsif event[:delay].is_a? Symbol
send event[:delay]
else
event[:delay]
end
delayed_event = DelayedEvent.new(path, event, state_manager)
Delayed::Job.enqueue delayed_event, :run_at => delay.from_now
end
end
def exited
# TODO: we currently just have logic inside the job itself which
# skips the event if it is no longer relevant. This is not perfect.
# Ideally we should cancel events in this method (requiring an
# efficient way to do this without looping over all events).
end
end
end
class State
include DelayedJob::State
def entered
super
end
def exited
super
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems