| 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/hgext/lfs/__pycache__/ |
Upload File : |
a
�+�b3C � @ s� d dl mZ d dlZd dlmZ d dlmZmZmZ d dl m
Z
m Z d dl m
Z
mZmZmZmZmZmZmZmZmZmZmZmZmZ d dl m Z m Z d dl!m"Z" d d l#m$Z$m%Z% d
d l&m'Z' d d
l(m)Z)m*Z* e�� Z+e+�,ed�dd� �Z-e+�,ed�dd� �Z.e+�,ed�dd� �Z/dd� Z0dd� Z1dd � Z2dYd d �Z3ddej4fd d �Z5d!d"� Z6d#d$� Z7e+�,ed%�d&d'� �Z8e+�,ej9d(�d)d*� �Z:e+�,ej9d+�d,d-� �Z;d.d/� Z<e+�,ed0�d1d2� �Z=e+�,ed3�d4d5� �Z>e+�,ej?d6�d7d8� �Z@d9d:� ZAd;d<� ZBd=d>� ZCd?d@� ZDdAdB� ZEe+�,edC�dDdE� �ZFe+�,e
dF�dGdH� �ZGdIdJ� ZHdZdLdM�ZId[dNdO�ZJdPdQ� ZKe+�,e dR�dSdT� �ZLe+�,e dU�e+�,e dV�dWdX� ��ZMdS )\� )�absolute_importN)�_)�bin�hex�short)�getattr�setattr)�bundle2� changegroup�cmdutil�context�error�exchange� exthelper� localrepo�pycompat�revlog�scmutil�util�vfs�wireprotov1server)�actions�engine)�
repository)� storageutil�
stringutil� )�lfutil� )� blobstore�pointers makefilestoragec K s( d|v r|� tj� | f ||d�|��S )N� lfs)� requirements�features)�addr ZREPO_FEATURE_LFS)�origr" r# �kwargs� r' �7/usr/lib64/python3.9/site-packages/hgext/lfs/wrapper.py�localrepomakefilestorage: s r) s allsupportedversionsc C s | |�}|� d� |S )Ns 03)r$ )r% �uiZversionsr' r' r( �allsupportedversionsB s
r+ s
_capabilitiesc C s: | ||�}t �|jd�r6d|jv r,|�d� |�d� |S )z5Wrap server command to announce lfs server capability� lfslocalblobstorer! s lfs-serve)r � safehasattr�svfsr" �append)r% �repo�protoZcapsr' r' r( �
_capabilitiesI s
r2 c C s dS �NFr' )�self�textr' r' r( �bypasscheckhashY s r6 c C s� t �|�}|�� }| jj}|�|�s>| j|_| jj�|g|� |j |dd�}i }|�
� D ]*}|� d�rX|t d�d� }|| ||< qX|s�|� d�r�t
�||�}|dfS )a% Read filelog content from local blobstore transform for flagprocessor.
Default tranform for flagprocessor, returning contents from blobstore.
Returns a 2-typle (text, validatehash) where validatehash is True as the
contents of the blobstore should be checked using checkhash.
F)Zverifys x-hg-Ns
T)r � deserialize�oid�opener�lfslocalblobstore�has�filename�lfsremoteblobstore� readbatch�read�keys�
startswith�lenr Zpackmeta)r4 r5 �pr8 �store�hgmeta�k�namer' r' r( �
readfromstore] s
rH c
C s� t �|�\}}|r&|dkr&||d � }tt�|��� �}| jj�||� d| }t j
|dt |� d�}t �
|�sxd|d< |d ur�t�|�D ]\}}||d| < q�|�� } | dfS ) Nr s sha256:%ss %d)r8 �size� 0� x-is-binarys x-hg-%sF)r � parsemetar �hashlibZsha256�digestr9 r: �writer Z
gitlfspointerrB r Zbinaryr Z iteritemsZ serialize)
r4 r5 rE �offsetr8 Zlongoid�metadatarF �v�rawtextr' r' r( � writetostorez s
rT c C sP |d u r |d u rdS | � |�}n
| �|�}|| jkr8dS | �|�}t|tj@ �S r3 )�rev�nodeZnullid�flags�boolr �REVIDX_EXTSTORED)ZrlogrV rU rW r' r' r( �_islfs� s
rZ c
K sp |j jj�d�} | rNt|�} t�|�\}
}|r6| |8 } | |j j| �rN| tj O } | ||||||f||| d�|
��S )Ns lfstrack)�
cachedeltarV rW )
�_revlogr9 �options�getrB r rL r< r rY )r% r4 r5 Z transaction�link�p1�p2r[ rV rW �kwdsZlfstrackZtextlen�metarP r' r' r( �filelogaddrevision� s,
��
�rd c C s\ t |j|�rR|j�|�}|s dS t�|�}d|v rNd|v rN|d t|d �fS dS | ||�S )NFs x-hg-copys x-hg-copyrev)rZ r\ �rawdatar r7 r )r% r4 rV rS rQ r' r' r( �filelogrenamed� s
rf c C s: t |j|d�r0|j�|�}t�|�}t|d �S | ||�S )N)rU s size)rZ r\ re r r7 �int)r% r4 rU rS rQ r' r' r( � filelogsize� s
rh s _verify_revisionc C sj t ||d�rX|�|�}t�|�}|jj�|�� �r@|tj M }n|tj @ rX|d �
|� | ||||� d S )N)rV s safe_renamed) rZ re r r7 r9 r: r; r8 r rY r$ )r% ZrlZ skipflags�staterV rS rQ r' r' r( �_verify_revision� s
rj s cmpc C sP |� � rFt|ddd� �� rFt�|�� �}t�|�� �}|�� |�� kS | ||�S )z+returns True if text is different than fctx�islfsc S s dS r3 r' r' r' r' r( �<lambda>� � z filectxcmp.<locals>.<lambda>)rk r r r7 re r8 )r% r4 �fctxr` ra r' r' r( �
filectxcmp� s
ro s isbinaryc C s2 |� � r*t�|�� �}tt|�dd���S | |�S )NrK r )rk r r7 re rX rg r^ )r% r4 rQ r' r' r( �filectxisbinary s rp c C s t | �� j| �� �S �N)rZ �filelogr\ �filenode)r4 r' r' r( � filectxislfs s rt s _updatecatformatterc C s( | |||||� |j || �� d� d S )N)re )�datare )r% Zfm�ctxZmatcher�path�decoder' r' r( �_updatecatformatter s ry s wrapconvertsinkc s2 | |�}|j dkr.G � fdd�d|j�� � |_|S )Ns hgc s e Zd Z� �fdd�Z� ZS )z convertsink.<locals>.lfssinkc sl t �| �j} | ||||||||�}
d| jjvrh| j|
� t� fdd�|D ��rh| jj�d� t�| j� |
S )Nr! c 3 s& | ] \}}|� v o � | � � V qd S rq )rk )�.0�f�n�rv r' r( � <genexpr>= rm z9convertsink.<locals>.lfssink.putcommit.<locals>.<genexpr>)�super� putcommitr0 r" �anyr$ r Zwritereporequirements) r4 �filesZcopies�parentsZcommit�sourceZrevmapZfullZcleanp2ZpcrV )� __class__�lfssinkr} r( r� ! s" �
z&convertsink.<locals>.lfssink.putcommit)�__name__�
__module__� __qualname__r� �
__classcell__r' �r� )r� r( r� s r� )Zrepotyper� )r% Zsinkr' r� r( � convertsink s
#r� s __init__c C s^ | ||� |j �� D ] \}}|�d�r||j |< qdD ]"}t�||�r6t||t||�� q6d S )Nr! )r, � lfsremoteblobstore)r] �itemsrA r r- r r )r% r4 ZothervfsrF rR rG r' r' r( �vfsinitJ s
r� c
C s� t �| jd�sdS g }t� }| jj}|D ]f\}}| | }|�|�D ]J}t||�} | rB| �� |vrB|�| �� �sB|| _ |�
| � |� | �� � qBq(|r�t �
| ��||� dS )zSEnsure that required LFS blobs are present, fetching them as a group if
needed.r, N)r r- r. �setr: �walk�pointerfromctxr8 r; r< r/ r$ r �remoter> )
r0 Z
revmatches�pointersZoidsZ
localstorerU �matchrv r{ rC r' r' r( �_prefetchfilesX s
r� c C s" t �| jd�sdS t| jjtj�S )Nr� T�r r- r. �
isinstancer= r Z _nullremote�r0 r' r' r( �_canskipuploadq s r� c C s$ t �| jd�sdS t| jjtj� S )Nr� Fr� r� r' r' r( � candownloadz s r� c C s$ t | �r dS t| |�}t| |� dS )zuupload lfs blobs introduced by revs
Note: also used by other extensions e. g. infinitepush. avoid renaming.
N)r� �extractpointers� uploadblobs)r0 �revsr� r' r' r( �uploadblobsfromrevs� s
r� c C s t | j| jj�S )z�Prepush hook.
Read through the revisions to push, looking for filelog entries that can be
deserialized into metadata so that we can block the push on their upload to
the remote blobstore.
)r� r0 �outgoing�missing)Zpushopr' r' r( �prepush� s r� s pushc O s� d|j v r�|�� s:|�d�s:td�}tj|d td�d��|jj}z6t� ||�
� �|j_| ||g|�R i |��W ||j_S ||j_0 n| ||g|�R i |��S dS )z�bail on push if the extension isn't enabled on remote when needed, and
update the remote store based on the destination path.r! s: required features are not supported in the destination: %ss& enable the lfs extension on the server)�hintN) r" �localZcapabler r
�Abortr. r= r r� �url)r% r0 r� �argsr& �mZ remotestorer' r' r( �push� s
�� r� s writenewbundlec O s, t ||j� | ||||||g|�R i |��S )z;upload LFS blobs added by outgoing revisions on 'hg bundle')r� r� ) r% r* r0 r� r< Z
bundletyper� r� r& r' r' r( �writenewbundle� s ���r� c C s� | j �d� i }| j j}|td�td�t|���\}|D ]2}| | }t|��� D ]}|||�� < qN|�� q6t |�� dd� d�W d � S 1 s�0 Y dS )z1return a list of lfs pointers added by given revss& lfs: computing set of blobs to upload
s
lfs searchs
changesetsc S s | � � S rq )r8 )rC r' r' r( rl � rm z!extractpointers.<locals>.<lambda>)�keyN)
r* �debug� makeprogressr rB �pointersfromctx�valuesr8 Z increment�sorted)r0 r� r� r� Zprogress�rrv rC r' r' r( r� � s �
r� Fc
C s� | }|| vrD|sdS || � � v r*| � � }n|| �� v r@| �� }ndS || }t|�� j|�� �sddS z"t�|�� �}| |kr�|W S i W S tj y� } z,t
� t d�|t
|�� �|f ��W Y d}~n
d}~0 0 dS )a? return a pointer for the named file from the given changectx, or None if
the file isn't LFS.
Optionally, the pointer for a file deleted from the context can be returned.
Since no such pointer is actually stored, and to distinguish from a non LFS
file, this pointer is represented by an empty dict.
Ns# lfs: corrupted pointer (%s@%s): %s
)r` ra rZ rr r\ rs r r7 re ZInvalidPointerr
r� r r rV )rv r{ �removedZ_ctxrn rC �exr' r' r( r� � s.
��r� c C sJ i }| � � �� }| �� D ],}||�s&qt| ||d�}|dur|||< q|S )z�return a dict {path: pointer} for given single changectx.
If ``removed`` == True and the LFS file was removed from ``ctx``, the value
stored for the path is an empty dict.
)r� N)r0 Z narrowmatchr� r� )rv r� �resultr� r{ rC r' r' r( r� � s
r� c C s$ |sdS | j j}|�|| j j� dS )z*upload given pointers from local blobstoreN)r. r= Z
writebatchr: )r0 r� Z
remoteblobr' r' r( r� s r� s finishdatamigrationc C s� | ||||� t �|jd�r�t �|jd�r�|jjj}|jjj}|�� D ]>\}}} | D ].}
|�td�|
� t� |�
|
�|�
|
�� qTqFd S )Nr, s copying lfs blob %s
) r r- r. r: r r� rO r r r_ �join) r% r* ZsrcrepoZdstrepor" Z srclfsvfsZ dstlfsvfs�dirpath�dirsr� r8 r' r' r( �upgradefinishdatamigration s � �
r� s preservedrequirementss supporteddestrequirementsc C s | |�}d|j v r |�d� |S )Nr! )r" r$ )r% r0 Zreqsr' r' r( �upgraderequirements s
r� )NN)F)F)NZ
__future__r rM Zmercurial.i18nr Zmercurial.noder r r Zmercurial.pycompatr r Z mercurialr r
r r r
r r r r r r r r Zvfsmodr Zmercurial.upgrade_utilsr Zupgrade_actionsr Zupgrade_engineZmercurial.interfacesr Zmercurial.utilsr r Z
largefilesr � r r ZehZ wrapfunctionr) r+ r2 r6 rH rT rZ ZREVIDX_DEFAULT_FLAGSrd rf rh rj Z basefilectxro rp rt ry r� Z readonlyvfsr� r� r� r� r� r� r� r� r� r� r� r� r� r� r' r' r' r( �<module> st @
�
)
.
!