asterisk_spec.rb in punchblock-0.6.2

- old
+ new

@@ -49,36 +49,47 @@
           end
         end
       end
 
       describe '#register_call' do
-        it 'should make the call accessible by ID' do
-          call_id = 'abc123'
-          call    = mock 'Translator::Asterisk::Call', :id => call_id
+        let(:call_id) { 'abc123' }
+        let(:channel) { 'SIP/foo' }
+        let(:call)    { Translator::Asterisk::Call.new channel, subject }
+
+        before do
+          call.stubs(:id).returns call_id
           subject.register_call call
+        end
+
+        it 'should make the call accessible by ID' do
           subject.call_with_id(call_id).should be call
         end
+
+        it 'should make the call accessible by ID' do
+          subject.call_for_channel(channel).should be call
+        end
       end
 
       describe '#execute_call_command' do
         let(:call_id) { 'abc123' }
-        let(:call)    { mock 'Translator::Asterisk::Call', :id => call_id }
+        let(:call)    { Translator::Asterisk::Call.new 'SIP/foo', subject }
         let(:command) { mock 'Command::Answer', :call_id => call_id }
 
         before do
+          call.stubs(:id).returns call_id
           subject.register_call call
         end
 
         it 'sends the command to the call for execution' do
-          call.expects(:execute_command).once.with command
+          call.expects(:execute_command!).once.with command
           subject.execute_call_command command
         end
       end
 
       describe '#execute_component_command' do
         let(:call_id) { 'abc123' }
-        let(:call)    { Translator::Asterisk::Call.new }
+        let(:call)    { Translator::Asterisk::Call.new 'SIP/foo', subject }
 
         let(:component_id)  { '123abc' }
         let(:component)     { mock 'Translator::Asterisk::Component', :id => component_id }
 
         let(:command) { mock 'Component::Stop', :call_id => call_id, :component_id => component_id }
@@ -88,11 +99,11 @@
           call.register_component component
           subject.register_call call
         end
 
         it 'sends the command to the component for execution' do
-          component.expects(:execute_command).once.with command
+          component.expects(:execute_command!).once.with command
           subject.execute_component_command command
         end
       end
 
       describe '#execute_global_command' do
@@ -103,20 +114,28 @@
         context 'with an AMI action' do
           let :command do
             Component::Asterisk::AMI::Action.new :name => 'Status', :params => { :channel => 'foo' }
           end
 
-          let(:mock_action) { mock 'Asterisk::AMIAction' }
+          let(:mock_action) { mock 'Asterisk::Component::Asterisk::AMIAction' }
 
           it 'should create a component actor and execute it asynchronously' do
-            Asterisk::AMIAction.expects(:new).once.with(command, subject.ami_client).returns mock_action
+            Asterisk::Component::Asterisk::AMIAction.expects(:new).once.with(command, subject).returns mock_action
             mock_action.expects(:execute!).once
             subject.execute_global_command command
           end
         end
       end
 
+      describe '#handle_pb_event' do
+        it 'should forward the event to the connection' do
+          event = mock 'Punchblock::Event'
+          subject.connection.expects(:handle_event).once.with event
+          subject.handle_pb_event event
+        end
+      end
+
       describe '#handle_ami_event' do
         let :ami_event do
           RubyAMI::Event.new('Newchannel').tap do |e|
             e['Channel']  = "SIP/101-3f3f"
             e['State']    = "Ring"
@@ -143,11 +162,10 @@
             subject.connection.expects(:handle_event).never
             subject.handle_ami_event :foo
           end
         end
 
-
         describe 'with a FullyBooted event' do
           let(:ami_event) { RubyAMI::Event.new 'FullyBooted' }
 
           context 'once' do
             it 'does not send anything to the connection' do
@@ -161,9 +179,71 @@
               subject.connection.expects(:handle_event).once.with Connection::Connected.new
               subject.handle_ami_event ami_event
               subject.handle_ami_event ami_event
             end
           end
