doorpi.sipphone.pjsua_lib.SipPhoneAccountCallBack

Complexity

Total Complexity

13

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

7 Methods

Rating	Name	Duplication	Size	Complexity
B	SipPhoneAccountCallBack.on_incoming_call()	25	44	5
A	SipPhoneAccountCallBack.destroy()	0	3	1
A	SipPhoneAccountCallBack.__init__()	0	12	1
A	SipPhoneAccountCallBack.wait()	0	3	1
A	SipPhoneAccountCallBack.__del__()	0	2	1
A	SipPhoneAccountCallBack.answer_call()	0	5	1
A	SipPhoneAccountCallBack.on_reg_state()	0	4	3

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import logging
logger = logging.getLogger(__name__)
logger.debug("%s loaded", __name__)

import threading
import datetime

The import datetime seems to be unused.

import time

The import time seems to be unused.

import os

The import os seems to be unused.

import pjsua as pj
from doorpi import DoorPi
from SipPhoneCallCallBack import SipPhoneCallCallBack as CallCallback

class SipPhoneAccountCallBack(pj.AccountCallback):

    sem = None

    def __init__(self, account = None):
        logger.debug("__init__")
        pj.AccountCallback.__init__(self, account)
        DoorPi().event_handler.register_event('BeforeCallIncoming', __name__)
        DoorPi().event_handler.register_event('OnCallReconnect', __name__)
        DoorPi().event_handler.register_event('AfterCallReconnect', __name__)
        DoorPi().event_handler.register_event('OnCallBusy', __name__)
        DoorPi().event_handler.register_event('AfterCallBusy', __name__)
        DoorPi().event_handler.register_event('OnCallIncoming', __name__)
        DoorPi().event_handler.register_event('AfterCallIncoming', __name__)
        DoorPi().event_handler.register_event('OnCallReject', __name__)
        DoorPi().event_handler.register_event('AfterCallReject', __name__)
        #DoorPi().event_handler.register_event('AfterAccountRegState', __name__)

    def __del__(self):
        self.destroy()

    def destroy(self):
        logger.debug("destroy")
        DoorPi().event_handler.unregister_source(__name__, True)

    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()

        #DoorPi().event_handler('AfterAccountRegState', __name__)
        #logger.debug(self.account.info.reg_status)

    def answer_call(self, call):
        DoorPi().sipphone.current_callcallback = CallCallback()
        call.set_callback(DoorPi().sipphone.current_callcallback)
        DoorPi().sipphone.current_call = call
        DoorPi().sipphone.current_call.answer(code = 200)

    def on_incoming_call(self, call):
        # SIP-Status-Codes: http://de.wikipedia.org/wiki/SIP-Status-Codes
        # 200 = OK
        # 401 = Unauthorized
        # 403 = Forbidden
        # 486 = Busy Here
        # 494 = Security Agreement Required
        logger.debug("on_incoming_call")
        logger.info("Incoming call from %s", str(call.info().remote_uri))
        DoorPi().event_handler('BeforeCallIncoming', __name__)

        call.answer(180)

        if DoorPi().sipphone.current_call is not None and DoorPi().sipphone.current_call.is_valid():
            logger.debug("Incoming call while another call is active")
            logger.debug("- incoming.remote_uri: %s", call.info().remote_uri)
            logger.debug("- current.remote_uri : %s", DoorPi().sipphone.current_call.info().remote_uri)

            if call.info().remote_uri == DoorPi().sipphone.current_call.info().remote_uri:

This code seems to be duplicated in your project.

                logger.info("Current call is incoming call - quitting current and connecting to incoming. Maybe connection reset?")
                DoorPi().event_handler('OnCallReconnect', __name__, {'remote_uri': call.info().remote_uri})
                DoorPi().current_call.hangup()
                self.answer_call(call)
                DoorPi().event_handler('AfterCallReconnect', __name__)
                return
            else:
                logger.info("Incoming and current call are different - sending busy signal to incoming call")
                DoorPi().event_handler('OnCallBusy', __name__, {'remote_uri': call.info().remote_uri})
                call.answer(code = 494, reason = "Security Agreement Required")
                DoorPi().event_handler('AfterCallBusy', __name__)
                return

        if DoorPi().sipphone.is_admin_number(call.info().remote_uri):

This code seems to be duplicated in your project.

            logger.debug("Incoming call from trusted admin number %s -> autoanswer", call.info().remote_uri)
            DoorPi().event_handler('OnCallIncoming', __name__, {'remote_uri': call.info().remote_uri})
            self.answer_call(call)
            DoorPi().event_handler('AfterCallIncoming', __name__)
            return
        else:
            logger.debug("Incoming call ist not from a trusted admin number %s -> sending busy signal", call.info().remote_uri)
            DoorPi().event_handler('OnCallReject', __name__, {'remote_uri': call.info().remote_uri})
            call.answer(code = 494, reason = "Security Agreement Required")
            DoorPi().event_handler('AfterCallReject', __name__)
            return