
    qi/$                     h   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  ej                         j!                  d      Z e       Z e
j(                  ee        e
j*                  ed	e       ej,                  d
k(  r#ded   _        ded   _        ded   j2                  d   _        ded   j2                  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   _        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(   _        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   _        d>ed   _        d@edA   _        dBedA   _        dCedD   _        dEedD   _        dFedG   _        dHedG   _        dIedJ   _        dKedJ   _        dLedM   _        dNedM   _        dOedP   _        dQedP   _        dRedS   _        dTedS   _        yy)UzGenerated protocol buffer code.    )
descriptor)descriptor_pool)symbol_database)builder   )modelssW  
livekit_agent.protolivekitlivekit_models.proto"
Job

id (	
dispatch_id	 (	
type (2.livekit.JobType
room (2.livekit.Room2
participant (2.livekit.ParticipantInfoH 
	namespace (	B
metadata (	

agent_name (	 
state (2.livekit.JobState
enable_recording
 (B
_participant"
JobState"
status (2.livekit.JobStatus
error (	

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

updated_at (
participant_identity (	
	worker_id (	
agent_id (	"
WorkerMessage2
register (2.livekit.RegisterWorkerRequestH 5
availability (2.livekit.AvailabilityResponseH 4
update_worker (2.livekit.UpdateWorkerStatusH .

update_job (2.livekit.UpdateJobStatusH #
ping (2.livekit.WorkerPingH 3
simulate_job (2.livekit.SimulateJobRequestH 1
migrate_job (2.livekit.MigrateJobRequestH 5
text_response (2.livekit.TextMessageResponseH -
	push_text	 (2.livekit.PushTextRequestH B	
message"
ServerMessage3
register (2.livekit.RegisterWorkerResponseH 4
availability (2.livekit.AvailabilityRequestH ,

assignment (2.livekit.JobAssignmentH .
termination (2.livekit.JobTerminationH #
pong (2.livekit.WorkerPongH 3
text_request (2.livekit.TextMessageRequestH B	
message"
SimulateJobRequest
type (2.livekit.JobType
room (2.livekit.Room-
participant (2.livekit.ParticipantInfo"

WorkerPing
	timestamp ("7

WorkerPong
last_timestamp (
	timestamp ("
RegisterWorkerRequest
type (2.livekit.JobType

agent_name (	
version (	
ping_interval (
	namespace (	H ;
allowed_permissions (2.livekit.ParticipantPermissionB

_namespace"U
RegisterWorkerResponse
	worker_id (	(
server_info (2.livekit.ServerInfo"$
MigrateJobRequest
job_ids (	"B
AvailabilityRequest
job (2.livekit.Job
resuming ("
AvailabilityResponse
job_id (	
	available (
supports_resume (
	terminate (
participant_name (	
participant_identity (	
participant_metadata (	X
participant_attributes (28.livekit.AvailabilityResponse.ParticipantAttributesEntry<
ParticipantAttributesEntry
key (	
value (	:8"T
UpdateJobStatus
job_id (	"
status (2.livekit.JobStatus
error (	"l
UpdateWorkerStatus*
status (2.livekit.WorkerStatusH 
load (
	job_count (B	
_status"S
JobAssignment
job (2.livekit.Job
url (	H 
token (	B
_url" 
JobTermination
job_id (	"
TextMessageRequest

message_id (	

session_id (	

agent_name (	
metadata (	
session_data (
text (	"6
PushTextRequest

message_id (	
content (	"N
TextMessageResponse

message_id (	
session_data (
error (	*<
JobType
JT_ROOM 
JT_PUBLISHER
JT_PARTICIPANT*-
WorkerStatus
WS_AVAILABLE 
WS_FULL*J
	JobStatus

JS_PENDING 

JS_RUNNING

JS_SUCCESS
	JS_FAILEDBFZ#github.com/livekit/protocol/livekitLiveKit.ProtoLiveKit::Protobproto3agentFN
DESCRIPTORsF   Z#github.com/livekit/protocol/livekitLiveKit.ProtoLiveKit::Proto_JOB	namespaces   0_AVAILABILITYRESPONSE_PARTICIPANTATTRIBUTESENTRYs   8iP  _JOBTYPEi  i  _WORKERSTATUSi  i  
_JOBSTATUSi  7   iW  iZ  	_JOBSTATEi  i  _WORKERMESSAGEi  i  _SERVERMESSAGEi5  i8  _SIMULATEJOBREQUESTi  i  _WORKERPINGi  i  _WORKERPONGi  i  _REGISTERWORKERREQUESTi  i  _REGISTERWORKERRESPONSEiB  iD  _MIGRATEJOBREQUESTih  ij  _AVAILABILITYREQUESTi  i  _AVAILABILITYRESPONSEi	  i  i	  _UPDATEJOBSTATUSiX	  iZ	  _UPDATEWORKERSTATUSi	  i	  _JOBASSIGNMENTi
  i
  _JOBTERMINATIONi=
  i@
  _TEXTMESSAGEREQUESTi
  i
  _PUSHTEXTREQUESTi
  i   _TEXTMESSAGERESPONSEiN  )__doc__google.protobufr   _descriptorr   _descriptor_poolr   _symbol_databasegoogle.protobuf.internalr   _builderDefault_sym_db r   _models_AddSerializedFiler
   globals_globalsBuildMessageAndEnumDescriptorsBuildTopDescriptorsAndMessages_USE_C_DESCRIPTORS_options_serialized_optionsfields_by_name_serialized_start_serialized_end     H/opt/pipecat/venv/lib/python3.12/site-packages/livekit/protocol/agent.py<module>r=      su  
 & 5 ? ? 8 #

"
"
$ ! &%%'99  ;XV  YV
9 ' ' '
H = ' ' '
GX F!!U*$((<! 0I(<,:>(6!!+.7EP(6!!+.BJN(=>GU](=>R)-(:('+(:&.2(?-,0(?++/(<*)-(<(%'(6$#&(6"*-(;)(+(;'/2(.-1(,/3(.-1(,48( !326( !1,0(=+*.(=),0(=+*.(=)7;(#$659(#$48<($%76:($%537( 215( 059(!"437(!"26:("#548("#3QU(=>POS(=>N15(0/3(.48( !326( !1/3(.-1(,04(/.2(-48( !326( !115(0/3(.59(!"437(!"2i +r;   