+        end
+
+        describe 'with an AsyncAGI Start event' do
+          let :ami_event do
+            RubyAMI::Event.new('AsyncAGI').tap do |e|
+              e['SubEvent'] = "Start"
+              e['Channel']  = "SIP/1234-00000000"
+              e['Env']      = "agi_request%3A%20async%0Aagi_channel%3A%20SIP%2F1234-00000000%0Aagi_language%3A%20en%0Aagi_type%3A%20SIP%0Aagi_uniqueid%3A%201320835995.0%0Aagi_version%3A%201.8.4.1%0Aagi_callerid%3A%205678%0Aagi_calleridname%3A%20Jane%20Smith%0Aagi_callingpres%3A%200%0Aagi_callingani2%3A%200%0Aagi_callington%3A%200%0Aagi_callingtns%3A%200%0Aagi_dnid%3A%201000%0Aagi_rdnis%3A%20unknown%0Aagi_context%3A%20default%0Aagi_extension%3A%201000%0Aagi_priority%3A%201%0Aagi_enhanced%3A%200.0%0Aagi_accountcode%3A%20%0Aagi_threadid%3A%204366221312%0A%0A"
+            end
+          end
+
+          before { subject.actor_subject.stubs :handle_pb_event }
+
+          it 'should be able to look up the call by channel ID' do
+            subject.handle_ami_event ami_event
+            call_actor = subject.call_for_channel('SIP/1234-00000000')
+            call_actor.actor_subject.should be_a Asterisk::Call
+            call_actor.agi_env.should be_a Hash
+            call_actor.agi_env[:agi_request].should == 'async'
+          end
+
+          it 'should instruct the call to send an offer' do
+            mock_call = stub_everything 'Asterisk::Call'
+            Asterisk::Call.expects(:new).once.returns mock_call
+            mock_call.expects(:send_offer!).once
+            subject.handle_ami_event ami_event
+          end
+        end
+
+        describe 'with an AMI event for a known channel' do
+          let :ami_event do
+            RubyAMI::Event.new('Hangup').tap do |e|
+              e['Uniqueid']     = "1320842458.8"
+              e['Calleridnum']  = "5678"
+              e['Calleridname'] = "Jane Smith"
+              e['Cause']        = "0"
+              e['Cause-txt']    = "Unknown"
+              e['Channel']      = "SIP/1234-00000000"
+            end
+          end
+
+          let(:call) do
+            Asterisk::Call.new "SIP/1234-00000000", subject, "agi_request%3A%20async%0Aagi_channel%3A%20SIP%2F1234-00000000%0Aagi_language%3A%20en%0Aagi_type%3A%20SIP%0Aagi_uniqueid%3A%201320835995.0%0Aagi_version%3A%201.8.4.1%0Aagi_callerid%3A%205678%0Aagi_calleridname%3A%20Jane%20Smith%0Aagi_callingpres%3A%200%0Aagi_callingani2%3A%200%0Aagi_callington%3A%200%0Aagi_callingtns%3A%200%0Aagi_dnid%3A%201000%0Aagi_rdnis%3A%20unknown%0Aagi_context%3A%20default%0Aagi_extension%3A%201000%0Aagi_priority%3A%201%0Aagi_enhanced%3A%200.0%0Aagi_accountcode%3A%20%0Aagi_threadid%3A%204366221312%0A%0A"
+          end
+
+          before do
+            subject.actor_subject.stubs :handle_pb_event
+            subject.register_call call
+          end
+
+          it 'sends the AMI event to the call and to the connection as a PB event' do
+            subject.actor_subject.expects(:handle_pb_event).once
+            call.expects(:process_ami_event!).once.with ami_event
+            subject.handle_ami_event ami_event
+          end
+        end
+      end
+
+      describe '#send_ami_action' do
+        it 'should send the action to the AMI client' do
+          ami_client.expects(:send_action).once.with 'foo', :foo => :bar
+          subject.send_ami_action 'foo', :foo => :bar
         end
       end
     end
   end
 end