sekarpdkt / misc Goto Github PK

import pjsua2 as pj
import time

# Subclass to extend the Account and get notifications etc.
class Account(pj.Account):
    def onRegState(self, prm):
        print("***OnRegState: " + prm.reason)
        if prm.code == 200:
            make_call(self)

# Subclass to handle call events
class MyCall(pj.Call):
    def __init__(self, acc, dest_uri):
        pj.Call.__init__(self, acc)
        self.dest_uri = dest_uri

    def on_state(self):
        if self.info().state == pj.PJSIP_INV_STATE_CALLING:
            print("Chamando", self.dest_uri)
        elif self.info().state == pj.PJSIP_INV_STATE_INCOMING:
            print("Chamada recebida de", self.info().remote_uri)
            self.answer()
        elif self.info().state == pj.PJSIP_INV_STATE_EARLY:
            pass
        elif self.info().state == pj.PJSIP_INV_STATE_CONNECTING:
            pass
        elif self.info().state == pj.PJSIP_INV_STATE_CONFIRMED:
            print("Chamada conectada. Reproduzindo áudio...")
            self.start_audio("testeaudio.wav")
        elif self.info().state == pj.PJSIP_INV_STATE_DISCONNECTED:
            print("Chamada desconectada, motivo:", self.info().last_reason)
            self.delete()

# pjsua2 test function
def pjsua2_test():
    # Create and initialize the library
    ep_cfg = pj.EpConfig()
    ep = pj.Endpoint()
    ep.libCreate()
    ep.libInit(ep_cfg)

    # Create SIP transport. Error handling sample is shown
    sipTpConfig = pj.TransportConfig()
    sipTpConfig.port = 5064
    ep.transportCreate(pj.PJSIP_TRANSPORT_UDP, sipTpConfig)
    # Start the library
    ep.libStart()

    acfg = pj.AccountConfig()
    acfg.idUri = "sip:[email protected]:5064"
    acfg.regConfig.registrarUri = "sip:sbc.dominio.servidor:5064"
    cred = pj.AuthCredInfo("digest", "*", "9999", 0,  "9999#")
    acfg.sipConfig.authCreds.append(cred)
    # Create the account
    acc = Account()
    acc.create(acfg)
    # Here we don't have anything else to do..
    try:
        while True:
            time.sleep(1)
    except KeyboardInterrupt:
        print("Encerrando chamada...")
        if acc.calls.count > 0:
            call = acc.calls[0]
            call.hangup()
            time.sleep(2)
        ep.libDestroy()

def make_call(account):
    dest_uri = "sip:[email protected]:5064"  # Ramal 1571
    call = MyCall(account, dest_uri)
    call.make_call(dest_uri)

#
# main()
#
if __name__ == "__main__":
    pjsua2_test()

***OnRegState: OK
Traceback (most recent call last):
  File "/app/notifica_voz/call_2.py", line 9, in onRegState
    make_call(self)
  File "/app/notifica_voz/call_2.py", line 72, in make_call
    call.make_call(dest_uri)
AttributeError: 'MyCall' object has no attribute 'make_call'