q hi RSSKJr SSKrSSKrSSKrSSKrSSKrSSKJrJ r J r J r J r J r JrJrJr 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.J/r/ SSK0J1r1 SSK,J2r2 SSK3J4r4J5r5J6r6J7r7 "SS\85r9"SS\85r:"SS\85r;"SS\85r<"SS\85r="SS \5r>\ S!/\ \ \ \?\ \?44r@\"S"\ \2/\ \ \ \?\ \?44S#9rA"S$S%\>5rB"S&S'\>5rCg)() annotationsN) ListUnionCallableDict AwaitableOptionalMappingcastTypeVar)abstractmethodABC) FfiClient FfiHandle)ffi_pb2)participant_pb2)TrackPublishOptions)TranscriptionSegment)ParticipantTrackPermission)BroadcastQueue) LocalTrack)LocalTrackPublicationRemoteTrackPublicationTrackPublication) Transcription)RpcError)"RpcMethodInvocationResponseRequest)logger)RpcInvocationData)TextStreamWriterByteStreamWriterByteStreamInfoSTREAM_CHUNK_SIZEc\rSrSrSSjrSrg)PublishTrackError:cXlgNmessageselfr+s I/var/www/html/env/lib/python3.13/site-packages/livekit/rtc/participant.py__init__PublishTrackError.__init__; r*Nr+strreturnNone__name__ __module__ __qualname____firstlineno__r/__static_attributes__r2r.r&r&:r2r&c\rSrSrSSjrSrg)UnpublishTrackError?cXlgr)r*r,s r.r/UnpublishTrackError.__init__@r1r2r*Nr3r7r=r2r.r@r@?r>r2r@c\rSrSrSSjrSrg)PublishDataErrorDcXlgr)r*r,s r.r/PublishDataError.__init__Er1r2r*Nr3r7r=r2r.rErEDr>r2rEc\rSrSrSSjrSrg)PublishDTMFErrorIcXlgr)r*r,s r.r/PublishDTMFError.__init__Jr1r2r*Nr3r7r=r2r.rJrJIr>r2rJc\rSrSrSSjrSrg)PublishTranscriptionErrorNcXlgr)r*r,s r.r/"PublishTranscriptionError.__init__Or1r2r*Nr3r7r=r2r.rOrONr>r2rOc\rSrSrS Sjr\\SSj55r\SSj5r\SSj5r \SSj5r \SSj5r \SSj5r \SS j5r \SS j5rS rg ) ParticipantScnURUl[URR5Ulgr))info_inforhandleid _ffi_handle)r- owned_infos r.r/Participant.__init__Ts&__ $Z%6%6%9%9:r2cg)E A dictionary of track publications associated with the participant. Nr=r-s r.track_publicationsParticipant.track_publicationsXs r2c.URR$r))rXsidr`s r.rdParticipant.sid`szz~~r2c.URR$r))rXnamer`s r.rgParticipant.namedszzr2c.URR$r))rXidentityr`s r.rjParticipant.identityhzz"""r2c.URR$r))rXmetadatar`s r.rnParticipant.metadatalrlr2c@[URR5$)z2Custom attributes associated with the participant.)dictrX attributesr`s r.rrParticipant.attributespsDJJ))**r2c.URR$)zLParticipant's kind (e.g., regular participant, ingress, egress, sip, agent).)rXkindr`s r.ruParticipant.kinduszzr2cURR[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)rXdisconnect_reasonproto_participantDisconnectReasonUNKNOWN_REASONr`s r.rxParticipant.disconnect_reasonzs6( :: ' '+<+M+M+\+\ \zz+++r2)r[rXNr\"proto_participant.OwnedParticipantr5r6)r5zMapping[str, TrackPublication]r5r4)r5dict[str, str])r5z+proto_participant.ParticipantKind.ValueType)r5z6Optional[proto_participant.DisconnectReason.ValueType])r8r9r:r;r/propertyr rardrgrjrnrrrurxr<r=r2r.rTrTSs;  ####++, ?,,r2rTr F)boundc:^\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.SjrS/SjrS0SjrS SS S S S S S.S1SjjrS SS S S.S2SjjrS SS S S SS.S3SjjrSS S S S.S4Sjjr\"54S5SjjrS6S jrS7S!jrS"rU=r$)8LocalParticipantz+Represents the local participant in a room.cL>[TU]U5 Xl0Ul0Ulgr))superr/ _room_queue_track_publications _rpc_handlers)r- room_queuer\ __class__s r.r/LocalParticipant.__init__s( $%EG 46r2cUR$r_rr`s r.ra#LocalParticipant.track_publications '''r2T)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 r./LocalParticipant.publish_data..s !..11T5F5F5O5OOr2N) isinstancer4encodelenctypesc_byte proto_ffi FfiRequestr[rYrlocal_participant_handle addressofdata_ptrdata_lenrrrextendrinstancequeue subscriberequestwait_for unsubscribeerrorrE) r-payloadrrrrcdatareqrcbrs @r.rLocalParticipant.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 r.r/LocalParticipant.publish_dtmf..s"!,,559N9N9W9WWr2N)rrr[rYrrcodedigitrrrrrrrrrJ)r-rrrrrrs @r. 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. )rZtext start_timeend_timefinallanguagec^>URRTRR:H$r))publish_transcriptionrrs r.r8LocalParticipant.publish_transcription..s"!11::d>X>X>a>aar2N)rrsegmentsProtoTranscriptionSegmentrZrrrrrr[rYrrparticipant_identityr track_sidtrack_idrrrrrrrrrO)r- transcriptionrsproto_segmentsrrrs @r.r&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`. Nic^>URRTRR:H$r)) perform_rpcrrs r.r.LocalParticipant.perform_rpc..Bs 1==11T5E5E5N5NNr2r)rrr[rYrrdestination_identitymethodrintresponse_timeout_msrrrrrrrHasFieldr _from_protor) r-rrrrrrrrs @r.rLocalParticipant.perform_rpcs2.""$373C3C3J3J0/C,!'")  '256F6M2NCOO /""((224 8%%--c2D~~OB    $ $ 0 0 7 >> " "7 + +&&r~~';';< <~~%%%    $ $ 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)) rrrr[rYregister_rpc_methodrrrrr) handler_funcr method_namer-s r.register6LocalParticipant.register_rpc_method..registerusc.:D  { +&&(C?C?O?O?V?VC # # <-8C # # *    & &s + r2)rrr5rr=)r-rhandlerrs`` r.r$LocalParticipant.register_rpc_methodLs&R    G$ $Or2cURRUS5 [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) rpoprrr[rYunregister_rpc_methodrrrrr)r-rrs r.r&LocalParticipant.unregister_rpc_methodsb vt,""$=A=M=M=T=T!!:+1!!(""3'r2)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) rrr[rY"set_track_subscription_permissionsrall_participants_allowed permissionsrrrr)r-allow_all_participantsrrs r.r3LocalParticipant.set_track_subscription_permissionsss # *&( #""$JNJZJZJaJa..GJ`..G ..::AABYZ""3'r2c # 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 r4 Exceptionr exceptionAPPLICATION_ERRORrrrr[rY _to_protorrrrr)r-rr request_idcaller_identityrrresponse_errorresponse_payloadparamsrrrreserrs r._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 r.r/LocalParticipant.set_metadata..s"!..774;R;R;[;[[r2N)rrr[rYrrrnrrrrrrr)r-rnrrrs @r. 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 r.r+LocalParticipant.set_name..s"!**33t7J7J7S7SSr2N)rrr[rYrrrgrrrrrrr)r-rgrrrs @r.set_nameLocalParticipant.set_names""$6:6F6F6M6M3"&""((224 8%%--c2D..S      $ $ 0 0 7      $ $ 0 0 7rc0^# [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 r.r1LocalParticipant.set_attributes..#s"!0099T=V=V=_=__r2N)rrr[rYrrrrkeyvalueupdateitemsaddrrrrrrr) r-rrrentryexisting_attributesrr rrs @r.set_attributesLocalParticipant.set_attributes s@""$<@3D64D>D8D>0D:1 D>> E D< E!E"E4E6D>8D>:D><E>EE  EEc^# [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 r.r0LocalParticipant.publish_track..s !//22d6H6H6Q6QQr2N)rrr[rYrQ track_handleroptionsCopyFromrrrrrrrr&r publication_trackrdrXr task_doner)r-trackrTrrrtrack_publicationrs @r.rQLocalParticipant.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 r.r2LocalParticipant.unpublish_track..s"!++448L8L8U8UUr2N)rrr[rYr^rrstop_on_unpublishrrrrrrrr@rrrWrXr)r-rrrrrVrs @r.r^ 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=)rdrjrgr`s r.__repr__LocalParticipant.__repr__s.*488*K gVZV_V_U``abbr2)rrr)rz"BroadcastQueue[proto_ffi.FfiEvent]r\r~r5r6)r5z#Mapping[str, LocalTrackPublication]) rzUnion[bytes, str]rboolrz List[str]rr4r5r6)rrrr4r5r6)rrr5r6) rr4rr4rr4rzOptional[float]r5r4r))rr4rz Optional[F]r5zUnion[F, Callable[[F], F]])rr4r5r6)rrirz*Optional[List[ParticipantTrackPermission]]r5r6)rrrr4rr4rr4rr4rfloatr5r6)rnr4r5r6)rgr4r5r6)rrrr5r6)rOptional[List[str]]rr4rrOptional[Dict[str, str]]r( str | Noner)rmr* int | Noner+rmr5r!) rr4rrkrr4rrrlr)rm)rgr4r*rnr8r4rrrlr(rmrrkrr4r5r") rGr4rr4rrkrrrlr(rmr5r#)rYrrTrr5r)rr4r5r6r)r8r9r:r;__doc__r/rrarrrrrrrr rrr&r/r5r:rMrrQr^rgr< __classcell__rs@r.rrs576777  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  -  BAT@U'0'0*='0 '0R0>ccr2rcJ^\rSrSrSU4Sjjr\SSj5rSSjrSrU=r $) RemoteParticipantic2>[TU]U5 0Ulgr))rr/r)r-r\rs r.r/RemoteParticipant.__init__s $FH r2cUR$rrr`s r.ra$RemoteParticipant.track_publicationsrr2cVSURSURSURS3$)Nzrtc.RemoteParticipant(sid=rcrdrerfr`s r.rgRemoteParticipant.__repr__s.+DHH:[wW[W`W`Vaabccr2rr})r5z$Mapping[str, RemoteTrackPublication]r) r8r9r:r;r/rrargr<rprqs@r.rsrss)I(( ddr2rs)D __future__rrrr>rBrDtypingrrrrrr r r r abcr r _ffi_clientrr_protorrrry_proto.room_pb2rrr_proto.track_pb2r_utilsrrYrrZrrrrrrpcr_proto.rpc_pb2rlogrr data_streamr!r"r#r$rr&r@rErJrOrTr4 RpcHandlerrrrsr=r2r.rs4#  [[[#-(8# )>"  ) y y   =,#=,@*+U9Xc]3KXVY]3Z-[[ \  x*+U9Xc]3KXVY]3Z-[[\ K c{K c\ d dr2