Class: Punchblock::Translator::Asterisk

Inherits:
Object
  • Object
show all
Extended by:
ActiveSupport::Autoload
Includes:
Celluloid
Defined in:
lib/punchblock/translator/asterisk.rb,
lib/punchblock/translator/asterisk/call.rb,
lib/punchblock/translator/asterisk/component.rb,
lib/punchblock/translator/asterisk/agi_command.rb,
lib/punchblock/translator/asterisk/component/input.rb,
lib/punchblock/translator/asterisk/component/output.rb,
lib/punchblock/translator/asterisk/component/record.rb,
lib/punchblock/translator/asterisk/component/asterisk.rb,
lib/punchblock/translator/asterisk/component/stop_by_redirect.rb,
lib/punchblock/translator/asterisk/component/asterisk/ami_action.rb,
lib/punchblock/translator/asterisk/component/asterisk/agi_command.rb

Defined Under Namespace

Modules: Component Classes: AGICommand, Call

Constant Summary collapse

REDIRECT_CONTEXT = 
'adhearsion-redirect'
REDIRECT_EXTENSION = 
'1'
REDIRECT_PRIORITY = 
'1'
CHANNEL_NORMALIZATION_REGEXP = 
/^(?<prefix>Bridge\/)*(?<channel>[^<>]*)(?<suffix><.*>)*$/.freeze
EVENTS_ALLOWED_BRIDGED = 
%w{agiexec asyncagi}

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(ami_client, connection, media_engine = nil) ⇒ Asterisk

Returns a new instance of Asterisk.



28
29
30
31
32
 
# File 'lib/punchblock/translator/asterisk.rb', line 28

def initialize(ami_client, connection, media_engine = nil)
  @ami_client, @connection, @media_engine = ami_client, connection, media_engine
  @calls, @components, @channel_to_call_id = {}, {}, {}
  @fully_booted_count = 0
end

Instance Attribute Details

#ami_client ⇒ Object (readonly)

Returns the value of attribute ami_client.



17
18
19
 
# File 'lib/punchblock/translator/asterisk.rb', line 17

def ami_client
  @ami_client
end

#calls ⇒ Object (readonly)

Returns the value of attribute calls.



17
18
19
 
# File 'lib/punchblock/translator/asterisk.rb', line 17

def calls
  @calls
end

#connection ⇒ Object (readonly)

Returns the value of attribute connection.



17
18
19
 
# File 'lib/punchblock/translator/asterisk.rb', line 17

def connection
  @connection
end

#media_engine ⇒ Object (readonly)

Returns the value of attribute media_engine.



17
18
19
 
# File 'lib/punchblock/translator/asterisk.rb', line 17

def media_engine
  @media_engine
end

Instance Method Details

#actor_died(actor, reason) ⇒ Object 



149
150
151
152
153
154
155
156
157
 
# File 'lib/punchblock/translator/asterisk.rb', line 149

def actor_died(actor, reason)
  return unless reason
  if id = @calls.key(actor)
    @calls.delete id
    end_event = Punchblock::Event::End.new :target_call_id  => id,
                                           :reason          => :error
    handle_pb_event end_event
  end
end

#call_for_channel(channel) ⇒ Object 



48
49
50
 
# File 'lib/punchblock/translator/asterisk.rb', line 48

def call_for_channel(channel)
  call_with_id @channel_to_call_id[channel.match(CHANNEL_NORMALIZATION_REGEXP)[:channel]]
end

#call_with_id(call_id) ⇒ Object 



44
45
46
 
# File 'lib/punchblock/translator/asterisk.rb', line 44

def call_with_id(call_id)
  @calls[call_id]
end

#check_recording_directory ⇒ Object 



145
146
147
 
# File 'lib/punchblock/translator/asterisk.rb', line 145

def check_recording_directory
  pb_logger.warn "Recordings directory #{Component::Record::RECORDING_BASE_PATH} does not exist. Recording might not work. This warning can be ignored if Adhearsion is running on a separate machine than Asterisk. See http://adhearsion.com/docs/call-controllers#recording" unless File.exists?(Component::Record::RECORDING_BASE_PATH)
end

#component_with_id(component_id) ⇒ Object 



56
57
58
 
# File 'lib/punchblock/translator/asterisk.rb', line 56

def component_with_id(component_id)
  @components[component_id]
end

#deregister_call(call) ⇒ Object 



