module RecurlyEvent

# File lib/recurly_event.rb, line 18
def all(callable=Proc.new {})
  subscribe nil, callable
end

# File lib/recurly_event.rb, line 13
def configure(&block)
  raise ArgumentError, "missing block" unless block_given?
  yield self
end

# File lib/recurly_event.rb, line 22
def process_request(request)
  parsed_request = parser.parse(request)
  publish(parsed_request.event_name, parsed_request.payload)
end

# File lib/recurly_event.rb, line 27
def publish(event_name, payload)
  notifications.instrument(namespace.parse_with_namespace(event_name), payload)
end

# File lib/recurly_event.rb, line 31
def subscribe(event_name, callable=Proc.new {})
  notifications.subscribe namespace.regexp_wrap(event_name) do |*args|
    recurly_object = parser.from_payload(args.last)
    callable.call(recurly_object)
  end
end