%i.ddlZddlmZddlmZmZmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZmZddlmZddlmZdZ Gd deZ!y) N)uuid4)CreateRoomRequestListRoomsRequestDeleteRoomRequestListRoomsResponseDeleteRoomResponseListParticipantsRequestListParticipantsResponseRoomParticipantIdentityMuteRoomTrackRequestMuteRoomTrackResponseUpdateParticipantRequestUpdateSubscriptionsRequestSendDataRequestSendDataResponseUpdateRoomMetadataRequestRemoveParticipantResponseUpdateSubscriptionsResponseForwardParticipantRequestForwardParticipantResponseMoveParticipantRequestMoveParticipantResponse)RoomParticipantInfo)Service) VideoGrants RoomServiceceZdZdZdej dededeffd Zdede fd Z d e de fd Z d edefd Zdede fdZd edefdZdedefdZdedefdZdeddfdZdeddfdZdede fdZ!de"defdZ#de$de%fdZ&de'de(fdZ)xZ*S)ra`Client for LiveKit RoomService API Recommended way to use this service is via `livekit.api.LiveKitAPI`: ```python from livekit import api lkapi = api.LiveKitAPI() room_service = lkapi.room ``` Also see https://docs.livekit.io/home/server/managing-rooms/ and https://docs.livekit.io/home/server/managing-participants/ sessionurlapi_key api_secretc*t|||||y)N)super__init__)selfr r!r"r# __class__s R/var/www/html/engine/venv/lib/python3.12/site-packages/livekit/api/room_service.pyr&zRoomService.__init__0s #w ;createreturnc K|jjtd||jt dt d{S7w)aCreates a new room with specified configuration. Args: create (CreateRoomRequest): arg containing: - name: str - Unique room name - empty_timeout: int - Seconds to keep room open if empty - max_participants: int - Max allowed participants - metadata: str - Custom room metadata - egress: RoomEgress - Egress configuration - min_playout_delay: int - Minimum playout delay in ms - max_playout_delay: int - Maximum playout delay in ms - sync_streams: bool - Enable A/V sync for playout delays >200ms Returns: Room: The created room object CreateRoomT room_createN)_clientrequestSVC _auth_headerrr)r'r+s r) create_roomzRoomService.create_room3sH(\\))      kd; <      AA A A listc K|jjtd||jt dt d{S7w)a!Lists active rooms. Args: list (ListRoomsRequest): arg containing: - names: list[str] - Optional list of room names to filter by Returns: ListRoomsResponse: - rooms: list[Room] - List of active Room objects ListRoomsT) room_listN)r1r2r3r4rrr'r7s r) list_roomszRoomService.list_roomsOsH\\))      kD9 :      r6deletec K|jjtd||jt dt d{S7w)zDeletes a room and disconnects all participants. Args: delete (DeleteRoomRequest): arg containing: - room: str - Name of room to delete Returns: DeleteRoomResponse: Empty response object DeleteRoomTr/N)r1r2r3r4rr)r'r=s r) delete_roomzRoomService.delete_roombsH\\))      kd; <      r6updatec K|jjtd||jt d|j t d{S7w)aPUpdates a room's [metadata](https://docs.livekit.io/home/client/data/room-metadata/). Args: update (UpdateRoomMetadataRequest): arg containing: - room: str - Name of room to update - metadata: str - New metadata to set Returns: Room: Updated Room object UpdateRoomMetadataT room_adminroomN)r1r2r3r4rrFrr'rAs r)update_room_metadataz RoomService.update_room_metadatatsN\\))     kT L M      AAAAc K|jjtd||jt d|j t d{S7w)aFLists all participants in a room. Args: list (ListParticipantsRequest): arg containing: - room: str - Name of room to list participants from Returns: ListParticipantsResponse: - participants: list[ParticipantInfo] - List of participant details ListParticipantsTrDN)r1r2r3r4rrFr r;s r)list_participantszRoomService.list_participantssN\\))      kT J K $     rIgetc K|jjtd||jt d|j t d{S7w)a/Gets details about a specific participant. Args: get (RoomParticipantIdentity): arg containing: - room: str - Room name - identity: str - Participant identity to look up Returns: ParticipantInfo: - sid: str - Participant session ID - identity: str - Participant identity - state: int - Connection state - tracks: list[TrackInfo] - Published tracks - metadata: str - Participant metadata - joined_at: int - Join timestamp - name: str - Display name - version: int - Protocol version - permission: ParticipantPermission - Granted permissions - region: str - Connected region GetParticipantTrDNr1r2r3r4rrFr)r'rMs r)get_participantzRoomService.get_participantsN*\\))      kTI J      rIremovec K|jjtd||jt d|j t d{S7w)a3Removes a participant from a room. Args: remove (RoomParticipantIdentity): arg containing: - room: str - Room name - identity: str - Identity of participant to remove Returns: RemoveParticipantResponse: Empty response object RemoveParticipantTrDN)r1r2r3r4rrFr)r'rRs r)remove_participantzRoomService.remove_participantsN\\))      kT L M %     rIforwardNc K|jjtd||jt d|j |j td{y7w)aForwards a participant and their published tracks from one room to another. This feature is only available for LiveKit Cloud/Private Cloud. Args: forward (ForwardParticipantRequest): arg containing: - room: str - Room name - identity: str - identity of Participant to forward - destination_room: str - Destination room name ForwardParticipantTrErFdestination_roomN)r1r2r3r4rrFrZr)r'rVs r)forward_participantzRoomService.forward_participantsYll""     #',,IaIa  '  AA$A"A$movec K|jjtd||jt d|j |j td{y7w)ahMoves a participant from one room to another. This feature is only available for LiveKit Cloud/Private Cloud. Args: move (MoveParticipantRequest): arg containing: - room: str - Room name - identity: str - Participant identity - destination_room: str - Destination room name MoveParticipantTrYN)r1r2r3r4rrFrZr)r'r]s r)move_participantzRoomService.move_participants[ll""      #%)%:%:  $  r\c K|jjtd||jt d|j t d{S7w)aMutes or unmutes a participant's published track. Args: update (MuteRoomTrackRequest): arg containing: - room: str - Room name - identity: str - Participant identity - track_sid: str - Track session ID to mute - muted: bool - True to mute, False to unmute Returns: MuteRoomTrackResponse containing: - track: TrackInfo - Updated track information MutePublishedTrackTrDN)r1r2r3r4rrFr rGs r)mute_published_trackz RoomService.mute_published_tracksN"\\))     kT L M !     rIc K|jjtd||jt d|j t d{S7w)aUpdates a participant's metadata or permissions. Args: update (UpdateParticipantRequest): arg containing: - room: str - Room name - identity: str - Participant identity - metadata: str - New metadata - permission: ParticipantPermission - New permissions - name: str - New display name - attributes: dict[str, str] - Key-value attributes Returns: ParticipantInfo: Updated participant information UpdateParticipantTrDNrPrGs r)update_participantzRoomService.update_participantsN\\))      kT L M      rIc K|jjtd||jt d|j t d{S7w)aUpdates a participant's track subscriptions. Args: update (UpdateSubscriptionsRequest): arg containing: - room: str - Room name - identity: str - Participant identity - track_sids: list[str] - Track session IDs - subscribe: bool - True to subscribe, False to unsubscribe - participant_tracks: list[ParticipantTracks] - Participant track mappings Returns: UpdateSubscriptionsResponse: Empty response object UpdateSubscriptionsTrDN)r1r2r3r4rrFrrGs r)update_subscriptionsz RoomService.update_subscriptions.sN \\))  !    kT L M '     rIsendc Ktj|_|jj t d||j td|jtd{S7w)aSends data to participants in a room. Args: send (SendDataRequest): arg containing: - room: str - Room name - data: bytes - Data payload to send - kind: DataPacket.Kind - RELIABLE or LOSSY delivery - destination_identities: list[str] - Target participant identities - topic: str - Optional topic for the message Returns: SendDataResponse: Empty response object SendDataTrDN) rbytesnoncer1r2r3r4rrFr)r'rjs r) send_datazRoomService.send_dataFs[W]] \\))      kT J K      sA(A1*A/+A1)+__name__ __module__ __qualname____doc__aiohttp ClientSessionstrr&rrr5rrr<rrr@rrHr r rLr rrQrrUrr[rr`r r rcrrfrrrirrro __classcell__)r(s@r)rr"s? < 5 5P $ 1J t & ,C H` & )@ _ : - " * 1J t 0 +A d 4 $   2 /G O . 0 $ 0 O 8H r*)"rtuuidrlivekit.protocol.roomrrrrrr r r r r rrrrrrrrrrrlivekit.protocol.modelsrr_servicer access_tokenrr3rr*r)r~sJ.:%z 'z r*