
    qis                        d Z ddlmZ ddlmZ ddlmZ ddlm	Z
  ej                         ZddlmZ ddlmZ  ej                         j'                  d	      Z e       Z e
j.                  ee        e
j0                  ed
e       ej2                  dk(  rSded   _        ded   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d   _        ded   j8                  d    _        ded   j8                  d    _        ded!   _        ded!   _        ded"   j8                  d   _        ded"   j8                  d   _        ded"   j8                  d#   _        ded"   j8                  d#   _        d$ed%   _        d&ed%   _        d'ed(   _        d)ed(   _        d*ed+   _        d,ed+   _        d-ed   _        d.ed   _        d/ed0   _        d1ed0   _        d2ed3   _        d4ed3   _        d5ed   _        d6ed   _        d7ed8   _        d9ed8   _        d:ed;   _        d<ed;   _        d=ed>   _        d?ed>   _        d@edA   _        dBedA   _        dCedD   _        dEedD   _        dFedG   _        dHedG   _        dIed   _        dEed   _        dJedK   _        dLedK   _        dMedN   _        dOedN   _        dPedQ   _        dRedQ   _        dSedT   _        dUedT   _        dVedW   _        dXedW   _        dYedZ   _        d[edZ   _        d\ed]   _        d^ed]   _        d_ed   _        d^ed   _        d`eda   _        dbeda   _        dcedd   _        deedd   _        dfedg   _        dhedg   _        diedj   _        dhedj   _        dkedl   _        dmedl   _        dnedo   _        dpedo   _        dqedr   _        dsedr   _        dtedu   _        dvedu   _        dwedx   _        dvedx   _        dyed   _        dzed   _        d{ed   _        d|ed   _        d}ed   _        d|ed   _        d~ed   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded"   _        ded"   _        ded!   _        ded!   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        yy)zGenerated protocol buffer code.    )
descriptor)descriptor_pool)symbol_database)builder   )models)optionss+  
livekit_rtc.protolivekitlivekit_models.protologger/options.proto"
SignalRequest,
offer (2.livekit.SessionDescriptionH -
answer (2.livekit.SessionDescriptionH *
trickle (2.livekit.TrickleRequestH -
	add_track (2.livekit.AddTrackRequestH )
mute (2.livekit.MuteTrackRequestH 3
subscription (2.livekit.UpdateSubscriptionH 5
track_setting (2.livekit.UpdateTrackSettingsH &
leave (2.livekit.LeaveRequestH 7
update_layers
 (2.livekit.UpdateVideoLayersBH B
subscription_permission (2.livekit.SubscriptionPermissionH (

sync_state (2.livekit.SyncStateH -
simulate (2.livekit.SimulateScenarioH 
ping (H =
update_metadata (2".livekit.UpdateParticipantMetadataH !
ping_req (2.livekit.PingH <
update_audio_track (2.livekit.UpdateLocalAudioTrackH <
update_video_track (2.livekit.UpdateLocalVideoTrackH F
publish_data_track_request (2 .livekit.PublishDataTrackRequestH J
unpublish_data_track_request (2".livekit.UnpublishDataTrackRequestH C
update_data_subscription (2.livekit.UpdateDataSubscriptionH B	
message"
SignalResponse%
join (2.livekit.JoinResponseH -
answer (2.livekit.SessionDescriptionH ,
offer (2.livekit.SessionDescriptionH *
trickle (2.livekit.TrickleRequestH ,
update (2.livekit.ParticipantUpdateH :
track_published (2.livekit.TrackPublishedResponseH &
leave (2.livekit.LeaveRequestH )
mute	 (2.livekit.MuteTrackRequestH 4
speakers_changed
 (2.livekit.SpeakersChangedH *
room_update (2.livekit.RoomUpdateH >
connection_quality (2 .livekit.ConnectionQualityUpdateH 9
stream_state_update (2.livekit.StreamStateUpdateH E
subscribed_quality_update (2 .livekit.SubscribedQualityUpdateH O
subscription_permission_update (2%.livekit.SubscriptionPermissionUpdateH 
refresh_token (	H >
track_unpublished (2!.livekit.TrackUnpublishedResponseH 
pong (H /
	reconnect (2.livekit.ReconnectResponseH "
	pong_resp (2.livekit.PongH >
subscription_response (2.livekit.SubscriptionResponseH 4
request_response (2.livekit.RequestResponseH 4
track_subscribed (2.livekit.TrackSubscribedH 0

room_moved (2.livekit.RoomMovedResponseH G
media_sections_requirement (2!.livekit.MediaSectionsRequirementH L
subscribed_audio_codec_update (2#.livekit.SubscribedAudioCodecUpdateH H
publish_data_track_response (2!.livekit.PublishDataTrackResponseH L
unpublish_data_track_response (2#.livekit.UnpublishDataTrackResponseH L
data_track_subscriber_handles (2#.livekit.DataTrackSubscriberHandlesH B	
message"
SimulcastCodec
codec (	
cid (	#
layers (2.livekit.VideoLayer2
video_layer_mode (2.livekit.VideoLayer.Mode"
AddTrackRequest
cid (	
name (	 
type (2.livekit.TrackType
width (
height (
muted (
disable_dtx (B$
source (2.livekit.TrackSource#
layers	 (2.livekit.VideoLayer1
simulcast_codecs
 (2.livekit.SimulcastCodec
sid (	
stereo (B
disable_red (,

encryption (2.livekit.Encryption.Type
stream (	7
backup_codec_policy (2.livekit.BackupCodecPolicy2
audio_features (2.livekit.AudioTrackFeature"i
PublishDataTrackRequest

pub_handle (
name (	,

encryption (2.livekit.Encryption.Type"@
PublishDataTrackResponse$
info (2.livekit.DataTrackInfo"/
UnpublishDataTrackRequest

pub_handle ("B
UnpublishDataTrackResponse$
info (2.livekit.DataTrackInfo"
DataTrackSubscriberHandlesH
sub_handles (23.livekit.DataTrackSubscriberHandles.SubHandlesEntryZ
PublishedDataTrack
publisher_identity (	
publisher_sid (	
	track_sid (	i
SubHandlesEntry
key (E
value (26.livekit.DataTrackSubscriberHandles.PublishedDataTrack:8"]
TrickleRequest
candidateInit (	%
target (2.livekit.SignalTarget
final (".
MuteTrackRequest
sid (	
muted ("
JoinResponse
room (2.livekit.Room-
participant (2.livekit.ParticipantInfo4
other_participants (2.livekit.ParticipantInfo
server_version (	'
ice_servers (2.livekit.ICEServer
subscriber_primary (
alternative_url (	:
client_configuration (2.livekit.ClientConfiguration
server_region	 (	
ping_timeout
 (
ping_interval ((
server_info (2.livekit.ServerInfo
sif_trailer (.
enabled_publish_codecs (2.livekit.Codec
fast_publish ("
ReconnectResponse'
ice_servers (2.livekit.ICEServer:
client_configuration (2.livekit.ClientConfiguration(
server_info (2.livekit.ServerInfo
last_message_seq ("H
TrackPublishedResponse
cid (	!
track (2.livekit.TrackInfo"-
TrackUnpublishedResponse
	track_sid (	"
SessionDescription
type (	
sdp (	

id (F
mid_to_track_id (2-.livekit.SessionDescription.MidToTrackIdEntry3
MidToTrackIdEntry
key (	
value (	:8"C
ParticipantUpdate.
participants (2.livekit.ParticipantInfo"s
UpdateSubscription

track_sids (	
	subscribe (6
participant_tracks (2.livekit.ParticipantTracks"
UpdateDataSubscription7
updates (2&.livekit.UpdateDataSubscription.Updatef
Update
	track_sid (	
	subscribe (6
options (2%.livekit.DataTrackSubscriptionOptions"
UpdateTrackSettings

track_sids (	
disabled (&
quality (2.livekit.VideoQuality
width (
height (
fps (
priority ("X
UpdateLocalAudioTrack
	track_sid (	,
features (2.livekit.AudioTrackFeature"I
UpdateLocalVideoTrack
	track_sid (	
width (
height ("
LeaveRequest
can_reconnect ()
reason (2.livekit.DisconnectReason,
action (2.livekit.LeaveRequest.Action(
regions (2.livekit.RegionSettings"3
Action

DISCONNECT 

RESUME
	RECONNECT"O
UpdateVideoLayers
	track_sid (	#
layers (2.livekit.VideoLayer:"
UpdateParticipantMetadata8
metadata (	B&,,<redacted ({{ .Size }} bytes)>4
name (	B&,,<redacted ({{ .Size }} bytes)>n

attributes (22.livekit.UpdateParticipantMetadata.AttributesEntryB&,,<redacted ({{ .Size }} bytes)>

request_id (1
AttributesEntry
key (	
value (	:8"?
	ICEServer
urls (	
username (	

credential (	"9
SpeakersChanged&
speakers (2.livekit.SpeakerInfo")

RoomUpdate
room (2.livekit.Room"l
ConnectionQualityInfo
participant_sid (	+
quality (2.livekit.ConnectionQuality
score ("J
ConnectionQualityUpdate/
updates (2.livekit.ConnectionQualityInfo"b
StreamStateInfo
participant_sid (	
	track_sid (	#
state (2.livekit.StreamState"D
StreamStateUpdate/
stream_states (2.livekit.StreamStateInfo"L
SubscribedQuality&
quality (2.livekit.VideoQuality
enabled ("O
SubscribedCodec
codec (	-
	qualities (2.livekit.SubscribedQuality"
SubscribedQualityUpdate
	track_sid (	<
subscribed_qualities (2.livekit.SubscribedQualityB3
subscribed_codecs (2.livekit.SubscribedCodec"o
SubscribedAudioCodecUpdate
	track_sid (	>
subscribed_audio_codecs (2.livekit.SubscribedAudioCodec"p
TrackPermission
participant_sid (	

all_tracks (

track_sids (	
participant_identity (	"g
SubscriptionPermission
all_participants (3
track_permissions (2.livekit.TrackPermission"[
SubscriptionPermissionUpdate
participant_sid (	
	track_sid (	
allowed ("
RoomMovedResponse
room (2.livekit.Room
token (	-
participant (2.livekit.ParticipantInfo4
other_participants (2.livekit.ParticipantInfo"
	SyncState+
answer (2.livekit.SessionDescription1
subscription (2.livekit.UpdateSubscription7
publish_tracks (2.livekit.TrackPublishedResponse/
data_channels (2.livekit.DataChannelInfo*
offer (2.livekit.SessionDescription
track_sids_disabled (	D
datachannel_receive_states (2 .livekit.DataChannelReceiveState>
publish_data_tracks (2!.livekit.PublishDataTrackResponse"B
DataChannelReceiveState
publisher_sid (	
last_seq ("S
DataChannelInfo
label (	

id (%
target (2.livekit.SignalTarget"
SimulateScenario
speaker_update (H 
node_failure (H 
	migration (H 
server_leave (H ?
switch_candidate_protocol (2.livekit.CandidateProtocolH 
subscriber_bandwidth (H %
disconnect_signal_on_resume (H 1
'disconnect_signal_on_resume_no_messages (H &
leave_request_full_reconnect	 (H B

scenario"&
Ping
	timestamp (
rtt ("6
Pong
last_ping_timestamp (
	timestamp ("6
RegionSettings$
regions (2.livekit.RegionInfo";

RegionInfo
region (	
url (	
distance ("R
SubscriptionResponse
	track_sid (	'
err (2.livekit.SubscriptionError"
RequestResponse

request_id (/
reason (2.livekit.RequestResponse.Reason
message (	*
trickle (2.livekit.TrickleRequestH -
	add_track (2.livekit.AddTrackRequestH )
mute (2.livekit.MuteTrackRequestH =
update_metadata (2".livekit.UpdateParticipantMetadataH <
update_audio_track (2.livekit.UpdateLocalAudioTrackH <
update_video_track	 (2.livekit.UpdateLocalVideoTrackH >
publish_data_track
 (2 .livekit.PublishDataTrackRequestH B
unpublish_data_track (2".livekit.UnpublishDataTrackRequestH "
Reason
OK 
	NOT_FOUND
NOT_ALLOWED
LIMIT_EXCEEDED

QUEUED
UNSUPPORTED_TYPE
UNCLASSIFIED_ERROR
INVALID_HANDLE
INVALID_NAME
DUPLICATE_HANDLE	
DUPLICATE_NAME
B	
request"$
TrackSubscribed
	track_sid (	"
ConnectionSettings
auto_subscribe (
adaptive_stream (#
subscriber_allow_pause (H 
disable_ice_lite (&
auto_subscribe_data_track (HB
_subscriber_allow_pauseB
_auto_subscribe_data_track"
JoinRequest(
client_info (2.livekit.ClientInfo8
connection_settings (2.livekit.ConnectionSettings8
metadata (	B&,,<redacted ({{ .Size }} bytes)>w
participant_attributes (2/.livekit.JoinRequest.ParticipantAttributesEntryB&,,<redacted ({{ .Size }} bytes)>4
add_track_requests (2.livekit.AddTrackRequest4
publisher_offer (2.livekit.SessionDescription
	reconnect (2
reconnect_reason (2.livekit.ReconnectReason
participant_sid	 (	&

sync_state
 (2.livekit.SyncState<
ParticipantAttributesEntry
key (	
value (	:8"
WrappedJoinRequest<
compression (2'.livekit.WrappedJoinRequest.Compression
join_request ("!
Compression
NONE 
GZIP"B
MediaSectionsRequirement

num_audios (

num_videos (*-
SignalTarget
	PUBLISHER 

SUBSCRIBER*%
StreamState

ACTIVE 

PAUSED*.
CandidateProtocol
UDP 
TCP
TLSBFZ#github.com/livekit/protocol/livekitLiveKit.ProtoLiveKit::Protobproto3rtcFN
DESCRIPTORsF   Z#github.com/livekit/protocol/livekitLiveKit.ProtoLiveKit::Proto_SIGNALREQUESTupdate_layerss   _ADDTRACKREQUESTdisable_dtxstereo+_DATATRACKSUBSCRIBERHANDLES_SUBHANDLESENTRYs   8%_SESSIONDESCRIPTION_MIDTOTRACKIDENTRY_UPDATEVIDEOLAYERS*_UPDATEPARTICIPANTMETADATA_ATTRIBUTESENTRY_UPDATEPARTICIPANTMETADATAmetadatas&   ,,<redacted ({{ .Size }} bytes)>name
attributes_SUBSCRIBEDQUALITYUPDATEsubscribed_qualities'_JOINREQUEST_PARTICIPANTATTRIBUTESENTRY_JOINREQUESTparticipant_attributesi*  _SIGNALTARGETi+  i+  _STREAMSTATEi*+  i,+  _CANDIDATEPROTOCOLiZ+  K   iy  i|  _SIGNALRESPONSEi
  i
  _SIMULCASTCODECi  i  i  i  _PUBLISHDATATRACKREQUESTi|  i~  _PUBLISHDATATRACKRESPONSEi  i  _UNPUBLISHDATATRACKREQUESTi  i  _UNPUBLISHDATATRACKRESPONSEi3  i6  _DATATRACKSUBSCRIBERHANDLESic  i  ._DATATRACKSUBSCRIBERHANDLES_PUBLISHEDDATATRACKi  i  ie  _TRICKLEREQUESTi  i  _MUTETRACKREQUESTi  i  _JOINRESPONSEi   i  _RECONNECTRESPONSEi  i  _TRACKPUBLISHEDRESPONSEi	  i  _TRACKUNPUBLISHEDRESPONSEi8  i;  _SESSIONDESCRIPTIONi  i  i  _PARTICIPANTUPDATEi8  i:  _UPDATESUBSCRIPTIONi  i  _UPDATEDATASUBSCRIPTIONii  i  _UPDATEDATASUBSCRIPTION_UPDATEil  _UPDATETRACKSETTINGSi  i  _UPDATELOCALAUDIOTRACKig  ii  _UPDATELOCALVIDEOTRACKi  i  _LEAVEREQUESTi  i_  _LEAVEREQUEST_ACTIONi  i  i  i(  i  i*  
_ICESERVERii  ik  _SPEAKERSCHANGEDi  i  _ROOMUPDATEi  i  _CONNECTIONQUALITYINFOi=  i?  _CONNECTIONQUALITYUPDATEi  i  _STREAMSTATEINFOi  i  _STREAMSTATEUPDATEi3  i5  _SUBSCRIBEDQUALITYi  i  _SUBSCRIBEDCODECi  i  it  iv  _SUBSCRIBEDAUDIOCODECUPDATEi  i  _TRACKPERMISSIONiW  iY  _SUBSCRIPTIONPERMISSIONi  i  _SUBSCRIPTIONPERMISSIONUPDATEi  i   _ROOMMOVEDRESPONSEi  i  
_SYNCSTATEik   im   _DATACHANNELRECEIVESTATEi   i   _DATACHANNELINFOi!  i!  _SIMULATESCENARIOig"  ii"  _PINGi"  i"  _PONGi"  i"  _REGIONSETTINGSi"  i#  _REGIONINFOi<#  i>#  _SUBSCRIPTIONRESPONSEi#  i#  _REQUESTRESPONSEi&  i%  _REQUESTRESPONSE_REASONi&  i&  _TRACKSUBSCRIBEDi&  i&  _CONNECTIONSETTINGSi'  i'  i*  i)  i*  _WRAPPEDJOINREQUESTi*  io*  _WRAPPEDJOINREQUEST_COMPRESSIONi*  _MEDIASECTIONSREQUIREMENTi*  )__doc__google.protobufr   _descriptorr   _descriptor_poolr   _symbol_databasegoogle.protobuf.internalr   _builderDefault_sym_db r   _models_	logger_pbr	   logger_dot_options__pb2AddSerializedFiler   globals_globalsBuildMessageAndEnumDescriptorsBuildTopDescriptorsAndMessages_USE_C_DESCRIPTORS_options_serialized_optionsfields_by_name_serialized_start_serialized_end     F/opt/pipecat/venv/lib/python3.12/site-packages/livekit/protocol/rtc.py<module>rs      sV
  
 & 5 ? ? 8 #

"
"
$ ! 9 &%%'99  ;L]  M]
9 ' ' '
H = ' ' '
E8 D!!U*$((<! 0I(<,HL(++O<ES^(++O<PHL(--m<ES^(--m<PCG(--h7@NY(--h7KEI(89BPX(89M?C(23<JR(23G,0( )7B( 4DH(78AOW(78LOS('(77
CL [V('(77
CWKO('(77?H WR('(77?SQU('(77EN ]X('(77EYY](%&556LMVdo(%&556LMaAE(45>LT(45IAE(>))*5> MH(>))*5IOS(>))*BCL [V(>))*BCW.3(?-,1(?+-2(>,+0(>*38( 216( 0/1(.-1(,04(/.2(-04(/.2(-15(0/3(.9=(%&87;(%&6:>(&'98<(&'7;?('(:9=('(8<@(();:>(()9<@(();:>(()9OS(;<NMQ(;<LLP(89KJN(89I04(/.2(-26(104(/.2(?-,0(?+37( 215( 08<($%76:($%5:>(&'98<(&'748( !326( !1FJ(23EDH(23C37( 215( 048( !326( !18<($%76:($%5?C(+,>=A(+,<59(!"437(!"27;(#$659(#$47;(#$659(#$4.2(?-,0(?+59(!"437(!"237( 215( 0;?('(:9=('(8KO(78JIM(78H+/(<*)-(<(15(0/3(.,0(=+*.(=)7;(#$659(#$49=(%&87;(%&615(0/3(.37( 215( 037( 215( 015(0/3(.9=(%&87;(%&6<@(();:>(()915(0/3(.8<($%76:($%5>B(*+=<@(*+;37( 215( 0+/(<*)-(<(9=(%&87;(%&615(0/3(.26(104(/&*(7%$((7#&*(7%$((7#04(/.2(-,0(=+*.(=)6:("#548("#315(0/3(.8<($%76:($%515(0/3(.48( !327( !1-2(>,+0(>*HM(45GFK(45E49( !327( !1@E(,-?>C(,-=:?(&'98=(&'7I +rq   