feat: realtime client secret added

Author: csgulati09

portkey_ai/__init__.py

@@ -137,6 +137,8 @@
     AsyncWebhooks,
     MainRealtime,
     AsyncMainRealtime,
+    ClientSecrets,
+    AsyncClientSecrets,
 )
 
 from portkey_ai.version import VERSION
@@ -293,4 +295,6 @@
     "AsyncWebhooks",
     "MainRealtime",
     "AsyncMainRealtime",
+    "ClientSecrets",
+    "AsyncClientSecrets",
 ]

portkey_ai/api_resources/__init__.py

@@ -125,6 +125,8 @@
     AsyncWebhooks,
     MainRealtime,
     AsyncMainRealtime,
+    ClientSecrets,
+    AsyncClientSecrets,
 )
 from .utils import (
     Modes,
@@ -285,4 +287,6 @@
     "AsyncWebhooks",
     "MainRealtime",
     "AsyncMainRealtime",
+    "ClientSecrets",
+    "AsyncClientSecrets",
 ]

portkey_ai/api_resources/apis/__init__.py

@@ -160,6 +160,8 @@
 from .main_realtime import (
     MainRealtime,
     AsyncMainRealtime,
+    ClientSecrets,
+    AsyncClientSecrets,
 )
 
 sys.modules["openai"] = vendored_openai  # For pydantic v1 and v2 compatibility
@@ -300,4 +302,6 @@
     "AsyncWebhooks",
     "MainRealtime",
     "AsyncMainRealtime",
+    "ClientSecrets",
+    "AsyncClientSecrets",
 ]

portkey_ai/api_resources/apis/main_realtime.py

@@ -1,3 +1,4 @@
+from typing import Any
 from portkey_ai._vendor.openai.resources.realtime.realtime import (
     AsyncRealtimeConnectionManager,
     RealtimeConnectionManager,
@@ -14,6 +15,7 @@ class MainRealtime(APIResource):
     def __init__(self, client: Portkey) -> None:
         super().__init__(client)
         self.openai_client = client.openai_client
+        self.client_secrets = ClientSecrets(client)
 
     def connect(
         self,
@@ -35,6 +37,7 @@ class AsyncMainRealtime(AsyncAPIResource):
     def __init__(self, client: AsyncPortkey) -> None:
         super().__init__(client)
         self.openai_client = client.openai_client
+        self.client_secrets = AsyncClientSecrets(client)
 
     def connect(
         self,
@@ -50,3 +53,57 @@ def connect(
             extra_headers=extra_headers,
             websocket_connection_options=websocket_connection_options,
         )
+
+
+class ClientSecrets(APIResource):
+    def __init__(self, client: Portkey) -> None:
+        super().__init__(client)
+        self.openai_client = client.openai_client
+
+    def create(
+        self,
+        *,
+        expires_after: Any,
+        session: Any,
+        **kwargs: Any,
+    ) -> Any:
+        extra_headers = kwargs.pop("extra_headers", None)
+        extra_query = kwargs.pop("extra_query", None)
+        extra_body = kwargs.pop("extra_body", None)
+        timeout = kwargs.pop("timeout", None)
+
+        return self.openai_client.realtime.client_secrets.create(
+            expires_after=expires_after,
+            session=session,
+            extra_headers=extra_headers,
+            extra_query=extra_query,
+            extra_body={**(extra_body or {}), **kwargs},
+            timeout=timeout,
+        )
+
+
+class AsyncClientSecrets(AsyncAPIResource):
+    def __init__(self, client: AsyncPortkey) -> None:
+        super().__init__(client)
+        self.openai_client = client.openai_client
+
+    async def create(
+        self,
+        *,
+        expires_after: Any,
+        session: Any,
+        **kwargs: Any,
+    ) -> Any:
+        extra_headers = kwargs.pop("extra_headers", None)
+        extra_query = kwargs.pop("extra_query", None)
+        extra_body = kwargs.pop("extra_body", None)
+        timeout = kwargs.pop("timeout", None)
+
+        return await self.openai_client.realtime.client_secrets.create(
+            expires_after=expires_after,
+            session=session,
+            extra_headers=extra_headers,
+            extra_query=extra_query,
+            extra_body={**(extra_body or {}), **kwargs},
+            timeout=timeout,
+        )