
    qib                        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(  red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   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   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   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!   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%   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.   _        d0ed1   _        d2ed1   _        d3ed4   _        d5ed4   _        d6ed7   _        d8ed7   _        d9ed:   _        d;ed:   _        d<ed=   _        d>ed=   _        d?ed@   _        dAed@   _        dBed   _        dCed   _        dDed   _        dEed   _        dFedG   _        dHedG   _        dIed   _        dJed   _        dKedL   _        dMedL   _        dNedO   _        dPedO   _        dQedR   _        dSedR   _        dTedU   _        dVedU   _        dWedX   _        dYedX   _        dZed   _        d[ed   _        d\ed   _        d[ed   _        d]ed   _        d^ed   _        d_ed!   _        d`ed!   _        daed$   _        dbed$   _        dcedd   _        deedd   _        dfedg   _        dhedg   _        diedj   _        dkedj   _        dledm   _        dnedm   _        doedp   _        dqedp   _        dreds   _        dteds   _        duedv   _        dwedv   _        dxedy   _        dzedy   _        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   _        yy)zGenerated protocol buffer code.    )
descriptor)descriptor_pool)symbol_database)builder   )models)optionss#  
livekit_egress.protolivekitlivekit_models.protologger/options.proto"
RoomCompositeEgressRequest
	room_name (	
layout (	

audio_only (*
audio_mixing (2.livekit.AudioMixing

video_only (
custom_base_url (	.
file (2.livekit.EncodedFileOutputBH +
stream (2.livekit.StreamOutputBH 4
segments
 (2.livekit.SegmentedFileOutputBH 0
preset (2.livekit.EncodingOptionsPresetH,
advanced	 (2.livekit.EncodingOptionsH0
file_outputs (2.livekit.EncodedFileOutput-
stream_outputs (2.livekit.StreamOutput5
segment_outputs (2.livekit.SegmentedFileOutput+
image_outputs (2.livekit.ImageOutput(
webhooks (2.livekit.WebhookConfigB
outputB	
options"
WebEgressRequest
url (	

audio_only (

video_only (
await_start_signal (.
file (2.livekit.EncodedFileOutputBH +
stream (2.livekit.StreamOutputBH 4
segments (2.livekit.SegmentedFileOutputBH 0
preset (2.livekit.EncodingOptionsPresetH,
advanced (2.livekit.EncodingOptionsH0
file_outputs	 (2.livekit.EncodedFileOutput-
stream_outputs
 (2.livekit.StreamOutput5
segment_outputs (2.livekit.SegmentedFileOutput+
image_outputs (2.livekit.ImageOutput(
webhooks (2.livekit.WebhookConfigB
outputB	
options"
ParticipantEgressRequest
	room_name (	
identity (	
screen_share (0
preset (2.livekit.EncodingOptionsPresetH ,
advanced (2.livekit.EncodingOptionsH 0
file_outputs (2.livekit.EncodedFileOutput-
stream_outputs (2.livekit.StreamOutput5
segment_outputs (2.livekit.SegmentedFileOutput+
image_outputs	 (2.livekit.ImageOutput(
webhooks
 (2.livekit.WebhookConfigB	
options"
TrackCompositeEgressRequest
	room_name (	
audio_track_id (	
video_track_id (	.
file (2.livekit.EncodedFileOutputBH +
stream (2.livekit.StreamOutputBH 4
segments (2.livekit.SegmentedFileOutputBH 0
preset (2.livekit.EncodingOptionsPresetH,
advanced (2.livekit.EncodingOptionsH0
file_outputs (2.livekit.EncodedFileOutput-
stream_outputs (2.livekit.StreamOutput5
segment_outputs (2.livekit.SegmentedFileOutput+
image_outputs (2.livekit.ImageOutput(
webhooks (2.livekit.WebhookConfigB
outputB	
options"
TrackEgressRequest
	room_name (	
track_id (	)
file (2.livekit.DirectFileOutputH 
websocket_url (	H (
webhooks (2.livekit.WebhookConfigB
output"
EncodedFileOutput+
	file_type (2.livekit.EncodedFileType
filepath (	
disable_manifest (
s3 (2.livekit.S3UploadH !
gcp (2.livekit.GCPUploadH )
azure (2.livekit.AzureBlobUploadH '
aliOSS (2.livekit.AliOSSUploadH B
output"
SegmentedFileOutput0
protocol (2.livekit.SegmentedFileProtocol
filename_prefix (	
playlist_name (	
live_playlist_name (	
segment_duration (5
filename_suffix
 (2.livekit.SegmentedFileSuffix
disable_manifest (
s3 (2.livekit.S3UploadH !
gcp (2.livekit.GCPUploadH )
azure (2.livekit.AzureBlobUploadH '
aliOSS	 (2.livekit.AliOSSUploadH B
output"
DirectFileOutput
filepath (	
disable_manifest (
s3 (2.livekit.S3UploadH !
gcp (2.livekit.GCPUploadH )
azure (2.livekit.AzureBlobUploadH '
aliOSS (2.livekit.AliOSSUploadH B
output"
ImageOutput
capture_interval (
width (
height (
filename_prefix (	1
filename_suffix (2.livekit.ImageFileSuffix(
image_codec (2.livekit.ImageCodec
disable_manifest (
s3 (2.livekit.S3UploadH !
gcp	 (2.livekit.GCPUploadH )
azure
 (2.livekit.AzureBlobUploadH '
aliOSS (2.livekit.AliOSSUploadH B
output"
S3Upload

access_key (	B,
secret (	B,
session_token (	B,
assume_role_arn (	B,%
assume_role_external_id (	B,
region (	
endpoint (	
bucket (	
force_path_style (1
metadata (2.livekit.S3Upload.MetadataEntry
tagging (	
content_disposition	 (	#
proxy
 (2.livekit.ProxyConfig/
MetadataEntry
key (	
value (	:8"[
	GCPUpload
credentials (	B,
bucket (	#
proxy (2.livekit.ProxyConfig"`
AzureBlobUpload
account_name (	B,
account_key (	B,
container_name (	"p
AliOSSUpload

access_key (	B,
secret (	B,
region (	
endpoint (	
bucket (	">
ProxyConfig
url (	
username (	
password (	"G
StreamOutput)
protocol (2.livekit.StreamProtocol
urls (	"
EncodingOptions
width (
height (
depth (
	framerate ((
audio_codec (2.livekit.AudioCodec
audio_bitrate (
audio_quality (
audio_frequency ((
video_codec (2.livekit.VideoCodec
video_bitrate	 (
video_quality (
key_frame_interval
 ("8
UpdateLayoutRequest
	egress_id (	
layout (	"]
UpdateStreamRequest
	egress_id (	
add_output_urls (	
remove_output_urls (	"I
ListEgressRequest
	room_name (	
	egress_id (	
active ("8
ListEgressResponse"
items (2.livekit.EgressInfo"&
StopEgressRequest
	egress_id (	"

EgressInfo
	egress_id (	
room_id (	
	room_name (	.
source_type (2.livekit.EgressSourceType%
status (2.livekit.EgressStatus

started_at
 (
ended_at (

updated_at (
details (	
error	 (	

error_code (=
room_composite (2#.livekit.RoomCompositeEgressRequestH (
web (2.livekit.WebEgressRequestH 8
participant (2!.livekit.ParticipantEgressRequestH ?
track_composite (2$.livekit.TrackCompositeEgressRequestH ,
track (2.livekit.TrackEgressRequestH -
stream (2.livekit.StreamInfoListBH%
file (2.livekit.FileInfoBH-
segments (2.livekit.SegmentsInfoBH+
stream_results (2.livekit.StreamInfo'
file_results (2.livekit.FileInfo.
segment_results (2.livekit.SegmentsInfo*
image_results (2.livekit.ImagesInfo
manifest_location (	
backup_storage_used (B	
requestB
result"7
StreamInfoList!
info (2.livekit.StreamInfo:"

StreamInfo
url (	

started_at (
ended_at (
duration (*
status (2.livekit.StreamInfo.Status
error (	
last_retry_at (
retries (".
Status

ACTIVE 
FINISHED

FAILED"t
FileInfo
filename (	

started_at (
ended_at (
duration (
size (
location (	"
SegmentsInfo
playlist_name (	
live_playlist_name (	
duration (
size (
playlist_location (	
live_playlist_location	 (	
segment_count (

started_at (
ended_at ("`

ImagesInfo
filename_prefix (	
image_count (

started_at (
ended_at ("
AutoParticipantEgress0
preset (2.livekit.EncodingOptionsPresetH ,
advanced (2.livekit.EncodingOptionsH 0
file_outputs (2.livekit.EncodedFileOutput5
segment_outputs (2.livekit.SegmentedFileOutputB	
options"
AutoTrackEgress
filepath (	
disable_manifest (
s3 (2.livekit.S3UploadH !
gcp (2.livekit.GCPUploadH )
azure (2.livekit.AzureBlobUploadH '
aliOSS (2.livekit.AliOSSUploadH B
output*B
EncodedFileType
DEFAULT_FILETYPE 
MP4
OGG
MP3*N
SegmentedFileProtocol#
DEFAULT_SEGMENTED_FILE_PROTOCOL 
HLS_PROTOCOL*/
SegmentedFileSuffix	
INDEX 
	TIMESTAMP*f
ImageFileSuffix
IMAGE_SUFFIX_INDEX 
IMAGE_SUFFIX_TIMESTAMP
IMAGE_SUFFIX_NONE_OVERWRITE*9
StreamProtocol
DEFAULT_PROTOCOL 
RTMP
SRT*U
AudioMixing
DEFAULT_MIXING 
DUAL_CHANNEL_AGENT
DUAL_CHANNEL_ALTERNATE*
EncodingOptionsPreset
H264_720P_30 
H264_720P_60
H264_1080P_30
H264_1080P_60
PORTRAIT_H264_720P_30
PORTRAIT_H264_720P_60
PORTRAIT_H264_1080P_30
PORTRAIT_H264_1080P_60*
EgressStatus
EGRESS_STARTING 
EGRESS_ACTIVE
EGRESS_ENDING
EGRESS_COMPLETE
EGRESS_FAILED
EGRESS_ABORTED
EGRESS_LIMIT_REACHED*J
EgressSourceType
EGRESS_SOURCE_TYPE_WEB 
EGRESS_SOURCE_TYPE_SDK2
EgressT
StartRoomCompositeEgress#.livekit.RoomCompositeEgressRequest.livekit.EgressInfo@
StartWebEgress.livekit.WebEgressRequest.livekit.EgressInfoP
StartParticipantEgress!.livekit.ParticipantEgressRequest.livekit.EgressInfoV
StartTrackCompositeEgress$.livekit.TrackCompositeEgressRequest.livekit.EgressInfoD
StartTrackEgress.livekit.TrackEgressRequest.livekit.EgressInfoA
UpdateLayout.livekit.UpdateLayoutRequest.livekit.EgressInfoA
UpdateStream.livekit.UpdateStreamRequest.livekit.EgressInfoE

ListEgress.livekit.ListEgressRequest.livekit.ListEgressResponse=

StopEgress.livekit.StopEgressRequest.livekit.EgressInfoBFZ#github.com/livekit/protocol/livekitLiveKit.ProtoLiveKit::Protobproto3egressFN
DESCRIPTORsF   Z#github.com/livekit/protocol/livekitLiveKit.ProtoLiveKit::Proto_ROOMCOMPOSITEEGRESSREQUESTfiles   streamsegments_WEBEGRESSREQUEST_TRACKCOMPOSITEEGRESSREQUEST_S3UPLOAD_METADATAENTRYs   8	_S3UPLOAD
access_keys   ,secretsession_tokenassume_role_arnassume_role_external_id
_GCPUPLOADcredentials_AZUREBLOBUPLOADaccount_nameaccount_key_ALIOSSUPLOAD_EGRESSINFO_STREAMINFOLISTiD  _ENCODEDFILETYPEi  i  _SEGMENTEDFILEPROTOCOLi  i  _SEGMENTEDFILESUFFIXi  i	  _IMAGEFILESUFFIXio  iq  _STREAMPROTOCOLi  i  _AUDIOMIXINGi  i  _ENCODINGOPTIONSPRESETi  i  _EGRESSSTATUSiu   iw   _EGRESSSOURCETYPEi   N   i  i  iN  iQ  _PARTICIPANTEGRESSREQUESTi   i  iZ	  i]	  _TRACKEGRESSREQUESTi
  i
  _ENCODEDFILEOUTPUTi  i"  _SEGMENTEDFILEOUTPUTi  i  _DIRECTFILEOUTPUTi  i  _IMAGEOUTPUTi   i#  i  i  i  i   i"  i  i  i  i  _PROXYCONFIGi4  i6  _STREAMOUTPUTi}  i  _ENCODINGOPTIONSi  i  _UPDATELAYOUTREQUESTi  i  _UPDATESTREAMREQUESTiP  iR  _LISTEGRESSREQUESTi  i  _LISTEGRESSRESPONSEi  i  _STOPEGRESSREQUESTi  i   i  i  i  i  _STREAMINFOi  i  _STREAMINFO_STATUSi  	_FILEINFOi4  i7  _SEGMENTSINFOi  i  _IMAGESINFOir  iu  _AUTOPARTICIPANTEGRESSi`  ic  _AUTOTRACKEGRESSiB  i   _EGRESSi`#  )__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     I/opt/pipecat/venv/lib/python3.12/site-packages/livekit/protocol/egress.py<module>r\      s	  
 & 5 ? ? 8 #

"
"
$ ! 9 &%%'99  ;w  @x
9 ' ' '
H = ' ' '
Hh G!!U*$((<! 0I(<,LP(()88@IWb(()88@TNR(()88BKYd(()88BVPT(()88DM[f(()88DXBF(..v6?MX(..v6JDH(..x8AOZ(..x8LFJ(..z:CQ\(..z:NMQ()*99&AJXc()*99&AUOS()*99(CLZe()*99(CWQU()*99*EN\g()*99*EY15($%.<D($%9@D(;&&|4=K[(;&&|4H<@(;&&x09GW(;&&x0DCG(;&&7@N^(;&&7KEI(;&&'89BP`(;&&'89MMQ(;&&'@AJXh(;&&'@AUBF(<''6?M](<''6JIM(--n=FTd(--n=QHL(--m<ESc(--m<PDH(?**<8AO_(?**<8L@D(?**84=K[(?**84H>B(=((2;IT(=((2F<@(=((09GR(=((0D@D(=((4=KV(=((4H)-(&4?(115(0/3(.7;(#$659(#$459(!"437(!"215(0/3(.04(/.2(--1(>,+/(>*7;(#$659(#$4.2(?-,0(?+26(104(/<>(();:=(()925(104(/:>(&'98<(&'7=A()*<;?()*:48( !326( !137( 215( 059(!"437(!"226(104(/-1(>,+/(>**.(;)(,(;'8<($%76:($%5+/(<*)-(<(15(0/3(..2(?-,0(?+-1(>,+/(>*.2(?-,0(?+15(0/3(.59(!"437(!"259(!"437(!"237( 215( 048( !326( !137( 215( 0,0(=+*.(=)04(/.2(-,0(=+*.(=)37( 215( 0*.(;)(,(;'.2(?-,0(?+,0(=+*.(=)7;(#$659(#$415(0/3(.(,(9'&*(9%I +rZ   