o
    i                  
   @  s   d dl mZ d dlZd dlZd dlmZmZ d dlmZ d dl	m
Z
 ddlmZ ddlmZmZ eG d	d
 d
ZeG dd dZeG dd dZeG dd dZeG dd deZeG dd dZejeejeejeejeejeiZdS )    )annotationsN)	dataclassfield)ClassVar)agent   )channel)JobAcceptArgumentsRunningJobInfoc                   @  s^   e Zd ZU ded< ded< ded< ded< dZded	< dZded
< dZded< dZded< dS )CliArgsstr	log_levelz
str | Noneurlapi_key
api_secretFbooldevmodereloadr   intreload_countNzsocket.socket | Nonemp_cch)__name__
__module____qualname____annotations__r   r   r   r    r   r   Z/var/www/html/livekit_bhavya/venv/lib/python3.10/site-packages/livekit/agents/cli/proto.pyr      s   
 r   c                   @     e Zd ZU dZded< dS )ActiveJobsRequest   ClassVar[int]MSG_IDNr   r   r   r!   r   r   r   r   r   r   %      
 r   c                   @  sL   e Zd ZU dZded< eedZded< dZded	< dddZ	dddZ
dS )ActiveJobsResponser   r    r!   )default_factoryzlist[RunningJobInfo]jobsr   r   r   b
io.BytesIOreturnNonec                 C  s   t |t| j | jD ]?}|j}t ||j  t ||j	 t ||j
 t ||j t ||j t ||j t ||j t ||j qt || j d S )N)r   	write_intlenr&   accept_argumentswrite_bytesjobSerializeToStringwrite_stringnameidentitymetadatar   token	worker_id
write_boolfake_jobr   )selfr'   running_jobaccept_argsr   r   r   write0   s   
zActiveJobsResponse.writec                 C  s   t t|D ]6}t }|t| | jt	t
t|t|t|d|t|t|t|t|d qt|| _d S )N)r2   r3   r4   )r-   r/   r   r5   r6   r8   )ranger   read_intr   JobParseFromString
read_bytesr&   appendr
   r	   read_string	read_boolr   )r9   r'   _r/   r   r   r   read?   s$   zActiveJobsResponse.readN)r'   r(   r)   r*   )r   r   r   r!   r   r   listr&   r   r<   rF   r   r   r   r   r$   *   s   
 
r$   c                   @  r   )ReloadJobsRequest   r    r!   Nr"   r   r   r   r   rH   U   r#   rH   c                   @  r   )ReloadJobsResponse   r    r!   Nr"   r   r   r   r   rJ   Z   r#   rJ   c                   @  r   )Reloaded   r    r!   Nr"   r   r   r   r   rL   _   r#   rL   )
__future__r   iosocketdataclassesr   r   typingr   livekit.protocolr   ipcr   r/   r	   r
   r   r   r$   rH   rJ   rL   r!   IPC_MESSAGESr   r   r   r   <module>   s4    *