pjsip pjsua python脚本

import pjsua as pj
import time


class sip_acc_cb(pj.AccountCallback):
    def __init__(self, account = None):
        pj.AccountCallback.__init__(self, account)

    def on_reg_state(self):
        if self.account.info().reg_status == 200:
            print self.account.info().uri, "register ok", self.account.info().reg_expires
        elif self.account.info().reg_status > 200:
            print self.account.info().uri, "register fail :", self.account.info().reg_status, self.account.info().reg_reason, self.account.info().reg_active, self.account.info().reg_expires

    def on_incoming_call2(self, call, rdata):
        print "incoming call :", "contact :", call.info().remote_contact, "from :", call.info().remote_uri
        incoming_call_cb = sip_call_cb(call)
        call.set_callback(incoming_call_cb)
        call.answer(200)

class sip_call_cb(pj.CallCallback):
    def __init__(self, call = None, ring_time = 60, call_duration = 60):
        pj.CallCallback.__init__(self, call)
        self.call_done = 0
        self.call_ok = 0
        self.ring_time = ring_time
        self.call_duration = call_duration

    def bye(self, ring_time = 60, call_duration = 60):
        cancel_time = 0
        bye_time = 0
        while( not self.call_done ):
            time.sleep(1)
            cancel_time += 1
            if self.call_ok:
                bye_time += 1
                if bye_time >= call_duration and not self.call_done:
                    print "bye call"
                    self.call.hangup()
                    break
            elif cancel_time >= ring_time and not self.call_done:
                print "cancel call"
                self.call.hangup()
                break
        else:
            print "call done"

    def on_state(self):
        print self.call.info().remote_uri, self.call.info().state, self.call.info().state_text, self.call.info().last_code, self.call.info().last_reason
        if self.call.info().state == pj.CallState.DISCONNECTED:
            self.call_done = 1
        elif self.call.info().state == pj.CallState.CONFIRMED:
            self.call_ok = 1
            self.bye(self.ring_time, self.call_duration)

class sip_ua():
    def __init__(self, local_ip = "", local_port = 5060, enable_siptrace = False, level = 5, console_level = 5):
        self.lib = pj.Lib()
        ua_cfg = None
        log_cfg = pj.LogConfig(callback = self.log_cb, level = level, console_level = console_level)
        log_cfg.msg_logging = enable_siptrace
        media_cfg = None
        self.lib.init(ua_cfg = ua_cfg, log_cfg = log_cfg, media_cfg = media_cfg)
        tp_cfg = pj.TransportConfig(local_port, local_ip)
        udp = self.lib.create_transport(pj.TransportType.UDP, tp_cfg)
        self.lib.start()
        #print self.lib.get_snd_dev()
        self.lib.set_null_snd_dev()

        self.acount_list = {}

    def create_account(self, account_name = "", domain = "", username = "", password = "", enable_register = True, register_expires = 3600):
        sip_uri = pj.SIPUri()
        sip_uri.scheme = "sip"
        sip_uri.user = username
        sip_uri.host = domain
        acc_cfg = pj.AccountConfig()
        acc_cfg.id = sip_uri.encode()
        if enable_register:
            acc_cfg.reg_uri = acc_cfg.id
            acc_cfg.reg_timeout = register_expires
            acc_cfg.auth_cred = [pj.AuthCred("*", username, password)]
        acc_cb = sip_acc_cb()
        acc = self.lib.create_account(acc_cfg, cb = acc_cb)
        self.acount_list[account_name] = acc

    def create_call(self, account_name = "", callee_id = "", ring_time = 60, call_duration = 60):
        call_cb = sip_call_cb(ring_time = ring_time, call_duration = call_duration)
        self.call = self.acount_list[account_name].make_call(callee_id, cb = call_cb)

    def log_cb(self, log_level, log_str, log_len):
        print log_level, log_str,

    def main_loop(self):
        while True:
            pass

    def end(self):
        self.lib.destroy()
        print "sip ua exit done"


uac = sip_ua(local_ip = "192.168.56.101", local_port = 5061, enable_siptrace = False, level = 1, console_level = 1)
uac.create_account(account_name = "test1", domain = "192.168.56.104:5060", username = "1001", password = "1234", register_expires = 60, enable_register = True)
uac.create_call(account_name = "test1", callee_id = "sip:5000@192.168.56.104:5060", ring_time = 60, call_duration = 6)
uac.main_loop()