Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
mercurial
/
hgweb
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: 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# ��
Save
Cancel