Sha256: 517b7dc5cc9b84862a54190d92e3a56d9aa2634c673db29f0ae09a3656a582a2
Contents?: true
Size: 1.52 KB
Versions: 20
Compression:
Stored size: 1.52 KB
Contents
# encoding: utf-8
module Adhearsion
class Router
extend ActiveSupport::Autoload
autoload :EventedRoute
autoload :OpenendedRoute
autoload :Route
autoload :UnacceptingRoute
NoMatchError = Class.new Adhearsion::Error
attr_reader :routes
def initialize(&block)
@routes = []
instance_exec(&block)
end
def route(*args, &block)
Route.new(*args, &block).tap do |route|
@routes << route
end
end
def match(call)
@routes.find { |route| route.match? call }
end
def handle(call)
raise NoMatchError unless route = match(call)
logger.info "Call #{call.id} selected route \"#{route.name}\" (#{route.target})"
route.dispatch call
rescue NoMatchError
logger.warn "Call #{call.id} could not find a matching route. Rejecting."
call.reject :error
end
module Filters
def evented(&block)
filtered_routes EventedRoute, &block
end
def unaccepting(&block)
filtered_routes UnacceptingRoute, &block
end
def openended(&block)
filtered_routes OpenendedRoute, &block
end
def filtered_routes(mixin, &block)
FilteredRouter.new(self, mixin).instance_exec(&block)
end
end
include Filters
class FilteredRouter < SimpleDelegator
include Filters
def initialize(delegate, mixin)
super delegate
@mixin = mixin
end
def route(*args, &block)
super.tap { |r| r.extend @mixin }
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems