Contents

require "message_router/version"

class MessageRouter

  autoload :Context,  'message_router/context'
  autoload :Matcher,  'message_router/matcher'
  autoload :Mount,    'message_router/mount'

  class << self
    def match(*args, &block)
      route Matcher.new(*args, &block)
    end

    def context(proc, &block)
      route Context.new(proc, &block)
    end

    def mount(mounted_router_klass)
      route Mount.new(mounted_router_klass)
    end

    def routes
      @routes ||= []
    end

    def route(proc)
      routes.push proc
    end

    def dispatch(*args)
      new(*args).dispatch
    end
  end

  attr_accessor :message, :halted_value

  def initialize(*args)
    @message = normalize_arguments(*args)
  end

  def halt(val=nil, opts={})
    @halted = true
    @halted_value = normalize_arguments(val, opts)
  end

  def halted?
    !!@halted
  end

  # Iterate through all of the matchers, find the first one, and call the block on it.
  def dispatch
    self.class.routes.each do |route|
      # Break out of the loop if a match is found
      if match = route.call(self)
        return match
      elsif halted?
        return halted_value
      end
    end
    return nil # If nothing is matched, we get here and we should return a nil
  end

  def default_key
    :body
  end

private
  # Make our router accept the first argument as the default message key, then optional keys last.
  def normalize_arguments(message=nil, opts={})
    message = opts.merge(:body => message) unless message.is_a? Hash and opts.empty?
    message
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
message_router-0.0.2	lib/message_router.rb