fmt

Author: bcherry

livekit-api/livekit/api/agent_dispatch_service.py

@@ -1,6 +1,12 @@
 import aiohttp
 from typing import Optional
-from livekit.protocol.agent_dispatch import CreateAgentDispatchRequest, AgentDispatch, DeleteAgentDispatchRequest, ListAgentDispatchRequest, ListAgentDispatchResponse
+from livekit.protocol.agent_dispatch import (
+    CreateAgentDispatchRequest,
+    AgentDispatch,
+    DeleteAgentDispatchRequest,
+    ListAgentDispatchRequest,
+    ListAgentDispatchResponse,
+)
 from ._service import Service
 from .access_token import VideoGrants
 
@@ -25,9 +31,7 @@ def __init__(
     ):
         super().__init__(session, url, api_key, api_secret)
 
-    async def create_dispatch(
-        self, req: CreateAgentDispatchRequest
-    ) -> AgentDispatch:
+    async def create_dispatch(self, req: CreateAgentDispatchRequest) -> AgentDispatch:
         """Create an explicit dispatch for an agent to join a room.
 
         To use explicit dispatch, your agent must be registered with an `agentName`.
@@ -46,9 +50,7 @@ async def create_dispatch(
             AgentDispatch,
         )
 
-    async def delete_dispatch(
-        self, dispatch_id: str, room_name: str
-    ) -> AgentDispatch:
+    async def delete_dispatch(self, dispatch_id: str, room_name: str) -> AgentDispatch:
         """Delete an explicit dispatch for an agent in a room.
 
         Args:
@@ -69,9 +71,7 @@ async def delete_dispatch(
             AgentDispatch,
         )
 
-    async def list_dispatch(
-        self, room_name: str
-    ) -> list[AgentDispatch]:
+    async def list_dispatch(self, room_name: str) -> list[AgentDispatch]:
         """List all agent dispatches in a room.
 
         Args:
@@ -104,9 +104,7 @@ async def get_dispatch(
         res = await self._client.request(
             SVC,
             "ListDispatch",
-            ListAgentDispatchRequest(
-                dispatch_id=dispatch_id, room=room_name
-            ),
+            ListAgentDispatchRequest(dispatch_id=dispatch_id, room=room_name),
             self._auth_header(VideoGrants(room_admin=True, room=room_name)),
             ListAgentDispatchResponse,
         )

livekit-api/livekit/api/egress_service.py

@@ -1,24 +1,38 @@
 import aiohttp
-from livekit.protocol.egress import RoomCompositeEgressRequest, WebEgressRequest, ParticipantEgressRequest, TrackCompositeEgressRequest, TrackEgressRequest, UpdateLayoutRequest, UpdateStreamRequest, ListEgressRequest, StopEgressRequest, EgressInfo, ListEgressResponse
+from livekit.protocol.egress import (
+    RoomCompositeEgressRequest,
+    WebEgressRequest,
+    ParticipantEgressRequest,
+    TrackCompositeEgressRequest,
+    TrackEgressRequest,
+    UpdateLayoutRequest,
+    UpdateStreamRequest,
+    ListEgressRequest,
+    StopEgressRequest,
+    EgressInfo,
+    ListEgressResponse,
+)
 from ._service import Service
 from .access_token import VideoGrants
 
 SVC = "Egress"
 """@private"""
 
+
 class EgressService(Service):
     """Client for LiveKit Egress Service API
-    
+
     Recommended way to use this service is via `livekit.api.LiveKitAPI`:
-    
+
     ```python
     from livekit import api
     lkapi = api.LiveKitAPI()
     egress = lkapi.egress
     ```
