|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/mercurial/__pycache__/ |
Upload File : |
o
�]Lb;b � @ s� d dl mZ d dlZd dlZd dlZddlmZ ddlmZ ddl m
Z
m Z m Z
mZmZmZmZmZ ddlmZmZ ejZejZejZejZd/dd �ZG d
d � d e�ZG d d
� d
ej �Z dd� Z e� ed�Z G dd� dej �Z dd� Z!dd� Z"G dd� dej#�Z$G dd� dej �Z%G dd � d e$�Z&e r�G d d � d ej �Z'G d d � d ej(ej)�Z)G d!d"� d"ej*�Z*G d#d$� d$ej+�Z+G d%d&� d&ej,�Z-g Z. ' (d0d)d*�Z/d1d+d,�Z0d-d.� Z1dS )2� )�absolute_importN� )�_)�getattr)�encoding�error�httpconnection� keepalive�pycompat�sslutil� urllibcompat�util)�
stringutil�urlutilc C s8 | � dd�} | � dd�} | � dd�} |r| � 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 �//usr/lib/python3/dist-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__8 s
zpasswordmgr.__init__c C s | j �||||�S r )r � add_password)r �realm�uri�user�passwdr r r r < s zpasswordmgr.add_passwordc
C s� t |td �tf�s J �t |t�sJ �| j�||�}|\}}t�|�t�|�}}|r<|r<| �||� t�|�t�|�fS |r@|sat �
| j ||�}|ra|\}}|� d�|� d�}}| j �
d| � |re|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 �Abortr � hidepassword�bytes�write�prompt�getpassr )
r r! �authuri�authinfor# r$ �res�group�auth�ur r r r* ? sN
�� ��
z passwordmgr.find_user_passwordc C s0 t d�}| j�|||rdt|� pdf � d S )N� http auth: user %s, password %s
� *� not set)r r r1 �len)r r# r$ �msgr r r r, p s (zpasswordmgr._writedebugc C s | j �d |�S r )r r* )r r; r r r �find_stored_passwordt � z passwordmgr.find_stored_passwordN)�__name__�
__module__� __qualname__r r r* r, rF r r r r r 7 s 1 r c @ � e Zd Zdd� Zdd� ZdS )� proxyhandlerc C s |� dd�p tj�d�}|r{|�d�s |�d�s d| d }t�|�}|js4|� dd�|_|� dd�|_d d
g}|� d d � |�
dd
�D �� |� dd � tj�dd�� d�D �� |� dd�rbg | _
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>� s z)proxyhandler.__init__.<locals>.<listcomp>s noc S s g | ] }|� � r|� � �� �qS r )�striprN rO r r r rR � s �
�s no_proxy� � ,s always)�http�httpss proxying through %s
)�configr �environr0 �
startswithr r2 r# r$ �extend�
configlist�split�
configbool�no_listr) r1 r6 r7 �urlreqrL r r )r r �proxyurl�proxyr_ �proxiesr r r r y sB ���
���
�
zproxyhandler.__init__c C s� t �t�|���d�d }| jD ]+}||kr d S |�d�r*|�|dd � �r* d S |�d�r;|�|dd � �r; d S qtj �
| |||�S )N� :r s *.� � .r ) r
r+ r �gethostr] r_ rZ �endswithr` rL �
proxy_open)r �reqrb �type_�host�er r r ri � s
�zproxyhandler.proxy_openN)rH rI rJ r ri r r r r rL x s 0rL c s � fdd�}|S )Nc sB t |tj�r|�d� t�|�D ]}� | |� qd S � | |� d S �Nr )r' r. � httpsendfile�seekr
�
filechunkiter)r �data�chunk��orgsendr r � _sendfile� s
�z _gen_sendfile.<locals>._sendfiler )ru rv r rt r �
_gen_sendfile� s
rw s httpshandlerc @ s e Zd Zeejj�Zdd� ZdS )r c C s4 t | dd �}|r|jr| �� d | _|S tj�| �S )N�proxyres)r �
will_close�closerx r �HTTPConnection� getresponse)r rx r r r r| � s zhttpconnection.getresponseN)rH rI rJ rw r r{ �sendr| r r r r r � s r c C s� |j }|r|d d� dvrd| }d}nt�|�}d}|s$|t�|�krOt�t�|��}|s3|jdkrOd� |j
|j p;dg�|_ |j
�� |_
|j
�| jj� d S d |_ d |_
d S ) N� )zhttp://zhttps:/zhttps://TFs httpsrd s 443)� _tunnel_hostr � getselector�
getfullurlr r2 r
r+ �scheme�joinrl �port� realhostport�headers�copy�update�parent�
addheaders)�handler�hrj � tunnel_host�
new_tunnelr@ r r r �_generic_start_transaction� s
r� c s^ �fdd��j D �}��d�j � t�|�D ] }��d| � q��d� i }tjs0�j|d< �j�jfd�j i|��� � �
� \}}}|t j krKn t
t� fd d
�d �� q>|� _|�� � _� jd krot
t� jjd�� dS |d
krwd� _n|�d�r�d� _n
|dkr�d� _nt �|��� jdkr�d � _d� _d� _t �t� �� _ dS t �� j�� _ d � j _� j � d�}|r�|� � dkr�d� _d � _ nd� _� � � � _� j � d�}|r� js�zt!|�� _W n t"y� d � _Y n
w � jdk r�d � _nd � _|t j#k�s|t j$k�sd| k�rd k �sn � j dk�rd� _� j�s*� j�s*� jd u �r*d� _� �_%dS )Nc s2 i | ]}|� � �d �rt�|�t�� j| ��qS )zproxy-)rN rZ r
�bytestrr� )rP �x�r r r �
<dictcomp>� s ��z(_generic_proxytunnel.<locals>.<dictcomp>s CONNECT %s HTTP/1.0
s %s: %s
s
s strict�methodTc s � j �� �� S r )�fp�readlinerS r )r= r r �<lambda> s z&_generic_proxytunnel.<locals>.<lambda>rT �� s HTTP/1.0�
s HTTP/1.� s HTTP/0.9� r r Fs transfer-encodings chunkeds content-length�d s HEAD)&r� r} r� r
� iteritems�ispy3�strict�response_class�sock�_method� _read_status�httplib�CONTINUE�list�iter�statusrS �reasonr� r� �versionrZ �UnknownProtocol�length�chunkedry � HTTPMessage�stringiorE � getheaderrN �
chunk_left� _check_close�int�
ValueError�
NO_CONTENT� NOT_MODIFIEDrx ) r � proxyheaders�header�kwargsr� r� r� �trencr� r )r= r r �_generic_proxytunnel� s~
�
�
�
� r� c @ rK )� httphandlerc C s | � t|�S r )�do_openr �r rj r r r � http_openR s zhttphandler.http_openc C � t | ||� tj�| ||�S r )r� r � HTTPHandler�_start_transaction�r r� rj r r r r� U � z httphandler._start_transactionN)rH rI rJ r� r� r r r r r� Q s r� c @ s* e Zd Zdd� Zejdk rdd� ZdS dS )�logginghttpconnectionc O s$ t jj| g|�R i |�� || _d S r )r r{ r �_create_connection)r �
createconn�argsr� r r r r [ �
z logginghttpconnection.__init__)re r~ r~ c C s2 | � | j| jf| j| j�| _| jr| �� d S d S r )r� rl r� �timeout�source_addressr� r �_tunnelr� r r r �connectb s � �z logginghttpconnection.connectN)rH rI rJ r �sys� version_infor� r r r r r� Z 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 �logfh�name� observeroptsr� �� __class__r r r m s
zlogginghttphandler.__init__c C s | � | j|�S r )r� �_makeconnectionr� r r r r� w rG z logginghttphandler.http_openc s" � fdd�}t |g|�R i |��S )Nc s, t j| i |��}tj� j|� jfi � j��S r )�socket�create_connectionr
�makeloggingsocketr� r� r� )r� r� r� r� r r �createconnection{ s
��z<logginghttphandler._makeconnection.<locals>.createconnection)r� )r r� r� r� r r� r r� z s z"logginghttphandler._makeconnectionr )rH rI rJ �__doc__r r� r� �
__classcell__r r r� r r� j s
r� c @ sF e Zd ZejZejZe ej
�Z e� ej
�Z ddd�Zdd� ZdS )�httpsconnectionNc O s. t jj| ||g|�R i |�� || _|| _d S r )r r{ r �key_file� cert_file)r rl r� r� r� r� r� r r r r � 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 )Nrd r r )r �serverhostname)r� r� rl r� r� r� r� �rsplitr �
wrapsocketr� r� r �validatesocket)r rl r r r r� � s �zhttpsconnection.connect)NNN)rH rI rJ r � HTTPResponser� r� �
HTTPS_PORT� default_portrw �safesendr} �wrapgetresponser{ r| r 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 r` r� r r �httppasswordmgrdb�pwmgr)r r r� r r r r � s zhttpshandler.__init__c C r� r )r� r r� r� r� r r r r� � r� z httpshandler._start_transactionc C sb t �|�}| j�|�\}}t�| j||�}|r'|\}}|| _| j�d| � nd | _| � | j
|�S )Nr% ) r r� r� rF r. r/ r r? r1 r� r� )r rj r2 r# �passwordr= r> r? r r r �
https_open� s
zhttpshandler.https_openc O s� d }d }t |�dkr|d }t |�dkr|d }|dd � }| jr5d| jv r5d| jv r5| jd }| jd }t||||g|�R i |��}| j|_|S )Nr r re s keys cert)rD r? r� r )r rl r� r� r� �keyfile�certfile�connr r r r� � s&
���z httpshandler._makeconnectionr )rH rI rJ r r� r� r� r r r r r� � s
r� c @ �$ e Zd Zdd� Zdd� Zdd� ZdS )�httpdigestauthhandlerc O s$ t jj| g|�R i |�� d | _d S r )r` r� r � retried_req�r r� r� r r r r � r� z httpdigestauthhandler.__init__c C � d S r r r� r r r �reset_retry_count� � z'httpdigestauthhandler.reset_retry_countc C �* || j ur || _ d| _tj�| ||||�S rn )r� �retriedr` r� �http_error_auth_reqed�r � auth_headerrl rj r� r r r r � �
�z+httpdigestauthhandler.http_error_auth_reqedN)rH rI rJ 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? r` r r r� r� r r r r � s
z httpbasicauthhandler.__init__c C � | j r |�| j| j � |S r �r? �add_unredirected_headerr �r �requestr r r � http_request� � z!httpbasicauthhandler.http_requestc C r r r r r r r �
https_request� r z"httpbasicauthhandler.https_requestc C r� r r r� r r r r� r� z&httpbasicauthhandler.reset_retry_countc C r� rn )r� r r` r r r r r r r r z*httpbasicauthhandler.http_error_auth_reqedc C s� | j �|t�|��\}}|d urCdt�|�t�|�f }dt�t�|�� � � }|�
| j d �|kr3d S || _ |�
| j |� | j�|�S d S )Ns %s:%szBasic %s)r$ r* r r� r
r+ r- �base64� b64encoderS �
get_headerr r? r r� �open)r rl rj r! r# �pw�rawr? r r r �retry_http_basic_auth s
� z*httpbasicauthhandler.retry_http_basic_authN) rH rI rJ r r r
r� r r r r r r r � s r c @ r� )�
cookiehandlerc
C s� d | _ |�dd�}|s
d S t�|�}ztj�t�|��}|�� || _ W d S tjj yH } z|�
t d�|t �
|�f � W Y d }~d S d }~ww )Ns auths
cookiefiles? (error loading cookie file %s: %s; continuing without cookies)
)� cookiejarrX r
�
expandpath� cookielib�MozillaCookieJarr
�fsdecode�load� LoadError�warnr r � forcebytestr)r r �
cookiefiler rm r r r r ! s*
� � ����zcookiehandler.__init__c C � | j r | j �|� |S r �r �add_cookie_headerr r r r r 8 � zcookiehandler.http_requestc C r r r! r r r r r
> r# zcookiehandler.https_requestN)rH rI rJ r r r
r r r r r s r � sTc sz �� tdd�}g }|r|�t|||pi |d�� n|�t|d�� tr,|�t�|d�� |�t��� t��j �� |durk|\} }
} } � �
|
d �\}
}| |
ksR| rZ� � | |
| | � �� d| | rfdt
| � pgdf � |�t� �t� �f� |�� �fd d
�tD �� |�t��� tj|� }d|_d|_d|_|s�d t�� }d t�|�fg|_ n d t�|�fg|_ |r�|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 rA rB rC c s g | ]}|�� ��qS r r )rP r� ��passmgrr r r rR � s zopener.<locals>.<listcomp>s" mercurial/proto-1.0 (Mercurial %s)z
User-agent)�Acceptzapplication/mercurial-0.1) �
configwith�float�appendr� r� � has_httpsr� rL r r� rF r r1 rD r[ r r� � handlerfuncsr r` � buildopener�
requestscount�sentbytescount�receivedbytescountr
r� r
�sysstrr� )r r< � useragent� loggingfh� loggingname� loggingopts�
sendacceptr� �handlersr! �urisr# r$ � saveduser� savedpass�opener�agentr r% r r; H sN �� ���
r; c C st t �|�}|jr|j�� |_|�� \}}nt�t�|��}dt� t
� t� |��� }d }t
| ||d��t�|�|�S )Ns file://)r6 )r r2 r� rN r< r
�normpath�abspathr
r+ r` � pathname2urlr r; r r- )r �url_rr r6 r@ r< �pathr r r r � 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 jy5 } z#|jr$t|j�}|j| }td�||f }ntd�}tj|td�d��d }~w t jyN } z
tjtd�| td�d��d }~ww )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� �IncompleteRead�expectedrD �partialr r �PeerTransportError�
HTTPException)r �sizerm �got�totalrE ��origreadr r �read� s8
�����
����z&wrapresponse.<locals>.readerproxy.readr )rH rI rJ rM r rK r r � readerproxy� s rN N)rM r� )�resprN r rK r � wrapresponse� s
"rP r )NNNr$ NT)NT)2�
__future__r r r� r� �i18nr r
r � r r r r. r r r r
�utilsr r r� r� �urlerrr` r �objectr rL rw � safehasattrr+ r{ r� r� r� r� r� r� r� r� r� r� r � basehandlerr r, r; r rP r r r r �<module> sN (
A> d $01%
�
a