| 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/infinitepush/__pycache__/ |
Upload File : |
a
�+�b� � @ s� d dl mZ d dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
d dl m Z m
Z
G dd� de�ZG d d
� d
e�ZG d d � d e�ZG d
d� de�Zddd�ZG dd� de�ZdS )� )�absolute_importN)�hex)�open)�pycompat)�hashutil�procutilc @ s e Zd ZdS )�BundleWriteExceptionN��__name__�
__module__� __qualname__� r
r
�>/usr/lib64/python3.9/site-packages/hgext/infinitepush/store.pyr s r c @ s e Zd ZdS )�BundleReadExceptionNr r
r
r
r r s r c @ s2 e Zd ZdZejZejdd� �Zejdd� �Z dS )�abstractbundlestorea6 Defines the interface for bundle stores.
A bundle store is an entity that stores raw bundle data. It is a simple
key-value store. However, the keys are chosen by the store. The keys can
be any Python object understood by the corresponding bundle index (see
``abstractbundleindex`` below).
c C s dS )z�Write bundle data to the store.
This function receives the raw data to be written as a str.
Throws BundleWriteException
The key of the written data MUST be returned.
Nr
)�self�datar
r
r �write( s zabstractbundlestore.writec C s dS )z�Obtain bundle data for a key.
Returns None if the bundle isn't known.
Throws BundleReadException
The returned object should be a file object supporting read()
and close().
Nr
)r �keyr
r
r �read1 s zabstractbundlestore.readN)
r
r r �__doc__�abc�ABCMetaZ
__metaclass__�abstractmethodr r r
r
r
r r s
r c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
�filebundlestorezkbundle store in filesystem
meant for storing bundles somewhere on disk and on network filesystems
c C sP || _ || _|�dd�| _| js2| jj�dd�| _tj�| j�sLt� | j� d S )Ns
scratchbranchs storepaths scratchbranchess filebundlestore)
�ui�repoZ
configpath� storepathZvfs�join�os�path�exists�makedirs)r r r r
r
r �__init__B s �zfilebundlestore.__init__c C s" t j�| j|dd� |dd� �S )z�First two bytes of the hash are the name of the upper
level directory, next two bytes are the name of the
next level directoryr � � )r r r r )r � hashvaluer
r
r �_dirpathM s zfilebundlestore._dirpathc C s t j�| �|�|�S )N)r r r r' )r �filenamer
r
r � _filepathS s zfilebundlestore._filepathc C sp t t�|��� �}| �|�}tj�|�s2t�|� t | �
|�d��}|� |� W d � n1 sb0 Y |S )Ns wb) r r Zsha1�digestr' r r r! r" r r) r )r r r( �dirpath�fr
r
r r V s
(zfilebundlestore.writec C sX z>t | �|�d��}|�� W d � W S 1 s20 Y W n tyR Y d S 0 d S )Ns rb)r r) r �IOError)r r r, r
r
r r b s
, zfilebundlestore.readN) r
r r r r# r' r) r r r
r
r
r r < s r c C sL g }| D ]>}|r$|dkr$|� |� q|r<|dkr<|� |� q|� |� q|S )z�Formats `args` with Infinitepush replacements.
Hack to get `str.format()`-ed strings working in a BC way with
bytes.
s
{filename}s {handle})�append)�argsr( �handle�formatted_args�argr
r
r �format_placeholders_argsj s r3 c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�externalbundlestorec C s || _ || _|| _|| _dS )a6
`put_binary` - path to binary file which uploads bundle to external
storage and prints key to stdout
`put_args` - format string with additional args to `put_binary`
{filename} replacement field can be used.
`get_binary` - path to binary file which accepts filename and key
(in that order), downloads bundle from store and saves it to file
`get_args` - format string with additional args to `get_binary`.
{filename} and {handle} replacement field can be used.
N)�put_args�get_args�
put_binary�
get_binary)r r7 r5 r8 r6 r
r
r r# | s z externalbundlestore.__init__c C s< t jt�tj|�t jt jdd�}|�� \}}|j}|||fS )NT)�stdout�stderrZ close_fds) �
subprocess�Popenr Zrapplyr Z tonativestr�PIPEZ communicate�
returncode)r r/ �pr9 r: r> r
r
r � _call_binary� s � z externalbundlestore._call_binaryc C s� t �� ��}|�|� |�� |�d� t| j|jd�}| �| j g| �\}}}|dkrbt
d| ��|� � }t |�dkr�|d W d � S t
d| j |f ��W d � n1 s�0 Y d S )Nr )r( s& Failed to upload to external store: %s� s Bad output from %s: %s)
r �
namedtempfiler �flush�seekr3 r5 �namer@ r7 r �
splitlines�len)r r �tempr1 r> r9 r: Z stdout_linesr
r
r r � s(
�
�
� �zexternalbundlestore.writec C sr t �� �V}t| j|j|d�}| �| jg| �\}}}|dkrHtd| ��|�� W d � S 1 sd0 Y d S )N)r( r0 r s* Failed to download from external store: %s) r rB r3 r6 rE r@ r8 r r )r r0 rH r1 r> r9 r: r
r
r r � s
�
�
�zexternalbundlestore.readN)r
r r r# r@ r r r
r
r
r r4 { s r4 )NN)Z
__future__r r r r; Zmercurial.noder Zmercurial.pycompatr Z mercurialr Zmercurial.utilsr r � Exceptionr r �objectr r r3 r4 r
r
r
r �<module> s .