module ConektaEvent

Constants

VERSION

Attributes

adapter[RW]
backend[RW]
event_retriever[RW]
namespace[RW]
private_signature[RW]

Public Class Methods

all(callable = Proc.new) click to toggle source
# File lib/conekta_event.rb, line 38
def all(callable = Proc.new)
  subscribe nil, callable
end
configure() { |self| ... } click to toggle source
# File lib/conekta_event.rb, line 9
def configure(&block)
  raise ArgumentError, "must provide a block" unless block_given?
  block.arity.zero? ? instance_eval(&block) : yield(self)
end
Also aliased as: setup
instrument(params) click to toggle source
# File lib/conekta_event.rb, line 15
def instrument(params)
  begin
    event = event_retriever.call(params)
  rescue Conekta::ErrorList => error_list
    for error_detail in error_list.details do
      Rails.logger.info "Conekta Webhook Error => #{error_detail.message}"
    end
    if params[:type] == "account.application.deauthorized"
      event = OpenStruct.new(params)
    else
      raise UnauthorizedError.new(error_list)
    end
  rescue Conekta::Error => e
    raise UnauthorizedError.new(e)
  end
  
  backend.instrument namespace.call(event.type), event if event
end
listening?(name) click to toggle source
# File lib/conekta_event.rb, line 42
def listening?(name)
  namespaced_name = namespace.call(name)
  backend.notifier.listening?(namespaced_name)
end
setup(&block)
Alias for: configure
subscribe(name, callable = Proc.new) click to toggle source
# File lib/conekta_event.rb, line 34
def subscribe(name, callable = Proc.new)
  backend.subscribe namespace.to_regexp(name), adapter.call(callable)
end