File: //usr/lib/python3.6/site-packages/supervisor/__pycache__/web.cpython-36.opt-1.pyc
3
�k�`�^ � @ 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 dl
mZ d d lmZ d d
lmZ d d lmZ d d lmZ d d
lmZ d dlmZ d dlmZ d dlmZ 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_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 ZdZejdej�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 �/usr/lib/python3.6/web.py�__init__' s z DeferredWebProducer.__init__c C sn | j r
dS y$| j� }|tkr tS d| _ | j|�S tj� }| jjjj j
d|� d| _ | jj d� Y nX d S )N� TzWeb interface errori� ) r r r
� sendresponse� traceback�
format_excr �channelZserverZlogger�log�error)r �response�tbr r r �more- s
zDeferredWebProducer.morec
C s< |j di �}x|D ]}|| | j|< qW d| jkr<d| jd< |j d�r`d| jd< | jjd� d S |j dd �}t|�| jd< | jj|� t| j| jj�}d}d}| jjd
kr�|d kr�| jj d�s�d }q�d
| jd< nd }n|| jjdk�r@|dkr�d }nLd| jk�rRd| jk�r | jd dk�s>d }n | jj
�r:d| jd< d }nd }n| jjd k�rRd }t j | jj
� �}|�rrd| jd< |�r�t jt j| jj��} t j|| g�} n`t�r�t| jj�dk�r�| jjd }t|t��r�t j |�| jjd< | jjjd|� t j| jj�} | jjjt jt j| | jj��� d | jj_|�r8| jjj� d S )N�headersz 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* r3 r, Z
connectionZclose_itZwrap_in_chunkingZoutgoing_headerZoutgoing_producerr r r r! ? st
z DeferredWebProducer.sendresponseN) �__name__�
__module__� __qualname__�__doc__�re�compile�
IGNORECASEr2 r r) r! r r r r r " s
r c @ s e Zd Zdd� ZdS )� ViewContextc K s | j j|� d S )N)�__dict__�update)r �kwr r r r � s zViewContext.__init__N)r8 r9 r: r r r r r r? � s r? c @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd S ) �MeldViewztext/html;charset=utf-8g �?c C sR || _ | j j}tjj|�s<tjjtjjt��}tjj||�}t j
|�| _ d | _ d S )N)
�context�template�os�path�isabs�abspath�dirname�__file__�joinr Z parse_xml�rootr )r rD rE �herer r r r � s zMeldView.__init__c C s\ | j � }|tkrtS | jj}|d }| j|d< d|d< d|d< tjd�|d< t|�|d< |S ) Nr* z Content-Typezno-cacheZPragmaz
Cache-Controlr ZExpiresr, )�renderr
rD r' � content_typer Zbuild_http_dater )r r, r' r* r r r �__call__� s
zMeldView.__call__c C s d S )Nr )r r r r rO � s zMeldView.renderc C s
| j j� S )N)rM �clone)r r r r rR � s zMeldView.cloneN) r8 r9 r: rP r r rQ rO rR r r r r rC � s rC c @ s e Zd Zdd� ZdS )�TailViewc
C sL | j j}| j j}d|kr"d}d }n�|d }d}|jdd�}td|j� rRt|�d nd�}|sbd}ndt|�}y|j|||�}W nH t k
r� } z,|j
t j kr�d| }nd |j
|j
f }W Y d d }~X nX | j� } | jd
�}
|
jd | � | jd �} | j|� | jd
�} |d k �r8| jdtj|�tjtt|���f d� n| j� t| j� �S )N� processnamezNo process name foundr �limitZ1024i r- 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)�hrefi ������i ���)rD � supervisord�formr/ �min�isdigit�intr ZreadProcessStdoutLogr �coder �NO_FILE�textrR �findmeld�content�
attributesr �quote�str�absZdeparentr �write_xhtmlstring)
r r[ r\ �tailrT �offsetrU � rpcinterface�erM rV rW rX r r r rO � s@
$zTailView.renderN)r8 r9 r: rO r r r r rS � s rS c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�
StatusViewc C s� |j � }tjt|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 fkr�|d ||| g}
nd d ||| g}
|
S )NZStartz*index.html?processname=%s&action=start)�namerY �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 rf r �group�configro r �RUNNINGZSTOPPEDZEXITED�FATAL) r �process�staterT �start�restart�stop�clearlogZ tailf_stdoutZ tailf_stderr�actionsr r r �actions_for_process� s8
z StatusView.actions_for_processc C s* |t jkrdS |t jt jfkr"dS dS d S )NZ
statusrunningZ statuserrorZ
statusnominal)r rs rt ZBACKOFF)r rv 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|jj� ��fdd �}d|_|S |d
kr�|jj d d id d
ig���fdd�} d| _| S ��r|�fdd�}
d|
_t
��\} } |j j | �}
|
d kr�|
S |
j
j | �}|d k�r|
S |dk�ry|jj��� W n� tk
�r� } z�|jtjk�rDd�n`|jtjk�rXd�nL|jtjk�rld�n8|jtjk�r�d�n$|jtjk�r�d�nd|j|jf ���fdd�}d|_|S d }~X nX t� ��r� �fdd �}d|_|S �fd d �}d|_|S �nx|d k�r�y|jj��� W nD tk
�rb } z&d|j|jf ��fd d!�}d|_|S d }~X nX t� ��r�� �fd"d#�}d|_|S �fd$d%�}d|_|S n�|d&k�r|jj d'�gd(�d)�gd(�g�}t|��r�|���fd*d+�}d|_|S �fd,d-�}d|_|S nv|d.k�r|y|jj���W nD tk
�rd } z&d|j|jf ��fd/d0�}d|_|S d }~X nX �fd1d2�}d|_|S t|��d S )3N�
supervisor�systemZrefreshc S s dt j� } | S )NzPage refreshed at %s)�time�ctime)�messager r r � donothing. s z+StatusView.make_callback.<locals>.donothingg�������?�stopallc s � � t krt S dtj� S d S )NzAll stopped at %s)r
r� r� r )r r r r� 6 s
z)StatusView.make_callback.<locals>.stopall�
restartall�
methodNamezsupervisor.stopAllProcessesz supervisor.startAllProcessesc s � � } | t krt S dtj� S )NzAll restarted at %s)r
r� r� )�result)r r r r� B s z,StatusView.make_callback.<locals>.restartallc s d� S )NzNo such process named %sr r )�namespecr r �wrongK s z'StatusView.make_callback.<locals>.wrongrw z no such filezfile not executablezalready startedz spawn errorzabnormal terminationz unexpected rpc fault [%d] %sc s d�� f S )NzERROR: Process %s: %sr r )�msgr� r r �starterri s z*StatusView.make_callback.<locals>.starterrc s| y
� � } W n\ t k
rf } z@|jtjkr.d}n"|jtjkr@d}nd|j|jf }d�|f S d }~X nX | tkrttS d� S )Nz spawn errorzabnormal terminationz unexpected rpc fault [%d] %szERROR: Process %s: %szProcess %s started)r r` r � SPAWN_ERROR�ABNORMAL_TERMINATIONrb r
)r� rm r� )�bool_or_callbackr� r r � startprocesso s
z.StatusView.make_callback.<locals>.startprocessc s d� S )NzProcess %s startedr r )r� r r � startdone� s z+StatusView.make_callback.<locals>.startdonery c s � S )Nr r )r� r r �stoperr� s z)StatusView.make_callback.<locals>.stoperrc sL y
� � } W n, t k
r6 } zd|j|jf S d }~X nX | tkrDtS d� S )Nz unexpected rpc fault [%d] %szProcess %s stopped)r r` rb r
)r� rm )r� r� r r � stopprocess� s
z-StatusView.make_callback.<locals>.stopprocessc s d� S )NzProcess %s stoppedr r )r� r r �stopdone� s z*StatusView.make_callback.<locals>.stopdonerx zsupervisor.stopProcess)r� �paramszsupervisor.startProcessc s � � } | t krt S d� S )NzProcess %s restarted)r
)�results)r r� r r �restartprocess� s z0StatusView.make_callback.<locals>.restartprocessc s d� S )NzProcess %s restartedr r )r� r r � restartdone� s z-StatusView.make_callback.<locals>.restartdonerz c s � S )Nr r )r� r r �clearerr� s z*StatusView.make_callback.<locals>.clearerrc s d� S )NzLog for %s clearedr r )r� r r rz � s z*StatusView.make_callback.<locals>.clearlog) rD r[ r r r r r~ ZstopAllProcessesr Z multicallr �process_groupsr/ � processesZ startProcessr r` r ra ZNOT_EXECUTABLEZALREADY_STARTEDr� r� rb �callableZ stopProcessZclearProcessLogs�
ValueError)r r� �actionr[ �mainr rl r� r� r� r� Z
group_nameZ process_namerq ru rm r� r� r� r� r� r� Zresults_or_callbackr� r� r� rz r )r� r r� r� r �
make_callback! s�
zStatusView.make_callbackc C s. | j j}| j j}|jd�}|jd�}|jd�}|r�| jsJ| j||�| _tS | j� }|tkr^tS |d k r�|d }|d dtj|� }||d d< | j j }t
d t |�fg�} g }
x8|j j
� D ]*} x$| jj� D ]} |
j| jj| f� q�W q�W |
j� g }
x`|
D ]X\}}| j|j | j| �}t||�}| jj|�}|
j|d
||||d |d d
�� q�W | j� }|d k �r�|jd�}d|jd< |j|� |
�r�|jd�j |
�}d}�xN|D �].\}}|jd�}|j|d j � � | j |d �|jd< |jd�}|j|d � |jd�}t|d |d �}|j dtj|� d� |j|� |d }|jd �}xv|j |�D ]h\} } | jd �}| d k�r|d |jd< n>|j | d | d d � |j| d � | d! �rT|j | d! d"� �qTW |�r�d#|jd< | }�q�W n|jd$�} | j d%� |jd&�jt!� t"t#j$j%� j&�} |jd'�j| � t'|j(� �S )(NrT r� r� �
SERVER_URL�/z ?message=%sr* r+ r~ Z statenamerv � description)�statusro rq r{ rv r� Z
statusmessageZ
status_msg�classZtrF� status_textr� � info_textZ name_anchorrq ro ztail.html?processname=%s)rY r{ �
actionitem_tdZactionitem_anchorZhiddenrY )rY ro rp )rp ZshadeZ statustablezNo programs to manageZsupervisor_versionZcopyright_date))rD r\ r' r/ r r� r
r rf r[ r r r� �valuesr� �keys�appendrr ro �sortr| r r~ ZgetProcessInforR rc Zattribrd �repeat�lowerr} re �replacer rg �datetimeZdateZtodayZyearr ri ) r r\ r' rT r� r� Z
server_url�locationr[ rl Z processnamesrq Z gprocname�dataZ groupnamer{ Z sent_name�inforM Z
statusarea�iteratorZ shaded_trZ
tr_element�itemr� r� Zanchorr� Z
li_elementZ
actionitem�tableZcopyright_yearr r r rO � s�
zStatusView.renderN)r8 r9 r: r| r} r� rO r r r r rn � s
+ .rn c @ s e Zd ZdZdd� Zdd� ZdS )�OKViewr c C s
|| _ d S )N)rD )r rD r r r r 6 s zOKView.__init__c C s ddiS )Nr, ZOKr )r r r r rQ 9 s zOKView.__call__N)r8 r9 r: r r rQ r r r r r� 4 s r� zui/status.html)rE �viewz ui/tail.html)z
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 )N)r[ )r r[ r r r r O s z supervisor_ui_handler.__init__c C sd |j dkrdS |j� \}}}}x|jd�r8|dd � }q W |sBd}x tj� D ]}||krLdS qLW d S ) N�POST�GETFr� r- z
index.htmlT)r� r� )�commandZ split_uri�
startswith�VIEWSr� )r r rG r� �queryZfragmentZviewnamer r r �matchR s
zsupervisor_ui_handler.matchc C s( |j dkrt| |�|_n | jd|� d S )Nr� r )r� r �continue_request)r r r r r �handle_requestb s
z$supervisor_ui_handler.handle_requestc C s i }|j � }|j|� d|kr&d|d< |d }tj|�}tj|�}x |j� D ]\}} | d ||< qLW x|D ]\}} | ||< qjW |j� |d< |d }
x |
r�|
d dkr�|
dd � }
q�W |
s�d}
tj|
�} | d kr�d S d i i} | d
}
| d }t |||| | j
d �}|
|�}|j j }|t
||�� d S )
NZ QUERY_STRINGr r r� Z PATH_INFOr� r- z
index.htmlr* r� rE )rE r r\ r' r[ )Zcgi_environmentrA r Z parse_qslZparse_qs�itemsZget_server_urlr� r/ r? r[ r$ r7 r )r r� r r\ Zcgi_envr� Zform_urlencodedZ
query_data�k�vrG Zviewinfor' Z viewclassZ viewtemplaterD r� Z pushproducerr r r r� h s@
z&supervisor_ui_handler.continue_requestN)r8 r9 r: ZIDENTr r� r� r� r r r r r� L s
r� )+rF r< r� r" r� r~ r Zsupervisor.compatr 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 r? rC rS rn r� r� r� r r r r �<module> sN w". I