39
40
41
42
 
# File 'lib/punchblock/translator/asterisk.rb', line 39

def deregister_call(call)
  @channel_to_call_id.delete call.channel
  @calls.delete call.id
end

#execute_call_command(command) ⇒ Object 



103
104
105
106
107
108
109
 
# File 'lib/punchblock/translator/asterisk.rb', line 103

def execute_call_command(command)
  if call = call_with_id(command.target_call_id)
    call.async.execute_command command
  else
    command.response = ProtocolError.new.setup :item_not_found, "Could not find a call with ID #{command.target_call_id}", command.target_call_id
  end
end

#execute_command(command, options = {}) ⇒ Object 



88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
# File 'lib/punchblock/translator/asterisk.rb', line 88

def execute_command(command, options = {})
  command.request!

  command.target_call_id ||= options[:call_id]
  command.component_id ||= options[:component_id]

  if command.target_call_id
    execute_call_command command
  elsif command.component_id
    execute_component_command command
  else
    execute_global_command command
  end
end

#execute_component_command(command) ⇒ Object 



111
112
113
114
115
116
117
 
# File 'lib/punchblock/translator/asterisk.rb', line 111

def execute_component_command(command)
  if (component = component_with_id(command.component_id))
    component.async.execute_command command
  else
    command.response = ProtocolError.new.setup :item_not_found, "Could not find a component with ID #{command.component_id}", command.target_call_id, command.component_id
  end
end

#execute_global_command(command) ⇒ Object 



119
120
121
122
123
124
125
126
127
128
129
130
131
132
 
# File 'lib/punchblock/translator/asterisk.rb', line 119

def execute_global_command(command)
  case command
  when Punchblock::Component::Asterisk::AMI::Action
    component = Component::Asterisk::AMIAction.new command, current_actor, ami_client
    register_component component
    component.async.execute
  when Punchblock::Command::Dial
    call = Call.new_link command.to, current_actor, ami_client, connection
    register_call call
    call.async.dial command
  else
    command.response = ProtocolError.new.setup 'command-not-acceptable', "Did not understand command"
  end
end

#handle_ami_event(event) ⇒ Object 



65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
 
# File 'lib/punchblock/translator/asterisk.rb', line 65

def handle_ami_event(event)
  return unless event.is_a? RubyAMI::Event

  if event.name.downcase == "fullybooted"
    handle_pb_event Connection::Connected.new
    run_at_fully_booted
    return
  end

  handle_varset_ami_event event

  ami_dispatch_to_or_create_call event

  unless ami_event_known_call?(event)
    handle_pb_event Event::Asterisk::AMI::Event.new(:name => event.name, :attributes => event.headers)
  end
end

#handle_pb_event(event) ⇒ Object 



84
85
86
 
# File 'lib/punchblock/translator/asterisk.rb', line 84

def handle_pb_event(event)
  connection.handle_event event
end

#register_call(call) ⇒ Object 



34
35
36
37
 
# File 'lib/punchblock/translator/asterisk.rb', line 34

def register_call(call)
  @channel_to_call_id[call.channel] = call.id
  @calls[call.id] ||= call
end

#register_component(component) ⇒ Object 



52
53
54
 
# File 'lib/punchblock/translator/asterisk.rb', line 52

def register_component(component)
  @components[component.id] ||= component
end

#run_at_fully_booted ⇒ Object 



134
135
136
137
138
139
140
141
142
143
 
# File 'lib/punchblock/translator/asterisk.rb', line 134

def run_at_fully_booted
  send_ami_action 'Command', 'Command' => "dialplan add extension #{REDIRECT_EXTENSION},#{REDIRECT_PRIORITY},AGI,agi:async into #{REDIRECT_CONTEXT}"

  result = send_ami_action 'Command', 'Command' => "dialplan show #{REDIRECT_CONTEXT}"
  if result.text_body =~ /failed/
    pb_logger.error "Punchblock failed to add the #{REDIRECT_EXTENSION} extension to the #{REDIRECT_CONTEXT} context. Please add a [#{REDIRECT_CONTEXT}] entry to your dialplan."
  end

  check_recording_directory
end

#shutdown ⇒ Object 



60
61
62
63
 
# File 'lib/punchblock/translator/asterisk.rb', line 60

def shutdown
  @calls.values.each { |call| call.async.shutdown }
  terminate
end