
    vgC                        d dl mZ d dlmZ g Zd Zd Zd Zd Z G d d          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          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/ d0e          Z G d1 d2e          Z G d3 d4e	          Z G d5 d6e          Z  G d7 d8e          Z! G d9 d:e	          Z" G d; d<e"          Z# G d= d>e"          Z$ G d? d@e"          Z%e#e$e%gZ& G dA dB          Z'dC Z(dD Z)dES )F    )getProcessStateDescription)	as_stringc                 >    t                               | |f           d S N)	callbacksappendtypecallbacks     N/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/supervisor/events.py	subscriber      !    dH%&&&&&    c                 >    t                               | |f           d S r   )r   remover	   s     r   unsubscriber   	   r   r   c                 V    t           D ] \  }}t          | |          r ||            !d S r   )r   
isinstance)eventr
   r   s      r   notifyr      s?    #  heT"" 	HUOOO r   c                      g t           d d <   d S r   )r    r   r   clearr      s    IaaaLLLr   c                       e Zd ZdZdS )Eventz Abstract event type N)__name__
__module____qualname____doc__r   r   r   r   r      s        Dr   r   c                   "    e Zd ZdZdZd Zd ZdS )ProcessLogEvent
 Abstract Nc                 0    || _         || _        || _        d S r   processpiddataselfr%   r&   r'   s       r   __init__zProcessLogEvent.__init__       			r   c                 `   d}| j         j        | j         j        j        j        }	 t	          | j                  }n# t          $ r d| j        z  }Y nw xY wt	          d          }|t	          | j         j        j                  t	          |          | j        t	          | j                  |fz  }|S )N Undecodable: %rz0processname:%s groupname:%s pid:%s channel:%s
%s)	r%   groupconfignamer   r'   UnicodeDecodeErrorr&   channel)r)   	groupnamer'   fmtresults        r   payloadzProcessLogEvent.payload    s    	<)*16I	1TY''DD! 	1 	1 	1$ty0DDD	1
 KLL	$,"5":;;!),,dh!$,//7 7    ; AA)r   r   r   r   r3   r*   r7   r   r   r   r!   r!      s=        G  
    r   r!   c                       e Zd ZdZdS )ProcessLogStdoutEventstdoutNr   r   r   r3   r   r   r   r:   r:   1           GGGr   r:   c                       e Zd ZdZdS )ProcessLogStderrEventstderrNr<   r   r   r   r?   r?   4   r=   r   r?   c                   &    e Zd ZdZdZdZd Zd ZdS )ProcessCommunicationEventr"   s   <!--XSUPERVISOR:BEGIN-->s   <!--XSUPERVISOR:END-->c                 0    || _         || _        || _        d S r   r$   r(   s       r   r*   z"ProcessCommunicationEvent.__init__=   r+   r   c                     d}| j         j        | j         j        j        j        }	 t	          | j                  }n# t          $ r d| j        z  }Y nw xY wd| j         j        j        d|d| j        d|S )Nr-   r.   zprocessname:z groupname:z pid:
)r%   r/   r0   r1   r   r'   r2   r&   )r)   r4   r'   s      r   r7   z!ProcessCommunicationEvent.payloadB   s    	<)*16I	1TY''DD! 	1 	1 	1$ty0DDD	1 L$$$IIHHHD	 	r8   N)r   r   r   r   BEGIN_TOKEN	END_TOKENr*   r7   r   r   r   rB   rB   7   sB        -K+I  
    r   rB   c                       e Zd ZdZdS )ProcessCommunicationStdoutEventr;   Nr<   r   r   r   rI   rI   P   r=   r   rI   c                       e Zd ZdZdS )ProcessCommunicationStderrEventr@   Nr<   r   r   r   rK   rK   S   r=   r   rK   c                       e Zd Zd Zd ZdS )RemoteCommunicationEventc                 "    || _         || _        d S r   r
   r'   )r)   r
   r'   s      r   r*   z!RemoteCommunicationEvent.__init__W   s    				r   c                 &    d| j         d| j        S )Nztype:rE   rO   r)   s    r   r7   z RemoteCommunicationEvent.payload[   s      $			49955r   Nr   r   r   r*   r7   r   r   r   rM   rM   V   s2          6 6 6 6 6r   rM   c                       e Zd ZdZd ZdS )SupervisorStateChangeEventz Abstract class c                     dS )Nr-   r   rQ   s    r   r7   z"SupervisorStateChangeEvent.payload`   s    rr   N)r   r   r   r   r7   r   r   r   rT   rT   ^   s)            r   rT   c                       e Zd ZdS )SupervisorRunningEventNr   r   r   r   r   r   rW   rW   c           Dr   rW   c                       e Zd ZdS )SupervisorStoppingEventNrX   r   r   r   r[   r[   f   rY   r   r[   c                       e Zd Zd ZdS )EventRejectedEventc                 "    || _         || _        d S r   )r%   r   )r)   r%   r   s      r   r*   zEventRejectedEvent.__init__j   s    


