Sha256: eb293b97c939056c988aa132044bda8e685a7c4d1e6a90ce1a33a4eae12e460d
Contents?: true
Size: 1.5 KB
Versions: 6
Compression:
Stored size: 1.5 KB
Contents
require "delegate"
module Houston
class DuplicateTriggerError < ArgumentError; end
class Triggers < SimpleDelegator
attr_reader :config
attr_accessor :async
def initialize(config)
@config = config
@async = true
super Concurrent::Array.new
end
def every(value, action, params={})
push build(:every, value, action, params)
end
def on(event, action, params={})
push build(:on, event, action, params)
end
def build(method_name, value, action, params)
Trigger.new(self, method_name, value, action, params)
end
def push(trigger)
raise DuplicateTriggerError, "That exact trigger has already been defined" if member?(trigger)
super trigger
trigger.register!
trigger
end
end
class Trigger < Struct.new(:method_name, :value, :action, :params)
def initialize(triggers, *args)
@triggers = triggers
super *args
end
def register!
case method_name
when :every then config.timer.every(value, &method(:call))
when :on then config.observer.on(value, &method(:call))
else raise NotImplementedError, "Unrecognized method name: #{method_name.inspect}"
end
end
def call(params={})
options = { trigger: to_s, async: triggers.async }
config.actions.run action, self.params.merge(params.to_h), options
end
def to_s
"#{method_name}(#{value})"
end
private
attr_reader :triggers
def config
triggers.config
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems