mO0;ܒ F d Z ddlmZ ddlZddlmZ ddlmZ ddlmZ dd lm Z e j
e Z d
Z
G d d e Z G d
de Z G d de Zd Zd Z G d d e j ee Z G d de Z G d de ZdS )a Base implementation classes.
The public-facing ``Events`` serves as the base class for an event interface;
its public attributes represent different kinds of events. These attributes
are mirrored onto a ``_Dispatch`` class, which serves as a container for
collections of listener functions. These collections are represented both
at the class level of a particular ``_Dispatch`` class as well as within
instances of ``_Dispatch``.
)absolute_importN )_ClsLevelDispatch)_EmptyListener)_JoinedListener )utilc d | d o| dk p| d S )N_dispatch _sa_event)
startswith)names i/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/event/base.py_is_event_namer s9
OOC 7TZ%7 &
% %& c e Zd ZdZd ZdS )_UnpickleDispatchzSerializable callable that re-generates an instance of
:class:`_Dispatch` given a particular :class:`.Events` subclass.
c |j D ]2}d|j v r'|j d j | c S 3t d )Nr z*No class with a 'dispatch' member present.)__mro____dict__r
_for_classAttributeError)self
_instance_clsclss r __call__z_UnpickleDispatch.__call__/ sh ( O OCS\))|J/8CC! *
!!MNN Nr N)__name__
__module__ __qualname____doc__r r r r r ) s2
O O O O Or r c e Zd ZdZdZ ej ZddZd Z e
d Z e
d Z d Z
d Zd
Zd Zdd
Zd ZdS ) _Dispatcha; Mirror the event listening definitions of an Events class with
listener collections.
Classes which define a "dispatch" member will return a
non-instantiated :class:`._Dispatch` subclass when the member
is accessed at the class level. When the "dispatch" member is
accessed at the instance level of its owner, an instance
of the :class:`._Dispatch` class is returned.
A :class:`._Dispatch` class is generated for each :class:`.Events`
class defined, by the :func:`._create_dispatcher_class` function.
The original :class:`.Events` classes remain untouched.
This decouples the construction of :class:`.Events` subclasses from
the implementation used by the event internals, and allows
inspecting tools like Sphinx to work in an unsurprising
way against the public API.
)_parentr r _empty_listenersNc || _ | _ rH | j | _ d S # t $ r& fd|j D x| _ | j < Y d S w xY wi | _ d S )Nc < i | ]}|j t | S r" )r r ).0ls instance_clss r
z&_Dispatch.__init__..] s7 G^B = = r )r% r _empty_listener_regr& KeyError_event_descriptors)r parentr+ s `r __init__z_Dispatch.__init__S s ) '
(,(@ (N%%%
$ 7 %(@ ) ) ) )
%'D ! ! !s ' ,AAc | j | }t | |j | |S # t $ r t | w xY wN)r& setattrr r. r )r r r* s r __getattr__z_Dispatch.__getattr__d sZ &t,B
D"'2 & & &I ' ' ' && & 's
' Ac # B K | j D ]}t | | V d S r3 ) _event_namesgetattr)r ks r r/ z _Dispatch._event_descriptorso s= " # #A $"" " " " " # #r c | j j S r3 )_events_listenr s r r< z_Dispatch._listenv s
|##r c . | | | S r3 ) __class__)r r+ s r r z_Dispatch._for_classz s ~~dL111r c : |j }| | S r3 )r? r )r instancer+ s r
_for_instancez_Dispatch._for_instance} s ) |,,,r c d| j j vr7t d| j j z t fd| j i }|| j _ | | | S )zCreate a 'join' of this :class:`._Dispatch` and another.
This new dispatcher will dispatch events to both
:class:`._Dispatch` objects.
_joined_dispatch_clszJoined%s __slots__)r? r typer _JoinedDispatcherr7 rD )r otherr s r _joinz_Dispatch._join sc " )@ @ @T^ 44"$ d /0 C 36DN /((u555r c . t | j ffS r3 )r r r= s r
__reduce__z_Dispatch.__reduce__ s ""T%7$999r Tc |j D ]U}t |t rt | |j | || VdS )zIPopulate from the listeners in another :class:`_Dispatch`
object.)only_propagateN)r/
isinstancer r8 r
for_modify_update)r rH rM r* s r rP z_Dispatch._update sv * B"n--
D"' " " - -d 3 3 ; ;>
<
r c h | j D ])}| | *d S r3 )r/ rO clear)r r* s r _clearz_Dispatch._clear s? ) ( (B MM$ % % ' ' ' ' ( (r r3 )T)r r r r! rE weakrefWeakKeyDictionaryr- r1 r5 propertyr/ r< r rB rI rK rP rS r" r r r$ r$ 9 s * KI3'355' ' ' '" # # X# $ $ X$2 2 2- - -6 6 6": : : ( ( ( ( (r r$ c e Zd ZdZd ZdS )
_EventMetazKIntercept new Event subclasses and create
associated _Dispatch classes.c d t | ||| t | ||| d S r3 )_create_dispatcher_classrF r1 )r classnamebasesdict_s r r1 z_EventMeta.__init__ s4 i>>>
c9eU33333r N)r r r r! r1 r" r r rX rX s- % %4 4 4 4 4r rX c
t | d r
| j j }nt }d |D }t d|z |fd|i }||_ | | | }|j D ]G}t ||t | || t |
| H|j D ]i} t | t rR| t urI| j
j j D ]7}
t ||
j |
|j
|
j 8jt! | dd rt# | | j _ dS dS )zRCreate a :class:`._Dispatch` class corresponding to an
:class:`.Events` class.r c 0 g | ]}t | |S r" )r )r) r9 s r
z,_create_dispatcher_class.. s% 999~a'8'891999r z
%sDispatchrE _dispatch_targetN)hasattrr r? r$ rF r7
_set_dispatchr4 r _registrarsappend __bases__
issubclassr; r/ r r8
dispatcherra ) r r[ r\ r]
dispatch_base event_names dispatch_cls
dispatch_instr9 super_r* s r rZ rZ sv sJ " .
!
99e999Ky ="2[+4N L !,L %%c<88M
& # #
q"3Cq"B"BCCCA c"""" ( : : fi ( ( :V9-D-D n-@
:
:
rw333 )009999s&-- 8(23 %%%8 8r c | j j D ]7}t | | t | st |= 8d S r3 )r r7 rd remove)r r9 s r _remove_dispatcherrp sL
\
& A c"""1~ A r c e Zd ZdZed Zed Zed d Zed Z ed Z
dS )
Eventsz>Define event listening functions for a particular target type.c > |d | _ | |_ | j S r3 )r r; )r rk s r rc zEvents._set_dispatch s% $|D)) " |r c fd}fd}t d rW || j j s@ |t | j j s% |t r || j j rS d S d S d S )Nc : t fd| D S )Nc 3 B K | ]}t j | V d S r3 )rN r )r) ttargets r z;Events._accept_with..dispatch_is.. s/ EE!z&/155EEEEEEr )all)typesrx s r dispatch_isz(Events._accept_with..dispatch_is s& EEEEuEEEEE Er c 8 t j j | S r3 )rN r r0 )rw rx s r dispatch_parent_isz/Events._accept_with..dispatch_parent_is s fo 4a88 8r r )rb r r? rF rG )r rx r| r~ s ` r _accept_withzEvents._accept_with s F F F F F 9 9 9 9 9
6: & & CL 233
;tS\%;<<
K 122
+*3<+ABB
r Fc 6 | ||| d S )N) propagateinsertnamed) base_listen)r event_keyr r r s r r< zEvents._listen s# & NNNNNr c . | d S r3 )ro )r r s r _removezEvents._remove s r c 8 | j d S r3 )r rS )r s r rS z
Events._clear s r N)FFF) r r r r! staticmethodrc classmethodr r< r rS r" r r rr rr s HH \ [ ( O O O [O [ [ r rr c N e Zd ZdZdZd Zd Zed Zed Z dS )rG z5Represent a connection between two _Dispatch objects.localr0 r c D || _ || _ | j j | _ d S r3 r )r r r0 s r r1 z_JoinedDispatcher.__init__ s#
!Z 5r c t | j | }t | j |j | }t | |j | |S r3 )r8 r r r0 r r4 )r r r* jls r r5 z _JoinedDispatcher.__getattr__ sC TZ
&
&
T["'2
6
6bgr""" r c | j j S r3 )r0 r< r= s r r< z_JoinedDispatcher._listen
{""r c | j j S r3 )r0 r; r= s r r; z_JoinedDispatcher._events r r N)
r r r r! rE r1 r5 rV r< r; r" r r rG rG ss ??2I6 6 6
# # X# # # X# # #r rG c e Zd ZdZd Zd ZdS )rh zDescriptor used by target classes to
deliver the _Dispatch class at the class level
and produce new _Dispatch instances for target
instances.
c , |j | _ || _ d S r3 )r events)r r s r r1 zdispatcher.__init__) s
r c ` || j S | j | x|j d< }|S )Nr )r rB r )r objr disps r __get__zdispatcher.__get__- s5 ;= *.-*E*Ec*J*JJ Z 4 r N)r r r r! r1 r r" r r rh rh ! s< r rh )r!
__future__r rT attrr r r r defaultdictlistrd r objectr r$ rF rX rZ rp with_metaclassrr rG rh r" r r r s ' & & & & & # # # # # # ! ! ! ! ! ! d t$$ & & &
O
O
O
O
O
O
O
O h( h( h( h( h( h( h( h(V4 4 4 4 4 4 4 4 8 8 8D - - - - -
T
V
4
4 - - - `# # # # # # # #6 r