| 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/__pycache__/ |
Upload File : |
a
�+�bZ � @ s� d dl mZ d dlZd dlZd dlZddlmZ ddlmZm Z m
Z m Z m
Z
mZmZmZ ddlmZmZ ejZejZejZejZd.dd�ZG d d
� d
e�ZG d d � d ej�Zd
d� Z e� ed�Z G dd� de j �Z
dd� Z dd� Z!G dd� de j"�Z#G dd� de j �Z$G dd� de#�Z%e �rDG d d � d e j �Z&G d d � d e j'ej(�Z(G d d!� d!ej)�Z)G d"d#� d#ej*�Z*G d$d%� d%ej+�Z,g Z-d/d(d)�Z.d0d*d+�Z/d,d-� Z0dS )1� )�absolute_importN� )�_)�encoding�error�httpconnection� keepalive�pycompat�sslutil� urllibcompat�util)�
stringutil�urlutilc C s8 | � dd�} | � dd�} | � dd�} |r4| � dd�} | S ) a1 Replace special characters "&", "<" and ">" to HTML-safe sequences.
If the optional flag quote is true, the quotation mark character (")
is also translated.
This is the same as cgi.escape in Python, but always operates on
bytes, whereas cgi.escape in Python 3 only works on unicodes.
� &s &� <s <� >s >� "s ")�replace)�s�quote� r �3/usr/lib64/python3.9/site-packages/mercurial/url.py�escape& s r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) � passwordmgrc C s || _ || _d S �N)�ui�passwddb)�selfr r r r r �__init__7 s zpasswordmgr.__init__c C s | j �||||�S r )r � add_password)r �realmZuri�user�passwdr r r r ; s zpasswordmgr.add_passwordc
C s� t |td �tf�sJ �t |t�s$J �| j�||�}|\}}t�|�t�|� }}|rx|rx| �||� t�|�t�|�fS |r�|s�t �
| j ||�}|r�|\}}|� d�|� d� }}| j �
d| � |r�|�s�t�t�|��} d | _| j �� �s
t�td�t�t| �� ��| j �td�t�t| �� � | j �td�t�|� � |�r^| j �td�| � n| j jtd�d d �}|�s�| j �� }|d u �r�d
S | j�||||� | �||� t�|�t�|�fS ) Ns usernames password�# using auth.%s.* for authentication
s" http authorization required for %ss# http authorization required for %s
s
realm: %s
s user: %s
s user:)�default)NN)�
isinstance�type�strr �find_user_passwordr �bytesurl� _writedebug�strurl�httpconnectionmod�readauthforurir �get�debugr �url�query� interactiver ZAbortr � hidepassword�bytes�write�promptZgetpassr )
r r �authuri�authinfor! r" �res�group�auth�ur r r r( > sN
�� ��
z passwordmgr.find_user_passwordc C s0 t d�}| j�|||r"dt|� p$df � d S )N� http auth: user %s, password %s
� *� not set)r r r/ �len)r r! r" �msgr r r r* o s zpasswordmgr._writedebugc C s | j �d |�S r )r r( )r r7 r r r �find_stored_passwords s z passwordmgr.find_stored_passwordN)�__name__�
__module__� __qualname__r r r( r* rB r r r r r 6 s
1r c @ s e Zd Zdd� Zdd� ZdS )� proxyhandlerc C s |� dd�ptj�d�}|r�|�d�s<|�d�s<d| d }t�|�}|jsh|� dd�|_|� dd�|_d d
g}|� d d � |�
dd
�D �� |� dd � tj�dd�� d�D �� |� dd�r�g | _
n|| _
t|�}||d�}|�dt�t|�� � ni }tj�| |� || _d S )Ns
http_proxys hosts http:s https:s http://� /s users passwds localhosts 127.0.0.1c S s g | ] }|� � �qS r )�lower��.0�pr r r �
<listcomp>� � z)proxyhandler.__init__.<locals>.<listcomp>s noc S s g | ]}|� � r|� � �� �qS r )�striprH rI r r r rL � s �s no_proxyrM � ,s always)�http�httpss proxying through %s
)�configr �environr. �
startswithr r0 r! r" �extendZ
configlist�splitZ
configbool�no_listr' r/ r3 r4 �urlreqrF r r )r r Zproxyurl�proxyrW Zproxiesr r r r x sB ���
���
�zproxyhandler.__init__c C s� t �t�|���d�d }| jD ]V}||kr2 d S |�d�rT|�|dd � �rT d S |�d�r |�|dd � �r d S q tj �
| |||�S )N� :r s *.� � .r ) r r) r ZgethostrV rW rT �endswithrX rF �
proxy_open)r �reqrY �type_�host�er r r r^ � s
zproxyhandler.proxy_openN)rC rD rE r r^ r r r r rF w s 0rF c s � fdd�}|S )Nc s@ t |tj�r2|�d� t�|�D ]}� | |� q n
� | |� d S �Nr )r% r, Z httpsendfile�seekr Z
filechunkiter)r �data�chunk��orgsendr r � _sendfile� s
z _gen_sendfile.<locals>._sendfiler )rh ri r rg r �
_gen_sendfile� s
rj s httpshandlerc @ s e Zd Zeejj�ZdS )r N)rC rD rE rj r �HTTPConnection�sendr r r r r � s r c C s� |j }|r(|d d� dvr"d| }d}nt�|�}d}|sH|t�|�kr�t�t�|��}|sf|jdkr�d� |j
|j pvdg�|_ |j
�� |_
|j
�| jj� d S d |_ d |_
d S ) N� )zhttp://zhttps:/zhttps://TFs httpsrZ s 443)� _tunnel_hostr Z getselector�
getfullurlr r0 r r) �scheme�joinra �port� realhostport�headers�copy�update�parent�
addheaders)Zhandler�hr_ Z tunnel_hostZ
new_tunnelr< r r r �_generic_start_transaction� s
rz c s� �fdd��j D �}��d�j � t�|�D ]}��d| � q.��d� i }tjs`�j|d< �j�jfd�j i|��� � �
� \}}}|t j kr�q�t
t� fdd �d
�� qz|d kr�t
t� jjd�� n ��� t�d ||�� f ��d S )
Nc s2 i | ]*}|� � �d �rt�|�t�� j| ��qS )zproxy-)rH rT r Zbytestrrt )rJ �x�r r r �
<dictcomp>� s �z(_generic_proxytunnel.<locals>.<dictcomp>s CONNECT %s HTTP/1.0
s %s: %s
s
s strict�methodc s � j �� �� S r )�fp�readlinerN r )r9 r r �<lambda>� rM z&_generic_proxytunnel.<locals>.<lambda>rM �� z Tunnel connection failed: %d %s)rt rl rs r Z iteritemsZispy3�strict�response_class�sock�_methodZ _read_status�httplibZCONTINUE�list�iterr r� �close�socketr rN )r Z proxyheaders�header�kwargs�version�status�reasonr )r9 r r �_generic_proxytunnel� s*
�
�r� c @ s e Zd Zdd� Zdd� ZdS )� httphandlerc C s | � t|�S r )�do_openr �r r_ r r r � http_open
s zhttphandler.http_openc C s t | ||� tj�| ||�S r )rz r � HTTPHandler�_start_transaction�r ry r_ r r r r�
s z httphandler._start_transactionN)rC rD rE r� r� r r r r r� s r� c @ s& e Zd Zdd� Zejdk r"dd� ZdS )�logginghttpconnectionc O s$ t jj| g|�R i |�� || _d S r )r rk r �_create_connection)r Z
createconn�argsr� r r r r s z logginghttpconnection.__init__)r[ rm rm c C s. | � | j| jf| j| j�| _| jr*| �� d S r )r� ra rr �timeoutZsource_addressr� rn Z_tunnelr| r r r �connect s
�z logginghttpconnection.connectN)rC rD rE r �sys� version_infor� r r r r r� s
r� c s2 e Zd ZdZd � fdd� Zdd� Zdd� Z� ZS )
�logginghttphandlerz"HTTP handler that logs socket I/O.Nc s( t t| �j|d� || _|| _|| _d S �N�r� )�superr� r �_logfh�_logname�
_observeropts)r Zlogfh�nameZ observeroptsr� �� __class__r r r % s zlogginghttphandler.__init__c C s | � | j|�S r )r� �_makeconnectionr� r r r r� / s z logginghttphandler.http_openc s" � fdd�}t |g|�R i |��S )Nc s, t j| i |��}tj� j|� jfi � j��S r )r� �create_connectionr Zmakeloggingsocketr� r� r� )r� r� r� r| r r �createconnection3 s
��z<logginghttphandler._makeconnection.<locals>.createconnection)r� )r r� r� r� r r| r r� 2 s z"logginghttphandler._makeconnection)N)rC rD rE �__doc__r r� r� �
__classcell__r r r� r r� " s
r� c @ s@ e Zd ZejZejZe ej
�Z e� ej
�Zddd�Zdd� ZdS )�httpsconnectionNc O s. t jj| ||g|�R i |�� || _|| _d S r )r rk r �key_file� cert_file)r ra rr r� r� r� r� r r r r E s zhttpsconnection.__init__c C sh t �| j| jf�| _| j}| jr:t| � | j�dd�d }tj | j| j
| j | j |d�| _t�
| j� d S )NrZ r r )r Zserverhostname)r� r� ra rr r� rs r� �rsplitr
Z
wrapsocketr� r� r Zvalidatesocket)r ra r r r r� R s �zhttpsconnection.connect)NNN)rC rD rE r Z HTTPResponser� r� Z
HTTPS_PORTZ default_portrj Zsafesendrl Zwrapgetresponserk Z getresponser r� r r r r r� > s
�
r� c @ s0 e Zd Zd
dd�Zdd� Zdd� Zd dd �ZdS ) � httpshandlerNc C s8 t jj| |d� tj�| � || _t| j| jj�| _d S r� ) r �KeepAliveHandlerr rX r� r r �httppasswordmgrdb�pwmgr)r r r� r r r r c s zhttpshandler.__init__c C s t | ||� tj�| ||�S r )rz r r� r� r� r r r r� i s z httpshandler._start_transactionc C sb t �|�}| j�|�\}}t�| j||�}|rN|\}}|| _| j�d| � nd | _| � | j
|�S )Nr# ) r ro r� rB r, r- r r; r/ r� r� )r r_ r0 r! �passwordr9 r: r; r r r �
https_openm s
zhttpshandler.https_openc O s� d }d }t |�dkr |d }t |�dkr0|d }|dd � }| jrjd| jv rjd| jv rj| jd }| jd }t||||g|�R i |��}| j|_|S )Nr r r[ s keys cert)r@ r; r� r )r ra rr r� r� ZkeyfileZcertfileZconnr r r r� { s&
���z httpshandler._makeconnection)N)N)rC rD rE r r� r� r� r r r r r� b s
r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�httpdigestauthhandlerc O s$ t jj| g|�R i |�� d | _d S r )rX r� r � retried_req�r r� r� r r r r � s z httpdigestauthhandler.__init__c C s d S r r r| r r r �reset_retry_count� s z'httpdigestauthhandler.reset_retry_countc C s* || j ur|| _ d| _tj�| ||||�S rc )r� �retriedrX r� �http_error_auth_reqed�r � auth_headerra r_ rt r r r r� � s
�z+httpdigestauthhandler.http_error_auth_reqedN)rC rD rE r r� r� r r r r r� � s r� c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�httpbasicauthhandlerc O s* d | _ tjj| g|�R i |�� d | _d S r )r; rX r� r r� r� r r r r � s z httpbasicauthhandler.__init__c C s | j r|�| j| j � |S r �r; �add_unredirected_headerr� �r Zrequestr r r � http_request� s z!httpbasicauthhandler.http_requestc C s | j r|�| j| j � |S r r� r� r r r �
https_request� s z"httpbasicauthhandler.https_requestc C s d S r r r| r r r r� � s z&httpbasicauthhandler.reset_retry_countc C s* || j ur|| _ d| _tj�| ||||�S rc )r� r� rX r� r� r� r r r r� � s
�z*httpbasicauthhandler.http_error_auth_reqedc C s� | j �|t�|��\}}|d ur�dt�|�t�|�f }dt�t�|�� � � }|�
| j d �|krfd S || _ |�
| j |� | j�|�S d S d S )Ns %s:%szBasic %s)r" r( r ro r r) r+ �base64Z b64encoderN Z
get_headerr� r; r� rw �open)r ra r_ r r! Zpw�rawr; r r r �retry_http_basic_auth� s
� z*httpbasicauthhandler.retry_http_basic_authN) rC rD rE r r� r� r� r� r� r r r r r� � s r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�
cookiehandlerc
C s� d | _ |�dd�}|sd S t�|�}z$tj�t�|��}|�� || _ W nD tjj y� } z(|�
t d�|t �
|�f � W Y d }~n
d }~0 0 d S )Ns auths
cookiefiles? (error loading cookie file %s: %s; continuing without cookies)
)� cookiejarrR r Z
expandpathZ cookielibZMozillaCookieJarr �fsdecode�loadZ LoadError�warnr r
Z forcebytestr)r r Z
cookiefiler� rb r r r r � s&
�
� ��zcookiehandler.__init__c C s | j r| j �|� |S r �r� Zadd_cookie_headerr� r r r r� � s zcookiehandler.http_requestc C s | j r| j �|� |S r r� r� r r r r� � s zcookiehandler.https_requestN)rC rD rE r r� r� r r r r r� � s r� � sTc s~ �� tdd�}g }|r2|�t|||p&i |d�� n&|�t|d�� trX|�t�|d�� |�t��� t��j �� |dur�|\} }
} } � �
|
d �\}
}| |
ks�| r�� � | |
| | � �� d| | r�dt
| � p�df � |�t� �t� �f� |�� �fd d
�tD �� |�t��� tj|� }d|_d|_d|_|�sVd t�� }d t�|�fg|_ nd t�|�fg|_ |�rz|j �d
� |S )a@
construct an opener suitable for urllib2
authinfo will be added to the password manager
The opener can be configured to log socket events if the various
``logging*`` arguments are specified.
``loggingfh`` denotes a file object to log events to.
``loggingname`` denotes the name of the to print when logging.
``loggingopts`` is a dict of keyword arguments to pass to the constructed
``util.socketobserver`` instance.
``sendaccept`` allows controlling whether the ``Accept`` request header
is sent. The header is sent by default.
s https timeoutr� Nr r= r> r? c s g | ]}|�� ��qS r r )rJ ry �Zpassmgrr r r rL 9 rM zopener.<locals>.<listcomp>s" mercurial/proto-1.0 (Mercurial %s)z
User-agent)ZAcceptzapplication/mercurial-0.1) Z
configwith�float�appendr� r� � has_httpsr� rF r r� rB r r/ r@ rU r� r� � handlerfuncsr� rX Z buildopenerZ
requestscountZsentbytescountZreceivedbytescountr r� r Zsysstrrx )r r8 Z useragentZ loggingfhZ loggingnameZ loggingopts�
sendacceptr� �handlersr Zurisr! r" Z saveduserZ savedpass�openerZagentr r� r r� sN �� ���
r� c C st t �|�}|jr*|j�� |_|�� \}}n.t�t�|��}dt� t
� t� |��� }d }t
| ||d��t�|�|�S )Ns file://)r� )r r0 rp rH r8 r �normpath�abspathr r) rX Z pathname2urlr� r� r� r+ )r Zurl_re r� r< r8 �pathr r r r� a s
�
�r� c s& | j � G � fdd�d| j�}|| _dS )z�Wrap a response object with common error handlers.
This ensures that any I/O from any consumer raises the appropriate
error and messaging.
c s e Zd Zd� fdd� ZdS )z!wrapresponse.<locals>.readerproxyNc
s� z
� |�W S t jyv } zR|jrHt|j�}|j| }td�||f }ntd�}tj|td�d��W Y d }~nHd }~0 t jy� } z&tjtd�| td�d��W Y d }~n
d }~0 0 d S )NsB HTTP request error (incomplete response; expected %d bytes got %d)s( HTTP request error (incomplete response)sv this may be an intermittent network failure; if the error persists, consider contacting the network or server operator)�hints HTTP request error (%s)) r� ZIncompleteReadZexpectedr@ �partialr r ZPeerTransportErrorZ
HTTPException)r �sizerb Zgot�totalrA �Zorigreadr r �readz s2
����
��z&wrapresponse.<locals>.readerproxy.read)N)rC rD rE r� r r� r r � readerproxyy s r� N)r� r� )Zrespr� r r� r � wrapresponseq s "r� )N)NNNr� NT)NT)1Z
__future__r r� r� r� Zi18nr � r r r r, r r r
r r Zutilsr
r r� ZstringioZurlerrrX r �objectr rF rj Z safehasattrr� rk rz r� r� r� r� r� r� r� r� r� r� Z basehandlerr� r� r� r� r� r r r r �<module>
sJ (
A> & $01% �
a