
    /j              
         S SK Jr  S SKrS SKrS SKJrJr  S SKJr  S SK	J
r
  SSKJr  SSKJrJr  \ " S	 S
5      5       r\ " S S5      5       r\ " S S5      5       r\ " S S5      5       r\ " S S\5      5       r\ " S S5      5       r\R,                  \\R,                  \\R,                  \\R,                  \\R,                  \0rg)    )annotationsN)	dataclassfield)ClassVar)agent   )channel)JobAcceptArgumentsRunningJobInfoc                      \ rS rSr% S\S'   S\S'   \" SSS9rS\S	'   \" SSS9rS\S
'   SrS\S'   Sr	S\S'   Sr
S\S'   SrS\S'   Srg)CliArgs   str	log_levelz
str | NoneurlFN)reprdefaultapi_key
api_secretbooldevmodereloadr   intreload_countzsocket.socket | Nonemp_cch )__name__
__module____qualname____firstlineno____annotations__r   r   r   r   r   r   r   __static_attributes__r       I/app/agent/.venv/lib/python3.13/site-packages/livekit/agents/cli/proto.pyr   r      s]    N 
OUD9GZ9"t<J
<GTFD L# $(F 'r#   r   c                  $    \ rS rSr% SrS\S'   Srg)ActiveJobsRequest%      ClassVar[int]MSG_IDr   Nr   r   r   r    r*   r!   r"   r   r#   r$   r&   r&   %       FMr#   r&   c                  \    \ rS rSr% SrS\S'   \" \S9rS\S'   Sr	S	\S
'   SS jr
SS jrSrg)ActiveJobsResponse*   r   r)   r*   )default_factoryzlist[RunningJobInfo]jobsr   r   r   c                   [         R                  " U[        U R                  5      5        U R                   GH  nUR                  n[         R
                  " XR                  R                  5       5        [         R                  " XR                  5        [         R                  " XR                  5        [         R                  " XR                  5        [         R                  " XR                  5        [         R                  " XR                  5        [         R                  " XR                  5        [         R                  " XR                   5        GM!     [         R                  " XR"                  5        g )N)r	   	write_intlenr1   accept_argumentswrite_bytesjobSerializeToStringwrite_stringnameidentitymetadatar   token	worker_id
write_boolfake_jobr   )selfbrunning_jobaccept_argss       r$   writeActiveJobsResponse.write0   s    !S^,99K%66K??#D#D#FG  $4$45  $8$89  $8$89  OO4  $5$56  $9$9:q"6"67 % 	!../r#   c                r   [        [        R                  " U5      5       H  n[        R                  " 5       nUR                  [        R                  " U5      5        U R                  R                  [        [        [        R                  " U5      [        R                  " U5      [        R                  " U5      S9U[        R                  " U5      [        R                  " U5      [        R                  " U5      [        R                  " U5      S95        M     [        R                  " U5      U l        g )N)r:   r;   r<   )r5   r7   r   r=   r>   r@   )ranger	   read_intr   JobParseFromString
read_bytesr1   appendr   r
   read_string	read_boolr   )rA   rB   _r7   s       r$   readActiveJobsResponse.read?   s    w''*+A))+C 2 21 56II%7$003!(!4!4Q!7!(!4!4Q!7&
 ++A.!--a0%11!4$..q1 ,$ $,,Q/r#   )r   N)rB   z
io.BytesIOreturnNone)r   r   r   r    r*   r!   r   listr1   r   rE   rQ   r"   r   r#   r$   r.   r.   *   s0    FM!&t!<D
<L#00r#   r.   c                  $    \ rS rSr% SrS\S'   Srg)ReloadJobsRequestU      r)   r*   r   Nr+   r   r#   r$   rW   rW   U   r,   r#   rW   c                  $    \ rS rSr% SrS\S'   Srg)ReloadJobsResponseZ      r)   r*   r   Nr+   r   r#   r$   r[   r[   Z   r,   r#   r[   c                  $    \ rS rSr% SrS\S'   Srg)Reloaded_      r)   r*   r   Nr+   r   r#   r$   r_   r_   _   r,   r#   r_   )
__future__r   iosocketdataclassesr   r   typingr   livekit.protocolr   ipcr	   r7   r
   r   r   r&   r.   rW   r[   r_   r*   IPC_MESSAGESr   r#   r$   <module>rj      s    " 	  (  "  4 ( ( (,    '0 '0 '0T    +     
 /1/1OOXr#   