|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/tracopt/versioncontrol/git/__pycache__/ |
Upload File : |
o
�k�`6� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
m Z d dlm Z m
Z
d dlmZ d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZmZ g d �ZG d d
� d
e�Z G dd� de �Z dd� Z e� d� d��Z!e"d�Z#e$dd�D ]\Z%Z&e&e#e%< q�[%[&e'e#�Z#dd� Z(dd� Z)dd � Z*G d d � d e+�Z,G d d � d e-�Z.G d!d"� d"e+�Z/G d#d$� d$e+�Z0dS )%� N)�deque)�partial)�DEVNULL�PIPE)�Lock)�
TracBaseError)� terminate)� close_fds)�time_now)�exception_to_unicode�
to_unicode)�GitError� GitErrorSha�Storage�StorageFactoryc @ � e Zd ZdS )r
N��__name__�
__module__� __qualname__� r r �B/usr/lib/python3/dist-packages/tracopt/versioncontrol/git/PyGIT.pyr
% � r
c @ r )r Nr r r r r r ( r r c C s� | st �| �� }|s t �|�d�}i }d }}|ra|d dkr4|s*|}|| d g}|�|dd� � n|�dd�\}}|�|g ��|�� � |�d�}|r_|rT||kr_d�|�|| d< d}|sd�|�|fS )z�Parse the raw content of a commit (as given by `git cat-file -p <rev>`).
Return the commit message and a dict of properties.
r N� ���� �
)r �
splitlines�pop�append�split�
setdefault�strip�join)�raw�lines�line�props� multiline�
multiline_key�key�valuer r r � parse_commit- s,
�
r, z\\(?:[abtnvfr"\\]|[0-7]{3})�utf-8� s abtnvfr"\s
"\c C s4 | � d�r| �d�rdd� }t�|| dd� �} | S )N� "c S sD | � d�} t| �dkrt| dd � d�}d| S t| d }d| S )Nr � r � s %c)�group�len�int�_unquote_chars)�match�coder r r �replaceT s
�z_unquote.<locals>.replacer r )�
startswith�endswith� _unquote_re�sub)�pathr8 r r r �_unquoteR s r> c C s | d ur t | d�} | S �N�ascii)�str��revr r r �_rev_u_ �
rD c C s | d ur | � d�} | S r? ��encoderB r r r �_rev_be rE rH c @ st e Zd ZdZ ddd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z e
�d�Zedd� �ZdS )�GitCorez'Low-level wrapper around git executableN�gitc C s || _ || _|| _|| _d S �N)�_GitCore__git_bin�_GitCore__git_dir�
_GitCore__log�_GitCore__fs_encoding)�self�git_dir�git_bin�log� fs_encodingr r r �__init__n s
zGitCore.__init__c C s d| j | jf S )Nz<GitCore bin="%s" dir="%s">)rL rM �rP r r r �__repr__u s �zGitCore.__repr__c sv | j g}| jr|�d| j � |�|� |�|� | j� � dur9tjdkr,� fdd�}n� fdd�}tt||��}|S )z9construct command tuple for git call suitable for Popen()z --git-dir=%sN�ntc � t | t�r | �� d�} | S �Nr8 )�
isinstance�bytes�decode��arg�rT r r �to_cmd_encoding� �
z0GitCore.__build_git_cmd.<locals>.to_cmd_encodingc rY rZ )r[ rA rG r^ r` r r ra � rb ) rL rM r �extendrO �os�name�list�map)rP �gitcmd�args�cmdra r r` r �__build_git_cmdy s
zGitCore.__build_git_cmdc O sH |� dt� |� dt� |� dt� tj| j|g|�R � fdti|��S )N�stdin�stdout�stderrr )r! r �
subprocess�Popen�_GitCore__build_git_cmdr )rP �git_cmd�cmd_args�kwr r r �__pipe� s ��zGitCore.__pipec G sp | j |dti��}|�� \}}W d � n1 sw Y | jr6|jdks(|r6| j�d| j|j| j||� |S )z9execute git command and return file-like object of stdoutrl Nr z/%s exits with %d, dir: %r, args: %r, stderr: %r)�_GitCore__piper � communicaterN �
returncode�debugrL rM )rP ri �p� stdout_data� stderr_datar r r � __execute� s � �zGitCore.__executec C s | � dd�S )Nzcat-filez--batch�rv rV r r r �cat_file_batch� � zGitCore.cat_file_batchc G s | j dg|�R � S )NrS r~ )rP rs r r r �log_pipe� s zGitCore.log_pipec C s | � dddddd�S )Nz diff-treez--stdin�--root�-z�-r�-Mr~ rV r r r �diff_tree_pipe� s zGitCore.diff_tree_pipec C s. |� d�s |dv r
t|��t| j|�dd��S )N�_)r r� r� �-)r9 �AttributeErrorr �_GitCore__executer8 )rP re r r r � __getattr__� s
zGitCore.__getattr__s [0-9A-Fa-f]{4,40}$c C s0 dt |� kr
dksdS dS t| j�|��S )znreturns whether sha is a potential sha id
(i.e. proper hexstring between 4 and 40 characters)
r0 �( F)r3 �bool�_GitCore__is_sha_patr6 )�cls�shar r r �is_sha� s
�zGitCore.is_sha)NrJ NN)r r r �__doc__rU rW rq rv r� r r� r� r� �re�compiler� � classmethodr� r r r r rI k s
�
rI c @ s* e Zd ZdZd
dd�Zdd� Zdd� Zd S ) � SizedDictz6Size-bounded dictionary with FIFO replacement strategyr c C s$ t �| � || _t� | _t� | _d S rK )�dictrU �_SizedDict__max_sizer �_SizedDict__key_fifor �_SizedDict__lock)rP �max_sizer r r rU � s
zSizedDict.__init__c C s� | j �J t| �t| j�ksJ �| �|�s| j�|� t�| ||�}t| j�| jkr9| �| j� � � t| j�| jks)t| �t| j�ksDJ �|W d � S 1 sPw Y d S rK )
r� r3 r� � __contains__r r� � __setitem__r� � __delitem__�popleft)rP re r+ �rcr r r r� � s
�$�zSizedDict.__setitem__c G s t d��)Nz$SizedDict has no setdefault() method)�NotImplementedError)rP r� r r r r! � � zSizedDict.setdefaultN)r )r r r r� rU r� r! r r r r r� � s
r� c @ sP e Zd Ze�� Zi Zi Ze� Z d dd�Z
dd� Z e dd � �Z
e d
d � �ZdS )
r TrJ Nc
C s� || _ | j�E |rz| j|= W n ty Y nw z| j| }W n ty< | j�|�}t|||||�}|| j|< Y nw |sD|| j|< W d � n1 sNw Y || _| j � d|r^dnd|� d S )Nz,requested %s PyGIT.Storage instance for '%s'�weakznon-weak)
�logger�_StorageFactory__dict_lock� _StorageFactory__dict_nonweak�KeyError�_StorageFactory__dict� _StorageFactory__dict_rev_cache�getr �_StorageFactory__instry )rP �reporS r� rR �git_fs_encoding�i� rev_cacher r r rU � s. � �
� � �zStorageFactory.__init__c C s | j S rK )r� rV r r r � getInstance s zStorageFactory.getInstancec C s6 | j � || j|< W d � d S 1 sw Y d S rK )r� r� )r� r� r� r r r �
set_rev_cache s "�z StorageFactory.set_rev_cachec C sJ | j � | j�� | j�� | j�� W d � dS 1 s w Y dS )zFor testing purpose onlyN)r� r� �clearr� r� �r� r r r �_clean s
"�zStorageFactory._clean)TrJ N)r r r �weakref�WeakValueDictionaryr� r� r� r r� rU r� r� r� r� r r r r r � s
�
r c @ s� e Zd ZdZdZG dd� de�Zedd� �Zedhdd ��Z
did d �Z
d
d� Z dd� Z dd� Z
edd� �Zdjdd�Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zdjd&d'�Zd(d)� Zd*d+� Zd,d-� Zd.d/� Z d0d1� Z d2d3� Z d4d5� Z d6d7� Z dkd9d:�Z!d;d<� Z"dld=d>�Z#dmd@dA�Z$dBdC� Z%dDdE� Z&dFdG� Z'dHdI� Z(dldJdK�Z)dLdM� Z*dNdO� Z+dPdQ� Z,e-j.dRdS� �Z/dldTdU�Z0dldVdW�Z1dXdY� Z2dZd[� Z3d\d]� Z4d^d_� Z5dmd`da�Z6dbdc� Z7ddde� Z8dfdg� Z9d
S )nr z8High-level wrapper around GitCore with in-memory cachingr0 c @ s< e Zd ZdZdd� Zedd� �Zdd� Zdd � Zd
d � Z d S )
zStorage.RevCache)� youngest_rev�
oldest_rev�rev_dict� refs_dict� srev_dictc C sb || _ || _|| _|| _|| _|d ur |d ur |r |r |r d S |s+|s+|s+|s+|s+d S td| ��)NzInvalid RevCache fields: %r)r� r� r� r� r� �
ValueError)rP r� r� r� r� r� r r r rU s, ������ zStorage.RevCache.__init__c C s | d d i i i �S rK r r� r r r �empty. s zStorage.RevCache.emptyc C s( d| j | jt| j�t| j�t| j�f S )NziRevCache(youngest_rev=%r, oldest_rev=%r, rev_dict=%d entries, refs_dict=%d entries, srev_dict=%d entries))r� r� r3 r� r� r� rV r r r rW 2 s
��zStorage.RevCache.__repr__c c sH � | j �d�}| j �� D ]\}}|�d�r!|dd � |||kfV q d S )N� HEAD� refs/heads/� )r� r� �itemsr9 )rP �head�refnamerC r r r �
iter_branches9 s �
��z Storage.RevCache.iter_branchesc c s6 � | j �� D ]\}}|�d�r|dd � |fV qd S )N�
refs/tags/�
)r� r� r9 )rP r� rC r r r � iter_tags? s �
��zStorage.RevCache.iter_tagsN)
r r r � __slots__rU r� r� rW r� r� r r r r �RevCache s
r� c C sB t | �dksJ �t| d d� d�}d| kr dks J � J �|S )Nr0 � r i�� )r3 r4 )rC �srev_keyr r r � __rev_keyD s zStorage.__rev_keyrJ c
C s� d}zCt | d�}|�� �� \}|�� �� d }dd� }tt||�d���}i }||d< ||d< ||d < d
�tt|��|d < ||k|d < |W S t y[ } z
t
d
| t |�f ��d }~ww )N)r � � )rR � c S s" zt | �W S ty | Y S w rK )r4 r� ��sr r r �try_intY s
�z$Storage.git_version.<locals>.try_int� .�v_str�v_tuple� v_min_tuple�.� v_min_str� v_compatiblezQCould not retrieve GIT version (tried to execute/parse '%s --version' but got %s)) rI �versionr r" r �tuplerg r# rA � Exceptionr
�repr) rR �GIT_VERSION_MIN_REQUIRED�g�vr� r� �
split_version�result�er r r � git_versionL s(
���zStorage.git_versionNc
s� || _ d| _|p | j�� | _d| _t� | _td�| _ t� | _
d| _ t� | _ d| _
t� | _� durDt�� � � fdd�| _� fdd�| _ndd� | _| _zt�|� W n tyk } z | �||� W Y d}~nd}~ww | �|�s�tj�|d�}zt�|� W n ty� d}Y n
w | �|�r�d }|}nd}|r�td
| ��z ttj�|d �d �� W d � n1 s�w Y W n ty� } z | �||� W Y d}~nd}~ww t |||� �| _ || _ | j � d
|� dS )a( Initialize PyGit.Storage instance
`git_dir`: path to .git folder;
this setting is not affected by the `git_fs_encoding` setting
`log`: logger instance
`git_bin`: path to executable
this setting is not affected by the `git_fs_encoding` setting
`git_fs_encoding`: encoding used for paths stored in git repository;
if `None`, no implicit decoding/encoding to/from
unicode objects is performed, and bytestrings are
returned instead
NT�� c s | � � d�S rZ )r] r� �r� r r �<lambda>� s �z"Storage.__init__.<locals>.<lambda>c s
| � � �S rK rF r� r� r r r� � s
c S s | S rK r r� r r r r� � s z.gitFz#Git control files not found in '%s'�HEAD�rbz.PyGIT.Storage instance for '%s' is constructed) r� �commit_encodingr� r� �_Storage__rev_cache�_Storage__rev_cache_refreshr �_Storage__rev_cache_lockr� �_Storage__commit_msg_cache�_Storage__commit_msg_lock�_Storage__cat_file_pipe� _Storage__cat_file_pipe_lock�_Storage__diff_tree_pipe� _Storage__diff_tree_pipe_lock�codecs�lookup�_fs_to_unicode�_fs_from_unicoderd �listdir�EnvironmentError�_raise_not_readable�_control_files_existr= r# r
�openrI r� � repo_pathry ) rP rQ rS rR r� r� r� � dot_git_dir�missingr r� r rU n sb
��
�
�����zStorage.__init__c C s> |r |j |j|jfD ]}|r|�� q
t|� |�� d S d S rK )rl rm rn �closer �wait)rP �proc�fr r r �
_cleanup_proc� s � �zStorage._cleanup_procc C sj | j � | �| j� W d � n1 sw Y | j� | �| j� W d � d S 1 s.w Y d S rK )r� r r� r� r� rV r r r �__del__� s �"�zStorage.__del__c C s2 | j � d| _W d � d S 1 sw Y d S )NT)r� r� rV r r r �invalidate_rev_cache� s "�z Storage.invalidate_rev_cachec C s8 | j � | �� | jW d � S 1 sw Y dS )zrRetrieve revision cache
may rebuild cache on the fly if required
returns RevCache tuple
N)r� �_refresh_rev_cacher� rV r r r r� � s $�zStorage.rev_cacheFc C sr d}|s| j r7d| _ | �� }| jj|kr/| j�d| j� | �|�}|| _t� | j|� d}|S | j�d| j� |S )NFz'Detected changes in git repository '%s'Tz*Detected no changes in git repository '%s')
r� � _get_refsr� r� r� ry r� �_build_rev_cacher r� )rP �force� refreshed�refsr� r r r r � s"
�
��zStorage._refresh_rev_cachec sJ | j �d| j� t� }i }i }i ��fdd�� � fdd�|�� D �}dd� |�� D �}� fdd �| j�d
d d ��� D �}d �|rM|d
d
}|d d
}nd }}i ��fdd�} | j}
t |�D ]r\} } | d
}
| dd � }|�
|
|
�g �� |
� |
|v r�||
\}}}}|s�J �|r�J �|d
ks�J �nt � }t � }|
|v r�|�
|
� t|�t|�| d | |�f||
< |D ] }|�
|t � g d
t � f�\}}}}|�
|
� |�|� q�q`d �t|�dkr�dgt|�d ni }z |�� \}}t|�||< q� ty� Y nw t|�d
k�sJ �|}| �|||||�}| j �d| jt|�dt� | � |S )Nz,triggered rebuild of commit tree db for '%s'c s � � | | �S rK )r! rB )� revs_seenr r �
_rev_reuse� r� z,Storage._build_rev_cache.<locals>._rev_reusec s i | ] \}}|� |��qS r r ��.0r� rC �r r r �
<dictcomp>� � z,Storage._build_rev_cache.<locals>.<dictcomp>c S s h | ] \}}|� d �r|�qS )r� )r9 r r r r � <setcomp> s
�z+Storage._build_rev_cache.<locals>.<setcomp>c s g | ] }t t� |�� ���qS r )rf rg r )r r& r r r �
<listcomp> s �z,Storage._build_rev_cache.<locals>.<listcomp>z --parentsz --topo-order�--allr r c s t | �} � �| | �S rK )� frozensetr! )�rheads)� rheads_seenr r �
_rheads_reuse � z/Storage._build_rev_cache.<locals>._rheads_reuser i� r Tz>rebuilt commit tree db for '%s' with %d entries (took %.1f ms)i� )r� ry r� r
r� r� �rev_listr �_Storage__rev_key� enumerater! r �set�addr r� �updater3 �max�popitemr� r� )rP r �ts0�new_db�new_sdb� head_revsr �youngest�oldestr r �ord_rev�revsrC �parents� _children�_parents�_ord_rev�_rheads�parent�_rheads2�tmp�kr� r� r )r r
r r r � s� �
��
�
�
� " � �
�zStorage._build_rev_cachec C s� i }i }| j �d��� D ]!}d|vrq |�dd�\}}|�d�r)|||d d� < q |||< q |�t|�� �� |rL| j �dd�pAd� � }||v rL||d < |S )
Nz
--dereference� r s ^{}���z-qr� � r� )
r� �show_refr r r: r! �iterr� � symbolic_refr" )rP r �tagsr& rC r� r r r r N s
zStorage._get_refsc s< dd� }| j � t� fdd�| j�� D �|d�}dd� |D �S )z`returns list of (local) branches, with active (= HEAD) one being
the first item
c S s | \}}}| |fS rK r )ri re rC r� r r r �fng s
z Storage.get_branches.<locals>.fnc 3 s( � | ]\}}}� |�t |�|fV qd S rK �rD �r re rC r� �r� r r � <genexpr>k s � �z'Storage.get_branches.<locals>.<genexpr>�r* c S s g | ] \}}}||f�qS r r r> r r r r n r z(Storage.get_branches.<locals>.<listcomp>)r� �sortedr� r� )rP r< �branchesr r? r � get_branchesc s ��zStorage.get_branchesc c s< � | j }| jj�� D ]\}}|dkr||�t|�fV q
d S )Nr� )r� r� r� r� rD )rP r� r� rC r r r �get_refsp s ���zStorage.get_refsc C s | j jS rK )r� r� rV r r r � get_commitsv r� zStorage.get_commitsc C � t | jj�S rK )rD r� r� rV r r r r� y r� zStorage.oldest_revc C rG rK )rD r� r� rV r r r r� | r� zStorage.youngest_revc s| t |�}| j}z |j| d �W n ty g Y S w |r7| j� � �fdd�|�� D �}|jdd� d� |S ttt ���S )z�return list of reachable head sha ids or (names, sha) pairs if
resolve is true
see also get_branches()
� c s* g | ]\}}}|�v r� |�t |�f�qS r r= r> �r� r r r r � s
�z/Storage.get_branch_contains.<locals>.<listcomp>c S s | d S )Nr r )r� r r r r� � s z-Storage.get_branch_contains.<locals>.<lambda>rA )
rH r� r� r� r� r� �sortrf rg rD )rP r� �resolve�
_rev_cache�rvr rI r �get_branch_contains s � �zStorage.get_branch_containsc s" � fdd�}|t |�|�}t|�S )Nc sx � � � }| |vr t� �|dkr| S || d | }|dk s#|t|�kr%d S |�� D ]\}}|d |kr7| S q)td��)Nr r� r z internal inconsistency detected)rF r r3 r� r
)r� �rel_posr� �lin_revr4 r� rV r r �get_history_relative_rev� s �z>Storage.history_relative_rev.<locals>.get_history_relative_rev)rH rD )rP r� rO rQ r� r rV r �history_relative_rev� s z Storage.history_relative_revc C � | � |d�S )Nr �rR �rP r� r r r �hist_next_revision� r� zStorage.hist_next_revisionc C rS �Nr rT rU r r r �hist_prev_revision� r� zStorage.hist_prev_revisionc C s( | j d u r| j�dd��� pd| _ | j S )Nz--getzi18n.commitEncodingr- )r� r� �configr" rV r r r �get_commit_encoding� s
�zStorage.get_commit_encodingc C s
| � d�S )zget current HEAD commit idr� )� verifyrevrV r r r r� � s
z Storage.headc C s | � ||��� S rK )�_cat_file_reader�read)rP �kindr� r r r �cat_file� s zStorage.cat_filec
C s� | j �� | jd u r| j�� | _z�| jj�|d � | jj�� | jj�� � � }t
|�dkr5t dt |� ��|\}}}||krFt d||f ��t
|�}| jjj}|dkrXt�� } nt�� } |d }
|
dkr�|t|
d��} | s{t d |d |d |
f ��|
t
| �8 }
| �|
dkr�| n| d d
� � |
dksd| �d� | W W d � S ty� } z| j�d t| �� | �| j� d | _W Y d } ~ nd } ~ ww W d � d S 1 s�w Y d S ) N�
rH z(internal error (could not split line %s)z;internal error (got unexpected object kind %r, expected %r)i r r i z;internal error (expected to read %d bytes, but only got %d)r zclosing cat_file pipe: %s)r� r� r� r rl �write�flushrm �readliner r3 r
r� r4 r] �tempfile�
TemporaryFile�io�BytesIO�min�seekr� r� �warningr r )
rP r^ r� �split_stdout_line�_sha�_type�_size�size� stdout_read�buf� remaining�chunkr� r r r r\ � s\
� �
�
� �
�,� ��"�zStorage._cat_file_readerc s" � fdd�}|� � |��}t|�S )zaverify/lookup given revision object and return a sha id or None
if lookup failed
c s� � j }t�| �r� �| �}|r|S |j}| dkr%|�| �}||v r%|| S |�d| �}|r0|S |�d| �}|r;|S � j�d| ��� }|sHd S ||j v rO|S d S )Nr� r� r� z--verify)
r� rI r� �fullrevr� r� r� � rev_parser" r� )rC rL rt r r� �resolvedr� rV r r �
get_verifyrev s,
z(Storage.verifyrev.<locals>.get_verifyrev)r� rD )rP rC rw r� r rV r r[ � s zStorage.verifyrev� c s � fdd�}t |t|�|��S )Nc s� |�j k r�j }�j}| |jvrdS | d|� }t|j��| � �}t|�dkr*|S || h }t|d d�D ]� | d� � }|� fdd�|D �vrM| S q6| S )ztry to shorten sha idNr r� c s g | ]}|d � � �qS rK r )r �r��lr r r > � z:Storage.shortrev.<locals>.get_shortrev.<locals>.<listcomp>)�_Storage__SREV_MINr� r� r r� r r3 �range)rC �min_lenrL �srev�srevs�crevsrV rz r � get_shortrev% s
�z&Storage.shortrev.<locals>.get_shortrev)rD rH )rP rC r r� r rV r �shortrev# s zStorage.shortrevc C s� | j }t|�dkr||jv r|S t�|�sdS z
|j| �|� }W n
ty+ Y dS w d}|D ]}|�|�r@|dur> dS |}q0|S )ztry to reverse shortrev()r� N) r� r3 r� rI r� r� r r� r9 )rP rC rL r� rv r� r r r rt F s$
�
�zStorage.fullrevc s. � d urt � �� t� �fdd��j�� D ��S )Nc 3 s. � | ]\}}� d u s� |kr�� |�V qd S rK r? )r re �rev_�rC rP r r r@ b s � ��z#Storage.get_tags.<locals>.<genexpr>)rH rB r� r� �rP rC r r� r �get_tags_ s
�zStorage.get_tagsr7 c sd |r� � |�nd}� � |��d�pd}� j�|rdnd|d|��d�}� fdd ���fd
d �|D �S ) Nr� � /r� z-zlrz-zl�--� c sh | � dd�\}}|� � \}}}}t|d�}t|�}t|d�}|dkr$dnt|�}� �|�}|||||fS )z7split according to '<mode> <type> <sha> <size> <fname>'� r r- r1 � -N)r rA rD r4 r� )r{ �meta�fname�_moderm rl rn rV r r �split_ls_tree_linel s
z+Storage.ls_tree.<locals>.split_ls_tree_linec s g | ]}|r� |��qS r r )r r� )r� r r r x r| z#Storage.ls_tree.<locals>.<listcomp>)r� �lstripr� �ls_treer )rP rC r= � recursive�treer )rP r� r r� f s �� zStorage.ls_treec C s |st d��|}| �t|��}| �� }||vr!| j�d||� t�| j�# || jv r@| j| }|d t |d �fW d � S W d � n1 sJw Y | �
d|�}t || � � d�}t
|�}| j�
|| j|< W d � n1 stw Y |d t |d �fS )Nz'read_commit called with empty commit_idz read_commit failed for %r (%r)r r s commitr8 )r
rt rH rF r� �infor r� r� r� r_ rA rZ r, )rP � commit_id�commit_id_origr� r� r$ r r r � read_commitz s0 �
� � �zStorage.read_commitc C s t |�}| �d|�S )Ns blob)rH r\ rU r r r �get_file� r zStorage.get_filec C s@ t |�}zt| j�d|��� �}W |S ty td| ��w )Ns -szobject '%s' not found)rH r4 r� r_ r" r� r )rP r� �obj_sizer r r � get_obj_size� s � �zStorage.get_obj_sizec C sD t |�}| �� }z|| }W n
ty Y dS w ttt|d ��S )Nr r )rH rF r� rB rg rD �rP r� r� �itemr r r �children� s �zStorage.childrenc c s� � |du r | � � }t� }t� }|| d }|�|� |�|� |r<|�� }|V || d | }|�|� |�|� |s!t|�dksDJ �dS )z4Recursively traverse children in breadth-first orderNr )rF r r r! rc r� r3 )rP r� r� � work_list�seenr- rz r r r �children_recursive� s �
�zStorage.children_recursivec C sF t |�}| �� }z|| }W n ty g Y S w ttt|d ��S rW )rH rF r� rf rg rD r� r r r r, � s �zStorage.parentsc c s � | � � D ]}t|�V qd S rK )rF rD r� r r r �all_revs� s � �zStorage.all_revsc C s6 | j � | jdd�W d � S 1 sw Y d S )NT)r
)r� r rV r r r �sync� s
$�z Storage.syncc
# s� � g �i �g ��� � �p
d� � �����fdd�}|� �����fdd�}z|V W �r5���d � d S d S �rA���d � w w )Nr� c
3 s� � �j �ddd�d� �g�d d �< �d j} | D ]N}|dkr q|�d�}| D ]?}|dkr. n8|�d��dd�\}}t|�}|�vre|�|< �|gkrM|V z
|�d d�\}}W n ty` Y nw |�vsAq&q�rp���d � g �d d �< d V qw)
Nz--pretty=format:%n%Hz --no-renamesz
--name-statusr� r r` r� r r� ) r� r� rm �rstripr r> �rsplitr� r )r r{ �old_shar� r= )� base_path�change� next_pathrz rP r� r r �name_status_gen� s> �
�
��� �z.Storage.get_historian.<locals>.name_status_genc sL �� | �} z � | }W t|�S ty% | g�d d �< t��}Y t|�S w rK )r� r� �nextrD )r= rC )r� �genr� rP r r � historian� s
�
�z(Storage.get_historian.<locals>.historianr )r� r )rP r� r� r� r� r )r� r� r� r� rz rP r� r �
get_historian� s � ��zStorage.get_historianc C s0 |d ur||�S | j ||dd�D ]}| S d S )Nr )�limit)�history)rP r� r= r� �entryr r r � last_change s
zStorage.last_changec c s^ � |d u rd}d| t |�g}|r|�d| �|�f� | jj|� }|�� D ]}t|�V q%d S )Nr z--max-count=%dr� )rA rc r� r� r r rD )rP r� r= r� ri r3 rC r r r r� s � �zStorage.historyc C s0 | j �ddd| d|d �}dd� |�� D �S )Nr z --date-orderz --max-age=%dz --min-age=%dr c S s g | ]}t |��qS r r= )r rC r r r r s z-Storage.history_timerange.<locals>.<listcomp>)r� r r )rP �start�stop�outputr r r �history_timerange s
�zStorage.history_timerangec C s0 t |�}t |�}| �� }||v o|| �||�v S )z(return True if rev2 is successor of rev1)rH rF r� )rP �rev1�rev2r� r r r �rev_is_anchestor_of s �zStorage.rev_is_anchestor_ofc
c s� � d}t |�}| �|�}| j�dd||��� D ]6}|s J �|r&|�d� }q|�� }t|�dkr7|\}}}} n|\}}}t|�dksDJ �t|�|fV d}q|rRJ �d S )NFz-pr� r� r0 r� T) rH r� r� �blamer r9 r r3 rD )
rP �
commit_shar= � in_metadatar& �
split_liner� � orig_lineno�lineno�
group_sizer r r r� ( s$ �
�
z
Storage.blamec c sV � | j �� | jd u r| j�� | _| j}z_|j�|r#dt|�t|�f ndt|� � |j�� |jj }g }|d�}|s>t
� �|dkrqt � }|dkr]|� |d � |d�}|sYt
� �|dksI|� t
|�� |d�}|smt
� �|dksBW n d | _| �|� � W d � n1 s�w Y |s�d S |d �d�r�J �|dd � }| �|�E d H d S )Ns %s %s
s %s
r r` r� r � :)r� r� r� r� rl ra rH rb rm r] �EOFError� bytearrayr r\ r r9 �_iter_diff_tree)rP �tree1�tree2r r] �entries�cr� r r r � get_changes@ sT �
�
�
���
� � zStorage.get_changesc
c s� � | � |��d�p
d}ddg}|r|�d� |�|r |nd|d|g� | jj|� }|s-dS d d
� }t||��}|sE|�d �} | �d �rEJ �| � |�E dH dS )
zgcalls `git diff-tree` and returns tuples of the kind
(mode1,mode2,obj1,obj2,action,path1,path2)r� r� r� r� r� r� r� Nc s s8 � d} | � d|�}|dkrd S | ||� V |d }q)Nr Tr� r r )�find)r� r� �idxr r r �
iter_entryw s � �z%Storage.diff_tree.<locals>.iter_entryr r� )
r� r" r rc r� � diff_treerf r r9 r� )
rP r� r� r= � find_renames�diff_tree_argsr� r� r� r� r r r r� f s" �
�
zStorage.diff_treec # s� � � fdd�}t |�� z|� }W n
ty Y d S w |�d�s#J �|dd � �d�}t|�dks4J �|\}}}}} t|d�}t|d�}t|�}t|�}t| d d� d �} | �|� �}
d } | d
v rh| �|� �} ||||| |
| fV q ) Nc s t � �S rK )r� r �r� r r �
next_entry� r� z+Storage._iter_diff_tree.<locals>.next_entryTr� r r5 r� r1 r- )�R�C) r9 �
StopIterationr9 r r3 r4 rD rA r� ) rP r� r� r� �values�old_mode�new_moder� �new_shar� �old_path�new_pathr r� r r� � s4 �
�
��zStorage._iter_diff_treec C s t d|t|�f ��)Nz1Make sure the Git repository '%s' is readable: %s)r
r )rP rQ r� r r r r� � s
�zStorage._raise_not_readablec C s: dD ]}t j�t j�||��s| j�d||� dS qdS )N)r� �objectsr z%Missing Git control file '%s' in '%s'FT)rd r= �existsr# r� ry )rP rQ re r r r r� � s ��z Storage._control_files_exist)rJ )rJ NN)F)rx rK )r7 F):r r r r� r} �objectr� � staticmethodr r� rU r r r �propertyr� r r r rD rE rF r� r� rN rR rV rX rZ r� r_ r\ r[ r� rt r� r� r� r� r� r� r� r, r� r� �
contextlib�contextmanagerr� r� r� r� r� r� r� r� r� r� r� r r r r r sr +
!
�Q
\
6
&#
2
&# r )1r� r� rf rd r� ro rd r� � collectionsr � functoolsr r r � threadingr � trac.corer � trac.utilr �trac.util.compatr �trac.util.datefmtr
�trac.util.textr r �__all__r
r r, r� rG r; r� r5 �zip�_key�_valr\ r> rD rH r� rI r� r� r r r r r r �<module> sD
Z 2