Edit File: web.cpython-36.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
Back to File Manager