o ic @sdZddlZGdddZdS)zNLiveKit REST Helpers. Methods that wrap the LiveKit API for room management. Nc @sXeZdZdZdddedededejfdd Zdd ed efd dZ ded efddZ dS)LiveKitRESTHelperzlHelper class for interacting with LiveKit's REST API. Provides methods for managing LiveKit rooms. zhttps://your-livekit-host.com)api_urlapi_key api_secretraiohttp_sessioncCs"||_||_|d|_||_dS)a,Initialize the LiveKit REST helper. Args: api_key: Your LiveKit API key. api_secret: Your LiveKit API secret. api_url: LiveKit server URL (e.g. "https://your-livekit-host.com"). aiohttp_session: Async HTTP session for making requests. /N)rrrstriprr)selfrrrrr T/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/transports/livekit/utils.py__init__s  zLiveKitRESTHelper.__init__T room_createreturncCsNddl}ddl}|j|jt|t|dd|id}|j||jddS)zCreate a signed access token for LiveKit API authentication. Args: room_create: Whether to grant roomCreate permission. Returns: Signed JWT access token. rN< roomCreate)isssubnbfexpvideoHS256) algorithm)timejwtrintencoder)r r rrclaimsr r r _create_access_token*s   z&LiveKitRESTHelper._create_access_token room_namec s|jdd}d|dd}|jj|jd|d|id4Id H&}|jd kr=|Id H}td |d |jd |Wd Id HdS1Id HsNwYdS)a2Delete a LiveKit room by name. This will forcibly disconnect all participants currently in the room. Args: room_name: Name of the room to delete. Returns: True if deletion was successful. Raises: Exception: If deletion fails. T)r zBearer zapplication/json) Authorizationz Content-Typez%/twirp/livekit.RoomService/DeleteRoomroom)headersjsonNzFailed to delete room [z ] (status: z): )rrpostrstatustext Exception)r rtokenr!rr&r r r delete_room_by_nameCs$     z%LiveKitRESTHelper.delete_room_by_nameN)T) __name__ __module__ __qualname____doc__straiohttp ClientSessionr boolrr*r r r r rs  r)r.r0rr r r r s