Contents

# encoding: utf-8

require 'has_guarded_handlers'
require 'girl_friday'

module Adhearsion
  class Events

    include HasGuardedHandlers

    Message = Struct.new :type, :object

    class << self
      def method_missing(method_name, *args, &block)
        instance.send method_name, *args, &block
      end

      def respond_to?(method_name)
        instance.respond_to?(method_name) || super
      end

      def instance
        @@instance || refresh!
      end

      def refresh!
        @@instance = new
      end
    end

    refresh!

    def queue
      queue? ? @queue : reinitialize_queue!
    end

    def trigger(type, object = nil)
      queue.push_async Message.new(type, object)
    end

    def trigger_immediately(type, object = nil)
      queue.push_immediately Message.new(type, object)
    end

    def queue?
      instance_variable_defined? :@queue
    end

    def reinitialize_queue!
      GirlFriday.shutdown! if queue?
      # TODO: Extract number of threads to use from Adhearsion.config
      @queue = GirlFriday::WorkQueue.new 'main_queue', :error_handler => ErrorHandler do |message|
        work message
      end
    end

    def work(message)
      handle_message message
    rescue => e
      raise if message.type == :exception
      trigger :exception, e
    end

    def handle_message(message)
      trigger_handler message.type, message.object
    end

    def draw(&block)
      instance_exec(&block)
    end

    def method_missing(method_name, *args, &block)
      register_handler method_name, *args, &block
    end

    def respond_to?(method_name)
      return true if instance_variable_defined?(:@handlers) && @handlers.has_key?(method_name)
      super
    end

    alias :register_callback :register_handler

    private

    def call_handler(handler, guards, event)
      super
      throw :pass
    end

    class ErrorHandler
      def handle(exception)
        logger.error "Exception encountered in exception handler!"
        logger.error exception
      end
    end

  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
adhearsion-2.3.3	lib/adhearsion/events.rb
adhearsion-2.3.2	lib/adhearsion/events.rb
adhearsion-2.3.1	lib/adhearsion/events.rb
adhearsion-2.3.0	lib/adhearsion/events.rb
adhearsion-2.2.1	lib/adhearsion/events.rb
adhearsion-2.2.0	lib/adhearsion/events.rb