| # $Id$ |
| # |
| # SIP call sample. |
| # |
| # Copyright (C) 2003-2008 Benny Prijono <benny@prijono.org> |
| # |
| # This program is free software; you can redistribute it and/or modify |
| # it under the terms of the GNU General Public License as published by |
| # the Free Software Foundation; either version 2 of the License, or |
| # (at your option) any later version. |
| # |
| # This program is distributed in the hope that it will be useful, |
| # but WITHOUT ANY WARRANTY; without even the implied warranty of |
| # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| # GNU General Public License for more details. |
| # |
| # You should have received a copy of the GNU General Public License |
| # along with this program; if not, write to the Free Software |
| # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA |
| # |
| import sys |
| import pjsua as pj |
| |
| LOG_LEVEL=3 |
| current_call = None |
| |
| # Logging callback |
| def log_cb(level, str, len): |
| print str, |
| |
| |
| # Callback to receive events from account |
| class MyAccountCallback(pj.AccountCallback): |
| |
| def __init__(self, account=None): |
| pj.AccountCallback.__init__(self, account) |
| |
| # Notification on incoming call |
| def on_incoming_call(self, call): |
| global current_call |
| if current_call: |
| call.answer(486, "Busy") |
| return |
| |
| print "Incoming call from ", call.info().remote_uri |
| print "Press 'a' to answer" |
| |
| current_call = call |
| |
| call_cb = MyCallCallback(current_call) |
| current_call.set_callback(call_cb) |
| |
| current_call.answer(180) |
| |
| |
| # Callback to receive events from Call |
| class MyCallCallback(pj.CallCallback): |
| |
| def __init__(self, call=None): |
| pj.CallCallback.__init__(self, call) |
| |
| # Notification when call state has changed |
| def on_state(self): |
| global current_call |
| print "Call with", self.call.info().remote_uri, |
| print "is", self.call.info().state_text, |
| print "last code =", self.call.info().last_code, |
| print "(" + self.call.info().last_reason + ")" |
| |
| if self.call.info().state == pj.CallState.DISCONNECTED: |
| current_call = None |
| print 'Current call is', current_call |
| |
| # Notification when call's media state has changed. |
| def on_media_state(self): |
| if self.call.info().media_state == pj.MediaState.ACTIVE: |
| # Connect the call to sound device |
| call_slot = self.call.info().conf_slot |
| pj.Lib.instance().conf_connect(call_slot, 0) |
| pj.Lib.instance().conf_connect(0, call_slot) |
| print "Media is now active" |
| else: |
| print "Media is inactive" |
| |
| # Function to make call |
| def make_call(uri): |
| try: |
| print "Making call to", uri |
| return acc.make_call(uri, cb=MyCallCallback()) |
| except pj.Error, e: |
| print "Exception: " + str(e) |
| return None |
| |
| |
| # Create library instance |
| lib = pj.Lib() |
| |
| try: |
| # Init library with default config and some customized |
| # logging config. |
| lib.init(log_cfg = pj.LogConfig(level=LOG_LEVEL, callback=log_cb)) |
| |
| # Create UDP transport which listens to any available port |
| transport = lib.create_transport(pj.TransportType.UDP, |
| pj.TransportConfig(0)) |
| print "\nListening on", transport.info().host, |
| print "port", transport.info().port, "\n" |
| |
| # Start the library |
| lib.start() |
| |
| # Create local account |
| acc = lib.create_account_for_transport(transport, cb=MyAccountCallback()) |
| |
| # If argument is specified then make call to the URI |
| if len(sys.argv) > 1: |
| lck = lib.auto_lock() |
| current_call = make_call(sys.argv[1]) |
| print 'Current call is', current_call |
| del lck |
| |
| my_sip_uri = "sip:" + transport.info().host + \ |
| ":" + str(transport.info().port) |
| |
| # Menu loop |
| while True: |
| print "My SIP URI is", my_sip_uri |
| print "Menu: m=make call, h=hangup call, a=answer call, q=quit" |
| |
| input = sys.stdin.readline().rstrip("\r\n") |
| if input == "m": |
| if current_call: |
| print "Already have another call" |
| continue |
| print "Enter destination URI to call: ", |
| input = sys.stdin.readline().rstrip("\r\n") |
| if input == "": |
| continue |
| lck = lib.auto_lock() |
| current_call = make_call(input) |
| del lck |
| |
| elif input == "h": |
| if not current_call: |
| print "There is no call" |
| continue |
| current_call.hangup() |
| |
| elif input == "a": |
| if not current_call: |
| print "There is no call" |
| continue |
| current_call.answer(200) |
| |
| elif input == "q": |
| break |
| |
| # Shutdown the library |
| transport = None |
| acc.delete() |
| acc = None |
| lib.destroy() |
| lib = None |
| |
| except pj.Error, e: |
| print "Exception: " + str(e) |
| lib.destroy() |
| lib = None |
| |