-    
+
     Also see https://docs.livekit.io/home/egress/overview/
     """
+
     def __init__(
         self, session: aiohttp.ClientSession, url: str, api_key: str, api_secret: str
     ):
@@ -35,9 +49,7 @@ async def start_room_composite_egress(
             EgressInfo,
         )
 
-    async def start_web_egress(
-        self, start: WebEgressRequest
-    ) -> EgressInfo:
+    async def start_web_egress(self, start: WebEgressRequest) -> EgressInfo:
         return await self._client.request(
             SVC,
             "StartWebEgress",
@@ -68,9 +80,7 @@ async def start_track_composite_egress(
             EgressInfo,
         )
 
-    async def start_track_egress(
-        self, start: TrackEgressRequest
-    ) -> EgressInfo:
+    async def start_track_egress(self, start: TrackEgressRequest) -> EgressInfo:
         return await self._client.request(
             SVC,
             "StartTrackEgress",
@@ -79,9 +89,7 @@ async def start_track_egress(
             EgressInfo,
         )
 
-    async def update_layout(
-        self, update: UpdateLayoutRequest
-    ) -> EgressInfo:
+    async def update_layout(self, update: UpdateLayoutRequest) -> EgressInfo:
         return await self._client.request(
             SVC,
             "UpdateLayout",
@@ -90,9 +98,7 @@ async def update_layout(
             EgressInfo,
         )
 
-    async def update_stream(
-        self, update: UpdateStreamRequest
-    ) -> EgressInfo:
+    async def update_stream(self, update: UpdateStreamRequest) -> EgressInfo:
         return await self._client.request(
             SVC,
             "UpdateStream",
@@ -101,9 +107,7 @@ async def update_stream(
             EgressInfo,
         )
 
-    async def list_egress(
-        self, list: ListEgressRequest
-    ) -> ListEgressResponse:
+    async def list_egress(self, list: ListEgressRequest) -> ListEgressResponse:
         return await self._client.request(
             SVC,
             "ListEgress",
@@ -112,9 +116,7 @@ async def list_egress(
             ListEgressResponse,
         )
 
-    async def stop_egress(
-        self, stop: StopEgressRequest
-    ) -> EgressInfo:
+    async def stop_egress(self, stop: StopEgressRequest) -> EgressInfo:
         return await self._client.request(
             SVC,
             "StopEgress",

livekit-api/livekit/api/ingress_service.py

@@ -1,32 +1,39 @@
 import aiohttp
-from livekit.protocol.ingress import CreateIngressRequest, IngressInfo, UpdateIngressRequest, ListIngressRequest, DeleteIngressRequest, ListIngressResponse
+from livekit.protocol.ingress import (
+    CreateIngressRequest,
+    IngressInfo,
+    UpdateIngressRequest,
+    ListIngressRequest,
+    DeleteIngressRequest,
+    ListIngressResponse,
+)
 from ._service import Service
 from .access_token import VideoGrants
 
 SVC = "Ingress"
 """@private"""
 
+
 class IngressService(Service):
     """Client for LiveKit Ingress Service API
-    
+
     Recommended way to use this service is via `livekit.api.LiveKitAPI`:
-    
+
     ```python
     from livekit import api
     lkapi = api.LiveKitAPI()
     ingress = lkapi.ingress
     ```
-    
+
     Also see https://docs.livekit.io/home/ingress/overview/
     """
+
     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_ingress(
-        self, create: CreateIngressRequest
-    ) -> IngressInfo:
+    async def create_ingress(self, create: CreateIngressRequest) -> IngressInfo:
         return await self._client.request(
             SVC,
             "CreateIngress",
@@ -35,9 +42,7 @@ async def create_ingress(
             IngressInfo,
         )
 
-    async def update_ingress(
-        self, update: UpdateIngressRequest
-    ) -> IngressInfo:
+    async def update_ingress(self, update: UpdateIngressRequest) -> IngressInfo:
         return await self._client.request(
             SVC,
             "UpdateIngress",
@@ -46,9 +51,7 @@ async def update_ingress(
             IngressInfo,
         )
 
-    async def list_ingress(
-        self, list: ListIngressRequest
-    ) -> ListIngressResponse:
+    async def list_ingress(self, list: ListIngressRequest) -> ListIngressResponse:
         return await self._client.request(
             SVC,
             "ListIngress",
@@ -57,9 +60,7 @@ async def list_ingress(
             ListIngressResponse,
         )
 
-    async def delete_ingress(
-        self, delete: DeleteIngressRequest
-    ) -> IngressInfo:
+    async def delete_ingress(self, delete: DeleteIngressRequest) -> IngressInfo:
         return await self._client.request(
             SVC,
             "DeleteIngress",

livekit-api/livekit/api/livekit_api.py

@@ -10,7 +10,7 @@
 
 class LiveKitAPI:
     """LiveKit Server API Client
-    
+
     This class is the main entrypoint, which exposes all services.
 
     Usage:
@@ -31,7 +31,7 @@ def __init__(
         timeout: aiohttp.ClientTimeout = aiohttp.ClientTimeout(total=60),  # 60 seconds
     ):
         """Create a new LiveKitAPI instance.
-        
+
         Args:
             url: LiveKit server URL (read from `LIVEKIT_URL` environment variable if not provided)
             api_key: API key (read from `LIVEKIT_API_KEY` environment variable if not provided)
@@ -60,35 +60,35 @@ def __init__(
     @property
     def agent_dispatch(self) -> AgentDispatchService:
         """Instance of the AgentDispatchService
-        
+
         See `livekit.api.agent_dispatch_service.AgentDispatchService`"""
         return self._agent_dispatch
 
     @property
     def room(self) -> RoomService:
         """Instance of the RoomService
-        
+
         See `livekit.api.room_service.RoomService`"""
         return self._room
 
     @property
     def ingress(self) -> IngressService:
         """Instance of the IngressService
-        
+
         See `livekit.api.ingress_service.IngressService`"""
         return self._ingress
 
     @property
     def egress(self) -> EgressService:
         """Instance of the EgressService
-        
+
         See `livekit.api.egress_service.EgressService`"""
         return self._egress
 
     @property
     def sip(self) -> SipService:
         """Instance of the SipService
-        
+
         See `livekit.api.sip_service.SipService`"""
         return self._sip