| 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
�+�bQi � @ s� d dl mZ d dlZd dlZddlmZ ddlmZ ddlm Z ddl
m Z m Z m
ZmZmZmZmZmZmZmZmZmZmZ ddlmZm Z ej Z ej Z ed �Z ed
�Z d e e f Z!d d
� Z"dd� Z#dd� Z$dd� Z%dd� Z&e�'� Z(dfdd�Z)e)dddd �d d � �Z*e)d d dd �d!d"� �Z+e)d#dd �d$d%� �Z,e)d&d'dd �d(d)� �Z-e)d*d+dd �d,d-� �Z.g d.�Z/d/d0� Z0e)d1dd �d2d3� �Z1e)d4d5dd �d6d7� �Z
e)d8d9dd �d:d;� �Z2e)d<d=dd �d>d?� �Z3d@dA� Z4e)dBdCdd �dDdE� �Z5e)dFdd �dGdH� �Z6e)dIdd �dJdK� �Z7e)dLdMdd �dNdO� �Z8e)dPdQdd �dRdS� �Z9e)dTdUdd �dVdW� �Z:e)dXdYdd �dZd[� �Z;e)d\d]dd �d^d_� �Ze)d`dd �dadb� �Z<e)dcdFdd �ddde� �Z=dS )g� )�absolute_importN� )�_)�hex)�getattr)
�bundle2� bundlecaches� changegroup� discovery�encoding�error�exchange�pushkey�pycompat� requirements� streamclone�util�wireprototypes)�procutil�
stringutils/ incompatible Mercurial client; bundle2 requireds9 see https://www.mercurial-scm.org/wiki/IncompatibleClients %s
(%s)
c C s6 | � � D ]$}|�d�r|dd� �d� S qddgS )a Returns a list of compression methods supported by the client.
Returns a list of the compression methods supported by the client
according to the protocol capabilities. If no such capability has
been announced, fallback to the default of zlib and uncompressed.
s comp=� N� ,s zlibs none)� getprotocaps�
startswith�split)�protoZcap� r �A/usr/lib64/python3.9/site-packages/mercurial/wireprotov1server.py�clientcompressionsupport0 s
r c C s | j �dd�}| �|�S )z�Obtain the repo used for processing wire protocol commands.
The intent of this function is to serve as a monkeypatch point for
extensions that need commands to operate on different repo views under
specialized circumstances.
� servers view)�uiZconfigZfiltered)�repor �commandZ
viewconfigr r r �getdispatchrepo@ s r# c C s4 t | ||�} t| \}}|�|�}|| |g|�R � S �N)r# �commandsZgetargs)r! r r" �func�spec�argsr r r �dispatchK s
r) c C sJ i }|D ] }||v r|| ||< ||= q|rFt j�d| d�|�f � |S )Ns, warning: %s ignored unexpected arguments %s
r )r �stderr�write�join)�cmd�keys�others�opts�kr r r �optionsT s ��r2 c C sv | j }tj| jv }|r2|�dd| �}|dur2|S |�dd| �}|durN|S |rj|�dd�}|durj|S |�dd�S )z�Whether a bundle1 operation is allowed from the server.
Priority is:
1. server.bundle1gd.<action> (if generaldelta active)
2. server.bundle1.<action>
3. server.bundle1gd (if generaldelta active)
4. server.bundle1
r s bundle1gd.%sNs
bundle1.%ss bundle1gds bundle1)r �requirementsmodZGENERALDELTA_REQUIREMENTr �
configbool)r! �actionr �gd�vr r r �bundle1allowedb s
r8 � pushc s` dd� t j�� D ���dvr*t�d� ��� du r6d� t� t�sJt�d��� ���fdd �}|S )
a� Decorator to declare a wire protocol command.
``name`` is the name of the wire protocol command being provided.
``args`` defines the named arguments accepted by the command. It is
a space-delimited list of argument names. ``*`` denotes a special value
that says to accept all named arguments.
``permission`` defines the permission type needed to run this command.
Can be ``push`` or ``pull``. These roughly map to read-write and read-only,
respectively. Default is to assume command requires ``push`` permissions
because otherwise commands not declaring their permissions could modify
a repository that is supposed to be read-only.
c S s h | ]\}}|d dkr|�qS )s versionr r )�.0r1 r7 r r r � <setcomp>� s z#wireprotocommand.<locals>.<setcomp>)r9 � pullsC invalid wire protocol permission; got %s; expected "push" or "pull"N� s: arguments for version 1 commands must be declared as bytesc s0 �t v rt�d� ��tj| � ��d�t �< | S )Ns+ %s command already registered for version 1)r( �
transports�
permission)r% r �ProgrammingErrorr Z commandentry)r& �r( �namer? r> r r �register� s ��
z"wireprotocommand.<locals>.register)r Z
TRANSPORTS�itemsr r@ �
isinstance�bytes)rB r( r? rC r rA r �wireprotocommand� s" ���
� rG s batchs cmds *r< )r? c sX t j}g }|�d�D �]0}|�dd�\}}i } |�d�D ]&}
|
r8|
�d�\} } || �| || �< q8t| \}
}t| j}|�|� |�r|�� }i � |D ]H}|dkr�i }| �� D ]}||vr�| | ||< q�|� d< q�| | � |< q�|
| |g� fdd�|D ��R � }n
|
| |�}t|t j��r"| S t|t j ��r6|j
}|� t � |�� qt � d�
|��S ) N� ;� r r � =� *c s g | ] }� | �qS r r )r: r1 ��datar r �
<listcomp>� r= zbatch.<locals>.<listcomp>)r Zunescapebatchargr r% r? Z checkpermr. rE �ooberror�
bytesresponserM �appendZescapebatchargr, )r! r Zcmdsr/ Z unescapearg�resZpair�opr( Zvals�a�nr7 r& r' Zpermr. r1 Zstar�key�resultr rL r �batch� s>
"
rX s betweens pairsc C sL dd� |� d�D �}g }| �|�D ]}|�t�|�d � q"t�d�|��S )Nc S s g | ]}t �|d ��qS )� -)r �
decodelist)r: �pr r r rN � r= zbetween.<locals>.<listcomp>rI �
r= )r �betweenrQ r �
encodelistrP r, )r! r �pairs�r�br r r r] � s
r] � branchmapc C s\ | � � }g }t�|�D ]4\}}t�t�|��}t�|�}|� d||f � qt�
d� |��S )Ns %s %sr\ ) � branchmapr � iteritems�urlreq�quoter Z fromlocalr r^ rQ rP r, )r! r rc �heads�branch�nodesZ
branchnameZ branchnodesr r r rc � s
rc s branches� nodesc C sB t �|�}g }| �|�D ]}|�t �|�d � qt �d�|��S )Nr\ r= )r rZ �branchesrQ r^ rP r, )r! r ri r` ra r r r rk � s
rk s clonebundlesr= c C s t �| j�tj��S )aZ Server command for returning info for available bundles to seed clones.
Clients will parse this response and determine what bundle to fetch.
Extensions may wrap this command to filter or dynamically emit data
depending on the request. e.g. you could advertise URLs for the closest
data center given the client's IP address.
)r rP �vfs�tryreadr ZCB_MANIFEST_FILE�r! r r r r � clonebundles s
�ro )� lookuprb � pushkey� known� getbundles unbundlehashc C s t t�}t�d|�r |�d� t�| �rz| j�dd�r@|�d� t� | �}|t
j h sb|�d� n|�dd� t
|�� � | j�dd �r�t�tj| dd
��}|�d t�|� � |�d d� tj� � | j�dd
�r�|�tj� | j�dd�r�|�tj� |�| |�S )a) return a list of capabilities for a repo
This function exists to allow extensions to easily wrap capabilities
computation
- returns a lists: easy to alter
- change done here will be propagated to both `capabilities` and `hello`
command without any other action needed.
� changegroupsubsetr s preferuncompresseds stream-preferreds streams
streamreqs=%sr s experimentals bundle2-advertise)Zroles bundle2=s unbundle=%ss narrows narrowservebrokenellipses)�list�
wireprotocapsr% ZcommandavailablerQ r Zallowservergenerationr r4 Zstreamed_requirementsr3 ZREVLOGV1_REQUIREMENTr, �sortedr Z
encodecapsZ getrepocapsre rf Zbundlepriorityr Z NARROWCAPZ ELLIPSESCAPZaddcapabilities)r! r �capsZrequiredformatsZcapsblobr r r �
_capabilities s&
ry s capabilitiesc C s t | |�}t�d�t|���S )NrI )ry r rP r, rw �r! r rx r r r � capabilitiesE s
r{ s changegroups rootsc sL t �|�}tj| || �� d�}t�| |dd�� t� fdd�d�}t j|d�S )N�Z missingrootsZ ancestorsof� 01� servec s
� � d�S �Ni � ��readr �Zcgr r �<lambda>R r= z changegroup.<locals>.<lambda>r= ��gen) r rZ r
�outgoingrg �changegroupmod�makechangegroup�iter� streamres)r! r �rootsri r� r� r r� r r K s
�r rt s bases headsc sR t �|�}t �|�}tj| ||d�}t�| |dd�� t� fdd�d�}t j|d�S )Nr| r} r~ c s
� � d�S r r� r r� r r r� \ r= z#changegroupsubset.<locals>.<lambda>r= r� )r rZ r
r� r� r� r� r� )r! r �basesrg r� r� r r� r �changegroupsubsetV s
r� �
debugwireargss one two *c C s0 t dddg|�}t�| j||fi t�|����S )Nr� s threes four)r2 r rP �
debugwireargsr � strkwargs)r! r ZoneZtwor/ r0 r r r r� ` s �r� c s� dd� }| j �d�}|s dS t�| |�}t�| |�}|s<dS | �� j� � j� fdd�|D �dd��� j� fd d�|D �dd��t|�} |D �]N}
|
� d
�} t
j j � | �} | r�| | vr�| | vr�q�d |
v �r6z||
d �}
W n t
y� Y q�Y n0 |
�|�r�q�t� �fd d
�|
D ���rq�t� ��fdd
�|
D ���r6q�d|
v �r�z||
d �}W n t
�yh Y q�Y n0 t� �fdd
�|D ���s�q�|
d }| j�d| � z| j �|�W S t�y� | j�d| � Y q�Y q�0 q�dS )a� Return a file object for the first matching pullbundle.
Pullbundles are specified in .hg/pullbundles.manifest similar to
clonebundles.
For each entry, the bundle specification is checked for compatibility:
- Client features vs the BUNDLESPEC.
- Revisions shared with the clients vs base revisions of the bundle.
A bundle can be applied only if all its base revisions are known by
the client.
- At least one leaf of the bundle's DAG is missing on the client.
- Every leaf of the bundle's DAG is part of node set the client wants.
E.g. do not send a bundle of all changes if the client wants only
one specific branch of many.
c S s dd� | � d�D �S )Nc S s h | ]}t �|��qS r )�binasciiZ unhexlify)r: �hr r r r; z r= z;find_pullbundle.<locals>.decodehexstring.<locals>.<setcomp>rH )r )�sr r r �decodehexstringy s z(find_pullbundle.<locals>.decodehexstrings pullbundles.manifestNc s g | ]}� � |��qS r ��rev�r: r� ��clr r rN � r= z#find_pullbundle.<locals>.<listcomp>T)Z inclusivec s g | ]}� � |��qS r r� r� r� r r rN � r= s COMPRESSION� headsc 3 s | ]}� � |��v V qd S r$ r� r� �r� �
common_ancr r � <genexpr>� r= z"find_pullbundle.<locals>.<genexpr>c 3 s* | ]"}� � |��vo � � |��vV qd S r$ r� r� �r� r� Z heads_ancr r r� � s �s basesc 3 s | ]}� � |��v V qd S r$ r� r� r� r r r� � r= s URLs sending pullbundle "%s"
s pullbundle "%s" not accessible
)rl rm r ZparseclonebundlesmanifestZfilterclonebundleentriesZ
unfiltered� changelogZ ancestorsr �getr Z compenginesZ _bundlenames� TypeError�issubset�all�anyr �debug�open�IOError)r! r r0 �clheadsrg �commonr� ZmanifestrR Z compformats�entry�compZaltcompZ bundle_headsZ bundle_bases�pathr r� r �find_pullbundlei sZ
�
r� rs rK c
C s� t dtj�� |�}t�|�D ]�\}}tj| }|dkrFt�|�||< q |dkrbt|�d��||< q |dkr~t |�d��||< q |dkr�|dkr�d||< q�t
|�||< q |d kr t d
| ��q t | d �s�t
�|�d ��s�|jd
kr�t�t�S tjttd���z t | j�� �}t |�dt � ��}t |�dt � ��} | �| j� | j� dd��r�d|� � v �r�t | ||||| �}
|
�r�tj t �!|
�dd�W S | j� dd��r�|�dd�} | �r�| �s�||k�r�tjt"d�t"d�d��t
j#| dfi t�$|���\} }
| �dd�}W n� tj�y� } z�t
�|�d ���sJ|jd
k�rHt�|j%d �W Y d }~S � t&�'| j�}d |j%fg}g }|j(d u�r�|�)d |j(f� |�*t&�+d ||�� |�,� }
d}W Y d }~n
d }~0 0 tj |
| d�S ) Nrs rj s csvr s scsvs boolean� 0Fs plains unknown getbundle option type %sr< s
bundlecaps� http-v1��hintr� s commonr s
pullbundles partial-pullT)r� Zprefer_uncompresseds disablefullbundles cgs% server has pull-based clones disableds/ remove --pull if specified or upgrade Mercurialr~ s prefercompressedr\ � message� hint� error:abort)-r2 r ZGETBUNDLE_ARGUMENTSr. r rd rZ ru r �set�bool�KeyErrorr8 r
Zbundle2requestedr� rB rO �bundle2requiredr �Abort�bundle2requiredmain�bundle2requiredhintr� rg �discardZnullidr r4 r r� r� r Z
filechunkiterr Zgetbundlechunksr� �messager �bundle20r� rQ �addpart�
bundlepart� getchunks)r! r r/ r0 r1 r7 Zkeytyper� rg r� Zbundler �info�chunksZprefercompressed�exc�bundler�manargs�advargsr r r � getbundle� s� �
�
�
� ���
�r� r� c C s | � � }t�t�|�d �S )Nr\ )rg r rP r^ )r! r r� r r r rg � s rg s helloc C s t | |�j}t�d| �S )af Called as part of SSH handshake to obtain server info.
Returns a list of lines describing interesting things about the
server, in an RFC822-like format.
Currently, the only one defined is ``capabilities``, which consists of a
line of space separated tokens describing server abilities:
capabilities: <token0> <token1> <token2>
s capabilities: %s
)r{ rM r rP rz r r r �hello s r� s listkeys� namespacec C s( t | �t�|���� �}t�t�|��S r$ ) rw �listkeysr �tolocalrD r rP �
pushkeymodZ
encodekeys)r! r � namespace�dr r r r� s r� rp � keyc
C sj z$t �|�}| �|�}t|�}d}W n2 tyV } zt�|�}d}W Y d }~n
d }~0 0 t�d||f �S )Nr r s %d %s
) r r� �lookupr � Exceptionr � forcebytestrr rP )r! r rV r1 rU r` �success�instr r r r� s
r� rr s nodes *c C s* d� dd� | �t�|��D ��}t�|�S )Nr= c s s | ]}|rd pdV qdS )� 1r� Nr )r: ra r r r r� ) s zknown.<locals>.<genexpr>)r, �knownr rZ rP )r! r ri r/ r7 r r r r� ' s
�r� s protocapss capsc C s& |j tjkr t|�d��|_t�d�S )NrI s OK)rB r ZSSHV1r� r Z
_protocapsrP rz r r r � protocaps/ s r� rq s namespace key old newc C s� t |�dkrHt�|�|krHz|�d� t�|�}W qR tyD Y qR0 n
t�|�}|�� �6}| �t�|�t�|�t�|�|�p�d}W d � n1 s�0 Y |r�|� � nd}t
� dt |�|f �S )N� zutf-8Fr= s %d
%s)
�lenr Z escapestr�decoder r� �UnicodeDecodeError�mayberedirectstdior �getvaluer rP �int)r! r r� rV �old�new�outputr` r r r r 6 s$
��
r s
stream_outc C s t �t�| ��S )z�If the server supports streaming clone, it advertises the "stream"
capability with a value representing the version and flags of the repo
it is serving. Client checks to see if it understands the format.
)r �streamreslegacyr Zgeneratev1wireprotorn r r r �streamS s r� s unbundlec sT t �|�}|�� ��*}�z�t�| |d� dd� }�zx|�� �| j�dd�rb�fdd�}t� ��� nfd\� �� �fd d�}t
j d
d �\}�| j� d � � t
�|t
�d
��� �D ]}� �|� q�� �d� t�| j� d �}t|tj��r.t| d��s.|jdk�r t �t�W |� W W d � S tjt t d��t� | ||d|� � �} t� | d��rzt j!| �"� d�W |� W W d � S t �#| |�r�|�$� nd�W |� W W d � S |� 0 W �nv tj%tjtj&f�y. }
�zNt'|
dd��s�z� W n� tj�yb }
zZt(j)�|
�*� � t(j)�+� t �#d|�r.|�$� nd�W Y d }
~
W Y d }
~
W d � S d }
~
0 tj&�y� t �,t
�-|
�|�r�|�$� nd� Y W Y d }
~
W d � S 0 t.�/| j�} t'|
dd�D ]} | �0| � �qʐzz� W �n tj1�y� }
z�t'|
dd �}
|
d u�r&d|
�2d d�v�r&� | �3d �}|�4d |
j5� |
j6d u�r\|j4d |
j6dd � |
j7d u�rz|j4d!|
j7dd � |
j8d u�r�|j4d"|
j8dd � |
j9d u�r�|j4d#|
j9dd � |
j:d u�r�|j4d$|
j:dd � W Y d }
~
n
d }
~
0 0 W �n tj%�yV }
zL| �3d%�}|
j;d u�r&|�4d&|
j;� |
j<�rB|�4d'd(�=|
j<�� W Y d }
~
n�d }
~
0 tj�y� }
zLd)|
j>fg}g }|
j?d u�r�|�@d*|
j?f� | �0t.�Ad+||�� W Y d }
~
nHd }
~
0 tj&�y� }
z$| �3d,d)tB�C|
�fg� W Y d }
~
n
d }
~
0 0 t j!| �"� d�W Y d }
~
W d � S d }
~
0 0 W d � n1 �sF0 Y d S )-Ns preparing changesc S s d S r$ r r r r r r� c r= zunbundle.<locals>.<lambda>r s streamunbundlec s � D ]} qd S r$ r )r[ )�payloadr r �cleanuph s zunbundle.<locals>.cleanup)NNc s � r � � � �rt��� d S r$ )�close�os�unlinkr )�fp�tempnamer r r� s s s hg-unbundle-)�prefixs" redirecting incoming bundle to %s
s wb+r r9 r� r� r~ s addpartr� r= Zduringunbundle2FZ_bundle2salvagedoutputr Z
_replycapsrq s errors
error:pushkeys in-reply-tor� )Z mandatoryr� s news olds rets error:unsupportedcontents parttypes params� r� r� r� s error:pushraced)Dr rZ r� r
Z check_headsZ
getpayloadr r4 r Z chunkbufferr Zmkstempr� r� �fdopenZsysstrr+ �seekZ
readbundlerE r� Z cg1unpackerr8 rB rO r� r r� r� r� �unbundleZclientZ safehasattrr� r� Zpushresr� ZBundleValueErrorZ PushRacedr r r* �format�flushZpusherrZbytestrr r� r� Z
PushkeyFailedr� ZnewpartZaddparamZpartidr� rV r� r� �retZparttype�paramsr, r� r� rQ r� r r� )r! r rg Z their_headsr� r� �fdr[ r� r` r� r� �outZ
remotecaps�partZerrpartr� r� r )r� r� r� r r� \ s�
�
��
������
�2�$ ��
� .
( ��r� )Nr9 )>Z
__future__r r� r� Zi18nr Znoder r r � r r r r� r
r r r
r r� r r3 r r r Zutilsr r Zurlerrre r� r� r� r r# r) r2 r8 Z commanddictr% rG rX r] rc rk ro rv ry r{ r� r� r� r� rg r� r� r� r� r� r� r� r r r r �<module> s| <�
0
-
+
F
N