_ d Z ddlmZ ddlZddlZddlZddlmZ ddlmZ ej e
Z ej e
Z d Z
d Zd Zd
Zd Z G d d
e ZdS )aJ Provides managed registration services on behalf of :func:`.listen`
arguments.
By "managed registration", we mean that event listening functions and
other objects can be added to various collections in such a way that their
membership in all those collections can be revoked at once, based on
an equivalent :class:`._EventKey`.
)absolute_importN )exc)utilc t r | t vrd S t | }| D ]I}|t v r>t | }| | |st | Jd S N)_collection_to_keypopvalues_key_to_collection)reflistener_to_keykey dispatch_regs m/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/event/registry.py_collection_gcedr 5 s ,>!>!>(,,S11O %%'' , , $ $ $-c2L S ! ! !
,"&&s+++
, , c | j }t | }|j }t j | j }||v rdS |||< t
| }|||< dS )NFT)_keyr r
weakref
_listen_fnr ) event_keyownerr r owner_ref
listen_refr s r _stored_in_collectionr C s_
.C%c*L IY 122JL u (L(3O"%OJ 4r c | j }t | }t j | j }|j }| |d |st |= |t v r$t | }| | d S d S r )r r r r
r r
r )r r r r r r r s r _removed_from_collectionr V s
.C%c*LY 122J IY%%% $ s #&&&,Y7J''''' '&r c |sd S |j }| j } t | }t | }|D ]H}t j | }|| }t | }| |v r|| |k sJ n||| < |||< Id S r )r
r r r ) newowneroldownerelementsold_listener_to_keynew_listener_to_key listen_fnr r r s r _stored_in_collection_multir& g s |H|H,X6,X6 . . [++
!*-)#. | # # )Z77777%/L "*-J'' . .r c |sd S | j } t | }|D ]K}t j | }|| }t | }| | d |st |= Ld S r )r
r r r r
)r r" r r% r r r s r _clearr( } s IE(/O ( ( [++
j))#. %%% ("3'( (r c e Zd ZdZdZddZed Zd Zd Z d Z
d Z d
Z dd Z
ed
Zd Zd Zd ZdS ) _EventKeyz$Represent :func:`.listen` arguments.)target
identifierfnfn_keyfn_wrapdispatch_targetNc || _ || _ || _ t |t j r.t
|j t
|j f| _ nt
| | _ || _
|| _ d S r ) r+ r, r-
isinstancetypes
MethodTypeid__func____self__r. r/ r0 )selfr+ r, r- r0 _fn_wraps r __init__z_EventKey.__init__ sl $ b%* + + ! R[//2bk??:DKK R&&DK . r c D t | j | j | j fS r )r5 r+ r, r. r8 s r r z_EventKey._key s 4; $+>>r c h || j u r| S t | j | j | j | j | S N)r9 )r r* r+ r, r- r0 )r8 r/ s r with_wrapperz_EventKey.with_wrapper sC do % %K $
r c h || j u r| S t | j | j | j || j S r> )r0 r* r+ r, r- r/ )r8 r0 s r with_dispatch_targetz _EventKey.with_dispatch_target sC d 2 2 2K
r c x | dd }| dd }| dd }| j | j | j }}}t |j | } | || }
| |
} t | j j j | j } t | d r|
|s|r; | t j | j | j
|i | d S | j j j | g|R i | d S )NonceF_once_unless_exceptionnamed_sa_warn)retry_on_exception)r
r0 r, r getattrdispatch_adjust_fn_specr? _eventshasattrrF r only_oncelisten_listen) r8 argskwrC once_unless_exceptionrE r+ r, r- dispatch_collection adjusted_fn
stub_functions r rN z_EventKey.listen sy vvfe$$ "'? G G w&&
O O
&foz B B)99"eDD -- ) 14?
=* - - % " " $ $ $ E( E
D O8M
d
" !
"
"
"
"
"
2D ) 1$ D D D D D D D D Dr c h | j }|t vr-t j d| j d| j d| j d t | }| D ]E\ }} | } | }|*|(| |
| Fd S )Nz No listeners found for event z / ) r r r InvalidRequestErrorr+ r, r- r
itemsremover? )r8 r r collection_ref listener_ref
collection listener_fns r rZ z_EventKey.remove s i ( ( ());;;:
*--c22 ,8,>,>,@,@ B B (NL' ))J&,..K%+*A!!$"3"3K"@"@AAA B Br c | j t v S )z6Return True if this event key is registered to listen.)r r r< s r containsz_EventKey.contains s y ...r Fc | j | j }}t |j | }|r0| |j | | d S | |j | | d S r )r0 r, rH rI
for_modifyinsertappend)r8 propagaterc rE retvalr+ r, rS s r base_listenz_EventKey.base_listen s " 14?
%foz B B * *6? ; ; B Bi
* *6? ; ; B Bi
r c | j p| j S r )r/ r- r< s r r z_EventKey._listen_fn s |&tw&r c ^ t | | r | | j dS dS NTF)r rd r r8 r list_s r append_to_listz_EventKey.append_to_list s2 u - - LL ) ) )45r c Z t | | | | j d S r )r rZ r rk s r remove_from_listz_EventKey.remove_from_list s, u---
T_%%%%%r c ^ t | | r | | j dS dS rj )r
appendleftr rk s r prepend_to_listz_EventKey.prepend_to_list s4 u - - T_ - - -45r r )FFFN)__name__
__module__ __qualname____doc__ __slots__r: propertyr r? rA rN rZ r` rg r rm ro rr r r r* r* s ..I / / / / ? ? X?
E E E@B B B / / /
BF " ' ' X' & & & r r* )rv
__future__r collectionsr3 r r r defaultdictdictr r r r r r& r( objectr* ry r r r s" ' & & & & & -[,T22 -[,T22 , , , &( ( (". . .,
(
(
( L L L L L L L L L Lr