Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
tracopt
/
versioncontrol
/
git
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: PyGIT.cpython-310.pyc
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
Save
Cancel