
    /j                       S SK J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Jr  SS	K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\ " 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\R6                  \\R6                  \\R6                  \\R6                  \\R6                  \\R6                  \\R6                  \\R6                  \\R6                  \\R6                  \\R6                  \\R6                  \0rg)"    )annotationsN)	dataclassfield)ClassVar)agent   )JobAcceptArgumentsRunningJobInfo   )channelc                      \ rS rSr% SrSrS\S'   SrS\S'   SrS	\S
'   Sr	S	\S'   Sr
S	\S'   SrS\S'   SS jrSS jrSrg)InitializeRequest   zisent by the main process to the subprocess to initialize it. this is going to call initialize_process_fncr   ClassVar[int]MSG_IDFboolasyncio_debugfloatping_intervalping_timeouthigh_ping_threshold str
http_proxyc                D   [         R                  " XR                  5        [         R                  " XR                  5        [         R                  " XR
                  5        [         R                  " XR                  5        [         R                  " XR                  5        g N)	r   
write_boolr   write_floatr   r   r   write_stringr   selfbs     I/app/agent/.venv/lib/python3.13/site-packages/livekit/agents/ipc/proto.pywriteInitializeRequest.write   sd    1001A112A001A778Q0    c                   [         R                  " U5      U l        [         R                  " U5      U l        [         R                  " U5      U l        [         R                  " U5      U l        [         R                  " U5      U l        g r   )	r   	read_boolr   
read_floatr   r   r   read_stringr   r    s     r#   readInitializeRequest.read!   s`    $..q1$//2#..q1#*#5#5a#8 !--a0r&   )r   r   r   r   r   Nr"   z
io.BytesIOreturnNone)__name__
__module____qualname____firstlineno____doc__r   __annotations__r   r   r   r   r   r$   r+   __static_attributes__ r&   r#   r   r      sL    sFMM4M5L%!""J11r&   r   c                  J    \ rS rSr% SrSrS\S'   SrS\S'   SS	 jrSS
 jr	Sr
g)InitializeResponse)   zmark the process as initializedr   r   r   r   r   errorc                D    [         R                  " XR                  5        g r   )r   r   r;   r    s     r#   r$   InitializeResponse.write0   s    Q

+r&   c                :    [         R                  " U5      U l        g r   )r   r*   r;   r    s     r#   r+   InitializeResponse.read3   s    ((+
r&   )r;   Nr-   )r0   r1   r2   r3   r4   r   r5   r;   r$   r+   r6   r7   r&   r#   r9   r9   )   s"    )FME3O,,r&   r9   c                  J    \ rS rSr% SrSrS\S'   SrS\S'   SS	 jrSS
 jr	Sr
g)PingRequest7   zHsent by the main process to the subprocess to check if it is still aliver   r   r   r   int	timestampc                D    [         R                  " XR                  5        g r   )r   
write_longrD   r    s     r#   r$   PingRequest.write>   s    1nn-r&   c                :    [         R                  " U5      U l        g r   )r   	read_longrD   r    s     r#   r+   PingRequest.readA   s     **1-r&   )rD   Nr-   )r0   r1   r2   r3   r4   r   r5   rD   r$   r+   r6   r7   r&   r#   rA   rA   7   s#    RFMIs..r&   rA   c                  X    \ rS rSr% SrSrS\S'   SrS\S'   SrS\S	'   SS
 jr	SS jr
Srg)PongResponseE   zresponse to a PingRequest   r   r   r   rC   last_timestamprD   c                    [         R                  " XR                  5        [         R                  " XR                  5        g r   )r   rF   rO   rD   r    s     r#   r$   PongResponse.writeM   s(    11121nn-r&   c                p    [         R                  " U5      U l        [         R                  " U5      U l        g r   )r   rI   rO   rD   r    s     r#   r+   PongResponse.readQ   s'    %//2 **1-r&   )rO   rD   Nr-   )r0   r1   r2   r3   r4   r   r5   rO   rD   r$   r+   r6   r7   r&   r#   rL   rL   E   s-    #FMNCIs..r&   rL   c                  R    \ rS rSr% SrSrS\S'   \" SS9rS\S	'   SS
 jr	SS jr
Srg)StartJobRequestV   zsent by the main process to the subprocess to start a job, the subprocess will only
receive this message if the process is fully initialized (after sending a InitializeResponse).   r   r   F)initr
   running_jobc                   U R                   R                  n[        R                  " XR                   R                  R                  5       5        [        R                  " XR                  5        [        R                  " XR                  5        [        R                  " XR                  5        [        R                  " XR                   R                  5        [        R                  " XR                   R                  5        [        R                  " XR                   R                  5        [        R                  " XR                   R                  5        g r   )rY   accept_argumentsr   write_bytesjobSerializeToStringr   nameidentitymetadataurltoken	worker_idr   fake_job)r!   r"   accept_argss      r#   r$   StartJobRequest.write^   s    &&77A//33EEGHQ 0 01Q 4 45Q 4 45Q 0 0 4 45Q 0 0 6 67Q 0 0 : :;1..778r&   c           
        [         R                  " 5       nUR                  [        R                  " U5      5        [        [        [        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U l	        g )N)r_   r`   ra   )r[   r]   rb   rc   rd   re   )
r   JobParseFromStringr   
read_bytesr
   r	   r*   r(   rY   )r!   r"   r]   s      r#   r+   StartJobRequest.readi   s    iikG..q12)/((+ ,,Q/ ,,Q/
 ##A&%%a())!,&&q)
r&   )rY   Nr-   )r0   r1   r2   r3   r4   r   r5   r   rY   r$   r+   r6   r7   r&   r#   rU   rU   V   s-    f FM"'U"3K3	9
r&   rU   c                  J    \ rS rSr% SrSrS\S'   SrS\S'   SS	 jrSS
 jr	Sr
g)ShutdownRequestz   zsent by the main process to the subprocess to indicate that it should shut down
gracefully. the subprocess will follow with a ExitInfo message   r   r   r   r   reasonc                D    [         R                  " XR                  5        g r   r   r   rq   r    s     r#   r$   ShutdownRequest.write       Q,r&   c                :    [         R                  " U5      U l        g r   r   r*   rq   r    s     r#   r+   ShutdownRequest.read       ))!,r&   rq   Nr-   r0   r1   r2   r3   r4   r   r5   rq   r$   r+   r6   r7   r&   r#   rn   rn   z   s(    F FMFC--r&   rn   c                  J    \ rS rSr% SrSrS\S'   SrS\S'   SS	 jrSS
 jr	Sr
g)Exiting   zIsent by the subprocess to the main process to indicate that it is exiting   r   r   r   r   rq   c                D    [         R                  " XR                  5        g r   rs   r    s     r#   r$   Exiting.write   ru   r&   c                :    [         R                  " U5      U l        g r   rw   r    s     r#   r+   Exiting.read   ry   r&   rz   Nr-   r{   r7   r&   r#   r}   r}      s#    SFMFC--r&   r}   c                  f    \ rS rSr% SrSrS\S'   SrS\S'   SrS\S	'   S
r	S\S'   SS jr
SS jrSrg)InferenceRequest   z=sent by a subprocess to the main process to request inference   r   r   r   r   method
request_idr&   bytesdatac                    [         R                  " XR                  5        [         R                  " XR                  5        [         R                  " XR
                  5        g r   )r   r   r   r   r\   r   r    s     r#   r$   InferenceRequest.write   s8    Q,Q0Ayy)r&   c                    [         R                  " U5      U l        [         R                  " U5      U l        [         R                  " U5      U l        g r   )r   r*   r   r   rk   r   r    s     r#   r+   InferenceRequest.read   s8    ))!,!--a0&&q)	r&   )r   r   r   Nr-   )r0   r1   r2   r3   r4   r   r5   r   r   r   r$   r+   r6   r7   r&   r#   r   r      s7    GFMFCJD%*
*r&   r   c                  f    \ rS rSr% SrSrS\S'   SrS\S'   S	rS
\S'   Sr	S\S'   SS jr
SS jrSrg	)InferenceResponse   zresponse to an InferenceRequest   r   r   r   r   r   Nzbytes | Noner   r;   c                "   [         R                  " XR                  5        [         R                  " XR                  S L5        U R                  b   [         R
                  " XR                  5        [         R                  " XR                  5        g r   )r   r   r   r   r   r\   r;   r    s     r#   r$   InferenceResponse.write   sY    Q01iit3499 99-Q

+r&   c                    [         R                  " U5      U l        [         R                  " U5      nU(       a  [         R                  " U5      U l        [         R                  " U5      U l        g r   )r   r*   r   r(   rk   r   r;   )r!   r"   has_datas      r#   r+   InferenceResponse.read   sK    !--a0$$Q'**1-DI((+
r&   )r   r;   r   r-   )r0   r1   r2   r3   r4   r   r5   r   r   r;   r$   r+   r6   r7   r&   r#   r   r      s6    )FMJD,E3O,,r&   r   c                  <    \ rS rSr% SrSrS\S'   S
S jrS
S jrSr	g	)DumpStackTraceRequest   zEsent by the main process to request a stack trace dump before killing	   r   r   c                    g r   r7   r    s     r#   r$   DumpStackTraceRequest.write       r&   c                    g r   r7   r    s     r#   r+   DumpStackTraceRequest.read   r   r&   r7   Nr-   )
r0   r1   r2   r3   r4   r   r5   r$   r+   r6   r7   r&   r#   r   r      s    OFMr&   r   c                  8    \ rS rSr% SrS\S'   S	S jrS	S jrSrg)
ShutdownRequestAck   
   r   r   c                    g r   r7   r    s     r#   r$   ShutdownRequestAck.write   r   r&   c                    g r   r7   r    s     r#   r+   ShutdownRequestAck.read   r   r&   r7   Nr-   	r0   r1   r2   r3   r   r5   r$   r+   r6   r7   r&   r#   r   r          FMr&   r   c                  8    \ rS rSr% SrS\S'   S	S jrS	S jrSrg)
ShuttingDown      r   r   c                    g r   r7   r    s     r#   r$   ShuttingDown.write   r   r&   c                    g r   r7   r    s     r#   r+   ShuttingDown.read   r   r&   r7   Nr-   r   r7   r&   r#   r   r      r   r&   r   )
__future__r   iodataclassesr   r   typingr   livekit.protocolr   r]   r	   r
   r   r   r   r9   rA   rL   rU   rn   r}   r   r   r   r   r   r   IPC_MESSAGESr7   r&   r#   <module>r      s   " 	 (  " 4  1 1 16 
, 
, 
, 
. 
. 
. . . .   
  
  
F - - - 
- 
- 
- * * *& , , ,. 	 	 	       /1OONNG-/  "71r&   