Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
trac
/
notification
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: model.cpython-310.pyc
o �k�`8 � @ s@ d dl mZmZmZ ddgZG dd� de�ZG dd� de�ZdS )� )� datetime_now�utc� to_utimestamp� Subscription�Watchc @ s� e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd d � Z e d d� �Z e d$dd��Z e d$dd��Z e dd� �Ze dd� �Ze d%dd��Ze dd� �Ze d d � �Ze d d � �Zd d!� Zd"d#� ZdS )&r ��env�values)�id�sid� authenticated� distributor�format�priority�adverb�classc C � || _ i | _d S �Nr ��selfr � r �9/usr/lib/python3/dist-packages/trac/notification/model.py�__init__ � zSubscription.__init__c s* d� � fdd�� jD ��}d� jj|f S )N� c 3 s$ � | ] }d |� j �|�f V qdS )z%s=%rN)r �get��.0�name�r r r � <genexpr> s � �z(Subscription.__repr__.<locals>.<genexpr>z<%s %s>)�join�fields� __class__�__name__)r r r r r �__repr__ s �zSubscription.__repr__c C � || j vr t|��| j�|�S r �r" �KeyErrorr r �r r r r r � __getitem__$ � zSubscription.__getitem__c C � || j vr t|��|| j|< d S r �r" r( r �r r �valuer r r � __setitem__) � zSubscription.__setitem__c C sP || d< || d< t |�| d< || d< |pd | d< t |�| d< || d< || d< d S ) Nr r r r r r r r ��int) r r r r r r r r �class_r r r �_from_database. s zSubscription._from_databasec C s� |j �K}t| �||d |d |d ��d }ttt��}|�� }|�d|||d t|d �|d |d p5dt|�|d |d f � |� |d �W d � S 1 sQw Y dS ) z id and priority overwritten.r r r � a INSERT INTO notify_subscription (time, changetime, sid, authenticated, distributor, format, priority, adverb, class) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s)r Nr r �notify_subscription) �db_transaction�len�find_by_sid_and_distributorr r r �cursor�executer3 � get_last_id)�clsr � subscription�dbr �nowr; r r r �add9 s$ �� �� $�zSubscription.addNc s� |j �e}d|i}|d us|d ur ||d< |rdnd|d< | j|fi |��D ]} n W d � d S |d|d f� | �||d |d |d �}ttt��� � fdd �t|d�D �} |�d | � W d � d S 1 skw Y d S ) Nr r r6 r r z+DELETE FROM notify_subscription WHERE id=%sr c �* g | ]\}}||d kr|� |d f�qS �r r r �r � new_priority�sub�rA r r � <listcomp>] � �z'Subscription.delete.<locals>.<listcomp>�w UPDATE notify_subscription SET priority=%s, changetime=%s WHERE id=%s )r8 �_findr: r r r � enumerate� executemany) r> r �rule_idr r r@ �kwargsrG �subsr r rH r �deleteN s* � � ��"�zSubscription.deletec sJ |j ��}d|i}|d us|d ur ||d< |rdnd|d< | j|fi |��D ]} n W d � d S | �||d |d |d �} d| krLt| �ksVn W d � d S t| �D ] \} }|d |krf n qZ W d � d S | �|d | �| �� ttt ��� � fdd�t| d�D �} |� d | � W d � d S 1 s�w Y d S ) Nr r r6 r r r c rC rD r rE rH r r rI { rJ z%Subscription.move.<locals>.<listcomp>rK ) r8 rL r: r9 rM �insert�popr r r rN ) r> r rO r r r r@ rP rG rQ �idxr r rH r �movee s< � �� �� ��"�zSubscription.movec C s� t |�}|j��}i }|d||f�D ]\}}} |�|| fg ��|� q|�� D ]} | jdd� q&i } ttt��} |D ]X} | d }| �|d� | | d7 < | | }|| d f}|� |�ry|| � � }|d| | d | d pmd || d | d |f� q9|d | | ||| d | d p�d || d | d f � q9g }|�� D ]} |� | � q�|r�|d d � dt |� � |� W d � d S W d � d S 1 s�w Y d S )Nz� SELECT id, distributor, class FROM notify_subscription WHERE sid=%s AND authenticated=%sT)�reverser r r6 r z� UPDATE notify_subscription SET changetime=%s,distributor=%s,format=%s,priority=%s, adverb=%s,class=%s WHERE id=%sr r z� INSERT INTO notify_subscription ( time,changetime,sid,authenticated,distributor, format,priority,adverb,class) VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s)z0DELETE FROM notify_subscription WHERE id IN (%s)�,)z%s)r3 r8 � setdefault�appendr �sortr r r r rT �extendr! r9 )r> r r r � subscriptionsr@ �ids_map�id_r r4 �ids� prioritiesrA rG �prio�key� delete_idsr r r � replace_all� sT � ���� ���("�zSubscription.replace_allc C sF |j �}|d|p d ||t|�f� W d � d S 1 s w Y d S )Nz� UPDATE notify_subscription SET format=%s WHERE distributor=%s AND sid=%s AND authenticated=%s �r8 r3 )r> r r r r r r@ r r r �$update_format_by_distributor_and_sid� s �"�z1Subscription.update_format_by_distributor_and_sidc + s � |j �~� g }g }t|�� �D ]&\}}|�d�r |d d� }|dkr&t|�}|�� �|�d � |�|� qd}|rC|dd�|� 7 }|r_t|t t f�sO|f}|dd �� fd d �|D �� 7 }� � � } | � ||� | D ]} t |�} | j| � | V qkW d � d S 1 s�w Y d S ) N�_���r �=%szdSELECT id, sid, authenticated, distributor, format, priority, adverb, class FROM notify_subscription� WHERE � AND � ORDER BY �, c 3 � � | ]}� � |�V qd S r ��quoter �r@ r r r � � � z%Subscription._find.<locals>.<genexpr>)�db_query�sorted�items�endswithr3 rZ rq r! � isinstance�tuple�listr; r< r r5 ) r> r �orderrP � conditions�argsr r/ �queryr; �rowrG r rr r rL � s8 � � �"�zSubscription._findc C � t | j||||dd��S )Nr )r r r r{ �rz rL )r> r r r r r r r r: � � �z(Subscription.find_by_sid_and_distributorc C s0 g }|D ]\}}|� | j||||dd�� q|S )z1uids should be a collection to tuples (sid, auth)r )r4 r r r{ )r\ rL )r> r �uidsr4 rQ r r r r r �find_by_sids_and_class� s �z#Subscription.find_by_sids_and_classc C s t | j||d��S )N)r4 r� )r> r r4 r r r � find_by_class� s zSubscription.find_by_classc C sF | j d | j d | j d | j d d | j d pd t| j d �| j d fS )Nr r r r r r r )r r3 r r r r �subscription_tuple� s �z Subscription.subscription_tuplec C sd | j j�$}|�� }ttt��}|�d|t| jd �| jd f� W d � d S 1 s+w Y d S )Nz� UPDATE notify_subscription SET changetime=%s, priority=%s WHERE id=%s r r ) r r8 r; r r r r< r3 r )r r@ r; rA r r r �_update_priority� s �"�z Subscription._update_priority)NNr )r$ � __module__� __qualname__� __slots__r" r r% r* r0 r5 � classmethodrB rR rV re rg rL r: r� r� r� r� r r r r r s8 / c @ s� e Zd ZdZdZdd� Zdd� Zdd� Zd d � Ze d d � �Z e d d� �Z e dd� �Z e dd� �Z e d dd��Ze dd� �Ze dd� �Ze dd� �Ze d d � �ZdS ) r r )r r r r �realm�targetc C r r r r r r r r r zWatch.__init__c C r& r r' r) r r r r* r+ zWatch.__getitem__c C r, r r- r. r r r r0 r1 zWatch.__setitem__c C s8 || d< || d< t |�| d< || d< || d< || d< d S )Nr r r r r� r� r2 )r r r r r4 r� r� r r r r5 s zWatch._from_databasec C sN |j �}|D ]}|d|t|�|||f� qW d � d S 1 s w Y d S )Nz� INSERT INTO notify_watch (sid, authenticated, class, realm, target) VALUES (%s, %s, %s, %s, %s) rf ) r> r r r r4 r� �targetsr@ r� r r r rB ! s ��"�z Watch.addc C s8 |j �}|d|f� W d � d S 1 sw Y d S )Nz&DELETE FROM notify_watch WHERE id = %s�r8 )r> r �watch_idr@ r r r rR + s "�z Watch.deletec C s@ |j �}|d|t|�|f� W d � d S 1 sw Y d S )Nz{ DELETE FROM notify_watch WHERE sid = %s AND authenticated = %s AND class = %s rf )r> r r r r4 r@ r r r �delete_by_sid_and_class0 s �"�z Watch.delete_by_sid_and_classc C s< |j �}|d|||f� W d � d S 1 sw Y d S )Nzv DELETE FROM notify_watch WHERE class = %s AND realm = %s AND target = %s r� )r> r r4 r� r� r@ r r r � delete_by_class_realm_and_target8 s �"�z&Watch.delete_by_class_realm_and_targetNc + s( � |j ��� g }g }t|�� �D ].\}}|�d�r |d d� }|dkr&t|�}|�� �|�d � |dkr8t|�}|�|� qd}|rK|dd�|� 7 }|rgt|t t f�sW|f}|dd �� fd d �|D �� 7 }� � � } | � ||� | D ]} t |�} | j| � | V qsW d � d S 1 s�w Y d S ) Nrh ri r rj zESELECT id, sid, authenticated, class, realm, target FROM notify_watchrk rl rm rn c 3 ro r rp r rr r r r V rs z Watch._find.<locals>.<genexpr>)rt ru rv rw r3 rZ rq r! rx ry rz r; r< r r5 ) r> r r{ rP r| r} r r/ r~ r; r �watchr rr r rL @ s< � � �"�z Watch._findc C r� )Nr� )r r r4 r{ r� )r> r r r r4 r r r �find_by_sid_and_class^ r� zWatch.find_by_sid_and_classc C s t | j|||||dd��S )Nr� )r r r4 r� r{ r� )r> r r r r4 r� r� r r r �"find_by_sid_class_realm_and_targetc s �z(Watch.find_by_sid_class_realm_and_targetc C s t | j||||d��S )N)r4 r� r� r� )r> r r4 r� r� r r r � find_by_class_realm_and_targeti s z$Watch.find_by_class_realm_and_targetc C s t | j|||d��S )N)r4 r� r� )r> r r4 r� r r r �find_by_class_and_realmm s z Watch.find_by_class_and_realmr )r$ r� r� r� r" r r* r0 r5 r� rB rR r� r� rL r� r� r� r� r r r r r s2 N)�trac.util.datefmtr r r �__all__�objectr r r r r r �<module> s r
Save
Cancel