| Server IP : 192.250.235.158 / Your IP : 216.73.216.4 Web Server : LiteSpeed System : Linux s4099.sgp1.stableserver.net 5.14.0-503.21.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Sun Jan 12 09:45:05 EST 2025 x86_64 User : vmxfzbqj ( 1905) PHP Version : 8.3.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /lib/python3.9/site-packages/supervisor/__pycache__/ |
Upload File : |
a
0�g�^ � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dlm Z d dlm
Z
d dlm Z d dlm Z d dlm
Z
d d lmZ d d
lmZ d d lmZ d d lmZ d d
lmZ d dlmZ d dlmZ d dlmZ d dlm Z d dl m Z d dl m Z d dl m Z d dl m!Z! d dl"m#Z# G dd� d�Z$G dd� d�Z%G dd � d �Z&G d d � d e&�Z'G d d � d e&�Z(G d!d"� d"�Z)d#e(d$�d%e'd$�de)d$�d&�Z*G d'd(� d(�Z+dS ))� N)�
templating)�urllib)�urlparse)�as_bytes)� as_string)�PY2)�unicode)� producers)� http_date)�
get_header)� collector)�
ProcessStates�� NOT_DONE_YET)�VERSION)�
make_namespec)�split_namespec)�SystemNamespaceRPCInterface)�RootRPCInterface)�Faults)�RPCError)� SupervisorNamespaceRPCInterfacec @ s6 e Zd ZdZe�dej�Zdd� Zdd� Z dd� Z
d S )
�DeferredWebProducerz� A medusa producer that implements a deferred callback; requires
a subclass of asynchat.async_chat that handles NOT_DONE_YET sentinel zConnection: (.*)c C s" || _ || _d| _t|j�| _d S )NF)�callback�request�finished�float�delay)�selfr r � r �2/usr/lib/python3.9/site-packages/supervisor/web.py�__init__( s z DeferredWebProducer.__init__c C sr | j r
dS z(| �� }|tu r"tW S d| _ | �|�W S t�� }| jjjj �
d|� d| _ | j� d� Y n0 d S )N� TzWeb interface errori� ) r r r � sendresponse� traceback�
format_excr �channelZserver�logger�log�error)r �response�tbr r r �more. s zDeferredWebProducer.morec
C s8 |� di �}|D ]}|| | j|< qd| jvr8d| jd< |� d�r\d| jd< | j�d� d S |� dd �}t|�| jd< | j�|� t| j| jj�}d}d}| jjd
kr�|d kr�| j� d�s�d }q�d
| jd< nd }n|| jjdk�r<|dkr�d }nLd| jv�rNd| jv �r | jd dk�s:d }n | jj
�r6d| jd< d }nd }n| jjd u �rNd }t � | j�
� �}|�rnd| jd< |�r�t �t �| jj��} t �|| g�} n`t�r�t| jj�dk�r�| jjd }t|t��r�t � |�| jjd< | jj�d|� t �| jj�} | jj�t �t �| | jj��� d | jj_|�r4| jj�� d S )N�headers� Content-Typez
text/plain�Locationr zContent-Lengthi- �bodyr" z1.0z
keep-alive� z
Keep-AliveZ
Connectionz1.1�closezTransfer-EncodingZchunked) �getr r) �len�pushr �
CONNECTION�header�versionZhas_keyZ use_chunkedr Zsimple_producerZbuild_reply_headerZchunked_producerZcomposite_producerZoutgoingr �
isinstancer �insertr& �push_with_producerZglobbing_producerZhooked_producerr( Zcurrent_requestZclose_when_done)
r r* r- r7 r0 Z
connectionZclose_itZwrap_in_chunkingZoutgoing_headerZoutgoing_producerr r r r# @ s�
�
�� ����
z DeferredWebProducer.sendresponseN) �__name__�
__module__� __qualname__�__doc__�re�compile�
IGNORECASEr6 r! r, r# r r r r r # s
r c @ s e Zd Zdd� ZdS )� ViewContextc K s | j �|� d S �N)�__dict__�update)r �kwr r r r! � s zViewContext.__init__N)r< r= r> r! r r r r rC � s rC c @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd S ) �MeldViewztext/html;charset=utf-8g �?c C sR || _ | j j}tj�|�s<tj�tj�t��}tj�||�}t �
|�| _ d | _ d S rD )
�context�template�os�path�isabs�abspath�dirname�__file__�joinr Z parse_xml�rootr )r rI rJ �herer r r r! � s zMeldView.__init__c C s\ | � � }|tu rtS | jj}|d }| j|d< d|d< d|d< t�d�|d< t|�|d< |S ) Nr- r. zno-cacheZPragmaz
Cache-Controlr ZExpiresr0 )�renderr rI r* � content_typer
Zbuild_http_dater )r r0 r* r- r r r �__call__� s
zMeldView.__call__c C s d S rD r �r r r r rT � s zMeldView.renderc C s
| j �� S rD )rR �clonerW r r r rX � s zMeldView.cloneN) r< r= r> rU r r! rV rT rX r r r r rH � s rH c @ s e Zd Zdd� ZdS )�TailViewc
C sN | j j}| j j}d|vr"d}d }n�|d }d}|�dd�}td|�� rRt|�d nd�}|sbd}nft|�}z|�|||�}W nJ t y� } z2|j
t j kr�d| }nd |j
|j
f }W Y d }~n
d }~0 0 | �� } | �d
�}
|
�d | � | �d �} | �|� | �d
�} |d u�r:| jdt�|�t�tt|���f d� n| �� t| �� �S )N� processnamezNo process name foundr �limitZ1024i ������zNo file for %sz#ERROR: unexpected rpc fault [%d] %s�titlez Supervisor tail of process %s�tailbody�refresh_anchorz!tail.html?processname=%s&limit=%s��href)rI � supervisord�formr3 �min�isdigit�intr ZreadProcessStdoutLogr �coder �NO_FILE�textrX �findmeld�content�
attributesr �quote�str�absZdeparentr �write_xhtmlstring)
r rb rc �tailrZ �offsetr[ � rpcinterface�erR r] r^ r_ r r r rT � sH �
�
��zTailView.renderN)r< r= r> rT r r r r rY � s rY c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�
StatusViewc C s� |� � }t�t|jjj|jj��}dd| d d�}dd| d d�}dd| d d�}dd | d d�}d
d | d d�}d
d| d d�} |tjkr�||||| g}
n2|tj tj
tj fv r�|d ||| g}
nd d ||| g}
|
S )NZStartz*index.html?processname=%s&action=start)�namera �targetZRestartz,index.html?processname=%s&action=restartZStopz)index.html?processname=%s&action=stopz Clear Logz-index.html?processname=%s&action=clearlogzTail -f Stdoutz
logtail/%sZ_blankzTail -f Stderrzlogtail/%s/stderr) Z get_stater rm r �group�configrv r
�RUNNINGZSTOPPEDZEXITED�FATAL) r �process�staterZ �start�restart�stop�clearlogZ tailf_stdoutZ tailf_stderr�actionsr r r �actions_for_process� sH �������
�z StatusView.actions_for_processc C s* |t jkrdS |t jt jfv r"dS dS d S )NZ
statusrunningZ statuserrorZ
statusnominal)r
rz r{ ZBACKOFF)r r} r r r �css_class_for_state s
z StatusView.css_class_for_statec
s� | j j}dt|�f}dt|g�f}t||g�}|�r�|dkrNdd� }d|_|S |dkrv|j�� ��fdd �}d|_|S |d
kr�|j� d d id d
ig���fdd�} d| _| S ��r��fdd�}
d|
_t
��\} } |j � | �}
|
d u r�|
S |
j
� | �}|d u �r|
S |dk�r z|j���� W n� t�y� } z�|jtjk�rBd�n`|jtjk�rVd�nL|jtjk�rjd�n8|jtjk�r~d�n$|jtjk�r�d�nd|j|jf ���fdd�}d|_|W Y d }~S d }~0 0 t� ��r� �fdd �}d|_|S �fd d �}d|_|S �n�|d k�r�z|j���� W nL t�yr } z2d|j|jf ��fd d!�}d|_|W Y d }~S d }~0 0 t� ��r�� �fd"d#�}d|_|S �fd$d%�}d|_|S n�|d&k�r|j� d'�gd(�d)�gd(�g�}t|��r�|���fd*d+�}d|_|S �fd,d-�}d|_|S n~|d.k�r�z|j����W nL t�y| } z2d|j|jf ��fd/d0�}d|_|W Y d }~S d }~0 0 �fd1d2�}d|_|S t|��d S )3N�
supervisor�systemZrefreshc S s dt �� } | S )NzPage refreshed at %s)�time�ctime)�messager r r � donothing/ s z+StatusView.make_callback.<locals>.donothingg�������?�stopallc s � � t u rt S dt�� S d S )NzAll stopped at %s�r r� r� r �r r r r� 7 s
z)StatusView.make_callback.<locals>.stopall�
restartall�
methodNamezsupervisor.stopAllProcessesz supervisor.startAllProcessesc s � � } | t u rt S dt�� S )NzAll restarted at %sr� )�resultr� r r r� C s z,StatusView.make_callback.<locals>.restartallc s d� S )NzNo such process named %sr r ��namespecr r �wrongL s z'StatusView.make_callback.<locals>.wrongr~ z no such filezfile not executablezalready started� spawn error�abnormal termination� unexpected rpc fault [%d] %sc s d�� f S )N�ERROR: Process %s: %sr r )�msgr� r r �starterrj s z*StatusView.make_callback.<locals>.starterrc
s� z
� � } W nd t yn } zL|jtjkr,d}n"|jtjkr>d}nd|j|jf }d�|f W Y d }~S d }~0 0 | tu r|tS d� S )Nr� r� r� r� �Process %s started)r rg r � SPAWN_ERROR�ABNORMAL_TERMINATIONri r )r� rt r� ��bool_or_callbackr� r r � startprocessp s
�"z.StatusView.make_callback.<locals>.startprocessc s d� S )Nr� r r r� r r � startdone� s z+StatusView.make_callback.<locals>.startdoner� c s � S rD r r �r� r r �stoperr� s z)StatusView.make_callback.<locals>.stoperrc
sT z
� � } W n4 t y> } z d|j|jf W Y d }~S d }~0 0 | tu rLtS d� S )Nr� �Process %s stopped)r rg ri r )r� rt r� r r � stopprocess� s
� z-StatusView.make_callback.<locals>.stopprocessc s d� S )Nr� r r r� r r �stopdone� s z*StatusView.make_callback.<locals>.stopdoner zsupervisor.stopProcess)r� �paramszsupervisor.startProcessc s � � } | t u rt S d� S �NzProcess %s restartedr )�results)r r� r r �restartprocess� s z0StatusView.make_callback.<locals>.restartprocessc s d� S r� r r r� r r � restartdone� s z-StatusView.make_callback.<locals>.restartdoner� c s � S rD r r r� r r �clearerr� s z*StatusView.make_callback.<locals>.clearerrc s d� S )NzLog for %s clearedr r r� r r r� � s z*StatusView.make_callback.<locals>.clearlog) rI rb r r r r r� ZstopAllProcessesr� Z multicallr �process_groupsr3 � processesZ startProcessr rg r rh ZNOT_EXECUTABLEZALREADY_STARTEDr� r� ri �callableZ stopProcessZclearProcessLogs�
ValueError)r r� �actionrb �mainr� rs r� r� r� r� Z
group_nameZ process_namerx r| rt r� r� r� r� r� r� Zresults_or_callbackr� r� r� r� r )r� r r� r� r �
make_callback" s�
��
��
�
����
� zStatusView.make_callbackc
C s | j j}| j j}|�d�}|�d�}|�d�}|r�| jsJ| �||�| _tS | �� }|tu r^tS |d ur�|d }|d dt�|� }||d d< | j j }t
d t |�fg�} g }
|j �
� D ]&} | j�� D ]} |
�| jj| f� q�q�|
�� g }
|
D ]X\}}| �|j | j| �}t||�}| j�|�}|
�|d
||||d |d d
�� q�| �� }|d u�rz|�d�}d|jd< |�|� |
�r�|�d�� |
�}d}|D �]*\}}|�d�}|�|d � � � | � |d �|jd< |�d�}|�|d � |�d�}t|d |d �}|j dt�|� d� |�|� |d }|�d �}|� |�D ]h\} } | �d �}| d u �rjd |jd< n>|j | d | d d � |�| d � | d! �rB|j | d! d"� �qB|�r�d#|jd< | }�q�n|�d$�} | � d%� |�d&��t!� t"t#j$�%� j&�} |�d'��| � t'|�(� �S )(NrZ r� r� �
SERVER_URL�/z ?message=%sr- r/ r� Z statenamer} � description)�statusrv rx r� r} r� Z
statusmessageZ
status_msg�class�trF� status_textr� � info_textZ name_anchorrx rv ztail.html?processname=%sr` r� �
actionitem_tdZactionitem_anchorZhiddenra )ra rv rw )rw ZshadeZ statustablezNo programs to manageZsupervisor_versionZcopyright_date))rI rc r* r3 r r� r r rm rb r r r� �valuesr� �keys�appendry rv �sortr� r r� ZgetProcessInforX rj Zattribrk �repeat�lowerr� rl �replacer rn �datetime�dateZtodayZyearr rp ) r rc r* rZ r� r� Z
server_url�locationrb rs Z processnamesrx Z gprocname�dataZ groupnamer� Z sent_name�inforR Z
statusarea�iteratorZ shaded_trZ
tr_element�itemr� r� �anchorr� Z
li_elementZ
actionitem�tableZcopyright_yearr r r rT � s�
� �� �
�
�
�
�
zStatusView.renderN)r< r= r> r� r� r� rT r r r r ru � s
+ .ru c @ s e Zd ZdZdd� Zdd� ZdS )�OKViewr c C s
|| _ d S rD )rI )r rI r r r r! 7 s zOKView.__init__c C s ddiS )Nr0 ZOKr rW r r r rV : s zOKView.__call__N)r< r= r> r r! rV r r r r r� 5 s r� zui/status.html)rJ �viewz ui/tail.html)�
index.htmlz tail.htmlzok.htmlc @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �supervisor_ui_handlerz&Supervisor Web UI HTTP Request Handlerc C s
|| _ d S rD )rb )r rb r r r r! P s z supervisor_ui_handler.__init__c C s^ |j dvrdS |�� \}}}}|�d�r6|dd � }q |s>d}t�� D ]}||krF dS qFd S )N)�POSTZGETFr� r1 r� T)�commandZ split_uri�
startswith�VIEWSr� )r r rL r� �query�fragmentZviewnamer r r �matchS s
zsupervisor_ui_handler.matchc C s( |j dkrt| |�|_n | �d|� d S )Nr� r" )r� r �continue_request)r r r r r �handle_requestc s
z$supervisor_ui_handler.handle_requestc C s i }|� � }|�|� d|vr&d|d< |d }t�|�}t�|�}|�� D ]\}} | d ||< qJ|D ]\}} | ||< qd|�� |d< |d }
|
r�|
d dkr�|
dd � }
q�|
s�d}
t�|
�} | d u r�d S d i i} | d
}
| d }t |||| | j
d �}|
|�}|j j }|t
||�� d S )
NZ QUERY_STRINGr" r r� Z PATH_INFOr� r1 r� r- r� rJ )rJ r rc r* rb )Zcgi_environmentrF r � parse_qsl�parse_qs�itemsZget_server_urlr� r3 rC rb r& r; r )r r� r rc Zcgi_envr� Zform_urlencodedZ
query_data�k�vrL Zviewinfor* Z viewclassZ viewtemplaterI r� Z pushproducerr r r r� i sB
�z&supervisor_ui_handler.continue_requestN)r< r= r> ZIDENTr! r� r� r� r r r r r� M s
r� ),rK r@ r� r$ r� r� r Zsupervisor.compatr r r r r r Zsupervisor.medusar Z supervisor.medusa.http_serverr
r Z supervisor.medusa.xmlrpc_handlerr Zsupervisor.processr
Zsupervisor.httpr Zsupervisor.optionsr r r Zsupervisor.xmlrpcr r r r Zsupervisor.rpcinterfacer r rC rH rY ru r� r� r� r r r r �<module> sX w". I
����