File: //usr/lib/python3.6/site-packages/supervisor/medusa/__pycache__/http_server.cpython-36.pyc
3
�k�`ss � @ sj d Z ddlZddlZddlZddlZddlmZ ddljj Z
ddl jj Z
ddljjZddljjZddljjZe j� d ZddlmZ yddlmZmZ W n$ ek
r� ddl mZmZ Y nX G dd� d�Z G d d
� d
e
j �Z G d d � d e
j �Z!d
d� Z"ej#dej$�Z%dd� Z&d(dd�Z'dd� Z(ej#d�Z)dd� Z*e+dk�rfe,ej-�dk �rbe.dej-d � �nddl/jj0Z0ddl1jj2Z2ddl3jj4Z4ddl5jj6Z6ddl7jj8Z8ddl9jj:Z:e:j;d �Z<ej=ej>�Z?e0j@d d d �ZAe2jBej-d �ZCe4j4eC�ZDe!d eEej-d �e<e?�ZFeFjGeD� e6j6e6jHej-d �d e<e?d!�ZIe8j8d d"�ZJd#ej-k�r^d$d%� ZKddlLZLeLjMd&d'� ne
jN� dS ))z>$Id: http_server.py,v 1.12 2004/04/21 15:11:44 akuchling Exp $� N)�as_bytes� )�counter)�unquote�
splitqueryc & @ sB e Zd ZdZe� ZdZdZdd� Zdd� Z dd � Z
d
d � Z d d
� Z dd� Z
dd� Zdd� Zdcdd�Zdd� Zdd� Zejd�Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zddd'd(�Z d)d*� Z e Z d+d,� Z d-d.� Z d/d0� Z!d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdV�%Z"dWj#de�Z$dadb� Z%dS )f� http_request�� � Nc G s^ |\| _ | _| _| _| _| _g | _dt tj t
j
� �d�| _ g | _ t
jj� | _d | _i | _d S )Nz Medusa/%s)ZServerZDate)�channel�request�command�uri�version�header�outgoing�VERSION_STRING� http_dateZbuild_http_date�time�
reply_headers� _http_request__reply_header_listr �request_counter� incrementZrequest_number�
_split_uri�
_header_cache)�self�args� r �!/usr/lib/python3.6/http_server.py�__init__9 s zhttp_request.__init__c C s || j |< d S )N)r )r �key�valuer r r � __setitem__P s zhttp_request.__setitem__c C s
| j | S )N)r )r r r r r � __getitem__S s zhttp_request.__getitem__c C s
|| j kS )N)r )r r r r r � __contains__V s zhttp_request.__contains__c C s
|| j kS )N)r )r r r r r �has_keyY s zhttp_request.has_keyc C s8 dd� | j j� D �}dj| j| j�g| �d }t|�S )Nc S s g | ] }d | �qS )z%s: %sr )�.0�itemr r r �
<listcomp>] s z3http_request.build_reply_header.<locals>.<listcomp>z
z
)r �items�join�response�
reply_coder )r Z header_items�resultr r r �build_reply_header\ s z http_request.build_reply_headerc C s | j j||f� dS )z$ Adds a header to the reply headers N)r �append)r �namer r r r �
add_headerm s zhttp_request.add_headerc C s | j j� g | jdd�< dS )z Clears the reply header list N)r �clearr )r r r r �
clear_headersq s
zhttp_request.clear_headersc C s� d}|| j kr0|dks$| j | |kr0| j |= d}g }|dk rZ||f| jkr�||fg}d}n*x(| jD ] }|d |krb|j|� d}qbW |s�|dkr�d| }n d||f }td| ��x|D ]}| jj|� q�W dS )z� Removes the specified header.
If a value is provided, the name and
value must match to remove the header.
If the value is None, removes all headers
with that name.r Nr z%sz%s: %szHeader '%s' not found)r r r. � LookupError�remove)r r/ r Zfound_itZremoved_headers�hZ search_valuer r r �
remove_headery s,
zhttp_request.remove_headerc C sX | j dd� }dd� |D �}x6| jj� D ](\}}||kr(|j||f� |j|� q(W |S )zP Get the tuple of headers that will be used
for generating reply headersNc S s g | ] \}}|�qS r r )r% �n�vr r r r' � s z2http_request.get_reply_headers.<locals>.<listcomp>)r r r( r. )r �
header_tuplesZ header_namesr7 r8 r r r �get_reply_headers� s z http_request.get_reply_headersc C s6 | j � }| j| j�g}|dd� |D �7 }dj|�d S )zE Gets the reply header (including status and
additional crlf)c S s g | ] }d | �qS )z%s: %sr )r% r5 r r r r' � s z6http_request.get_reply_header_text.<locals>.<listcomp>z
z
)r: r* r+ r) )r r9 �headersr r r �get_reply_header_text� s z"http_request.get_reply_header_textz#([^;?#]*)(;[^?#]*)?(\?[^#]*)?(#.*)?c C sD | j d kr>| jj| j�}|j� t| j�kr4td��n
|j� | _ | j S )Nz
Broken URI)r �
path_regex�matchr
�end�len�
ValueError�groups)r �mr r r � split_uri� s
zhttp_request.split_uric C s8 x2| j D ](}|j|�}|j� t|�kr|j|�S qW dS )N� )r r> r? r@ �group)r �head_regrF �linerC r r r �get_header_with_regex� s
z"http_request.get_header_with_regexc C sz |j � }| j}||krn|d }t|�}x:| jD ]0}|d |� j � |kr.||d � }|||< |S q.W d ||< d S || S d S )Nz: )�lowerr r@ r )r r Zhcr5 ZhlrH �rr r r �
get_header� s zhttp_request.get_headerc C s, | j r| j j|� n| jdt|� d� d S )Nz*Dropping %d bytes of incoming request data�warning)� collector�collect_incoming_data�log_infor@ )r �datar r r rO � s
z"http_request.collect_incoming_datac C s" | j r| j j� n | jdd� d S )Nz-Unexpected end-of-record for incoming requestrM )rN �found_terminatorrP )r r r r rR s
z http_request.found_terminatorc C s> t |t�rt|�}t |t�r.tj|t|�d�}| jj|� d S )N)� buffer_size) �
isinstance�strr �bytes� producers�simple_producerr@ r r. )r �thingr r r �push s
zhttp_request.pushc C s | j | }|| _d| j||f S )Nz
HTTP/%s %d %s)� responsesr+ r )r �code�messager r r r* s
zhttp_request.responsec C sR || _ | j| }| j||d� }t|�}t|�| d< d| d< | j|� | j� d S )N)r\ r] zContent-Lengthz text/htmlz Content-Type)r+ r[ �DEFAULT_ERROR_MESSAGEr r@ rZ �done)r r\ r] �sr r r �error s
zhttp_request.errorc C s< t t| j�j� }d}d}| jdkrH|dkrBd| kr8d}qFd| d< q�d}nb| jdkr�|d kr`d}q�d| kr�d
| kr�| d
d ks�d}q�| jr�d | d
< d}q�d}n| jd kr�d}tj| j� �}|r�d | d< |r�tj tj
| j ��}tj
||g�}n| j j d|� tj
| j �}| j
jtjtj|| j��� d | j
_|�r8| j
j� d S )
z;finalize this transaction - send output to the http channelr z1.0z
keep-alivezContent-Lengthr z
Keep-AliveZ
Connectionz1.1�closezTransfer-EncodingZchunkedN)rL �
CONNECTIONr rJ r � use_chunkedrW rX r< Zchunked_producer�composite_producerr �insertr
Zpush_with_producerZglobbing_producerZhooked_producer�log�current_request�close_when_done)r Z
connectionZclose_itZwrap_in_chunkingZoutgoing_headerZoutgoing_producerr r r r_ ( sP
zhttp_request.donec C s� t j|�}t jr |d r t j}nt j}|dkr4d}n
d}| }t|d�\}}t|d�\}}|rld||f }n d||f }t jd|�| S ) N� r r i �< z -%02d%02dz +%02d%02dz%d/%b/%Y:%H:%M:%S )r ZgmtimeZdaylightZaltzoneZtimezone�divmodZstrftime) r ZwhenZgmtZtz�negr5 ZremrC �offsetr r r �log_date_stringt s
z http_request.log_date_stringc C sB | j jjj| j jd d| j jd | jtj� �| j| j|f � d S )Nr z%d - - [%s] "%s" %d %d
r ) r
�server�loggerrg �addrro r r r+ )r rV r r r rg � s
zhttp_request.logZContinuezSwitching ProtocolsZOKZCreatedZAcceptedz Non-Authoritative Informationz
No Contentz
Reset ContentzPartial ContentzMultiple ChoiceszMoved PermanentlyzMoved Temporarilyz See Otherz Not Modifiedz Use Proxyz Bad RequestZ UnauthorizedzPayment RequiredZ Forbiddenz Not FoundzMethod Not AllowedzNot Acceptablez Proxy Authentication RequiredzRequest Time-outZConflictZGonezLength RequiredzPrecondition FailedzRequest Entity Too LargezRequest-URI Too LargezUnsupported Media TypezInternal Server ErrorzNot Implementedz Bad GatewayzService UnavailablezGateway Time-outzHTTP Version not supported)%�d �e r �� �� �� �� �� �� i, i- i. i/ i0 i1 i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� z
�<head>� <title>Error response</title>�</head>�<body>�<h1>Error response</h1>�<p>Error code %(code)d.�<p>Message: %(message)s.�</body>rE c C s d S )Nr )r �msg�levelr r r rP � s zhttp_request.log_info)N)r ) r{ r| r} r~ r r� r� r� rE )&�__name__�
__module__� __qualname__r+ r r rd rN r r! r" r# r$ r- r0 r2 r6 r: r< �re�compiler= rD rI rL rO rR rZ r* ra Z reply_nowr_ ro rg r[ r) r^ rP r r r r r & s�
(
L
r c @ s� e Zd Zd ZdZe� Zdd� Zdd� ZdZ d d
� Z
d d � Z d Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � ZdS )!� http_channelr � Nc C s` t jj� | _t� | _tjj| |� || _ || _
| j d� d| _ t
tj� �| _| j| _| j� d S )Ns
� )r� �channel_counterr �channel_numberr r �asynchat�
async_chatr rp rr Zset_terminator� in_buffer�intr Z
creation_time� last_used�check_maintenance)r rp �connrr r r r r � s
zhttp_channel.__init__c C s& t jj| �dd� }d|| j| jf S )Nr z <%s channel#: %s requests:%s>���)r� r� �__repr__r� r )r �arr r r r� � s
zhttp_channel.__repr__i� c C s | j | j s| j� d S )N)r� �maintenance_interval� maintenance)r r r r r� � s z http_channel.check_maintenancec C s | j � d S )N)� kill_zombies)r r r r r� � s zhttp_channel.maintenance� rk c C sL t tj� �}x:ttjj� �D ](}|j| jkr ||j |jkr |j � q W d S )N)
r� r �list�asyncoreZ
socket_map�values� __class__r� �zombie_timeoutrb )r Znowr
r r r r� � s
zhttp_channel.kill_zombiesc C s2 t jj| |�}| jjjt|�� ttj� �| _ |S )N)
r� r� �sendrp � bytes_outr r@ r� r r� )r rQ r, r r r r� s zhttp_channel.sendc C sV y2t jj| |�}| jjjt|�� ttj� �| _ |S t
k
rP t j d� Y nX d S )NzOut of Memory!)
r� r� �recvrp �bytes_inr r@ r� r r� � MemoryError�sys�exit)r rS r, r r r r� s zhttp_channel.recvc C s6 t j� d d� \}}|tkr&||��n tjj| � d S )Nr )r� �exc_info�
SystemExitr� r� � handle_error)r �tr8 r r r r� s
zhttp_channel.handle_errorc G s d S )Nr )r r r r r rg $ s zhttp_channel.logc C s$ | j r| j j|� n | j| | _d S )N)rh rO r� )r rQ r r r rO + s z"http_channel.collect_incoming_datac C s� | j r| j j� �n�| j}d| _|jd�}x |rH|d rH|dd � }q,W |sZ| j� d S |d }t|�\}}}t|dd � �}t|�\}}d|kr�|r�t|�d | }nt|�}t | |||||�} | j
j � | j j
j � |d k�r| jdt|� d� | jd � d S x�| j jD ]�}
|
j| ��ry| | _ |
j| � W nb | j jj � tj� \\} } }
}}}| jd
||| |
f d� y| jd � W n Y nX Y nX d S �qW | jd � d S )
Nr� s
r r �%�?zBad HTTP request: %sra i� z'Server Error: %s, %s: file: %s line: %si� i� )rh rR r� �splitri �
crack_request� join_headersr r r r r rp �total_requestsrP �reprra �handlersr> Zhandle_request�
exceptionsr� Zcompact_traceback)r r �linesr r r
r ZrpathZrqueryrK r5 �fileZfunrH r� r8 Ztbinfor r r rR 3 sT
z http_channel.found_terminatorc C s: | j r
dS t| j�r6| jj� }t|d�r2|j� S dS d S )Nr �stalled)Z
ac_out_bufferr@ Z
producer_fifo�first�hasattrr� )r �pr r r �writable_for_proxyz s
z http_channel.writable_for_proxyi i )r� r� r� Zac_out_buffer_sizerh r r� r r� r� r� r� r� r� r� r� r� rg rO rR r� r r r r r� � s"
Gr� c @ sd e Zd Zde ZeZddd�Zdd� Zdd� Z d d
� Z
d d � Z d
d� Z ddd�Z
dd� Zdd� ZdS )� http_serverzHTTP Server (V%s)Nc C sP || _ || _tjj| � | jtjtj� g | _ |s>t
j t j
�}| j� | j||f� | jd� | jj� \}}|s�| jdd� tjtj� �}ytj|�d | _W n( tjk
r� | jdd� || _Y nX || _t� | _t� | _t� | _ t� | _ t� | _ |�st
j t j
�}|�r t
j ||�| _
n t
j |�| _
| jdt!t"j#t"j"� �| j|f � d S )Ni zComputing default hostnamerM r zCannot do reverse lookupz2Medusa (V%s) started at %s
Hostname: %s
Port:%d
)$�ip�portr� �
dispatcherr Z
create_socket�socketZAF_INETZ SOCK_STREAMr� rq � file_loggerr� �stdoutZset_reuse_addrZbindZlistenZ getsocknamerP Z
gethostbynameZ gethostnameZ
gethostbyaddr� server_namera Z server_portr �
total_clientsr� r� r� r� Zresolving_loggerZunresolving_loggerr r Zctime)r r� r� �resolver�
logger_object�hostr r r r � sH
zhttp_server.__init__c C s dS )Nr r )r r r r �writable� s zhttp_server.writablec C s d S )Nr )r r r r � handle_read� s zhttp_server.handle_readc C s | j S )N)Z accepting)r r r r �readable� s zhttp_server.readablec C s d S )Nr )r r r r �handle_connect� s zhttp_server.handle_connectc C sn | j j� y| j� \}}W n@ tjk
r< | jdd� d S tk
rZ | jdd� d S X | j| ||� d S )Nz+warning: server accept() threw an exceptionrM z*warning: server accept() threw EWOULDBLOCK)r� r Zacceptr� ra rP � TypeError�
channel_class)r r� rr r r r �
handle_accept� s
zhttp_server.handle_acceptr c C s$ |r| j j|� n| j jd|� d S )Nr )r� r. rf )r �handlerZbackr r r �install_handler� s zhttp_server.install_handlerc C s | j j|� d S )N)r� r4 )r r� r r r �remove_handler� s zhttp_server.remove_handlerc s� ddl m� � fdd�}dd� tt| j�D �}| jrN| jj� t| jj� � }nd}t j
t j d| j d | j
d
| j d | j d | j d
| d|| jj� � d|| jj� � d| j dg
�g| t jd�g �S )Nr )�
english_bytesc s dj � | ��S )NrE )r) )r7 )r� r r �
nice_bytes� s z&http_server.status.<locals>.nice_bytesc S s g | ] }|r|�qS r r )r% Z_fr r r r' � s z&http_server.status.<locals>.<listcomp>g z <h2>%s</h2>z!<br>Listening on: <b>Host:</b> %sz<b>Port:</b> %dz#<p><ul><li>Total <b>Clients:</b> %sz<b>Requests:</b> %sz <b>Requests/Client:</b> %.1fz <li>Total <b>Bytes In:</b> %sz<b>Bytes Out:</b> %sz <li>Total <b>Exceptions:</b> %sz!</ul><p><b>Extension List</b><ul>z</ul>)Zsupervisor.medusa.utilr� �map� maybe_statusr� r� r� Zas_long�floatrW re Zlines_producer� SERVER_IDENTr� r� r� r� r� rX )r r� Z
handler_statsZratior )r� r �status� s zhttp_server.status)NN)r )r� r� r� r r� r� r� r r� r� r� r� r� r� r� r� r r r r r� � s
6
r� c C s t | d�r| j� S d S d S )Nr� )r� r� )rY r r r r� s
r� zConnection: (.*)c C sZ g }xPt t| ��D ]@}| | d dkrD|d | | dd � |d< q|j| | � qW |S )Nr z r r� r� )�ranger@ r. )r; rK �ir r r r� s r� r c C s: x4|D ],}| j |�}|r|j� t|�kr|j|�S qW dS )NrE )r> r? r@ rF )rG r� rF rH rC r r r rL $ s
rL c C s4 x.|D ]&}| j |�}|r|j� t|�kr|S qW dS )NrE )r> r? r@ )rG r� rH rC r r r �get_header_match+ s
r� z%([^ ]+) ([^ ]+)(( HTTP/([0-9.]+))$|$)c C sV t j| �}|rN|j� t| �krN|jd�r4|jd�}nd }|jd�|jd�|fS dS d S )N� � r r )NNN)�REQUESTr> r? r@ rF )rK rC r r r r r� 4 s
r� �__main__zusage: %s <root> <port>z 127.0.0.1Zfnordi' rE iU )r� r� r� ia z-pc C s& y t j� W n tk
r Y nX d S )N)r� �loop�KeyboardInterruptr r r r � profile_loopX s r� zprofile_loop()z profile.out)r )OZRCS_IDr� r� r� r Zsupervisor.compatr Z supervisor.medusa.asyncore_25ZmedusaZ asyncore_25r� Z supervisor.medusa.asynchat_25Z asynchat_25r� Zsupervisor.medusa.http_dater Zsupervisor.medusa.producersrW Zsupervisor.medusa.loggerrq r� r Zsupervisor.medusa.counterr Zurllibr r � ImportErrorZ urllib.parser r� r� r� r� r� r� �
IGNORECASErc r� rL r� r� r� r� r@ �argv�printZsupervisor.medusa.monitorZmonitorZsupervisor.medusa.filesysZfilesysZ!supervisor.medusa.default_handlerZdefault_handlerZ supervisor.medusa.ftp_serverZ
ftp_serverZ supervisor.medusa.chat_serverZ chat_serverZsupervisor.medusa.resolverr� Zcaching_resolverZrsr� r� ZlgZsecure_monitor_serverZmsZ
os_filesystemZfsZdhr� Zhsr� Zdummy_authorizerZftpZcsr� ZprofileZrunr� r r r r �<module> st / =