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