File: //usr/lib/python3/dist-packages/trac/versioncontrol/__pycache__/cache.cpython-310.pyc
o
�k�`�V � @ s� d dl Z d dlmZ d dlmZ d dlmZmZ d dlm Z d dl
m Z m Z m
Z
mZ e je jd�Ze je je je je jd�Zd d
� Zee�Zee�Zd Zd Z ee fZ d
d� Z G dd� de
�Z G dd� de �Z dS )� N)�cached)� TracError)�from_utimestamp�
to_utimestamp)�_)� Changeset�Node�
Repository�NoSuchChangeset)�D�F)�A�Cr �E�Mc C s t t| �� t| ���S �N)�dict�zip�values�list)�d� r �;/usr/lib/python3/dist-packages/trac/versioncontrol/cache.py� _invert_dict s r �repository_dir� youngest_revc C s
| j pdS )Nz (default)��reponame)�reposr r r �_norm_reponame+ �
r c @ s0 e Zd ZdZedd� �Zdd� Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z dd� Z
dd� Zed�dd� �ZdFdd�Zd d � Zd d � Zd d!� ZdGd"d#�ZdHd$d%�Zd&d'� ZdGd(d)�Zd*d+� Zd,d-� ZdId/d0�ZdId1d2�Z dId3d4�Z d5d6� Z d7d8� Z dHd9d:�Z d;d<� Z!d=d>� Z"d?d@� Z#dAdB� Z$ CdJdDdE�Z%dS )K�CachedRepositoryFc C � | j jS r )r �scope��selfr r r �<lambda>3 s zCachedRepository.<lambda>c C s2 || _ || _t| jj�| _t�| |j|j|� d S r ) �envr �str�id� _metadata_idr �__init__�name�params)r% r' r �logr r r r+ 5 s zCachedRepository.__init__c C s | j �� d S r )r �closer$ r r r r/ ; � zCachedRepository.closec C s
| j �� S r )r �get_baser$ r r r r1 > r zCachedRepository.get_basec C s | j �| �|��S r )r �get_quickjump_entries�
normalize_rev�r% �revr r r r2 A � z&CachedRepository.get_quickjump_entriesc C s | j �||�S r )r � get_path_url�r% �pathr5 r r r r7 D r0 z CachedRepository.get_path_urlc C s t | | �|�| j�S r )�CachedChangesetr3 r' r4 r r r �
get_changesetG � z CachedRepository.get_changesetc C � | j �|�S r )r �get_changeset_uidr4 r r r r> J � z"CachedRepository.get_changeset_uidc c sN � | j �d| jt|�t|�f�D ]\}z| �|�V W q ty$ Y qw d S )Nz�
SELECT rev FROM revision
WHERE repos=%s AND time >= %s AND time < %s
ORDER BY time DESC, rev DESC
)r' �db_queryr) r r; r
)r% �start�stopr5 r r r �get_changesetsM s �
� ��z CachedRepository.get_changesetsc C s� | j �|�}| �|j�}d }| jj�A}z
t| |j| j�}W n ty( d }Y nw |r<|dt|j �|j
|j | j |f� n| �
|j|� W d � |S W d � |S 1 sVw Y |S )NzyUPDATE revision SET time=%s, author=%s, message=%s
WHERE repos=%s AND rev=%s
)r r; �db_revr5 r' �db_transactionr: r
r �date�author�messager) �insert_changeset)r% r5 �cset�srev�old_cset�dbr r r �sync_changesetX s.
�
��
� �
� � z CachedRepository.sync_changesetr* c C s. t | j�dd�dgtt� � | jft ��S )z2Retrieve data for the cached `metadata` attribute.zr
SELECT name, value FROM repository
WHERE id=%%s AND name IN (%s)
�,�%s)r r' r@ �join�len�CACHE_METADATA_KEYSr) r$ r r r �metadatak s
�
�zCachedRepository.metadataNc C s� |r| � � | j}| �|� | j�� | jj}|�t�}|r2| j�|�}|s1| j �
d| jt | �� n
| j �
d| jt | �� d }d }||k�r_| j � d||t | �� |rZ| j�
|�}n,z!| jj}| jjdkrt| j�d|�st| jj
|dd�}| j�|�}W n
ty� Y d S w |d u r�d S | �|�}| jj�#}|d| j|f�D ]\} | jj|d� W d � d S W d � n1 s�w Y |d u�ra| �|�}| jj�s}| j � d |t | �� | j�|�}
z| �||
� W nE t�y, } z8t| | jjj ��r| j � d
|t | �| � n | j � d |t | �| � | jj|d� |� � W Y d } ~ W d � d S d } ~ ww |d t |�| jtf� | `W d � n 1 �sEw Y |}| j�
|�}|�rY||� |d us�d S d S d S )
Nz3normalize_rev failed (youngest_rev=%r, reponame=%s)z7cache metadata undefined (youngest_rev=%r, reponame=%s)z)repos rev [%s] != cached rev [%s] in '%s'�/T)�find_initial_revz2SELECT rev FROM revision WHERE repos=%s AND rev=%s)r z$Trying to sync revision [%s] in '%s'z&Revision %s in '%s' already cached: %rz:Unable to create cache records for revision %s in '%s': %rzh
UPDATE repository SET value=%s WHERE id=%s AND name=%s
)!� remove_cacherT �
save_metadatar �clearr �get�CACHE_YOUNGEST_REVr3 r. �debugr �info�next_rev�
oldest_revr# �has_noder rD r' r@ r) rE r; rI � Exception�
isinstance�db_exc�IntegrityError�warning�error�rollbackr( ) r% �feedback�cleanrT �repos_youngest�youngest�
next_youngestrK rM r5 rJ �er r r �synct s�
��
�
� �� �
�� �
� ��
��� �" ��#zCachedRepository.syncc s� � j �dt� �� � jj�3}|d� jf� |d� jf� |�d� fdd�tD �� |�d� fdd�tD �� � `W d � d S 1 sCw Y d S )
z Remove the repository cache.zCleaning cache in '%s'z#DELETE FROM revision WHERE repos=%sz&DELETE FROM node_change WHERE repos=%sz.DELETE FROM repository WHERE id=%s AND name=%sc s g | ]}� j |f�qS r �r) ��.0�kr$ r r �
<listcomp>� � z1CachedRepository.remove_cache.<locals>.<listcomp>zt
INSERT INTO repository (id, name, value)
VALUES (%s, %s, %s)
c s g | ]}� j |d f�qS �� ro rp r$ r r rs � � N) r. r] r r' rE r) � executemanyrS rT )r% rM r r$ r rW � s
����"�z CachedRepository.remove_cachec C s | j j�{}d}|�t�}|r/tj�|�tj�| j�kr.| j� d|| j� t
t dt | �d���n-|du rH| j� d| j� |d| j
t| jf� d}n| j� d | j� |d
| j| j
tf� d}t|vrk|d| j
td f� d}|rw| `W d � dS W d � dS 1 s�w Y dS ) z Save the repository metadata.Fz*'repository_dir' has changed from %r to %rz�The repository directory has changed, you should resynchronize the repository with: trac-admin $ENV repository resync '%(reponame)s'r Nz$Storing initial "repository_dir": %sziINSERT INTO repository (id, name, value)
VALUES (%s, %s, %s)
Tz Resetting "repository_dir": %sz6UPDATE repository SET value=%s WHERE id=%s AND name=%srv )r' rE rZ �CACHE_REPOSITORY_DIR�osr9 �normcaser, r. r] r r r r) r[ rT )r% rT rM �
invalidater r r r rX � sJ
���� � � �
��&"�z CachedRepository.save_metadatac
C s� | � |�}| jj�K}|d| j|t|j�|j|jf� |�� D ]-\}}}}} | j �
d|t | j �||||| f� t
| }t| }|d| j|||||| f� q W d � dS 1 sWw Y dS )zQCreate revision and node_change records for the given changeset
instance.z~
INSERT INTO revision (repos,rev,time,author,message)
VALUES (%s,%s,%s,%s,%s)
z'Caching node change in [%s] in '%s': %rz�
INSERT INTO node_change
(repos,rev,path,node_type,change_type,base_path,
base_rev)
VALUES (%s,%s,%s,%s,%s,%s,%s)
N)rD r' rE r) r rF rG rH � get_changesr. r\ r r �_inverted_kindmap�_inverted_actionmap)
r% r5 rJ rK rM r9 �kind�action�bpath�brevr r r rI s&
��
���"�z!CachedRepository.insert_changesetc C � | j �|| �|��S r )r �get_noder3 r8 r r r r� 6 r< zCachedRepository.get_nodec C s� | � |�}| �|�}| �||�}| jj�E}|du r4|d| j||f�}|d d dur2t|d d �nd}| �|�}dd� |d|�� | j||||�|d �f�D �W d � S 1 s\w Y dS )z\Return the revisions affecting `path` between `first` and `last`
revisions.
Nz�
SELECT MAX(rev) FROM node_change
WHERE repos=%s AND rev<=%s AND path=%s
AND change_type IN ('A', 'C', 'M')
r c S s g | ]\}t |��qS r )�int)rq r5 r r r rs I rt z3CachedRepository._get_node_revs.<locals>.<listcomp>z�
SELECT DISTINCT rev FROM node_change
WHERE repos=%%s AND rev>=%%s AND rev<=%%s
AND (path=%%s OR path %s)rU ) r3 rD r� r' r@ r) r� � prefix_match�prefix_match_value)r% r9 �last�first�slast�noderM �sfirstr r r �_get_node_revs9 s$
�$
�
��$�z CachedRepository._get_node_revsc s |si S �fdd�|D �}�� tdd� |D ���}�� tdd� |D ���}dd� |D �}dd� |D �}d }d
}�jj��� � �� }|t|�k r�|||| � } ||7 }t| �}
d �d |
�} d
| d�d| d f|
�| d�d| f|
�f } g }
|
�dd� | D �� | D ]\}}|
� � �
|j d �� |
� |j � q�|
��j ||f� |
�dd� | D �� |
�� fdd�| D �� � | |
�D ]#\}}��
|�}|| \}}|| kr�|jkr�n q�|| � |� q�|t|�k sFW d � |S W d � |S 1 s�w Y |S )Nc s g | ] \}}|� � |�f�qS r )r3 �rq r� r� r$ r r rs T s z6CachedRepository._get_changed_revs.<locals>.<listcomp>c s s � | ]\}}|V qd S r r r� r r r � <genexpr>V s � z5CachedRepository._get_changed_revs.<locals>.<genexpr>c s � � | ]\}}|j V qd S r )r5 r� r r r r� W � � c S s i | ]
\}}|j ||f�qS r �r9 r� r r r �
<dictcomp>X s z6CachedRepository._get_changed_revs.<locals>.<dictcomp>c S s i | ]\}}|j g �qS r r� r� r r r r� Y rw r �� rO �rP a SELECT DISTINCT
rev, (CASE WHEN path IN (%s) THEN path %s END) AS path
FROM node_change
WHERE repos=%%s AND rev>=%%s AND rev<=%%s
AND (path IN (%s) %s)
� z
WHEN path z THEN %szOR path c s r� r r� r� r r r r� u r� rU c s r� r r� r� r r r r� z r� c 3 s$ � | ]
\}}� � |jd �V qdS )rU N)r� r9 r� )rM r r r� { s � �)rD �min�maxr' r@ r� rR rQ �extend�appendr� r9 r) �rev_dbr5 )r% �
node_infosr� r� �
path_infos� path_revs�idx�deltar� �subset�count�holders�query�argsr� r� rK r9 r5 r )rM r% r �_get_changed_revsP sj
�
� ���
�
��
�%�
�%�%z"CachedRepository._get_changed_revsc C r� r )r r` r3 r8 r r r r` � r< zCachedRepository.has_nodec C r" r )r r_ r$ r r r �get_oldest_rev� s z CachedRepository.get_oldest_revc C s | � | j�t��S r )r� rT rZ r[ r$ r r r �get_youngest_rev� r6 z!CachedRepository.get_youngest_revrv c C s | j �| �|�|�S r )r � previous_revr3 �r% r5 r9 r r r r� � s
z CachedRepository.previous_revc C s( | j r
| �d||�S | j�| �|�|�S )N�>)�has_linear_changesets�_next_prev_revr r^ r3 r� r r r r^ � s zCachedRepository.next_revc C sD | � |�}| jj��}d}|dkrdnd}| j|g}|rn|�d�}|||dd�; }|d|�� 7 }|�||�|d �f� |�d��d�} d � d
t
| � �}
|d |
d 7 }t d
t
| �d
�D ]} |� d� | d | � �� q^n|||dd�; }|||�D ]\}|d ur�t
|� W d � S q{W d � d S 1 s�w Y d S )NzCSELECT %(aggr)s(rev) FROM %(tab)s WHERE repos=%%s AND rev%(dir)s%%s�<�MAX�MINrU � node_change)�aggr�dir�tabz AND (path=%s OR path rO r� z OR (path IN (z) AND change_type='D'))� �revision)rD r' r@ r) �lstripr� r� r� �splitrQ rR �ranger� r� ) r% � directionr5 r9 rK rM �sqlr� r� �
components�parents�ir r r r� � s0
�
��"�z CachedRepository._next_prev_revc C s | j r t�| |�S | j�|�S r )r� r � parent_revsr r4 r r r r� � s z CachedRepository.parent_revsc C s | j �| �|�| �|��S r )r �rev_older_thanr3 )r% �rev1�rev2r r r r� � s �z CachedRepository.rev_older_thanc C s | j �|| �|�|�S r )r �get_path_historyr3 )r% r9 r5 �limitr r r r� � s �z!CachedRepository.get_path_historyc C r= r )r �normalize_path)r% r9 r r r r� � r? z CachedRepository.normalize_pathc C sv |d u st |t�r|�� dv r| �| jpd�S z t|�}t| j�}W n ttfy0 Y t|��w ||kr7|S t|��)N)rv �head�latestrk r ) rb r( �lowerr� r r� �
ValueError� TypeErrorr
)r% r5 r r r r r3 � s �z CachedRepository.normalize_revc C s t |�S )z9Convert a revision to its representation in the database.)r( r4 r r r rD � s zCachedRepository.db_revc C s |S )z;Convert a revision from its representation in the database.r r4 r r r r� � s zCachedRepository.rev_dbr� c C s | j �|| �|�|| �|�|�S r )r r} r3 )r% �old_path�old_rev�new_path�new_rev�ignore_ancestryr r r r} � s
�z CachedRepository.get_changes)NFr )NNru )r� )&�__name__�
__module__� __qualname__r� �propertyr# r+ r/ r1 r2 r7 r; r> rC rN r rT rn rW rX rI r� r� r� r` r� r� r� r^ r� r� r� r� r� r3 rD r� r} r r r r r! / sH
k+
6
�r! c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )r: c C sv || _ |�|�}| j �d|j|f�D ]\}}}t|�}t�| ||�|�|||� d S |j� d|j|t
|�� t |��)Nzv
SELECT time, author, message FROM revision
WHERE repos=%s AND rev=%s
z(Missing revision record (%r, %r) in '%s') r' rD r@ r) r r r+ r� r. r\ r r
) r% r r5 r' �drev�_daterG rH rF r r r r+ � s
�� �zCachedChangeset.__init__c c sb � t | j�d| jj| j�| j�f��D ]\}}}}}t| }t| }||||| j� |�fV qd S )Nz�
SELECT path, node_type, change_type, base_path, base_rev
FROM node_change WHERE repos=%s AND rev=%s
ORDER BY path
)
�sortedr' r@ r r) rD r5 �_kindmap�
_actionmapr� )r% r9 r� �change� base_path�base_revr r r r} � s ����zCachedChangeset.get_changesc C s | j j �| j��� S r )r r; r5 �get_propertiesr$ r r r r� r< z CachedChangeset.get_propertiesN)r� r� r� r+ r} r� r r r r r: � s r: )!rz �
trac.cacher � trac.corer �trac.util.datefmtr r �trac.util.translationr �trac.versioncontrolr r r r
� DIRECTORY�FILEr� �ADD�COPY�DELETE�EDIT�MOVEr� r r~ r ry r[ rS r r! r: r r r r �<module> s. � @