Merge pull request #42 from moha-abdi/feature/incoming-calls

Feature/incoming calls

Author: moha-abdi

PySIP/codecs/__init__.py

@@ -1,13 +1,8 @@
-
 from .g711 import PcmaDecoder, PcmaEncoder, PcmuDecoder, PcmuEncoder
 from .codec_info import CodecInfo
 
 
-CODECS = [
-    CodecInfo.PCMA,
-    CodecInfo.PCMU,
-    CodecInfo.EVENT
-]
+CODECS = [CodecInfo.PCMA, CodecInfo.PCMU, CodecInfo.EVENT]
 
 
 def get_encoder(codec: CodecInfo):
@@ -18,6 +13,7 @@ def get_encoder(codec: CodecInfo):
     else:
         raise ValueError(f"No encoder found for: {codec}")
 
+
 def get_decoder(codec: CodecInfo):
     if codec == CodecInfo.PCMA:
         return PcmaDecoder()

PySIP/codecs/codec_info.py

@@ -46,9 +46,7 @@ def __int__(self) -> int:
             return int(self.value)
         except ValueError:
             pass
-        raise Exception(
-            self.description + " is a dynamically assigned payload"
-        )
+        raise Exception(self.description + " is a dynamically assigned payload")
 
     def __str__(self) -> str:
         if isinstance(self.value, int):
@@ -68,6 +66,7 @@ def __str__(self) -> str:
     L16 = 11, 44100, 1, "L16"
     QCELP = 12, 8000, 1, "QCELP"
     CN = 13, 8000, 1, "CN"
+    OPUS = 107, 48000, 2, "opus"
     # MPA channel varries, should be defined in the RTP packet.
     MPA = 14, 90000, 0, "MPA"
     G728 = 15, 8000, 1, "G728"

PySIP/sip_account.py

@@ -1,7 +1,8 @@
 import asyncio
 from concurrent.futures import ThreadPoolExecutor
+from functools import wraps
 import logging
-from typing import List, Literal, Optional
+from typing import Callable, List, Literal, Optional
 
 from .utils.logger import logger
 from .filters import ConnectionType
@@ -34,6 +35,7 @@ def __init__(
         self.__client_task = None
         self.__sip_client = None
         self.__calls: List[SipCall] = []
+        self.__pending_callbacks: List[Callable] = []
         if self.connection_type == "AUTO":
             self.__setup_connection_type()
 
@@ -97,6 +99,11 @@ async def register(self):
             caller_id=self.caller_id or "",
             sip_core=self.sip_core,
         )
+        # Register any pending callbacks
+        for callback in self.__pending_callbacks:
+            self.__sip_client._register_callback("incoming_call_cb", callback)
+        self.__pending_callbacks = []  # clear pending callbacks
+
         self.__client_task = asyncio.create_task(self.__sip_client.run())
         try:
             await asyncio.wait_for(self.__sip_client.registered.wait(), 4)
@@ -139,3 +146,14 @@ def remove_call(self, call: SipCall):
             self.__calls.remove(call)
         except ValueError:
             pass
+
+    def on_incoming_call(self, func):
+        @wraps(func)
+        async def wrapper(call: SipCall):
+            return await func(call)
+
+        if self.__sip_client:
+            self.__sip_client._register_callback("incoming_call_cb", wrapper)
+        else:
+            self.__pending_callbacks.append(wrapper)
+        return