|
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/trac/notification/__pycache__/ |
Upload File : |
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