/
lib64
/
python3.9
/
site-packages
/
mercurial
/
__pycache__
/
Upload File
HOME
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� | j �||�}|\}}t�|�t�|� }}|rT|rT| �||� 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�|� � |�r8| j�td�| � n| jjtd�d d �}|�s\| j�� }|d u �rjd 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)r �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% > sJ �� �� 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 r4 r r r �find_stored_passwords s z passwordmgr.find_stored_passwordN)�__name__� __module__� __qualname__r r r% r' r? 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 )�striprE rF r r r rI � s �s no_proxyrJ � ,s always)�http�httpss proxying through %s )�configr �environr+ � startswithr r- r! r" �extendZ configlist�splitZ configbool�no_list�strr, r0 r1 �urlreqrC r r )r r Zproxyurl�proxyrT 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 ZgethostrS rT rQ �endswithrV rC � proxy_open)r �reqrW �type_�host�er r r r\ � s zproxyhandler.proxy_openN)r@ rA rB r r\ r r r r rC w s 0rC c s � fdd�}|S )Nc s@ t |tj�r2|�d� t�|�D ]}� | |� q n � | |� d S �Nr )� isinstancer) Z httpsendfile�seekr Z filechunkiter)r �data�chunk��orgsendr r � _sendfile� s z _gen_sendfile.<locals>._sendfiler )rg rh r rf r � _gen_sendfile� s ri s httpshandlerc @ s e Zd Zeejj�ZdS )r N)r@ rA rB ri 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 httpsrX s 443)� _tunnel_hostr Z getselector� getfullurlr r- r r& �scheme�joinr_ �port� realhostport�headers�copy�update�parent� addheaders)Zhandler�hr] Z tunnel_hostZ new_tunnelr9 r r r �_generic_start_transaction� s ry 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-)rE rQ r Zbytestrrs )rG �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�readlinerK r )r6 r r �<lambda>� rJ z&_generic_proxytunnel.<locals>.<lambda>rJ �� z Tunnel connection failed: %d %s)rs rk rr r Z iteritemsZispy3�strict�response_class�sock�_methodZ _read_status�httplibZCONTINUE�list�iterr~ r �close�socketr rK )r Z proxyheaders�header�kwargs�version�status�reasonr )r6 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 )ry r � HTTPHandler�_start_transaction�r rx r] r r r r� s z httphandler._start_transactionN)r@ rA rB 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 rj r �_create_connection)r Z createconn�argsr� r r r r s z logginghttpconnection.__init__)rY rl rl c C s. | � | j| jf| j| j�| _| jr*| �� d S r )r� r_ rq �timeoutZsource_addressr� rm Z_tunnelr{ r r r �connect s �z logginghttpconnection.connectN)r@ rA rB 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)r@ rA rB �__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 rj r �key_file� cert_file)r r_ rq 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 )NrX r r )r Zserverhostname)r� r� r_ rq r� rr r� �rsplitr Z wrapsocketr� r� r Zvalidatesocket)r r_ r r r r� R s �zhttpsconnection.connect)NNN)r@ rA rB r Z HTTPResponser� r� Z HTTPS_PORTZ default_portri Zsafesendrk Zwrapgetresponserj 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 rV r� r r �httppasswordmgrdb�pwmgr)r r r� r r r r c s zhttpshandler.__init__c C s t | ||� tj�| ||�S r )ry 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 rn r� r? r) r* r r8 r, r� r� )r r] r- r! �passwordr6 r7 r8 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 rY s keys cert)r= r8 r� r )r r_ rq r� r� ZkeyfileZcertfileZconnr r r r� { s& ���z httpshandler._makeconnection)N)N)r@ rA rB 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 )rV 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 ra )r� �retriedrV r� �http_error_auth_reqed�r � auth_headerr_ r] rs r r r r� � s �z+httpdigestauthhandler.http_error_auth_reqedN)r@ rA rB 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 )r8 rV r� r r� r� r r r r � s z httpbasicauthhandler.__init__c C s | j r|�| j| j � |S r �r8 �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 ra )r� r� rV 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 rn r r& r( �base64Z b64encoderK Z get_headerr� r8 r� rv �open)r r_ r] r r! Zpw�rawr8 r r r �retry_http_basic_auth� s � z*httpbasicauthhandler.retry_http_basic_authN) r@ rA rB 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) )� cookiejarrO r Z expandpathZ cookielibZMozillaCookieJarr �fsdecode�loadZ LoadError�warnr r Z forcebytestr)r r Z cookiefiler� r` 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)r@ rA rB 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 )rG rx �Zpassmgrr r r rI 9 rJ zopener.<locals>.<listcomp>s" mercurial/proto-1.0 (Mercurial %s)z User-agent)ZAcceptzapplication/mercurial-0.1) Z configwith�float�appendr� r� � has_httpsr� rC r r� r? r r, r= rR r� r� � handlerfuncsr� rV Z buildopenerZ requestscountZsentbytescountZreceivedbytescountr r� r Zsysstrrw )r r5 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 r- ro rE r5 r �normpath�abspathr r& rV Z pathname2urlr� r� r� r( )r Zurl_rd r� r9 r5 �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 �sizer` Zgot�totalr> �Zorigreadr r �readz s2 ���� ��z&wrapresponse.<locals>.readerproxy.read)N)r@ rA rB 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� ZstringioZurlerrrV r �objectr rC ri Z safehasattrr� rj ry 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