Contents

# encoding: utf-8

module Adhearsion
  ##
  # This manages the list of calls the Adhearsion service receives
  class Calls < Hash
    include Celluloid

    trap_exit :call_died

    def from_offer(offer)
      Call.new(offer).tap do |call|
        self << call
      end
    end

    def <<(call)
      link call
      self[call.id] = call
      current_actor
    end

    def remove_inactive_call(call)
      if call_is_dead?(call) != nil
        call_id = key call
        delete call_id if call_id
      elsif call.respond_to?(:id)
        delete call.id
      else
        delete call
      end
    end

    def with_tag(tag)
      values.find_all do |call|
        call.tagged_with? tag
      end
    end

    private

    def call_is_dead?(call)
      !call.alive?
    rescue NoMethodError
    end

    def call_died(call, reason)
      catching_standard_errors do
        call_id = key call
        remove_inactive_call call
        return unless reason
        Adhearsion::Events.trigger :exception, reason
        logger.error "Call #{call_id} terminated abnormally due to #{reason}. Forcing hangup."
        PunchblockPlugin.client.execute_command Punchblock::Command::Hangup.new, :async => true, :call_id => call_id
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
adhearsion-2.4.0	lib/adhearsion/calls.rb
adhearsion-2.4.0.beta3	lib/adhearsion/calls.rb
adhearsion-2.4.0.beta2	lib/adhearsion/calls.rb
adhearsion-2.4.0.beta1	lib/adhearsion/calls.rb