SIP решения на основе библиотеки PJSIP
Материал из M-200 WIKI
Иногда имеется необходимость реализовать какой нибудь дополнительный функционал для клиентов АТС М-200.С появлением IP телефонии стало возможно доставлять голосовую информацию как от пользователя, так и к пользователю.
Так как М-200 поддерживает протокол SIP есть интересная библиотека реализации SIP стека и Media интерфейса http://www.pjsip.org/. По мимо реализации библиотеки на классическом С, есть обертка для языка Python. PJSIP может работать по Linux, MAC, Linux платформами. Библиотека распространяется под лицензией GPLv2.
На сколько это просто, покажет следующий пример. Данный пример регистрируется на станции 192.168.5.48, под номером 7000 с паролем 7000. При входящем на себя вызове проигрывает мелодию из файла /ATS/SOUND/music0.wav, в предответном состоянии в разговорном играется мелодия из файла /ATS/SOUND/music1.wav. При исходящем вызове при ответе играет мелодию из файла /ATS/SOUND/music4.wav
Клавиша a - ответ, с - звонок на номер 100, h - положить трубку.
Пример сделан из примера к самой библиотеке.
#coding=utf8
# $Id: call.py 2171 2008-07-24 09:01:33Z bennylp $
#
# 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
import threading
LOG_LEVEL=0
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)
# уведомление о входящем вызове
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 = callCallbackIn(current_call)
current_call.set_callback(call_cb)
# отвечаем call progressом
current_call.answer(183)
def wait(self):
self.sem = threading.Semaphore(0)
self.sem.acquire()
def on_reg_state(self):
if self.sem:
if self.account.info().reg_status >= 200:
self.sem.release()
# Сообщение от входящего вызова
class callCallbackIn(pj.CallCallback):
def __init__(self, call=None):
pj.CallCallback.__init__(self, call)
# уведомление об изменении состояния
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.EARLY:
call_slot = self.call.info().conf_slot
# создаем плеер wav файла
self.wav_player_id = pj.Lib.instance().create_player('/ATS/SOUND/music0.wav', loop=False)
self.wav_slot = pj.Lib.instance().player_get_slot(self.wav_player_id)
# проключаем канал плеера на разговор
pj.Lib.instance().conf_connect(self.wav_slot, call_slot)
# в разговорном подаем другую
if self.call.info().state == pj.CallState.CONFIRMED:
call_slot = self.call.info().conf_slot
# отключаем от музыки
pj.Lib.instance().conf_disconnect(self.wav_slot, call_slot)
# удаляем плеер
pj.Lib.instance().player_destroy(self.wav_player_id)
# создаем новый
self.wav_player_id = pj.Lib.instance().create_player('/ATS/SOUND/music1.wav', loop=False)
self.wav_slot = pj.Lib.instance().player_get_slot(self.wav_player_id)
# проключаем канал плеера на разговор
pj.Lib.instance().conf_connect(self.wav_slot, call_slot)
if self.call.info().state == pj.CallState.DISCONNECTED:
current_call = None
print 'Current call is', current_call
# уведомление об изменении состояния системы коммутации
def on_media_state(self):
if self.call.info().media_state == pj.MediaState.ACTIVE:
print "Media is now active"
else:
print "Media is inactive"
# Сообщение от исходящего вызова
class callCallbackOut(pj.CallCallback):
def __init__(self, call=None):
pj.CallCallback.__init__(self, call)
# уведомление об изменении состояния
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.CONFIRMED:
call_slot = self.call.info().conf_slot
# создаем новый
self.wav_player_id = pj.Lib.instance().create_player('/ATS/SOUND/music4.wav', loop=False)
self.wav_slot = pj.Lib.instance().player_get_slot(self.wav_player_id)
# проключаем канал плеера на разговор
pj.Lib.instance().conf_connect(self.wav_slot, call_slot)
if self.call.info().state == pj.CallState.DISCONNECTED:
current_call = None
print 'Current call is', current_call
# уведомление об изменении состояния системы коммутации
def on_media_state(self):
if self.call.info().media_state == pj.MediaState.ACTIVE:
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=callCallbackOut())
except pj.Error, e:
print "Exception: " + str(e)
return None
# Create library instance
lib = pj.Lib()
try:
my_media_cfg = pj.MediaConfig()
my_media_cfg.clock_rate = 8000
my_media_cfg.snd_clock_rate = 44100
my_media_cfg.no_vad = True
my_media_cfg.quality = 10
my_media_cfg.ptime = 0
my_media_cfg.max_media_ports = 4
# Init library with default config and some customized
# logging config.
lib.init(log_cfg = pj.LogConfig(level=LOG_LEVEL, callback=log_cb), media_cfg = my_media_cfg)
# Create UDP transport which listens to any available port
transport = lib.create_transport(pj.TransportType.UDP, pj.TransportConfig(5060))
print "\nListening on", transport.info().host,
print "port", transport.info().port, "\n"
# Start the library
lib.start()
# Create local account
acc = lib.create_account(pj.AccountConfig("192.168.5.48", "7000", "7000"))
acc_cb = MyAccountCallback(acc)
acc.set_callback(acc_cb)
acc_cb.wait()
print "\n"
print "Registration complete, status=", acc.info().reg_status, \
"(" + acc.info().reg_reason + ")"
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, c=call 407, 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 == "c":
lck = lib.auto_lock()
current_call = make_call("sip:100@192.168.5.48")
del lck
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
