| 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 : /usr/lib64/python3.9/site-packages/mercurial/__pycache__/ |
Upload File : |
a
�+�b�R � @ s( d dl mZ d dlZd dlZd dlZd dlZd dlZddlmZ ddl m
Z
ddl m Z m
Z
mZm Z mZmZmZmZ ddlmZ ejZejZejZdd � ZG d
d � d e�Zd d
� Z dd� Z dd� Z G dd� de
j �Z dd� Z!G dd� dej"�Z#G dd� de j$j%�Z&dd� Z'dej(fd d �Z)d d d �Z*dS )!� )�absolute_importN� )�_)�getattr)�bundle2�error�httpconnection�pycompat�statichttprepo�url�util�wireprotov1peer)�urlutilc
C sz t �|�d }|t|d � td� }g }d}t �dt| �|�D ]4}|d7 }|�|t|� t �| ||| � �f� q@|S )ac Encode a string value into multiple HTTP headers.
``value`` will be encoded into 1 or more HTTP headers with the names
``header-<N>`` where ``<N>`` is an integer starting at 1. Each header
name + value will be at most ``limit`` bytes long.
Returns an iterable of 2-tuples consisting of header names and
values as native strings.
z-%sZ000s :
r r )r �strurl�lenZxrange�append�str)�value�header�limitZfmtZvaluelen�result�n�i� r �8/usr/lib64/python3.9/site-packages/mercurial/httppeer.py�encodevalueinheaders$ s *r c @ s8 e Zd Zdd� Zedd� �Zd
dd�Zejfdd �Z dS ) �
_multifilec G s6 |D ] }t �|d�stdt|�|��q|| _d| _d S )N� lengthsO _multifile only supports file objects that have a length but this one does not:r )r � safehasattr�
ValueError�type� _fileobjs�_index)�selfZfileobjs�fr r r �__init__B s �z_multifile.__init__c C s t dd� | jD ��S )Nc s s | ] }|j V qd S �N)�length��.0r$ r r r � <genexpr>P � z$_multifile.length.<locals>.<genexpr>)�sumr! �r# r r r r' N s z_multifile.lengthNc C s� |dkr d� dd� | jD ��S g }|rz| jt| j�k rz|�| j| j �|�� t|d �}||k rp| jd7 _||8 }q"d� |�S )Nr r+ c s s | ]}|� � V qd S r& )�readr( r r r r* T r+ z"_multifile.read.<locals>.<genexpr>���r )�joinr! r" r r r. )r# Zamt�partsZgotr r r r. R s
z_multifile.readc C sB |t jkrtd��|dkr"td��| jD ]}|�d� q(d| _d S )NsP _multifile does not support anything other than os.SEEK_SET for whence on seek()r sQ _multifile only supports seeking to start, but that could be fixed if you need it)�os�SEEK_SET�NotImplementedErrorr! �seekr" )r# �offset�whencer$ r r r r5 ^ s
��
z_multifile.seek)N)
�__name__�
__module__� __qualname__r% �propertyr' r. r2 r3 r5 r r r r r A s
r c C s |dkrd|d< |� dd�}|� di �}| �d| � d|fg} d}
|duoRd |v } | r�|r�t�t|�� ��} |sx| }n@t|t�r�t� |�}
t
|�|
_ |
}t� | �}t
| �|_ t ||�}t
| �|d
< n�|�rF|d ks�J �|d �}|r�t
|�d
d�d �}
|
dk�r6t�t|�� ��}t|d|
�D ]\}}|||< �q n| t|�� �7 } dt�| � }d||f }d}t�|d��rz|j }n|du�r�t
|�}|du�r�d|v�r�d|d< t� }t� }|du�r�|d�}|�r�|�d� t|�d
��}|�d� d|v �r|�d� d|v �rB|d��rBdd � tj�tj�D �}|�d d
�|� � |�r|td �t|��d |
�p`d �}|D ]\}}|||< �qhg }|D ] }|�� �d!��r�|�|� �q�|�r�d"�t|��|d#< |t� |�||�} |du�r�| �d$| � | � d%d&| � | ||fS )'aW Make an HTTP request to run a command for a version 1 client.
``caps`` is a set of known server capabilities. The value may be
None if capabilities are not yet known.
``capablefn`` is a function to evaluate a capability.
``cmd``, ``args``, and ``data`` define the command, its arguments, and
raw data to pass to it.
s pushkeyr+ s dataNs headerss sending %s command
s cmdr � httppostargsz
X-HgArgs-Post� capabilitiess
httpheader� ,r s X-HgArgs ?%ss %s%sr � Content-Type�application/mercurial-0.1s
httpmediatypes 0.1s partial-pulls 0.2txs 0.2s compressionc S s g | ]}|� � j�qS r )Zwireprotosupport�name)r) �er r r �
<listcomp>� s �z(makev1commandrequest.<locals>.<listcomp>s comp=%s� s X-HgProto� zx-hg�,ZVarys sending %d bytes
zContent-Lengthz%d) �pop�debug�urlreq� urlencode�sorted�items�
isinstance�bytes�io�BytesIOr r' r �int�splitr r r �set�add� compenginesZsupportedwireenginesZ
CLIENTROLEr0 �lower�
startswithr r r Zadd_unredirected_header) �ui�requestbuilder�capsZ capablefnZ repobaseurl�cmd�args�data�headers�qZ
headersizeZ
postargsokZstrargsr ZargsioZ
httpheaderZ encoded_argsr r �qs�cu�sizeZ protoparamsZ
mediatypes�mt�compsZ protoheadersZ varyheaders�reqr r r �makev1commandrequestn s�
�
��
rf c C s t jr | jS | �� sdS | �� S )z3Get request data, if any. If no data, returns None.N)r Zispy3r] Zhas_data�get_data)re r r r �_reqdata� s
rh c
C sN | j }| j�r | �dd��r d}||d t�|�� �t�|�� �f � d}t|�� �D ]T\}}t�|�}t�|�}|� d�r�|du r�d}|t
|�7 }qX||d ||f � qX|dur�||d | � t |�}|du�rt |d
d�} | du r�t
|�} ||d | � t
�� }
d} z�z|�|�} W n� tj�yd } z(| jd k�rNt�td
���� W Y d} ~ nZd} ~ 0 tj�y� } z6| � dt�|�� � � | �� td| ��W Y d} ~ n
d} ~ 0 0 W | j�r@| �dd��r@| �r�| jnd}
||d t
�� |
|
f � nD| j�r>| �dd��r>| �r | jnd}
||d t
�� |
|
f � 0 t � | � | S )zDSend a prepared HTTP request.
Returns the response object.
s devels debug.peer-requests devel-peer-request: %s
s %s %sNs X-hgarg-r s %s %ss+ %d bytes of commands arguments in headersr' s %d bytes of datai� s authorization faileds http error requesting %s
r/ s finished in %.4f seconds (%d)) rH Z debugflagZ
configboolr �bytesurlZ
get_methodZ get_full_urlrK Z header_itemsrW r rh r r Ztimer�open�urlerr� httperror�coder �Abortr �httplibZ
HTTPExceptionr � hidepassword� traceback�IOError�urlmodZ wrapresponse)rX �openerre Zdbg�lineZ
hgargssizer r r] r' �start�res�instrm r r r � sendrequest� s� � ���
���
��"�������
ry c s e Zd Z� fdd�Z� ZS )�RedirectedRepoErrorc s t t| ��|� || _d S r& )�superrz r% �respurl)r# �msgr| �� __class__r r r% < s z RedirectedRepoError.__init__)r8 r9 r: r% �
__classcell__r r r~ r rz ; s rz c C s d}t �|�� �}|�|�r4|d t|� � }d}nd}|�d�|�d�krhd}| jsh| �td�| � zt �|� dd��} W n& t
y� t �|j � dd��} Y n0 t
�|�}
| �d�r�t�|�� ��| �d��s&| �d t
�|� � td
�|
| p�d |�d �f } |�r |�r t| |��n
t�| ��z,| �d
d�d } tdd� | �d�D ��}
W n* t�y| t�td�|
| f ��Y n0 |
dk�r�|�r�tjd �|�}n\|
dk�r�t � dt� |d��d }t� ||�}tj� |�}|�|�}nt�td�|
| f ��|| |fS )NFT� /s real URL is %s
z content-type� s application/hg-error� application/mercurial-s requested URL: '%s'
sI '%s' does not appear to be an hg repository:
---%%<--- (%s)
%s
---%%<---
s no content-typerE � -r c S s g | ] }t |��qS r )rQ )r) r r r r rC l r+ z*parsev1commandresponse.<locals>.<listcomp>� .s+ '%s' sent a broken Content-Type header (%s))r r s zlib)r � � Br s '%s' uses newer protocol %s) r ri �geturl�endswithr �rstrip�quiet�warnr Z getheader�AttributeErrorr^ �getr rp rW r ZOutOfBandErrorr. rH rz � RepoErrorrR �tupler r rU Zdecompressorreader�struct�unpackZ readexactlyZ forwiretype)rX Zbaseurl�requrlr` �resp� compressibleZ
redirectedr| Z qsdropped�protoZsafeurlr} Zsubtype� version_info�elenZenameZenginer r r �parsev1commandresponseA s\
��
�
�r� c @ s~ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
d dd�Z dd� Z dd� Z
dd� Zdd� Zd d � Zd S ) �httppeerc C s: || _ || _|| _|| _|d uo&d|v| _|| _|| _d S )Nr< )rX �_path�_url�_capsZlimitedarguments�
_urlopener�_requestbuilder)r# rX �pathr rt rY rZ r r r r% � s zhttppeer.__init__c C s, | j jD ] }|�� t|ddd� �� qd S )NZ close_allc S s d S r& r r r r r �<lambda>� r+ z"httppeer.__del__.<locals>.<lambda>)r� �handlers�closer )r# �hr r r �__del__� s zhttppeer.__del__c C s | j S r& )r� r- r r r r � s z httppeer.urlc C s d S r& r r- r r r �local� s zhttppeer.localc C s | S r& r r- r r r �peer� s z
httppeer.peerc C s dS )NTr r- r r r �canpush� s zhttppeer.canpushc C sT z | j j| j j| j j }}}W n ty4 Y d S 0 | j�td�|||f � d S )NsE (sent %d HTTP requests and %d bytes; received %d bytes in responses)
)r� Z
requestscountZsentbytescountZreceivedbytescountr� rX �noter )r# Zreqs�sentZrecvr r r r� � s � ���zhttppeer.closec C s | j S r& )r� r- r r r � capabilities� s zhttppeer.capabilitiesFc K s` t �|�}t| j| j| j| j| j||�\}}}t| j| j |�}t
| j| j||||�\| _}}|S r& ) r Z byteskwargsrf rX r� r� �capabler� ry r� r� ) r# r[ �
_compressibler\ re ra r` r� �ctr r r � _callstream� s
�
� zhttppeer._callstreamc K s4 | j |fi |��}z|�� W |�� S |�� 0 d S r& )r� r. r� )r# r[ r\ �fpr r r �_call� s �zhttppeer._callc
K s� | � d�}z|�d�}W n ty0 dg}Y n0 |D ]}|tjv r6|} qNq6t�| j|d |�}t�| j|d�}ddi} z�zZ| j |f|| d�|��}
|
�dd �} t
| �d
k r�t � t
d �|
��| W W |�� t�|� S tjy� � Y nh tj �yP } zL| jd tjtjfv �r,t �t
d
�| jd ��t �| jd ��W Y d } ~ n
d } ~ 0 0 W |�� t�|� n|�� t�|� 0 d S )Ns unbundler> r+ � rbr? r@ �r] r^ �
r r� s unexpected response:r s push failed: %s)r� rR r� r Z bundletypesZ writebundlerX r � httpsendfiler� r r Z
ResponseErrorr r� r2 �unlinkrk rl �socketr\ �errnoZ
ECONNRESETZEPIPErn )
r# r[ Zcgr\ �types�xr Ztempnamer� r^ �rZvals�errr r r � _callpush� s>
�( �zhttppeer._callpushc
K s� d }z�t jddd�\}}t�|d��4}|�d�}|rJ|�|� |�d�}q0W d � n1 s^0 Y t�| j|d��D}ddi} | j |f|| d �|��W d � W |d ur�t�
|� S 1 s�0 Y W |d ur�t�
|� n|d u� r�t�
|� 0 d S )
Ns
hg-bundle-s .hg)�prefix�suffix�wbi r� r? r@ r� ) r Zmkstempr2 �fdopenr. �writer r� rX r� r� )
r# r[ r� r\ �filename�fdZfh�dZfp_r^ r r r �_calltwowaystream s$
*&
� �
zhttppeer._calltwowaystreamc K s | j |fddi|��S )Nr� T)r� )r# r[ r\ r r r �_callcompressable s zhttppeer._callcompressablec C s |�d S r& r )r# � exceptionr r r �_abort s zhttppeer._abortN)F)r8 r9 r: r% r� r r� r� r� r� r� r� r� r� r� r� r� r r r r r� � s
(r� c @ s e Zd ZdZddd�ZdS )�queuedcommandfuturez@Wraps result() on command futures to trigger submission on call.Nc C s, | � � rtjj�| |�S | j�� | �|�S r& )Zdoner �futures�Futurer Z
_peerexecutorZ sendcommands)r# �timeoutr r r r s
zqueuedcommandfuture.result)N)r8 r9 r: �__doc__r r r r r r� s r� c C s d }dd� }i }t | ||||d|�\}}} t| ||�}
z t| ||| |
dd�\} } }
W nf ty� }
zNt | ||||
jd|�\}}} t| ||�}
t| ||| |
dd�\} } }
W Y d }
~
n
d }
~
0 0 z|
�� }W |
�� n
|
�� 0 | �d�s�t� d| ��dt
|� � �i}| |fS ) Nc S s t �d��d S )Ns should not be called)r �ProgrammingError)r� r r r r� 0 s z!performhandshake.<locals>.capabler= F)r� r� s unexpected content-type: %s� v1capabilities) rf ry r� rz r| r. r� rW r r� rS rR )rX r rt rY rZ r� r\ re r� r` r� r| r� rB Zrawdata�infor r r �performhandshake+ s4 �
��
�"
r� c C s� t �|�}|js|jr0t�td�|jp*|j ��|�� \}}| �d| � |pXt �
| |�}t | |||�\}}t | |||||d �S )a- Construct an appropriate HTTP peer instance.
``opener`` is an ``url.opener`` that should be used to establish
connections, perform HTTP requests.
``requestbuilder`` is the type used for constructing HTTP requests.
It exists as an argument so extensions can override the default.
s unsupported URL component: "%s"s using %s
r� )
r r �query�fragmentr rn r �authinforH rs rt r� r� ) rX r� rt rY �ur r� r| r� r r r �makepeer` s
� �r� c C s� |rt �td���z.|�d�r2tjs2t �td���t| |�}|W S t jy� } zXz2t� | d| |�}| �
td�� |W W Y d }~S t jy� |�Y n0 W Y d }~n
d }~0 0 d S )Ns! cannot create new http repositorys https:s1 Python support for SSL and HTTPS is not installeds static-s (falling back to static-http)
) r rn r rW rs Z has_httpsr� r� r
�instancer� )rX r� ZcreateZintentsZ
createoptsrx Z
httpexceptionr� r r r r� | s �
r� )NN)+Z
__future__r r� rO r2 r� r� Zi18nr r r r� r r r r
r rs r r
Zutilsr ro rk rI r �objectr rf rh ry r� rz r� Zwirepeerr� r� r� r� r� Zrequestr� r� r r r r �<module> s2 (
-| HG 5