asterisk_spec.rb in punchblock-0.7.0

- old
+ new

@@ -4,49 +4,51 @@
   module Translator
     describe Asterisk do
       let(:ami_client) { mock 'RubyAMI::Client' }
       let(:connection) { mock 'Connection::Asterisk' }
 
-      subject { Asterisk.new ami_client, connection }
+      let(:translator) { Asterisk.new ami_client, connection }
 
+      subject { translator }
+
       its(:ami_client) { should be ami_client }
       its(:connection) { should be connection }
 
+      after { translator.terminate }
+
       describe '#execute_command' do
         describe 'with a call command' do
           let(:command) { Command::Answer.new }
           let(:call_id) { 'abc123' }
 
           it 'executes the call command' do
-            subject.actor_subject.expects(:execute_call_command).with do |c|
+            subject.wrapped_object.expects(:execute_call_command).with do |c|
               c.should be command
               c.call_id.should == call_id
             end
             subject.execute_command command, :call_id => call_id
           end
         end
 
-        describe 'with a component command' do
+        describe 'with a global component command' do
           let(:command)       { Component::Stop.new }
-          let(:call_id)       { 'abc123' }
           let(:component_id)  { '123abc' }
 
           it 'executes the component command' do
-            subject.actor_subject.expects(:execute_component_command).with do |c|
+            subject.wrapped_object.expects(:execute_component_command).with do |c|
               c.should be command
-              c.call_id.should == call_id
               c.component_id.should == component_id
             end
-            subject.execute_command command, :call_id => call_id, :component_id => component_id
+            subject.execute_command command, :component_id => component_id
           end
         end
 
         describe 'with a global command' do
           let(:command) { Command::Dial.new }
 
           it 'executes the command directly' do
-            subject.actor_subject.expects(:execute_global_command).with command
+            subject.wrapped_object.expects(:execute_global_command).with command
             subject.execute_command command
           end
         end
       end
 
@@ -62,15 +64,25 @@
 
         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
+        it 'should make the call accessible by channel' do
           subject.call_for_channel(channel).should be call
         end
       end
 
+      describe '#register_component' do
+        let(:component_id) { 'abc123' }
+        let(:component)    { mock 'Asterisk::Component::Asterisk::AMIAction', :id => component_id }
+
+        it 'should make the component accessible by ID' do
+          subject.register_component component
+          subject.component_with_id(component_id).should be component
+        end
+      end
+
       describe '#execute_call_command' do
         let(:call_id) { 'abc123' }
         let(:call)    { Translator::Asterisk::Call.new 'SIP/foo', subject }
         let(:command) { mock 'Command::Answer', :call_id => call_id }
 
@@ -84,22 +96,17 @@
           subject.execute_call_command command
         end
       end
 
       describe '#execute_component_command' do
-        let(:call_id) { 'abc123' }
-        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 }
+        let(:command) { mock 'Component::Stop', :component_id => component_id }
 
         before do
-          call.stubs(:id).returns call_id
-          call.register_component component
-          subject.register_call call
+          subject.register_component component
         end
 
         it 'sends the command to the component for execution' do
           component.expects(:execute_command!).once.with command
           subject.execute_component_command command
@@ -114,17 +121,23 @@
         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::Component::Asterisk::AMIAction' }
+          let(:mock_action) { stub_everything 'Asterisk::Component::Asterisk::AMIAction' }
 
           it 'should create a component actor and execute it asynchronously' do
             Asterisk::Component::Asterisk::AMIAction.expects(:new).once.with(command, subject).returns mock_action
             mock_action.expects(:execute!).once
             subject.execute_global_command command
           end
+
+          it 'registers the component' do
+            Asterisk::Component::Asterisk::AMIAction.expects(:new).once.with(command, subject).returns mock_action
+            subject.wrapped_object.expects(:register_component).with mock_action
+            subject.execute_global_command command
+          end
         end
       end
 
       describe '#handle_pb_event' do
         it 'should forward the event to the connection' do
@@ -190,16 +203,16 @@
               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 }
+          before { subject.wrapped_object.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.wrapped_object.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
@@ -225,15 +238,15 @@
           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.wrapped_object.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
+            subject.wrapped_object.expects(:handle_pb_event).once
             call.expects(:process_ami_event!).once.with ami_event
             subject.handle_ami_event ami_event
           end
         end
       end