
    PiX	              
          d dl mZmZ d dlmZ d dlmZ  G d de          Z G d de          Z G d d	e          Z	 G d
 de          Z
 G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Zee	e
eeeeeeef	         ZdS )    )LiteralUnion)ServerMessage)	BaseModelc                   .    e Zd ZU eed<   dZedz  ed<   dS )BaseMessagemsgNevent_id)__name__
__module____qualname__r   __annotations__r
   str     j/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/gradio/server_messages.pyr   r      s2         	HcDjr   r   c                       e Zd ZU dZeez  dz  ed<   dZeez  dz  ed<   dZe	dz  ed<   dZ
edz  ed<   dZe	dz  ed<   dS )ProgressUnitNindexlengthunitprogressdesc)r   r   r   r   intfloatr   r   r   r   r   r   r   r   r   r   r      s          $E3;$$$!%FC%K$%%%D#*!Hedl!!!D#*r   r   c                   X    e Zd ZU ej        Zeej                 ed<   g Ze	e
         ed<   dS )ProgressMessager	   progress_dataN)r   r   r   r   r   r	   r   r   r   listr   r   r   r   r   r      sB         +8+AC'	(AAA(*M4%*****r   r   c                       e Zd ZU ej        Zeej                 ed<   eed<   ed         ed<   dZ	e
dz  ed<   dZeed	<   eed
<   dS )
LogMessager	   log)infowarningsuccesserrorlevel
   NdurationTvisibletitle)r   r   r   r   r"   r	   r   r   r   r)   r   r*   boolr   r   r   r!   r!      ss         &3&7C"	#777	HHH89999HedlGTJJJJJr   r!   c                   p    e Zd ZU ej        Zeej                 ed<   dZe	dz  ed<   e	ed<   dZ
edz  ed<   dS )EstimationMessager	   Nrank
queue_sizerank_eta)r   r   r   r   
estimationr	   r   r   r/   r   r1   r   r   r   r   r.   r.   "   s^         -:-EC)	*EEED#*OOO!Hedl!!!!!r   r.   c                   R    e Zd ZU ej        Zeej                 ed<   dZe	dz  ed<   dS )ProcessStartsMessager	   Neta)
r   r   r   r   process_startsr	   r   r   r5   r   r   r   r   r4   r4   )   sA         1>1MC-	.MMMCr   r4   c                   f    e Zd ZU ej        Zeej                 ed<   eed<   e	ed<   dZ
edz  ed<   dS )ProcessCompletedMessager	   outputr%   Nr+   )r   r   r   r   process_completedr	   r   r   dictr,   r+   r   r   r   r   r8   r8   .   sS         4A4SC0	1SSSLLLMMME3:r   r8   c                   t    e Zd ZU ej        Zeej        ej        f         ed<   e	ed<   e
ed<   dZedz  ed<   dS )ProcessGeneratingMessager	   r9   r%   N
time_limit)r   r   r   r   process_generatingr	   r   process_streamingr   r;   r,   r>   r   r   r   r   r=   r=   5   sf         ( 1=3RR	S    LLLMMM#J#####r   r=   c                   >    e Zd ZU ej        Zeej                 ed<   dS )HeartbeatMessager	   N)r   r   r   r   	heartbeatr	   r   r   r   r   r   rB   rB   >   s-         ,9,CC(	)CCCCCr   rB   c                   >    e Zd ZU ej        Zeej                 ed<   dS )CloseStreamMessager	   N)r   r   r   r   close_streamr	   r   r   r   r   r   rE   rE   B   s-         /</IC+	,IIIIIr   rE   c                   p    e Zd ZU ej        Zeej                 ed<   eed<   dZ	e
ed<   dZed         ed<   dS )UnexpectedErrorMessager	   messageFsession_not_foundr%   N)r   r   r   r   unexpected_errorr	   r   r   r   rJ   r,   r%   r   r   r   rH   rH   F   s[         3@3QC/	0QQQLLL#t####GWU^#####r   rH   N)typingr   r   gradio_client.utilsr   pydanticr   r   r   r   r!   r.   r4   r8   r=   rB   rE   rH   EventMessager   r   r   <module>rP      sO   ! ! ! ! ! ! ! ! - - - - - -               )      
    9   + + + + +k + + +
       " " " " " " " "    ;   
    k   $ $ $ $ ${ $ $ $D D D D D{ D D DJ J J J J J J J$ $ $ $ $[ $ $ $ 
r   