| 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
�+�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
< nt|�r:|d �}|r�t
|�d d
�d �}
|
dk�r*t�t|�� ��}t|d|
�D ]\}}|||< �qn| t|�� �7 } dt�| � }d||f }d}t�|d��rn|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 �r6|d��r6dd� tj�tj�D �}|�d d �|� � |�rptd �t|��d |
�pTd �}|D ]\}}|||< �q\g }|D ] }|�� �d ��rx|�|� �qx|�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-Posts
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�
�
��
re 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)rd r r r �_reqdata� s
rg 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)) rG Z debugflagZ
configboolr �bytesurlZ
get_methodZ get_full_urlrJ Z header_itemsrV r rg r r Ztimer�open�urlerr� httperror�coder �Abortr �httplibZ
HTTPExceptionr � hidepassword� traceback�IOError�urlmodZ wrapresponse)rW �openerrd Zdbg�lineZ
hgargssizer r r\ r' �start�res�instrl r r r � sendrequest� s� � ���
���
��"�������
rx c s e Zd Z� fdd�Z� ZS )�RedirectedRepoErrorc s t t| ��|� || _d S r& )�superry r% �respurl)r# �msgr{ �� __class__r r r% < s z RedirectedRepoError.__init__)r8 r9 r: r% �
__classcell__r r r} r ry ; s ry 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-typerD � -r c S s g | ] }t |��qS r )rP )r) r r r r rB 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 rh �geturl�endswithr �rstrip�quiet�warnr Z getheader�AttributeErrorr] �getr ro rV r ZOutOfBandErrorr. rG ry � RepoErrorrQ �tupler r rT Zdecompressorreader�struct�unpackZ readexactlyZ forwiretype)rW 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< )rW �_path�_url�_capsZlimitedarguments�
_urlopener�_requestbuilder)r# rW �pathr rs rX rY 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� rW �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 byteskwargsre rW r� r� �capabler� rx r� r� ) r# rZ �
_compressibler[ rd r` r_ r� �ctr r r � _callstream� s
�
� zhttppeer._callstreamc K s4 | j |fi |��}z|�� W |�� S |�� 0 d S r& )r� r. r� )r# rZ 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� rQ r� r Z bundletypesZ writebundlerW r � httpsendfiler� r r Z
ResponseErrorr r� r2 �unlinkrj rk �socketr[ �errnoZ
ECONNRESETZEPIPErm )
r# rZ 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� rW r� r� )
r# rZ r� r[ �filename�fdZfh�dZfp_r] r r r �_calltwowaystream s$
*&
� �
zhttppeer._calltwowaystreamc K s | j |fddi|��S )Nr� T)r� )r# rZ 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>.capables capabilitiesF)r� r� s unexpected content-type: %s� v1capabilities) re rx r� ry r{ r. r� rV r r� rR rQ )rW r rs rX rY r� r[ rd r� r_ r� r{ r� rA 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 rm r �authinforG rr rs r� r� ) rW r� rs rX �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 rm r rV rr Z has_httpsr� r� r
�instancer� )rW r� ZcreateZintentsZ
createoptsrw Z
httpexceptionr� r r r r� | s �
r� )NN)+Z
__future__r r� rN r2 r� r� Zi18nr r r r� r r r r
r rr r r
Zutilsr rn rj rH r �objectr re rg rx r� ry r� Zwirepeerr� r� r� r� r� Zrequestr� r� r r r r �<module> s2 (
-| HG 5