File: //usr/lib/python3/dist-packages/mercurial/hgweb/__pycache__/server.cpython-310.pyc
o
�]Lb 7 � @ sn d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZ ddl
m Z ddl m
Z
mZ ddlmZmZm Z mZ ddlmZ ejZejZejZejZdd lmZ d
d � ZG d d
� d
e �Z G dd� dej �Z G dd� de �Z z
d dl!Z!e!�"� ej#Z$W n e%y� e�&ed�r�ej'Z$nG dd� de �Z$Y nw dd� Z(G dd� de$eje �Z)G dd� de)�Z*dd � Z+dS ) � )�absolute_importN� )�_)�getattr�open)�encoding�error�pycompat�util)�urlutil� )�commonc C s2 d| v r
| � dd�\}}n| d}}t�|�|fS )z�Return path and query that has been split from uri
Just like CGI environment, the path is unquoted, the query is
not.
�?r � )�split�urlreq�unquote)�uri�path�query� r �8/usr/lib/python3/dist-packages/mercurial/hgweb/server.py� _splitURI+ s
r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�
_error_loggerc C s
|| _ d S �N)�handler)�selfr r r r �__init__9 s
z_error_logger.__init__c C s d S r r �r r r r �flush< s z_error_logger.flushc C s | � |�d�� d S )N�
)�
writelinesr )r �strr r r �write? s z_error_logger.writec C s" |D ] }| j �dt�|�� qd S )Nz
HG error: %s)r � log_errorr � strfromlocal)r �seq�msgr r r r! B s �z_error_logger.writelinesN)�__name__�
__module__� __qualname__r r r# r! r r r r r 8 s
r c @ s� e Zd ZdZedd� �Zdd� Zdd� Zdd � Zd
d � Z d$d
d�Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd%d d �Zd d � Zd d!� Zd"d#� ZdS )&�_httprequesthandlers httpc C s dS )z*Prepare .socket of new HTTPServer instanceNr )�
httpserver�uir r r �preparehttpserverK s z%_httprequesthandler.preparehttpserverc O s$ d| _ tjj| g|�R i |�� d S )N�HTTP/1.1)�protocol_version�
httpservermod�basehttprequesthandlerr )r �args�kargsr r r r O s z _httprequesthandler.__init__c G s8 |� t�d| jd | �� || f �d � |�� d S )Nz%s - - [%s] %sr r )r# r �sysbytes�client_address�log_date_time_stringr )r �fp�formatr3 r r r �_log_anyS s ����� z _httprequesthandler._log_anyc G � | j | jj|g|�R � d S r )r: �server�errorlog�r r9 r3 r r r r$ a � z _httprequesthandler.log_errorc G r; r )r: r< � accesslogr> r r r � log_messaged r? z _httprequesthandler.log_message�-c C sX g }t �| d�rdd� | j�� D �}| �d| jt|�t|�d�dd� t|�D ��� d S )Ns headersc S s g | ] }|d � d�r|�qS )r zx-)�
startswith��.0�hr r r �
<listcomp>j s
��z3_httprequesthandler.log_request.<locals>.<listcomp>z "%s" %s %s%sr c S s g | ]}d | �qS )z %s:%sr rD r r r rG r s ) r
� safehasattr�headers�itemsrA � requestliner" �join�sorted)r �code�size�xheadersr r r � log_requestg s ��z _httprequesthandler.log_requestc
C sF z| � � W d S tjy" } z|jtjkr� W Y d }~d S d }~ww r )�do_hgweb�socketr �errno�EPIPE)r �instr r r �do_writeu s ���z _httprequesthandler.do_writec
C s� z| � � W d S tyN } z;t|ttjf�r |jtjks4d�t j
t � � � �}t
d�}| �d| j||� | �dg � | �d� | �� W Y d }~d S d }~ww )Nr �
z6Exception happened during processing request '%s':%s%sz500 Internal Server Errors Internal Server Error)rW � Exception�
isinstance�OSErrorrS r rT �
ECONNRESETrL � traceback�format_exception�sys�exc_info�chrr$ r �_start_response�_write�_done)r �e�tb�newliner r r �do_POST| s& � �
��z_httprequesthandler.do_POSTc C � | � � d S r �rh r r r r �do_PUT� � z_httprequesthandler.do_PUTc C ri r rj r r r r �do_GET� rl z_httprequesthandler.do_GETc C s� d| _ t| j�\}}|| jjkr9|�| jjd �s9| �t�t �
d��g � | j dkr.dg| _ | �
d� | �� d S i }d|d< | j |d < | jj|d
< t| jj�|d < | j|d < t�| jj�|d
< t�|t| jj�d � �|d< | jd |d< | jd |d< |p�d|d< tjr�| j�� d u r�| j�� |d< n| j�� |d< | j�d�}n| jjd u r�| jj|d< n| jj|d< | j� d�}|r�||d< dd� | j� � D �D ] }d|� dd�� � }| j�|�}|� d d�� � }|r�|||< q�| j!|d < d |d < t�| j"�|d < |�d!d"��#� d#k�rt �$| j%| j&j'�| _%| j%|d$< t(| �|d%< t)| jt*j+�|d&< t,�-t*d'��r8t)| jt*j.�|d(< nd|d(< d|d)< t/j0�1|� d | _2g | _ d | _3d | _4| j�5|| j�D ]}| �
|� �qZ| j �sk| �6� | �� d S )*NF� /i� �POST)�
Connection�Closes Not FoundzCGI/1.1�GATEWAY_INTERFACE�REQUEST_METHOD� SERVER_NAME� SERVER_PORT� REQUEST_URI� SCRIPT_NAME� PATH_INFOr � REMOTE_HOST� REMOTE_ADDRr � QUERY_STRING� CONTENT_TYPE�content-length�CONTENT_LENGTHc S s g | ]
}|� � d vr|�qS ))z content-typer} ��lowerrD r r r rG � s
�z0_httprequesthandler.do_hgweb.<locals>.<listcomp>�HTTP_rB r �
�SERVER_PROTOCOL)r r z wsgi.versionzwsgi.url_scheme� HTTP_EXPECT� s 100-continuez
wsgi.inputz wsgi.errorszwsgi.multithreads ForkingMixInzwsgi.multiprocessz
wsgi.run_once)7� sent_headersr r r< �prefixrC rb r �strurlr
�
statusmessage�command�
saved_headersrc rd � server_namer" � server_port�sysstr�lenr6 �ispy3rI �get_content_type�get_default_type�get�
typeheader�type� getheader�keys�replace�upper�strip�request_version�
url_schemer� �continuereader�rfile�wfiler# r rZ � socketserver�ThreadingMixInr
rH � ForkingMixIn�wsgiref�validate�
check_environ� saved_status�length�_chunked� application� send_headers) r r r �envr� �header�hkey�hval�chunkr r r rR � s�
�
� �
�
� z _httprequesthandler.do_hgwebc C s� | j std��| j �d d�}t|d �|d< | j|� d | _d| _| jD ]}| j|� |d � � dkr:t|d �| _q$| jd u ra|d t
j kra| j oO| j
dk| _| jr[| �dd� n| �d d
� | �� d | _d S ) Ns. Sending headers before start_response() calledr r Fr} r/ zTransfer-Encoding�chunkedrp �closeT)r� �AssertionErrorr �int�
send_responser� r� r� � send_headerr� r
�HTTP_NOT_MODIFIED�close_connectionr� � end_headersr� )r r� rF r r r r� � s, �
��
z _httprequesthandler.send_headersNc sJ t |t�sJ �|�d d�\}}t|�}|| _d� � fdd�|D �| _| jS )Nr )�
connectionztransfer-encodingc s g | ] }|d � � � vr|�qS )r r rD �� bad_headersr r rG s z7_httprequesthandler._start_response.<locals>.<listcomp>)rZ r" r r� r� r� rc )r � http_statusrI r` rN r' r r� r rb s
�z#_httprequesthandler._start_responsec C s� | j std��| js| �� | jd ur't|�| jkr td��| jt|� | _n
| jr4|r4dt|�|f }| j�|� | j� � d S )Ns+ data written before start_response() calledsL Content-length header sent, but more bytes than specified are being written.s %x
%s
)
r� r� r� r� r� r� r� r� r# r )r �datar r r rc s
�
z_httprequesthandler._writec C s$ | j r| j�d� | j�� d S d S )Ns 0
)r� r� r# r r r r r rd * s �z_httprequesthandler._donec C s" | j jr t�| j j�S tj�| �S r )r< � serverheaderr r% r1 r2 �version_stringr r r r r� / s z"_httprequesthandler.version_string)rB rB r )r( r) r* r� � staticmethodr. r r: r$ rA rQ rW rh rk rm rR r� rb rc rd r� r r r r r+ G s&
X
r+ c @ s( e Zd ZdZdZedd� �Zdd� ZdS )�_httprequesthandlersslz*HTTPS handler based on Python's ssl modules httpsc C st z ddl m} |j W n ty t�td���w |�dd�}|�dd�}|�dd�}|j| j ||||d �| _ d S )
Nr )�sslutils SSL support is unavailable� web� certificates devels servercafiles serverrequirecert)�certfile�cafile�requireclientcert)
r r� �wrapserversocket� ImportErrorr �Abortr �config�
configboolrS )r, r- r� r� r� �reqcertr r r r. : s
� �z(_httprequesthandlerssl.preparehttpserverc C s0 | j | _| j �d| j�| _| j �d| j�| _d S )N�rb�wb)�requestr� �makefile�rbufsizer� �wbufsizer� r r r r �setupR s z _httprequesthandlerssl.setupN)r( r) r* �__doc__r� r� r. r� r r r r r� 5 s
r� s forkc @ s e Zd ZdS )�_mixinN)r( r) r* r r r r r� b s r� c C s | r | dkr t | d�S |S )N� -s ab)r )�opt�defaultr r r �openlogf s
r� c @ s e Zd Zejr dZdd� ZdS )�MercurialHTTPServerr c K s� t jj| ||fi |�� d| _|| _|�| |� |�dd�}|r'd|�d� }|| _t |�dd�|j
�}t |�dd�|j �}|| _ || _
| j�� dd� \| _| _| j| _|�dd �| _d S )
NTr� s prefixrn s accesslogs errorlogr r s
server-header)r1 r, r �daemon_threadsr� r. r� r� r� r� �fout�ferrr@ r= rS � getsockname�addr�portr� �fqaddrr� ) r r- �appr� r �kwargsr� �alog�elogr r r r r s z MercurialHTTPServer.__init__N)r( r) r* r � iswindows�allow_reuse_addressr r r r r r� l s r� c s( e Zd Zeedd�Z� fdd�Z� ZS )�IPv6HTTPServer�AF_INET6Nc s2 | j d u r t�td���tt| �j|i |�� d S )Ns$ IPv6 is not available on this system)�address_familyr � RepoErrorr �superr� r )r r3 r� �� __class__r r r � s
zIPv6HTTPServer.__init__)r( r) r* r rS r� r �
__classcell__r r r� r r� � s r� c C s | � dd�r t}nt}| �dd�rt}nt}z
dd l}|�� W n3 tyS t j
zt � t � W n
t
y> t t � Y nw t �� }t �d� |�� t �|� Y nw | � dd�}t�| � dd��}z
|| |||f|�W S tjy� } zt�td�||t�|jd �f ��d }~ww )
Nr� r� s ipv6r s latin1s addresss ports" cannot start server at '%s:%d': %sr )r� r� r+ r� r� r� � mimetypes�init�UnicodeDecodeErrorr_ �argv� importlib�reload�AttributeError�getdefaultencoding�setdefaultencodingr �getportrS r r� r r �
strtolocalr3 ) r- r� r �clsr� �oldenc�addressr� rV r r r �
create_server� sB �
� ����r� ),�
__future__r rT r� �osrS r_ r] �wsgiref.validater� �i18nr r r r r r r r
�utilsr r, r1 r� �urlerrr r
r �objectr r2 r+ r� � threading� active_countr� r� r� rH r� r� r� r� r� r r r r �<module> sH
o#
��