/jr SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r J r J r J r JrJrJrJr SSKJrJr SSKJrJr SSKJr SSKJr SS KJr SS KJr SS K!J"r" SS K#J$r$ SS K%J&r& SSK'J(r(J)r)J*r* SSK+J,r, SSK-J.r. SSK/J0r0 SSK1J2r2 SSK-J3r3 SSK4J5r5J6r6J7r7J8r8 SSK9J:r: SSKJ;r< "SS\=5r>"SS\=5r?"SS\=5r@"SS\=5rA"SS \=5rB"S!S"\=5rC"S#S$\5rD\ S%/\ \ \\E\\E44rF\"S&\ \3/\ \ \\E\\E44S'9rG"S(S)\D5rH"S*S+\D5rIg),) annotationsN) ListUnionCallableDict AwaitableOptionalMappingcastTypeVar)abstractmethodABC) FfiClient FfiHandle)ffi_pb2)participant_pb2)TrackPublishOptions)TranscriptionSegment)ParticipantTrackPermission)BroadcastQueue) LocalTrack)LocalTrackPublicationRemoteTrackPublicationTrackPublication) Transcription)RpcError)"RpcMethodInvocationResponseRequest)logger)RpcInvocationData)TextStreamWriterByteStreamWriterByteStreamInfoSTREAM_CHUNK_SIZE)LocalDataTrack)data_track_pb2c\rSrSrSSjrSrg)PublishTrackError=cXlgNmessageselfr-s H/app/agent/.venv/lib/python3.13/site-packages/livekit/rtc/participant.py__init__PublishTrackError.__init__> r,Nr-strreturnNone__name__ __module__ __qualname____firstlineno__r1__static_attributes__r4r0r(r(=r4r(c\rSrSrSSjrSrg)UnpublishTrackErrorBcXlgr+r,r.s r0r1UnpublishTrackError.__init__Cr3r4r,Nr5r9r?r4r0rBrBBr@r4rBc\rSrSrSSjrSrg)PublishDataErrorGcXlgr+r,r.s r0r1PublishDataError.__init__Hr3r4r,Nr5r9r?r4r0rGrGGr@r4rGc\rSrSrSSjrSrg)PublishDTMFErrorLcXlgr+r,r.s r0r1PublishDTMFError.__init__Mr3r4r,Nr5r9r?r4r0rLrLLr@r4rLc\rSrSrSSjrSrg)PublishTranscriptionErrorQcXlgr+r,r.s r0r1"PublishTranscriptionError.__init__Rr3r4r,Nr5r9r?r4r0rQrQQr@r4rQc\rSrSrSSjrSrg)PublishDataTrackErrorVcXlgr+r,r.s r0r1PublishDataTrackError.__init__Wr3r4r,Nr5r9r?r4r0rVrVVr@r4rVc\rSrSrSSjr\\SSj55r\SSj5r\SSj5r \SSj5r \SSj5r \SSj5r \SS j5r \SS j5r\SS j5r\SS j5r\SS j5rSrg) Participant[cnURUl[URR5Ulgr+)info_inforhandleid _ffi_handle)r/ owned_infos r0r1Participant.__init__\s&__ $Z%6%6%9%9:r4cg)E A dictionary of track publications associated with the participant. Nr?r/s r0track_publicationsParticipant.track_publications`s r4c.URR$r+)r_sidrgs r0rkParticipant.sidhszz~~r4c.URR$r+)r_namergs r0rnParticipant.namelszzr4c.URR$r+)r_identityrgs r0rqParticipant.identitypzz"""r4c.URR$r+)r_metadatargs r0ruParticipant.metadatatrsr4c@[URR5$)z2Custom attributes associated with the participant.)dictr_ attributesrgs r0ryParticipant.attributesxsDJJ))**r4c.URR$)zLParticipant's kind (e.g., regular participant, ingress, egress, sip, agent).)r_kindrgs r0r|Participant.kind}szzr4c.URR$)zGParticipant's connection state (joining, joined, active, disconnected).)r_statergs r0rParticipant.stateszzr4cURRS:Xag[RRURRS- [RR S9$)zMTimestamp of when the participant joined the room, or None if not yet joined.rN)tz)r_ joined_atdatetime fromtimestamptimezoneutcrgs r0rParticipant.joined_atsW ::  1 $  .. JJ 4 'H,=,=,A,A/  r4c.URR$)z.The participant's permissions within the room.)r_ permissionrgs r0 permissionsParticipant.permissionsszz$$$r4cURR[RR:XagURR$)aXReason for the participant's disconnection. Returns one of DisconnectReasons or None if the participant isn't disconnected. Common reasons are: - CLIENT_INITIATED - the client initiated the disconnect - DUPLICATE_IDENTITY - another participant with the same identity has joined the room - SERVER_SHUTDOWN - the server instance is shutting down - PARTICIPANT_REMOVED - RoomService.RemoveParticipant was called - ROOM_DELETED - RoomService.DeleteRoom was called - STATE_MISMATCH - the client is attempting to resume a session, but server is not aware of it - JOIN_FAILURE - client was unable to connect fully When dialing a participant via SIP, you may see the following reasons: - USER_UNAVAILABLE - SIP callee did not respond in time - USER_REJECTED - SIP callee rejected the call (busy) - SIP_TRUNK_FAILURE - SIP protocol failure or unexpected response N)r_disconnect_reasonproto_participantDisconnectReasonUNKNOWN_REASONrgs r0rParticipant.disconnect_reasons6( :: ' '+<+M+M+\+\ \zz+++r4)rbr_Nrc"proto_participant.OwnedParticipantr7r8)r7zMapping[str, TrackPublication]r7r6)r7dict[str, str])r7z+proto_participant.ParticipantKind.ValueType)r7z,proto_participant.ParticipantState.ValueType)r7zdatetime.datetime | None)r7z'proto_participant.ParticipantPermission)r7z6Optional[proto_participant.DisconnectReason.ValueType])r:r;r<r=r1propertyr rhrkrnrqruryr|rrrrr>r?r4r0r[r[[s;  ####++    %%, ?,,r4r[r F)boundcL^\rSrSrSrS$U4Sjjr\S%Sj5rS/SS.S&SjjrS'S jr S(S jr S S .S)S jjr S*S+Sjjr S,Sjr S S.S-SjjrS.SjrS/SjrS0SjrS1SjrS SS S S S S S.S2SjjrS SS S S.S3SjjrS SS S S SS.S4SjjrSS S S S.S5SjjrS6Sjr\"54S7S jjrS8S!jrS9S"jrS#rU=r$):LocalParticipantz+Represents the local participant in a room.cL>[TU]U5 Xl0Ul0Ulgr+)superr1 _room_queue_track_publications _rpc_handlers)r/ room_queuerc __class__s r0r1LocalParticipant.__init__s( $%EG 46r4cUR$rfrrgs r0rh#LocalParticipant.track_publications '''r4T)reliabledestination_identitiestopicc^ # [U[5(aURS5n[U5n[R U-"U6n[ R"5nURRURl [R"U5URl XWRlX'RlXGRlURR"R%U5 [&R(R*R-5n[&R(R/U5m UR1U 4Sj5IShvN n [&R(R*R3U5 U RR4(a[7U RR45egNh![&R(R*R3U5 f=f7f)a Publish arbitrary data to the room. Args: payload (Union[bytes, str]): The data to publish. reliable (bool, optional): Whether to send reliably or not. Defaults to True. destination_identities (List[str], optional): List of participant identities to send to. Defaults to []. topic (str, optional): The topic under which to publish the data. Defaults to "". Raises: PublishDataError: If there is an error in publishing data. zutf-8c^>URRTRR:H$r+) publish_dataasync_ideresps r0/LocalParticipant.publish_data..s !..11T5F5F5O5OOr4N) isinstancer6encodelenctypesc_byte proto_ffi FfiRequestrbr`rlocal_participant_handle addressofdata_ptrdata_lenrrrextendrinstancequeue subscriberequestwait_for unsubscribeerrorrG) r/payloadrrrrcdatareqrcbrs @r0rLocalParticipant.publish_dataso( gs # #nnW-Gw<)G4""$484D4D4K4K1$*$4$4U$;!$,!$,!!& //667MN""((224 8%%--c2D+0>>O,&B    $ $ 0 0 7 ?? "2??#8#89 9 ! &    $ $ 0 0 7s1D$G8(7G G G $A$G8G +G55G8c^# [R"5nURRURlXRlX#Rl[RRR5n[RRU5mURU4Sj5IShvN n[RRRU5 URR(a[!URR5egNh![RRRU5 f=f7f)z Publish SIP DTMF message. Args: code (int): DTMF code. digit (str): DTMF digit. Raises: PublishDTMFError: If there is an error in publishing SIP DTMF message. c^>URRTRR:H$r+)publish_sip_dtmfrrs r0r/LocalParticipant.publish_dtmf.. s"!,,559N9N9W9WWr4N)rrrbr`rrcodedigitrrrrrrrrrL)r/rrrrrrs @r0 publish_dtmfLocalParticipant.publish_dtmfs""$8<8H8H8O8O5$(!%*"""((224 8%%--c2D+0>>W,&B    $ $ 0 0 7   $ $"2#6#6#<#<= = % &    $ $ 0 0 7s1BE7D)>D'?D)A$E'D))+EEc ^# [R"5nURVs/sHMn[URUR UR URURURS9PMO nnURRURl URURlURRRU5 UR URl[$R&R(R+5n[$R&R-U5mUR/U4Sj5IShvN n[$R&R(R1U5 URR2(a[5URR25egs snfNm![$R&R(R1U5 f=f7f)z Publish transcription data to the room. Args: transcription (Transcription): The transcription data to publish. Raises: PublishTranscriptionError: If there is an error in publishing transcription. )ratext start_timeend_timefinallanguagec^>URRTRR:H$r+)publish_transcriptionrrs r0r8LocalParticipant.publish_transcription..2s"!11::d>X>X>a>aar4N)rrsegmentsProtoTranscriptionSegmentrarrrrrrbr`rrparticipant_identityr track_sidtrack_idrrrrrrrrrQ)r/ transcriptionrsproto_segmentsrrrs @r0r&LocalParticipant.publish_transcriptions""$#++  , &44VV<<gg  ,   >B=M=M=T=T!!:9F9[9[!!6 !!**11.A-:-D-D!!*""((224 8%%--c2D+0>>a,&B    $ $ 0 0 7 # # ) )+B,D,D,J,JK K *5  (&    $ $ 0 0 7s=$G;AG;B*G;&7G G G "A)G; G +G88G;N)response_timeoutc\^# [R"5nURRURlXRlX%RlX5RlUb[US-5URl [RRR5n[RRU5mUR!U4Sj5IShvN n[RRR#U5 URR%S5(a*[&R("URR*5eURR$N![RRR#U5 f=f7f)a Initiate an RPC call to a remote participant. Args: destination_identity (str): The `identity` of the destination participant method (str): The method name to call payload (str): The method payload response_timeout (Optional[float]): Timeout for receiving a response after initial connection Returns: str: The response payload Raises: RpcError: On failure. Details in `message`. Nrc^>URRTRR:H$r+) perform_rpcrrs r0r.LocalParticipant.perform_rpc..\s  0F0F$JZJZJcJc0cr4r)rrrbr`rrdestination_identitymethodrintresponse_timeout_msrrrrrrrHasFieldr _from_protor) r/rrrrrrrrs @r0rLocalParticipant.perform_rpc:s+.""$373C3C3J3J0/C,!'")  '256F6M2NCOO /""((224 8%%--c2D~~&cddB    $ $ 0 0 7 >> " "7 + +&&r~~';';< <~~%%%e    $ $ 0 0 7s1B3F,77E>.E</E>3B F,<E>>+F))F,c2^^SUU4SjjnUbU"U5$U$)a Establishes the participant as a receiver for calls of the specified RPC method. Can be used either as a decorator or a regular method. The handler will receive one argument of type `RpcInvocationData` and should return a string response which will be forwarded back to the caller. The handler may be synchronous or asynchronous. If unable to respond within `response_timeout`, the caller will hang up and receive an error on their side. You may raise errors of type `RpcError` in the handler, and they will be forwarded to the caller. Other errors raised in your handler will be caught and forwarded to the caller as "1500 Application Error". Args: method_name (str): The name of the indicated RPC method. handler (Optional[Callable]): Handler to be invoked whenever an RPC request for this method is received. Omit this argument to use the decorator syntax. Returns: None (when used as a decorator it returns the decorator function) Example: # As a decorator: @room.local_participant.register_rpc_method("greet") async def greet_handler(data: RpcInvocationData) -> str: print(f"Received greeting from {data.caller_identity}: {data.payload}") return f"Hello, {data.caller_identity}!" # As a regular method: async def greet_handler(data: RpcInvocationData) -> str: print(f"Received greeting from {data.caller_identity}: {data.payload}") return f"Hello, {data.caller_identity}!" room.local_participant.register_rpc_method('greet', greet_handler) c>UTRT'[R"5nTRRUR lTUR l[RRU5 U$r+) rrrrbr`register_rpc_methodrrrrr) handler_funcr method_namer/s r0register6LocalParticipant.register_rpc_method..registersc.:D  { +&&(C?C?O?O?V?VC # # <-8C # # *    & &s + r4)rrr7rr?)r/rhandlerrs`` r0r$LocalParticipant.register_rpc_methodes&R    G$ $Or4cURRUS5 [R"5nURR UR lXR l[RRU5 g)zs Unregisters a previously registered RPC method. Args: method (str): The name of the RPC method to unregister N) rpoprrrbr`unregister_rpc_methodrrrrr)r/rrs r0r&LocalParticipant.unregister_rpc_methodsb vt,""$=A=M=M=T=T!!:+1!!(""3'r4)participant_permissionsc*Uc/n[R"5nURRURlXRlURRRU5 [RRU5 g)a\ Set the track subscription permissions for the local participant. Args: allow_all_participants (bool): Whether to allow all participants to subscribe to this participant's tracks. participant_permissions (List[ParticipantTrackPermission]): Participant-specific track subscription permissions, ignored if `allow_all_participants` is True. N) rrrbr`"set_track_subscription_permissionsrall_participants_allowedrrrrr)r/allow_all_participantsrrs r0r3LocalParticipant.set_track_subscription_permissionsss # *&( #""$JNJZJZJaJa..GJ`..G ..::AABYZ""3'r4c # SnSn[X4XV5n URRU5n U (d/[R"[R R 5nO_[R"U 5(a%[R"U "U 5US9IShvN nO[[[ U "U 55n[*R,"[/UR0R2UU(aUR55OSUS9S9n [6R8R;U 5n U R<R>(a0U R<R>n[$R>"SU35 ggN![Ra/ [R"[R R5e[Ra/ [R"[R R5ef=f![a n U nSn A GNOSn A f["aL [$R&"SUS35 [R"[R R(5nGNf=f7f)N)timeoutz+Uncaught error returned by RPC handler for z'. Returning APPLICATION_ERROR instead. )r invocation_idrr)rpc_method_invocation_responsez.error sending rpc method invocation response: ) r rgetr _built_in ErrorCodeUNSUPPORTED_METHODasyncioiscoroutinefunctionr TimeoutErrorRESPONSE_TIMEOUTCancelledErrorRECIPIENT_DISCONNECTEDr r r6 Exceptionr exceptionAPPLICATION_ERRORrrrrbr` _to_protorrrr r)r/r r request_idcaller_identityrrresponse_errorresponse_payloadparamsrrrreserrs r0_handle_rpc_method_invocation.LocalParticipant._handle_rpc_method_invocations.2*.":Z$$((0%//0B0B0U0UVN Z..w77\181A1A#FO5E2,((,HSM76?'K$""+M)-)9)9)@)@+4Bn..0( ,   ((-  - - 3 344::C LLI#O P 4;,#//V&001C1C1T1TUU"11\&001C1C1Z1Z[[\ '!& Z  A&J<<"*!3!3H4F4F4X4X!Y  ZsoA"I.%HE9E7 E9$I.%HB5I.7E99BG==H I+ H I.AI+'I.*I++I.c^# [R"5nURRURlXRl[RRR5n[RRU5mURU4Sj5IShvN [RRRU5 gN.![RRRU5 f=f7f)z Set the metadata for the local participant. Note: this requires `canUpdateOwnMetadata` permission. Args: metadata (str): The new metadata. c^>URRTRR:H$r+)set_local_metadatarrs r0r/LocalParticipant.set_metadata.."!..774;R;R;[;[[r4N)rrrbr`r&rrurrrrrrr)r/rurrrs @r0 set_metadataLocalParticipant.set_metadatas""$:>:J:J:Q:Q7*2'""((224 8%%--c2D..[      $ $ 0 0 7      $ $ 0 0 70A3D 77C.C/C3*D C+D  D c^# [R"5nURRURlXRl[RRR5n[RRU5mURU4Sj5IShvN [RRRU5 gN.![RRRU5 f=f7f)z Set the name for the local participant. Note: this requires `canUpdateOwnMetadata` permission. Args: name (str): The new name. c^>URRTRR:H$r+)set_local_namerrs r0r+LocalParticipant.set_name..s"!**33t7J7J7S7SSr4N)rrrbr`r.rrnrrrrrrr)r/rnrrrs @r0set_nameLocalParticipant.set_name s""$6:6F6F6M6M3"&""((224 8%%--c2D..S      $ $ 0 0 7      $ $ 0 0 7r+c0^# [R"5nURRURlURR Vs0sHo3RUR_M nnURU5 UR5H5upVURR R5nXSlXclM7 [RRR5n[RR!U5mUR#U4Sj5IShvN [RRR%U5 gs snfN3![RRR%U5 f=f7f)z Set custom attributes for the local participant. Note: this requires `canUpdateOwnMetadata` permission. Args: attributes (dict[str, str]): A dictionary of attributes to set. c^>URRTRR:H$r+)set_local_attributesrrs r0r1LocalParticipant.set_attributes..<s"!0099T=V=V=_=__r4N)rrrbr`r4rrykeyvalueupdateitemsaddrrrrrrr) r/ryrentryexisting_attributesr6r7rrs @r0set_attributesLocalParticipant.set_attributes#s@""$<@3D64D>D8D>0D:1 D>> E D< E!E"E4E6D>8D>:D><E>EE  EEc>^# [R"US9n[R"5nURR UR lUR RRU5 [RRR5n[RRU5mURU4Sj5IShvN n[RRR!U5 UR R#S5(a)[%UR R&R(5e[+UR R,5$N![RRR!U5 f=f7f)alPublishes a data track. Args: name: The track name used to identify the track to other participants. Must not be empty and must be unique per publisher. Returns: The published data track. Use :meth:`LocalDataTrack.try_push` to send data frames on the track. Raises: PublishDataTrackError: If there is an error publishing the data track. )rnc^>URRTRR:H$r+)publish_data_trackrrs r0r5LocalParticipant.publish_data_track..r(r4Nr)proto_data_trackDataTrackOptionsrrrbr`rhroptionsCopyFromrrrrrrrrrVrr-r%track)r/rn proto_optsrrrrs @r0rh#LocalParticipant.publish_data_tracks.$&66DA ""$:>:J:J:Q:Q7 &&// ;""((224 8%%--c2D+0>>[,&B    $ $ 0 0 7 ) )' 2 2'(=(=(C(C(K(KL Lb3399::&    $ $ 0 0 7s1BF 7E/E-E/BF-E//+FFc^# [R"5nURRURlURRURlURRRU5 URR5n[RRU5mURU4Sj5IShvN nURR(a[!URR5e[#URR$5nXlUR(UR*lX`R,UR('UR/5 UURR1U5 $N!URR1U5 f=f7f)aC Publish a local track to the room. Args: track (LocalTrack): The track to publish. options (TrackPublishOptions, optional): Options for publishing the track. Returns: LocalTrackPublication: The publication of the published track. Raises: PublishTrackError: If there is an error in publishing the track. c^>URRTRR:H$r+) publish_trackrrs r0r0LocalParticipant.publish_track..s !//22d6H6H6Q6QQr4N)rrrbr`rs track_handlerrlrmrrrrrrrr(r publication_trackrkr_r task_doner)r/rnrlrrrtrack_publicationrs @r0rsLocalParticipant.publish_tracksQ ""$).):):)A)A&595E5E5L5L2 !!**73  **, 0%%--c2D+0>>Q,&B%%'(8(8(>(>?? 5b6F6F6R6R S ', $/33EKKO>O $ $%6%:%: ; OO $    ( ( /&    ( ( /s1BG#7F FB'F GF F==Gc^# [R"5nURRURlXRlSURlURR5n[RRU5mURU4Sj5IShvN nURR(a[URR5eUR R#U5nSUlUR'5 URR)U5 gN!URR)U5 f=f7f)z Unpublish a track from the room. Args: track_sid (str): The SID of the track to unpublish. Raises: UnpublishTrackError: If there is an error in unpublishing the track. Tc^>URRTRR:H$r+)unpublish_trackrrs r0r2LocalParticipant.unpublish_track..s"!++448L8L8U8UUr4N)rrrbr`r}rrstop_on_unpublishrrrrrrrrBrrrwrxr)r/rrrrrvrs @r0r} LocalParticipant.unpublish_tracks""$7;7G7G7N7N4(1%04-  **, 0%%--c2D+0>>U,&B!!'')"*<*<*B*BCC2266yAK!%K  OO     ( ( /&    ( ( /s1A6E :7E1D>2A0E"E >EEE cVSURSURSURS3$)Nzrtc.LocalParticipant(sid= , identity=, name=)rkrqrnrgs r0__repr__LocalParticipant.__repr__"s.*488*K gVZV_V_U``abbr4)rrr)rz"BroadcastQueue[proto_ffi.FfiEvent]rcrr7r8)r7z#Mapping[str, LocalTrackPublication]) rzUnion[bytes, str]rboolrz List[str]rr6r7r8)rrrr6r7r8)rrr7r8) rr6rr6rr6rzOptional[float]r7r6r+)rr6rz Optional[F]r7zUnion[F, Callable[[F], F]])rr6r7r8)rrrz*Optional[List[ParticipantTrackPermission]]r7r8)r rrr6rr6rr6rr6rfloatr7r8)rur6r7r8)rnr6r7r8)ryrr7r8)rOptional[List[str]]rr6ryOptional[Dict[str, str]]r? str | Noner@rrA int | NonerBrr7r!) rr6rrrr6ryrr@r)rnr6rArrOr6ryrr?rrrrr6r7r") r^r6rr6rrryrr?rr7r#)rnr6r7r%)rnrrlrr7r)rr6r7r8r)r:r;r<r=__doc__r1rrhrrrrrrrr"r)r0r=rFrLrQrdrhrrsr}rr> __classcell__rs@r0rrs7576777  7((,. ,:",: ,: !* ,:  ,: ,:\>8&L\-1 )&")& )&  )& * )& )&\ $444 $ 4l (&OS (!%("L (  (,5Q5Q5Q 5Q  5Q  5Q 5Q 5Qn8,8,8B7;/3 $"&!%&*!4  -    $ D7;/3"&!4    -  6"&3/3 $6:    - !4 D6:/3 $  !4  -  @$;$;  $;NAT@U'0'0*='0 '0R0>ccr4rcJ^\rSrSrSU4Sjjr\SSj5rSSjrSrU=r $) RemoteParticipanti&c2>[TU]U5 0Ulgr+)rr1r)r/rcrs r0r1RemoteParticipant.__init__'s $FH r4cUR$rrrgs r0rh$RemoteParticipant.track_publications+rr4cVSURSURSURS3$)Nzrtc.RemoteParticipant(sid=rrrrrgs r0rRemoteParticipant.__repr__2s.+DHH:[wW[W`W`Vaabccr4rr)r7z$Mapping[str, RemoteTrackPublication]r) r:r;r<r=r1rrhrr>rrs@r0rr&s)I(( ddr4r)J __future__rrrrrUrYr[typingrrrrrr r r r abcr r _ffi_clientrr_protorrrr_proto.room_pb2rrr_proto.track_pb2r_utilsrrnrryrrrrrrpcr_proto.rpc_pb2rlogrr data_streamr!r"r#r$ data_trackr%r&rjrr(rBrGrLrQrVr[r6 RpcHandlerrrrr?r4r0rsM#  [[[#-(8# )>" '6  ) y y   I P,#P,f*+U9Xc]3KXVY]3Z-[[ \  x*+U9Xc]3KXVY]3Z-[[\ o c{o cd d dr4