r   N)r   r   r   r*   r   r   r   r]   r]   i   s#            r   r]   c                   .    e Zd ZdZdZdZddZd Zd ZdS )ProcessStateEventz' Abstract class, never raised directly NTc                 b    || _         || _        || _        |                                 | _        d S r   )r%   
from_stateexpectedget_extra_valuesextra_values)r)   r%   rb   rc   s       r   r*   zProcessStateEvent.__init__r   s3    $  !1133r   c                    d}| j         j        | j         j        j        j        }d| j         j        j        fd|fdt	          | j                  fg}|                    | j                   d                    d |D                       }|S )Nr-   processnamer4   rb    c                 "    g | ]\  }}|d |S ):r   ).0r1   vals      r   
<listcomp>z-ProcessStateEvent.payload.<locals>.<listcomp>   s'    DDD+4444-DDDr   )	r%   r/   r0   r1   r   rb   extendre   join)r)   r4   Lss       r   r7   zProcessStateEvent.payloadz   s    	<)*16IT\056i8P6tGGHJ	"###HHDDDDDFFr   c                     g S r   r   rQ   s    r   rd   z"ProcessStateEvent.get_extra_values   s    	r   )T)	r   r   r   r   frmtor*   r7   rd   r   r   r   r`   r`   n   sV        11
C	B4 4 4 4      r   r`   c                       e Zd ZdS )ProcessStateFatalEventNrX   r   r   r   rv   rv      rY   r   rv   c                       e Zd ZdS )ProcessStateUnknownEventNrX   r   r   r   rx   rx      rY   r   rx   c                       e Zd Zd ZdS )"ProcessStateStartingOrBackoffEventc                 :    dt          | j        j                  fgS )Ntries)intr%   backoffrQ   s    r   rd   z3ProcessStateStartingOrBackoffEvent.get_extra_values   s    #dl233455r   Nr   r   r   rd   r   r   r   rz   rz      s#        6 6 6 6 6r   rz   c                       e Zd ZdS )ProcessStateBackoffEventNrX   r   r   r   r   r      rY   r   r   c                       e Zd ZdS )ProcessStateStartingEventNrX   r   r   r   r   r      rY   r   r   c                       e Zd Zd ZdS )ProcessStateExitedEventc                 J    dt          | j                  fd| j        j        fgS )Nrc   r&   )r}   rc   r%   r&   rQ   s    r   rd   z(ProcessStateExitedEvent.get_extra_values   s&    S//05$,:J2KLLr   Nr   r   r   r   r   r      s(        M M M M Mr   r   c                       e Zd Zd ZdS )ProcessStateRunningEventc                      d| j         j        fgS Nr&   r%   r&   rQ   s    r   rd   z)ProcessStateRunningEvent.get_extra_values       ()**r   Nr   r   r   r   r   r      #        + + + + +r   r   c                       e Zd Zd ZdS )ProcessStateStoppingEventc                      d| j         j        fgS r   r   rQ   s    r   rd   z*ProcessStateStoppingEvent.get_extra_values   r   r   Nr   r   r   r   r   r      r   r   r   c                       e Zd Zd ZdS )ProcessStateStoppedEventc                      d| j         j        fgS r   r   rQ   s    r   rd   z)ProcessStateStoppedEvent.get_extra_values   r   r   Nr   r   r   r   r   r      r   r   r   c                       e Zd Zd Zd ZdS )ProcessGroupEventc                     || _         d S r   r/   )r)   r/   s     r   r*   zProcessGroupEvent.__init__   s    


r   c                     d| j         z  S )Nzgroupname:%s
r   rQ   s    r   r7   zProcessGroupEvent.payload   s    $*,,r   NrR   r   r   r   r   r      s2          - - - - -r   r   c                       e Zd ZdS )ProcessGroupAddedEventNrX   r   r   r   r   r      rY   r   r   c                       e Zd ZdS )ProcessGroupRemovedEventNrX   r   r   r   r   r      rY   r   r   c                       e Zd ZdZd Zd ZdS )	TickEventr"   c                 "    || _         || _        d S r   )whensupervisord)r)   r   r   s      r   r*   zTickEvent.__init__   s    	&r   c                     d| j         z  S )Nzwhen:%s)r   rQ   s    r   r7   zTickEvent.payload   s    49$$r   N)r   r   r   r   r*   r7   r   r   r   r   r      s8        ' ' '% % % % %r   r   c                       e Zd ZdZdS )
Tick5Event   Nr   r   r   periodr   r   r   r   r      s        FFFr   r   c                       e Zd ZdZdS )Tick60Event<   Nr   r   r   r   r   r      s        FFFr   r   c                       e Zd ZdZdS )Tick3600Eventi  Nr   r   r   r   r   r      s        FFFr   r   c                   z    e Zd ZeZeZeZe	Z
eZeZeZeZeZeZeZeZeZeZeZ e!Z"e#Z$e%Z&e'Z(e)Z*e+Z,e-Z.e/Z0e1Z2e3Z4e5Z6e7Z8dS )
EventTypesN)9r   r   r   r   EVENTr`   PROCESS_STATEr   PROCESS_STATE_STOPPEDr   PROCESS_STATE_EXITEDr   PROCESS_STATE_STARTINGr   PROCESS_STATE_STOPPINGr   PROCESS_STATE_BACKOFFrv   PROCESS_STATE_FATALr   PROCESS_STATE_RUNNINGrx   PROCESS_STATE_UNKNOWNrB   PROCESS_COMMUNICATIONrI   PROCESS_COMMUNICATION_STDOUTrK   PROCESS_COMMUNICATION_STDERRr!   PROCESS_LOGr:   PROCESS_LOG_STDOUTr?   PROCESS_LOG_STDERRrM   REMOTE_COMMUNICATIONrT   SUPERVISOR_STATE_CHANGErW   SUPERVISOR_STATE_CHANGE_RUNNINGr[    SUPERVISOR_STATE_CHANGE_STOPPINGr   TICKr   TICK_5r   TICK_60r   	TICK_3600r   PROCESS_GROUPr   PROCESS_GROUP_ADDEDr   PROCESS_GROUP_REMOVEDr   r   r   r   r      s        E%M426640445#B #B !K..38&<#'>$DFGI%M04r   r   c                 ^    t           j                                        D ]\  }}|| u r|c S d S r   )r   __dict__items)	requestedr1   typs      r   getEventNameByTyper      sG    (..00  	c)KKK  r   c                 2    t          t          | |           d S r   )setattrr   )r1   r   s     r   registerr      s    Je$$$$$r   N)*supervisor.statesr   supervisor.compatr   r   r   r   r   r   r   r!   r:   r?   rB   rI   rK   rM   rT   rW   r[   r]   r`   rv   rx   rz   r   r   r   r   r   r   r   r   r   r   r   r   r   TICK_EVENTSr   r   r   r   r   r   <module>r      s   8 8 8 8 8 8 ' ' ' ' ' '	' ' '' ' '  
  	 	 	 	 	 	 	 	    e   2    O       O          2    &?       &?   6 6 6 6 6u 6 6 6       
	 	 	 	 	7 	 	 		 	 	 	 	8 	 	 	       
       2	 	 	 	 	. 	 	 		 	 	 	 	0 	 	 	6 6 6 6 6): 6 6 6	 	 	 	 	A 	 	 		 	 	 	 	 B 	 	 	M M M M M/ M M M+ + + + +0 + + ++ + + + + 1 + + ++ + + + +0 + + +- - - - - - - -	 	 	 	 	. 	 	 		 	 	 	 	0 	 	 	% % % % % % % %           )       I    K85 5 5 5 5 5 5 5:  
% % % % %r   