Author: mjordan Date: Thu Feb 12 14:50:23 2015 New Revision: 6398 URL: http://svnview.digium.com/svn/testsuite?view=rev&rev=6398 Log: rest_api/channels/redirect: Add tests for /channels/redirect operation
This patch adds the following tests: - rest_api/channels/redirect/off-nominal: Off-nominal testing of the redirect operation, verifying that the various off nominal error response codes are returned as expected - rest_api/channels/redirect/nominal: Nominal testing of the operation. For fun, this spawns four Asterisk instances (one call generator, one load balancer, and two destinations) - and proceeds to load balance 'calls' between the two destination instances. Review: https://reviewboard.asterisk.org/r/4352/ ASTERISK-24703 Added: asterisk/trunk/tests/rest_api/channels/redirect/ asterisk/trunk/tests/rest_api/channels/redirect/nominal/ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/extensions.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/http.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/pjsip.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/extensions.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/http.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/pjsip.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/extensions.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/http.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/pjsip.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/extensions.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/http.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/pjsip.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test (with props) asterisk/trunk/tests/rest_api/channels/redirect/nominal/test-config.yaml (with props) asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/ asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/ asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/extensions.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/pjsip.conf (with props) asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/redirect_off_nominal.py (with props) asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/test-config.yaml (with props) asterisk/trunk/tests/rest_api/channels/redirect/tests.yaml (with props) Modified: asterisk/trunk/tests/rest_api/channels/tests.yaml Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/extensions.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/extensions.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/extensions.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/extensions.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,8 @@ +[default] + +exten => _.,1,NoOp() + same => n,Stasis(call_spawner,${EXTEN}) + same => n,Hangup() + +exten => h,1,NoOp() + same => n,Hangup() Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/extensions.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/extensions.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/extensions.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/http.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/http.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/http.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/http.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,5 @@ +[general] +enabled=yes +bindaddr=127.0.0.1 +bindport=8088 +prefix= Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/http.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/http.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/http.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/pjsip.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/pjsip.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/pjsip.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/pjsip.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,40 @@ +[local-transport] +type=transport +protocol=udp +bind=127.0.0.1:5061 + +[endpoint-template](!) +type=endpoint +context=default +allow=!all,ulaw,g722 + +[aor-template](!) +type=aor +max_contacts=1 + +[ast2](aor-template) +contact=sip:ast2@127.0.0.1:5062 + +[ast2](endpoint-template) +transport=local-transport +aors=ast2 +from_user=ast1 +context=default + +[ast3](aor-template) +contact=sip:ast3@127.0.0.1:5063 + +[ast3](endpoint-template) +transport=local-transport +aors=ast3 +from_user=ast1 +context=default + +[ast4](aor-template) +contact=sip:ast4@127.0.0.1:5064 + +[ast4](endpoint-template) +transport=local-transport +aors=ast4 +from_user=ast1 +context=default Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/pjsip.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/pjsip.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast1/pjsip.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/extensions.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/extensions.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/extensions.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/extensions.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,8 @@ +[default] + +exten => _.,1,NoOp() + same => n,Stasis(balancer,ast2) + same => n,Hangup() + +exten => h,1,NoOp() + same => n,Hangup() Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/extensions.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/extensions.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/extensions.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/http.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/http.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/http.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/http.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,5 @@ +[general] +enabled=yes +bindaddr=127.0.0.2 +bindport=8088 +prefix= Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/http.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/http.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/http.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/pjsip.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/pjsip.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/pjsip.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/pjsip.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,40 @@ +[local-transport] +type=transport +protocol=udp +bind=127.0.0.1:5062 + +[endpoint-template](!) +type=endpoint +context=default +allow=!all,ulaw,g722 + +[aor-template](!) +type=aor +max_contacts=1 + +[ast1](aor-template) +contact=sip:ast1@127.0.0.1:5061 + +[ast1](endpoint-template) +transport=local-transport +aors=ast1 +from_user=ast2 +context=default + +[ast3](aor-template) +contact=sip:ast3@127.0.0.1:5063 + +[ast3](endpoint-template) +transport=local-transport +aors=ast3 +from_user=ast2 +context=default + +[ast4](aor-template) +contact=sip:ast4@127.0.0.1:5064 + +[ast4](endpoint-template) +transport=local-transport +aors=ast4 +from_user=ast2 +context=default Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/pjsip.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/pjsip.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast2/pjsip.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/extensions.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/extensions.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/extensions.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/extensions.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,8 @@ +[default] + +exten => _.,1,NoOp() + same => n,Stasis(balancer,ast3) + same => n,Hangup() + +exten => h,1,NoOp() + same => n,Hangup() Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/extensions.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/extensions.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/extensions.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/http.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/http.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/http.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/http.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,5 @@ +[general] +enabled=yes +bindaddr=127.0.0.3 +bindport=8088 +prefix= Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/http.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/http.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/http.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/pjsip.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/pjsip.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/pjsip.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/pjsip.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,31 @@ +[local-transport] +type=transport +protocol=udp +bind=127.0.0.1:5063 + +[endpoint-template](!) +type=endpoint +context=default +allow=!all,ulaw,g722 + +[aor-template](!) +type=aor +max_contacts=1 + +[ast1](aor-template) +contact=sip:ast1@127.0.0.1:5061 + +[ast1](endpoint-template) +transport=local-transport +aors=ast1 +from_user=ast3 +context=default + +[ast2](aor-template) +contact=sip:ast2@127.0.0.1:5062 + +[ast2](endpoint-template) +transport=local-transport +aors=ast2 +from_user=ast3 +context=default Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/pjsip.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/pjsip.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast3/pjsip.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/extensions.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/extensions.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/extensions.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/extensions.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,8 @@ +[default] + +exten => _.,1,NoOp() + same => n,Stasis(balancer,ast4) + same => n,Hangup() + +exten => h,1,NoOp() + same => n,Hangup() Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/extensions.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/extensions.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/extensions.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/http.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/http.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/http.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/http.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,5 @@ +[general] +enabled=yes +bindaddr=127.0.0.4 +bindport=8088 +prefix= Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/http.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/http.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/http.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/pjsip.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/pjsip.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/pjsip.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/pjsip.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,31 @@ +[local-transport] +type=transport +protocol=udp +bind=127.0.0.1:5064 + +[endpoint-template](!) +type=endpoint +context=default +allow=!all,ulaw,g722 + +[aor-template](!) +type=aor +max_contacts=1 + +[ast1](aor-template) +contact=sip:ast1@127.0.0.1:5061 + +[ast1](endpoint-template) +transport=local-transport +aors=ast1 +from_user=ast4 +context=default + +[ast2](aor-template) +contact=sip:ast2@127.0.0.1:5062 + +[ast2](endpoint-template) +transport=local-transport +aors=ast2 +from_user=ast4 +context=default Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/pjsip.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/pjsip.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/configs/ast4/pjsip.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test Thu Feb 12 14:50:23 2015 @@ -1,0 +1,336 @@ +#!/usr/bin/env python +# vim: sw=3 et: +"""A test that verifies the redirect operation for the ARI channels resource + +Copyright (C) 2015, Digium, Inc. +Matt Jordan <mjor...@digium.com> + +This program is free software, distributed under the terms of +the GNU General Public License Version 2. +""" + +import sys +import uuid +import logging + +from twisted.internet import reactor + +sys.path.append("lib/python") + +from asterisk.test_case import TestCase +from asterisk.ari import ARI, AriClientFactory + +LOGGER = logging.getLogger(__name__) + +USERPASS = ('testsuite', 'testsuite') + +CHANNEL_COUNT = 10 + + +class BaseReceiver(object): + """Base class for an ARI protocol receiver""" + + def __init__(self, test_object): + """Constructor + + Keyword Arguments: + test_object -- our TestCase instance + """ + self.test_object = test_object + + def on_ws_event(self, message): + """Handler for WebSocket events + + Keyword Arguments: + message -- The WS event payload + """ + msg_type = message.get('type') + callback = getattr(self, 'handle_{0}'.format(msg_type.lower()), None) + if callback: + callback(message) + + def on_ws_open(self, protocol): + """Handler for WebSocket Client Protocol opened + + Keyword Arguments: + protocol -- The WS Client protocol object + """ + LOGGER.debug("{0}: WebSocket connection made {1}".format(self, + protocol)) + self.test_object.protocol_connected(protocol) + + def on_ws_closed(self, protocol): + """Handler for WebSocket Client Protocol closed + + :param protocol The WS Client protocol object + """ + LOGGER.debug("{0}: WebSocket connection closed {1}".format(self, + protocol)) + + +class CallSpawner(BaseReceiver): + """A class that spawns calls and handles forwards + + The call spawner originates channels to another Asterisk instance + and - if the channel is forwarded - deals with the Local channel + and re-originates to the specified destination. + """ + + def __init__(self, ast, test_object): + """Constructor + + Keyword Arguments: + ast -- our call spawning Asterisk instance + test_object -- our TestCase object + """ + super(CallSpawner, self).__init__(test_object) + self.channels = [] + self.bridges = [] + self.redirected_channels = {} + self.client = ARI(ast.host, userpass=USERPASS) + self.factory = AriClientFactory(receiver=self, + host=ast.host, + port=8088, + apps='call_spawner', + userpass=USERPASS) + self.factory.connect() + + def spawn_calls(self): + """Make me a call!""" + for i in xrange(0, CHANNEL_COUNT): + LOGGER.debug('Originating channel {0}'.format(i)) + self.client.post('channels', + endpoint='PJSIP/ast2', + app='call_spawner') + + def handle_channelleftbridge(self, message): + """ChannelLeftBridge handler + + Keyword Arguments: + message -- the JSON message + """ + bridge = message['bridge'] + if not bridge['channels']: + self.client.delete('bridges', bridge['id']) + + def handle_stasisend(self, message): + """StasisEnd handler + + Keyword Arguments: + message -- the JSON message + """ + channel_id = message['channel']['id'] + self.channels.remove(channel_id) + + def handle_stasisstart(self, message): + """StasisStart handler + + Keyword Arguments: + message -- the JSON message + """ + channel_id = message['channel']['id'] + channel_name = message['channel']['name'] + args = message['args'] + + # args will be: + # - empty if the channel was spawned and accepted + # - ast3 or ast4 if we should redirect the channel there + # - redirected if it is a Local channel created due to a call + # forward being received + if not args: + LOGGER.debug('Spawned channel: {0}'.format(channel_name)) + elif 'ast3' in args or 'ast4' in args: + outbound_id = str(uuid.uuid4()) + self.redirected_channels[outbound_id] = channel_id + + LOGGER.debug('Got redirect to {0}'.format(args)) + self.client.post('channels', + channelId=outbound_id, + endpoint='PJSIP/{0}'.format(args[0]), + app='call_spawner', + appData='redirected') + elif 'redirected' in args: + bridge_id = str(uuid.uuid4()) + self.client.post('bridges', + bridgeId=bridge_id) + self.bridges.append(bridge_id) + redirect_id = self.redirected_channels[channel_id] + + LOGGER.debug('Bridging redirect {0} and {1} in {2}'.format( + redirect_id, channel_id, bridge_id)) + self.client.post('channels', channel_id, 'answer') + self.client.post('channels', redirect_id, 'answer') + self.client.post('bridges', 'addChannel', channel_id) + self.client.post('bridges', 'addChannel', redirect_id) + + self.channels.append(channel_id) + + def hangup_channels(self): + """Hang up all tracked channels""" + + # We will race between the StasisEnd event being processed + # from a BYE from the loaded systems and our attempt to + # delete the channel; ignore any HTTP errors + self.client.set_allow_errors(True) + for channel in self.channels: + LOGGER.debug('Hanging up {0}'.format(channel)) + self.client.delete('channels', channel) + self.client.set_allow_errors(False) + for bridge in self.bridges: + LOGGER.debug('Destroying bridge {0}'.format(bridge)) + self.client.delete('bridges', bridge) + + +class BalancerReceiver(BaseReceiver): + """A class that load balances and handles their destination + + The balancer load balances in a round-robin fashion between + destination servers. It maintains a connection to the destination + servers as well to detect when all calls are placed. + """ + + def __init__(self, ast_instances, test_object): + """Constructor + + Keyword Arguments: + ast_instances -- list of Asterisk instances to balance across + test_object -- our TestCase object + """ + super(BalancerReceiver, self).__init__(test_object) + + # The channels in each Asterisk instance + self.channels = {'ast3': [], 'ast4': []} + # The ARI clients for each Asterisk instance + self.client_map = {} + # The ARI clients + clients = [] + # Number of channels this has handled + self.channels_handled = 0 + + for ast_instance in ast_instances: + clients.append(ARI(ast_instance.host, userpass=USERPASS)) + factory = AriClientFactory(receiver=self, + host=ast_instance.host, + port=8088, + apps='balancer', + userpass=USERPASS) + factory.connect() + self.client_map['ast2'] = clients[0] + self.client_map['ast3'] = clients[1] + self.client_map['ast4'] = clients[2] + + def handle_stasisend(self, message): + """StasisEnd handler + + Keyword Arguments: + message -- the JSON message + """ + channel_id = message['channel']['id'] + for c_list in self.channels.itervalues(): + if channel_id in c_list: + c_list.remove(channel_id) + if sum(len(c_list) for c_list in self.channels.itervalues()) == 0: + LOGGER.info('All channels hung up') + + def handle_stasisstart(self, message): + """StasisStart handler + + Keyword Arguments: + message -- the JSON message + """ + channel_id = message['channel']['id'] + instance = message['args'][0] + client = self.client_map[instance] + + if instance == 'ast2': + self.channels_handled += 1 + rr_pick = self.channels_handled % 2 + target_instance = 'ast{0}'.format(rr_pick + 3) + LOGGER.debug('Bouncing {0} from {1} to {2}'.format( + channel_id, instance, target_instance)) + client.post('channels', channel_id, 'redirect', + endpoint='PJSIP/{0}'.format(target_instance)) + return + + LOGGER.debug('Answering channel {0} on {1}'.format( + channel_id, instance)) + client.post('channels', channel_id, 'answer') + channels = self.channels[instance] + channels.append(channel_id) + + if all([len(chan_list) == (CHANNEL_COUNT / 2) + for chan_list in self.channels.itervalues()]): + self.test_object.set_passed(True) + + LOGGER.info('All channels answered and balanced:') + for server, chan_list in self.channels.items(): + LOGGER.info('Server {0}: {1}'.format(server, chan_list)) + self.test_object.hangup_all_channels() + + def hangup_channels(self): + """Hang up all tracked channels""" + + for server, chan_list in self.channels.items(): + for chan in chan_list: + self.client_map[server].delete('channels', chan) + + +class RedirectTest(TestCase): + """A class that manages this test""" + + def __init__(self): + """Constructor""" + super(RedirectTest, self).__init__() + self.create_asterisk(count=4) + self.protocols = [] + self.spawner = None + self.balancer = None + + def run(self): + """Entry point for the twisted reactor""" + super(RedirectTest, self).run() + + # Create the ARI spawner + self.spawner = CallSpawner(self.ast[0], self) + # Create the ARI balancers + self.balancer = BalancerReceiver(self.ast[1:], self) + + def protocol_connected(self, protocol): + """Called by the various BaseReceivers on protocol connection + + Keyword Arguments: + protocol -- the twisted protocol that connected + """ + self.protocols.append(protocol) + if len(self.protocols) == 4: + LOGGER.info('Spawning calls!') + self.spawner.spawn_calls() + + def hangup_all_channels(self): + """Hangs up all channels in both the spawner and the balancer + """ + self.balancer.hangup_channels() + self.spawner.hangup_channels() + for protocol in self.protocols: + protocol.transport.loseConnection() + self.stop_reactor() + + +def main(): + """Main entry point for the test. + + Returns: + 0 on test pass + 1 on test failure + """ + + test = RedirectTest() + reactor.run() + + if not test.passed: + return 1 + + return 0 + +if __name__ == "__main__": + sys.exit(main() or 0) Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test ------------------------------------------------------------------------------ svn:executable = * Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/run-test ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/nominal/test-config.yaml URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/nominal/test-config.yaml?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/nominal/test-config.yaml (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/nominal/test-config.yaml Thu Feb 12 14:50:23 2015 @@ -1,0 +1,37 @@ +testinfo: + summary: Test redirecting channels using ARI + description: | + This test covers redirecting channels using ARI. Specifically, + it does the following: + - The first Asterisk instance (ast1) acts as a call generator + using a Stasis application. It spawns calls to the second + Asterisk instance (ast2). If a call is forwarded - which is + detected by a Local channel entering the destination extension + (ast3 or ast4), it creates a new call to that server and + bridges it with the Local channel. + - The second Asterisk instance (ast2) acts as a load balancer. + As calls are received from ast1, it picks a server to forward + them to in a round-robin fashion. It then uses the /redirect + operation on the channels resource to forward the calls to + the specified server. + - The third and fourth Asterisk instances (ast3 and ast4) + receive the forwarded calls. + Two Stasis applications handle the test: a call generator, + connected to ast1, and the load balancer, connected to ast2, + ast3, and ast4. When the load balancer detects that all calls + have been forwarded to ast3 and ast4, it stops the test. A + total of 10 calls are processed, with 5 being forwarded to both + ast3 and ast4. + +properties: + minversion: '13.3.0' + dependencies: + - python : autobahn.websocket + - python : requests + - python : twisted + - asterisk : res_ari_channels + - asterisk : res_ari_bridges + - asterisk : chan_pjsip + - asterisk : app_stasis + tags: + - ARI Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/test-config.yaml ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/test-config.yaml ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/nominal/test-config.yaml ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/extensions.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/extensions.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/extensions.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/extensions.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,9 @@ +[default] +exten => s,1,NoOp() + same => n,Answer() + same => n,Stasis(testsuite) + same => n,Hangup() + +exten => asterisk,1,NoOp() + same => n,Answer() + same => n,Echo() Propchange: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/extensions.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/extensions.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/extensions.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/pjsip.conf URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/pjsip.conf?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/pjsip.conf (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/pjsip.conf Thu Feb 12 14:50:23 2015 @@ -1,0 +1,22 @@ +[local-transport] +type=transport +protocol=udp +bind=127.0.0.1 + +[endpoint-template](!) +type=endpoint +context=default +allow=!all,ulaw,g722 + +[aor-template](!) +type=aor +max_contacts=1 + +[asterisk-aors](aor-template) +contact=sip:asterisk@127.0.0.1:5060 + +[asterisk](endpoint-template) +transport=local-transport +aors=asterisk-aors +context=default +from_user=asterisk Propchange: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/pjsip.conf ------------------------------------------------------------------------------ svn:eol-style = native Propchange: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/pjsip.conf ------------------------------------------------------------------------------ svn:keywords = Author Date Id Revision Propchange: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/configs/ast1/pjsip.conf ------------------------------------------------------------------------------ svn:mime-type = text/plain Added: asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/redirect_off_nominal.py URL: http://svnview.digium.com/svn/testsuite/asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/redirect_off_nominal.py?view=auto&rev=6398 ============================================================================== --- asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/redirect_off_nominal.py (added) +++ asterisk/trunk/tests/rest_api/channels/redirect/off-nominal/redirect_off_nominal.py Thu Feb 12 14:50:23 2015 @@ -1,0 +1,70 @@ +""" +Copyright (C) 2015, Digium, Inc. +Matt Jordan <mjor...@digium.com> +Joshua Colp <jc...@digium.com> + +This program is free software, distributed under the terms of +the GNU General Public License Version 2. +""" + +import logging +import requests + +LOGGER = logging.getLogger(__name__) + +CHANNELS = [] + + +def on_stasis_start(ari, event, test_object): + """StasisStart event handler + + Keyword Arguments: + event -- the ARI event. In this case, StasisStart. + test_object -- our one and only test object [... 161 lines stripped ...] -- _____________________________________________________________________ -- Bandwidth and Colocation Provided by http://www.api-digital.com -- svn-commits mailing list To UNSUBSCRIBE or update options visit: http://lists.digium.com/mailman/listinfo/svn-commits
