File: //usr/lib/python3/dist-packages/hgext/narrow/__pycache__/narrowwirepeer.cpython-310.pyc
o
�]LbU � @ st d dl mZ d dlmZmZmZmZmZmZm Z m
Z
ddl m Z dd� Z
dd� Ze
jd d
d d �d
d� �Zdd� ZdS )� )�absolute_import)�bundle2�error�
extensions�hg�
narrowspec�wireprototypes�wireprotov1peer�wireprotov1server� )�
narrowbundle2c C s t tj_d S )N)�peernarrowwidenr �wirepeer� narrow_widen� r r �=/usr/lib/python3/dist-packages/hgext/narrow/narrowwirepeer.py�uisetup s r c s � fdd�}t j�|� d S )Nc s � fdd�}t �|d|� d S )Nc sD |dkr� j \}}d�|�|d< d�|�|d< | |g|�R i |��S )Ns unbundle� ,� includepats� excludepats)�
narrowpats�join)�orig�cmd�args�kwargs�include�exclude��repor r �wrapped s
z1reposetup.<locals>.wirereposetup.<locals>.wrappeds _calltwowaystream)r � wrapfunction)�ui�peerr r r r �
wirereposetup s z reposetup.<locals>.wirereposetup)r �wirepeersetupfuncs�append)r r$ r r r � reposetup s r' � narrow_widensT oldincludes oldexcludes newincludes newexcludes commonheads cgversion known ellipsess pull)�
permissionc
C s� d}
z{dd� } | |�}| |�}| |�}| |�}t �t|�� t �t|�� t �t|�� t �t|�� t�|�} t�|�}| dkrDd} nt| �} |}t�| j�}
t j | j
||d�}t j | j
||d�}| sqt� |
| ||| ||| � n t �
|
| |||| |� W n: tjy� } z-t�| j�}
d|jfg}g }|jdur�|�d|jf� |
�t�d ||�� d
}
W Y d}~nd}~ww |
�� }tj||
d �S ) a� wireprotocol command to send data when a narrow clone is widen. We will
be sending a changegroup here.
The current set of arguments which are required:
oldincludes: the old includes of the narrow copy
oldexcludes: the old excludes of the narrow copy
newincludes: the new includes of the narrow copy
newexcludes: the new excludes of the narrow copy
commonheads: list of heads which are common between the server and client
cgversion(maybe): the changegroup version to produce
known: list of nodes which are known on the client (used in ellipses cases)
ellipses: whether to send ellipses data or not
Fc S s | r| � d�S g S )Nr )�split)�datar r r �
splitpathsQ s z narrow_widen.<locals>.splitpaths� 0)r r s messageNs hints error:abortT)�gen�prefer_uncompressed)r �validatepatterns�setr �
decodelist�boolr �bundle20r" �match�root� widen_bundler �&generate_ellipses_bundle2_for_wideningr �Abort�message�hintr& �addpart�
bundlepart� getchunks� streamres)r �proto� oldincludes� oldexcludes� newincludes� newexcludes� commonheads� cgversion�known�ellipses�preferuncompressedr, �common�bundler�newmatch�oldmatch�exc�manargs�advargs�chunksr r r r , sv "
��� ��
�� �r c K sj dD ] }t �|| �||< qdD ] }d�|| �||< qdt|d � |d< | jdi |��}t�| j|�S )N)rE rG )rA rC rB rD r s %irH r( )r( )r �
encodelistr r3 �_callcompressabler � getunbundlerr" )�remoter �ch�fr r r r
� s r
N)�
__future__r � mercurialr r r r r r r r
� r r r' �wireprotocommandr r
r r r r �<module> s ( �
^