Add SIP services. Support SIP DTMF in RTC.

Author: dennwc

livekit-api/livekit/api/sip_service.py

@@ -0,0 +1,90 @@
+import aiohttp
+from livekit.protocol import sip as proto_sip
+from ._service import Service
+from .access_token import VideoGrants
+
+SVC = "SIP"
+
+
+class SipService(Service):
+    def __init__(
+        self, session: aiohttp.ClientSession, url: str, api_key: str, api_secret: str
+    ):
+        super().__init__(session, url, api_key, api_secret)
+
+    async def create_sip_trunk(
+        self, create: proto_sip.CreateSIPTrunkRequest
+    ) -> proto_sip.SIPTrunkInfo:
+        return await self._client.request(
+            SVC,
+            "CreateSIPTrunk",
+            create,
+            self._auth_header(VideoGrants()),
+            proto_sip.SIPTrunkInfo,
+        )
+
+    async def list_sip_trunk(
+        self, list: proto_sip.ListSIPTrunkRequest
+    ) -> proto_sip.ListSIPTrunkResponse:
+        return await self._client.request(
+            SVC,
+            "ListSIPTrunk",
+            list,
+            self._auth_header(VideoGrants()),
+            proto_sip.ListSIPTrunkResponse,
+        )
+
+    async def delete_sip_trunk(
+        self, delete: proto_sip.DeleteSIPTrunkRequest
+    ) -> proto_sip.SIPTrunkInfo:
+        return await self._client.request(
+            SVC,
+            "DeleteSIPTrunk",
+            delete,
+            self._auth_header(VideoGrants()),
+            proto_sip.SIPTrunkInfo,
+        )
+
+    async def create_sip_dispatch_rule(
+        self, create: proto_sip.CreateSIPDispatchRuleRequest
+    ) -> proto_sip.SIPDispatchRuleInfo:
+        return await self._client.request(
+            SVC,
+            "CreateSIPDispatchRule",
+            create,
+            self._auth_header(VideoGrants()),
+            proto_sip.SIPDispatchRuleInfo,
+        )
+
+    async def list_sip_dispatch_rule(
+        self, list: proto_sip.ListSIPDispatchRuleRequest
+    ) -> proto_sip.ListSIPDispatchRuleResponse:
+        return await self._client.request(
+            SVC,
+            "ListSIPDispatchRule",
+            list,
+            self._auth_header(VideoGrants()),
+            proto_sip.ListSIPDispatchRuleResponse,
+        )
+
+    async def delete_sip_dispatch_rule(
+        self, delete: proto_sip.DeleteSIPDispatchRuleRequest
+    ) -> proto_sip.SIPDispatchRuleInfo:
+        return await self._client.request(
+            SVC,
+            "DeleteSIPDispatchRule",
+            delete,
+            self._auth_header(VideoGrants()),
+            proto_sip.SIPDispatchRuleInfo,
+        )
+
+    async def create_sip_participant(
+        self, create: proto_sip.CreateSIPParticipantRequest
+    ) -> proto_sip.SIPParticipantInfo:
+        return await self._client.request(
+            SVC,
+            "CreateSIPParticipant",
+            create,
+            self._auth_header(VideoGrants()),
+            proto_sip.SIPParticipantInfo,
+        )

livekit-protocol/generate_proto.sh

@@ -31,6 +31,7 @@ protoc \
     $API_PROTOCOL/livekit_ingress.proto \
     $API_PROTOCOL/livekit_models.proto \
     $API_PROTOCOL/livekit_agent.proto \
+    $API_PROTOCOL/livekit_sip.proto \
     $API_PROTOCOL/livekit_analytics.proto
 
 
@@ -59,7 +60,9 @@ mv "$API_OUT_PYTHON/livekit_agent_pb2.py" "$API_OUT_PYTHON/agent.py"
 mv "$API_OUT_PYTHON/livekit_agent_pb2.pyi" "$API_OUT_PYTHON/agent.pyi"
 mv "$API_OUT_PYTHON/livekit_analytics_pb2.py" "$API_OUT_PYTHON/analytics.py"
 mv "$API_OUT_PYTHON/livekit_analytics_pb2.pyi" "$API_OUT_PYTHON/analytics.pyi"
+mv "$API_OUT_PYTHON/livekit_sip_pb2.py" "$API_OUT_PYTHON/sip.py"
+mv "$API_OUT_PYTHON/livekit_sip_pb2.pyi" "$API_OUT_PYTHON/sip.pyi"
 
-perl -i -pe 's|^(import (livekit_egress_pb2\|livekit_room_pb2\|livekit_webhook_pb2\|livekit_ingress_pb2\|livekit_models_pb2\|livekit_agent_pb2\|livekit_analytics_pb2))|from . $1|g' "$API_OUT_PYTHON"/*.py "$API_OUT_PYTHON"/*.pyi
+perl -i -pe 's|^(import (livekit_egress_pb2\|livekit_room_pb2\|livekit_webhook_pb2\|livekit_ingress_pb2\|livekit_models_pb2\|livekit_agent_pb2\|livekit_analytics_pb2\|livekit_sip_pb2))|from . $1|g' "$API_OUT_PYTHON"/*.py "$API_OUT_PYTHON"/*.pyi
 
 perl -i -pe 's|livekit_(\w+)_pb2|${1}|g' "$API_OUT_PYTHON"/*.py "$API_OUT_PYTHON"/*.pyi