| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.9/site-packages/mercurial/hgweb/__pycache__/ |
Upload File : |
a
�+�b 7 � @ sr 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 zd dl!Z!e!�"� ej#Z$W n: e%�y6 e�&ed��r"ej'Z$nG dd� de �Z$Y n0 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)Zuri�path�query� r �</usr/lib64/python3.9/site-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)Zprotocol_version�
httpservermod�basehttprequesthandlerr )r �argsZkargsr 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 Zsysbytes�client_addressZlog_date_time_stringr )r �fp�formatr1 r r r �_log_anyS s ����� z _httprequesthandler._log_anyc G s | j | jj|g|�R � d S r )r5 �server�errorlog�r r4 r1 r r r r# a s z _httprequesthandler.log_errorc G s | j | jj|g|�R � d S r )r5 r6 � accesslogr8 r r r � log_messaged s z _httprequesthandler.log_message�-c C sX g }t �| d�r$dd� | 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 r= r r r r@ r � ) r
� safehasattr�headers�itemsr: Z requestliner! �join�sorted)r �code�sizeZxheadersr r r � log_requestg s ��z _httprequesthandler.log_requestc
C sF z | � � W n4 tjy@ } z|jtjkr,� W Y d }~n
d }~0 0 d S r )�do_hgweb�socketr �errnoZEPIPE)r �instr r r �do_writeu s
z _httprequesthandler.do_writec
C s� z | � � W n� ty� } ztt|ttjf�r8|jtjksfd�t j
t � � � �}t
d�}| �d| j||� | �dg � | �d� | �� W Y d }~n
d }~0 0 d S )Nr �
z6Exception happened during processing request '%s':%s%sz500 Internal Server Errors Internal Server Error)rN � Exception�
isinstance�OSErrorrK r rL Z
ECONNRESETrE � 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 s | � � d S r �r^ r r r r �do_PUT� s z_httprequesthandler.do_PUTc C s | � � d S r r_ r r r r �do_GET� s z_httprequesthandler.do_GETc C s� d| _ t| j�\}}|| jjkrr|�| jjd �sr| �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< |�pd|d< tj�rL| j�� d u �r0| j�� |d< n| j�� |d< | j�d�}n4| jjd u �rh| jj|d< n | jj|d< | j� d�}|�r�||d< dd� | j� � D �D ]D}d|� dd�� � }| j�|�}|� d d�� � }|�r�|||< �q�| j!|d < d |d < t�| j"�|d < |�d!d"��#� d#k�r4t �$| j%| j&j'�| _%| j%|d$< t(| �|d%< t)| jt*j+�|d&< t,�-t*d'��r~t)| jt*j.�|d(< nd|d(< d|d)< t/j0�1|� d | _2g | _ d | _3d | _4| j�5|| j�D ]}| �
|� �q�| j �s�| �6� | �� d S )*NF� /i� ZPOST)�
ConnectionZCloses Not FoundzCGI/1.1ZGATEWAY_INTERFACEZREQUEST_METHODZ SERVER_NAMEZ SERVER_PORTZ REQUEST_URIZ SCRIPT_NAMEZ PATH_INFOr Z REMOTE_HOSTZ REMOTE_ADDRr Z QUERY_STRINGZ CONTENT_TYPE�content-lengthZCONTENT_LENGTHc S s g | ]}|� � d vr|�qS ))z content-typerd ��lowerr= r r r r@ � s �z0_httprequesthandler.do_hgweb.<locals>.<listcomp>ZHTTP_r; r �
ZSERVER_PROTOCOL)r r z wsgi.versionzwsgi.url_schemeZ HTTP_EXPECTrA s 100-continuez
wsgi.inputz wsgi.errorszwsgi.multithreads ForkingMixInzwsgi.multiprocessz
wsgi.run_once)7� sent_headersr r r6 �prefixr< rX r Zstrurlr
Z
statusmessageZcommand�
saved_headersrY rZ � server_namer! Z server_portZsysstr�lenr2 Zispy3rC Zget_content_typeZget_default_type�getZ
typeheader�typeZ getheader�keys�replace�upper�strip�request_version�
url_schemerf Zcontinuereader�rfile�wfiler" r rQ � socketserver�ThreadingMixInr
rB � ForkingMixIn�wsgirefZvalidateZ
check_environ� saved_status�length�_chunked� application� send_headers) r r r �envr| �header�hkeyZhval�chunkr r r rJ � s�
�
�
��
z _httprequesthandler.do_hgwebc C s� | j std��| j �d d�}t|d �|d< | j|� d | _d| _| jD ],}| j|� |d � � dkrHt|d �| _qH| jd u r�|d t
j kr�| j o�| j
dk| _| jr�| �dd� n | �d d
� | �� d | _d S ) Ns. Sending headers before start_response() calledr r Frd r. zTransfer-EncodingZchunkedrc �closeT)r{ �AssertionErrorr �intZ
send_responser| r} rj Z send_headerrf r
ZHTTP_NOT_MODIFIEDZclose_connectionrs Z end_headersrh )r r{ r? r r r r � s* �
� z _httprequesthandler.send_headersNc s< |� d d�\}}t|�}|| _d� � fdd�|D �| _| jS )Nr )�
connectionztransfer-encodingc s g | ]}|d � � � vr|�qS )r re r= �Z bad_headersr r r@ s z7_httprequesthandler._start_response.<locals>.<listcomp>)r r� r{ rj rY )r Z http_statusrC rV rG r& r r� r rX s
�z#_httprequesthandler._start_responsec C s� | j std��n| js | �� | jd urPt|�| jkr>td��| jt|� | _n| jrj|rjdt|�|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� rh r r| rl r} rv r" r )r �datar r r rY s
�
z_httprequesthandler._writec C s | j r | j�d� | j�� d S )Ns 0
)r} rv r" r r r r r rZ * s z_httprequesthandler._donec C s" | j jrt�| j j�S tj�| �S r )r6 � serverheaderr r$ r/ r0 �version_stringr r r r r� / s z"_httprequesthandler.version_string)r; r; )N)r' r( r) rt � staticmethodr- r r5 r# r: rI rN r^ r` ra rJ r rX rY rZ 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 sx zddl m} |j W n ty6 t�td���Y n0 |�dd�}|�dd�}|�dd�}|j| j ||||d �| _ d S )
Nr )�sslutils SSL support is unavailable� web� certificates devels servercafiles serverrequirecert)�certfile�cafileZrequireclientcert)
r r� Zwrapserversocket� ImportErrorr �Abortr �config�
configboolrK )r+ r, r� r� r� Zreqcertr r r r- : s
�z(_httprequesthandlerssl.preparehttpserverc C s0 | j | _| j �d| j�| _| j �d| j�| _d S )N�rb�wb)Zrequestr� ZmakefileZrbufsizeru Zwbufsizerv r r r r �setupR s z _httprequesthandlerssl.setupN)r' r( r) �__doc__rt 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| dkrt | d�S |S )N� -s ab)r )�opt�defaultr r r �openlogf s
r� c @ s e Zd ZejrdZdd� ZdS )�MercurialHTTPServerr c K s� t jj| ||fi |�� d| _|| _|�| |� |�dd�}|rNd|�d� }|| _t |�dd�|j
�}t |�dd�|j �}|| _ || _
| j�� dd� \| _| _| j| _|�dd �| _d S )
NTr� s prefixrb s accesslogs errorlogr r s
server-header)r/ r+ r Zdaemon_threadsr~ r- r� rr ri r� ZfoutZferrr9 r7 rK Z getsockname�addr�portrk Zfqaddrr� ) r r, �appr� r �kwargsri ZalogZelogr r r r r s z MercurialHTTPServer.__init__N)r' r( r) r Z iswindowsZallow_reuse_addressr r r r r r� l s r� c s( e Zd Zeedd�Z� fdd�Z� ZS )�IPv6HTTPServerZAF_INET6Nc s2 | j d u rt�td���tt| �j|i |�� d S )Ns$ IPv6 is not available on this system)�address_familyr Z RepoErrorr �superr� r )r r1 r� �� __class__r r r � s
zIPv6HTTPServer.__init__)r' r( r) r rK r� r �
__classcell__r r r� r r� � s r� c C s, | � dd�rt}nt}| �dd�r(t}nt}zdd l}|�� W nf ty� t j
zt � t � W n t
y| t t � Y n0 t �� }t �d� |�� t �|� Y n0 | � dd�}t�| � dd��}z|| |||f|�W S tj�y& } z0t�td�||t�|jd �f ��W Y d }~n
d }~0 0 d S )
Nr� r� s ipv6r s latin1s addresss ports" cannot start server at '%s:%d': %sr )r� r� r* r� r� r� � mimetypes�init�UnicodeDecodeErrorrU �argv� importlib�reload�AttributeError�getdefaultencodingZsetdefaultencodingr ZgetportrK r r� r r Z
strtolocalr1 ) r, r� r �clsr� ZoldencZaddressr� rM r r r �
create_server� s:
��r� ),Z
__future__r rL r� �osrK rU rS Zwsgiref.validaterz Zi18nr r r r r r r r
Zutilsr r+ r/ rw Zurlerrr r
r �objectr r0 r* r� � threading� active_countrx r� r� rB ry r� r� r� r� r r r r �<module> sB
o#