U
|
¸ý°df< ã @ sâ U d Z ddlmZ ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lm Z dd
|
lm
|
Z
|
dd lm Z dd lm Z dd lm Z ddlmZ ddlmZ ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z e e ¡Z de d< d d d d d Z!G d!d" d"Z"G d#d$ d$ee Z#G d%d& d&e#e Z$d'd(d)d*d+Z%G d,d- d-ee Z&G d.d/ d/e&e Z'G d0d1 d1e#e Z(G d2d3 d3ee Z)G d4d5 d5e)e Z*dS )6aµ 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``.
|
|
é )Ú annotationsN)ÚAny)Úcast)ÚDict)ÚGeneric)ÚIterator)ÚList)ÚMutableMapping)ÚOptional)Úoverload)ÚTuple)ÚType)ÚUnioné )Ú_ClsLevelDispatch)Ú_EmptyListener)Ú_InstanceLevelDispatch)Ú_JoinedListener)Ú_ET)Ú _EventKeyé )Úutil)ÚLiteralz8MutableMapping[str, List[Type[_HasEventsDispatch[Any]]]]Ú _registrarsÚstrÚbool©ÚnameÚreturnc C s | d¡ r| dkp | d¡S )NÚ_ÚdispatchZ _sa_event)Ú
|
startswith)r © r" úLd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/event/base.pyÚ_is_event_name1 s ÿþr$ c @ s e Zd ZdZdddddZdS )Ú_UnpickleDispatchzSerializable callable that re-generates an instance of
|
:class:`_Dispatch` given a particular :class:`.Events` subclass.
|
|
ú Type[_ET]ú_Dispatch[_ET])Ú _instance_clsr c C s> |j D ]*}d|jkrtd|jd j |¡ S qtdd S )Nr r' z*No class with a 'dispatch' member present.)Ú__mro__Ú__dict__r r Ú
|
_for_classÚAttributeError)Úselfr( Úclsr" r" r# Ú__call__A s
|
|
|
ÿþ
|
z_UnpickleDispatch.__call__N)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r/ r" r" r" r# r% ; s r% c @ sL e Zd ZU dZded< dddddZd d
|
d d d ZeddddZdS )Ú_DispatchCommonr" úOptional[Type[_ET]]r( ú_DispatchCommon[_ET]ú_JoinedDispatcher[_ET]©Úotherr c C s
|
t d S ©N©ÚNotImplementedError)r- r9 r" r" r# Ú_joinP s z_DispatchCommon._joinr ú_InstanceLevelDispatch[_ET]r c C s
|
t d S r: r; ©r- r r" r" r# Ú __getattr__S s z_DispatchCommon.__getattr__ú Type[_HasEventsDispatch[_ET]]©r c C s
|
t d S r: r; ©r- r" r" r# Ú_eventsV s z_DispatchCommon._eventsN) r0 r1 r2 Ú __slots__Ú__annotations__r= r@ ÚpropertyrD r" r" r" r# r4 K s
|
r4 c @ sü e Zd ZU dZdZded< e ¡ Zded< ded< d ed
|
< d ed < d ed< ded< d<dd dddZ dddddZ
|
e dd d d Z d d d!d"d#d$Z d%d&d'd(d)Zd*d&d+d,d-Zd.d/d0d1d2Zd3d d4d5Zd=d&dd!d7d8d9Zd!d d:d;ZdS )>Ú _DispatchaM 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 :meth:`._HasEventsDispatch._create_dispatcher_class`
|
method. 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_listenersr Z_active_historyz9MutableMapping[Type[_ET], Dict[str, _EmptyListener[_ET]]]Ú_empty_listener_regz Dict[str, _EmptyListener[_ET]]rJ z List[str]Ú _event_namesr5 r( z Type[_JoinedDispatcher[_ET]]Ú_joined_dispatch_clsrA rD NzOptional[_Dispatch[_ET]])ÚparentÚ instance_clsc sn || _ | _ rd|d k s tz| j | _W qj tk
|
r` fdd|jD | _| j < Y qjX ni | _d S )Nc s i | ]}|j t| qS r" )r r )Ú.0Úls©rO r" r# Ú
|
<dictcomp> s ÿ z&_Dispatch.__init__.<locals>.<dictcomp>)rI r( ÚAssertionErrorrK rJ ÚKeyErrorÚ_event_descriptors)r- rN rO r" rR r# Ú__init__ s
|
þþ
|
ÿ
|
z_Dispatch.__init__r r> r c C sB z| j | }W n tk
|
r* t|Y nX t| |j| |S d S r: )rJ rU r, Úsetattrr )r- r rQ r" r" r# r@ s z_Dispatch.__getattr__z Iterator[_ClsLevelDispatch[_ET]]rB c c s | j D ]}t| |V qd S r: )rL Úgetattr)r- Úkr" r" r# rV © s
|
z _Dispatch._event_descriptorsú_EventKey[_ET]r ÚNone©Ú event_keyÚkwr c K s | j j|f|S r: )rD Ú_listen©r- r^ r_ r" r" r# r` ° s z_Dispatch._listenr& r' )rO r c C s | | |¡S r: )Ú __class__)r- rO r" r" r# r+ ³ s z_Dispatch._for_classr )Úinstancer c C s |j }| |¡S r: )rb r+ )r- rc rO r" r" r# Ú _for_instance¶ s z_Dispatch._for_instancer6 r7 r8 c C s< d| j jkr0td| j j tfd| ji}|| j _| | |¡S )z¡Create a 'join' of this :class:`._Dispatch` and another.
|
|
This new dispatcher will dispatch events to both
|
:class:`._Dispatch` objects.
|
|
rM zJoined%srE )rb r* Útyper0 Ú_JoinedDispatcherrL rM )r- r9 r. r" r" r# r= º s
|
ýz_Dispatch._joinzUnion[str, Tuple[Any, ...]]c C s t | jffS r: )r% r( rC r" r" r# Ú
|
__reduce__Ê s z_Dispatch.__reduce__T)r9 Úonly_propagater c C s8 |j D ],}t|trqt| |j | ¡j||d qdS )zIPopulate from the listeners in another :class:`_Dispatch`
|
object.)rh N)rV Ú
|
isinstancer rY r Ú
|
for_modifyÚ_update)r- r9 rh rQ r" r" r# rk Í s
|
|
ÿz_Dispatch._updatec C s | j D ]}| | ¡ ¡ qd S r: )rV rj Úclear)r- rQ r" r" r# Ú_clearÙ s
|
z_Dispatch._clear)N)T)r0 r1 r2 r3 rE rF ÚweakrefÚWeakKeyDictionaryrK rW r@ rG rV r` r+ rd r= rg rk rm r" r" r" r# rH [ s.
|
þ
|
|
ý ÿ rH rA r\ )r. r c C s. | j jD ] }t| | ¡ t| st|= qd S r: )r rL r Úremove)r. rZ r" r" r# Ú_remove_dispatcherÞ s rq c @ s® e Zd ZU ded< ded< ejr0ddddd Zd
|
d d d ZeddddddZ eddddddddddd
|
dddZ
|
e dddd d d Z edd d d
|
d!d"d#Z d$S )%Ú_HasEventsDispatchr5 Ú_dispatch_targetr' r r r> r c C s d S r: r" r? r" r" r# r@ ò s z _HasEventsDispatch.__getattr__r\ rB c C s | | j| j| j¡ dS )zOIntercept new Event subclasses and create associated _Dispatch
|
classes.N)Ú_create_dispatcher_classr0 Ú __bases__r* ©r. r" r" r# Ú__init_subclass__õ s z$_HasEventsDispatch.__init_subclass__úUnion[_ET, Type[_ET]]ú Optional[Union[_ET, Type[_ET]]]©ÚtargetÚ
|
identifierr c C s
|
t d S r: r; )r. r{ r| r" r" r# Ú _accept_withû s z _HasEventsDispatch._accept_withF©Ú propagateÚinsertÚnamedÚasyncior[ r ©r^ r r r r r c C s
|
t d S r: r; ©r. r^ r r r r r" r" r# r` s
|
z_HasEventsDispatch._listenrA úType[_Dispatch[_ET]])ÚklassÚ dispatch_clsr c C s |d | _ | |_| j S r: )r rD )r r r" r" r# Ú _set_dispatch s
|
|
z _HasEventsDispatch._set_dispatchzTuple[type, ...]zDict[str, Any])Ú classnameÚbasesÚdict_r c C s t | dr| jj}nt}dd |D }tdtd| |fd|i}||_| | |¡}|jD ](}t||t | || t
|
| | ¡ qZ|j D ]B} t | tr| tk r| jjjD ] }
|
t||
|
j|
|
|j |
|
j¡ qªqt| ddr | j} | dk sîtt | drd | jkrt| | _n
|
t| | _dS )
|
zVCreate a :class:`._Dispatch` class corresponding to an
|
:class:`.Events` class.r c S s g | ]}t |r|qS r" )r$ )rP rZ r" r" r# Ú
|
<listcomp>* s z?_HasEventsDispatch._create_dispatcher_class.<locals>.<listcomp>r
z
|
%sDispatchrE rs NÚ_slots_dispatch)Úhasattrr rb rH r re rL r rX r r Úappendru Ú
|
issubclassrD rV r rY rs rT rE Úslots_dispatcherÚ
|
dispatcher) r. r r r Z dispatch_baseZ event_namesr Z dispatch_instrZ Zsuper_rQ Zdispatch_target_clsr" r" r# rt s>
|
|
|
ýþ
|
|
ÿþ z+_HasEventsDispatch._create_dispatcher_classN)r0 r1 r2 rF ÚtypingÚ TYPE_CHECKINGr@ rw Ú classmethodr} r` Ú staticmethodr rt r" r" r" r# rr å s"
|
ù rr c @ st e Zd ZdZeddddddZeddddd d
|
d d d d d d ddZed
|
d dddZed dddZdS )ÚEventsz>Define event listening functions for a particular target type.rx r ry rz c sh ddd fdd }ddd fdd }t d rd|| jjs`|t| jjs`|trd|| jjrd S d S )
|
Nú Type[Any]r )Útypesr c s t fdd| D S )Nc 3 s | ]}t j|V qd S r: )ri r )rP Út©r{ r" r# Ú <genexpr>T s z;Events._accept_with.<locals>.dispatch_is.<locals>.<genexpr>)Úall)r r r" r# Ú dispatch_isS s z(Events._accept_with.<locals>.dispatch_is)r r c s t td jj| S )Nr7 )ri r r rN )r r r" r# Údispatch_parent_isV s ÿz/Events._accept_with.<locals>.dispatch_parent_isr )r r rb re rf )r. r{ r| r r r" r r# r} O s
|
|
ÿ þü
|
ûzEvents._accept_withFr~ r[ r r\ r c C s |j ||||d d S )Nr~ )Z base_listenr r" r" r# r` k s
|
ÿzEvents._listen)r^ r c C s | ¡ d S r: )rp )r. r^ r" r" r# Ú_removey s zEvents._removerB c C s | j ¡ d S r: )r rm rv r" r" r# rm } s z Events._clearN) r0 r1 r2 r3 r r} r` r rm r" r" r" r# r L s ù r c @ sr e Zd ZU dZdZded< ded< ded< dddd d
|
Zd d d ddZddddddZe ddddZ
|
dS )rf z5Represent a connection between two _Dispatch objects.©ÚlocalrN r( r6 r¢ rN r5 r( )r¢ rN c C s || _ || _| j j| _d S r: r¡ )r- r¢ rN r" r" r# rW s z_JoinedDispatcher.__init__r z_JoinedListener[_ET]r c C s. t | j|}t| j|j|}t| |j| |S r: )rY r¢ r rN r rX )r- r rQ Zjlr" r" r# r@ s z _JoinedDispatcher.__getattr__r[ r r\ r] c K s | j j|f|S r: )rN r` ra r" r" r# r` s z_JoinedDispatcher._listenrA rB c C s | j jS r: )rN rD rC r" r" r# rD s z_JoinedDispatcher._eventsN) r0 r1 r2 r3 rE rF rW r@ r` rG rD r" r" r" r# rf s
|
rf c @ s\ e Zd ZdZddddZedddd d
|
d Zed dd d dd Zd dd d dd ZdS )r zDescriptor used by target classes to
|
deliver the _Dispatch class at the class level
|
and produce new _Dispatch instances for target
|
instances.
|
|
rA )Úeventsc C s |j | _ || _d S r: )r r£ )r- r£ r" r" r# rW ª s zdispatcher.__init__z Literal[None]r r
©Úobjr. r c C s d S r: r" ©r- r¥ r. r" r" r# Ú__get__® s zdispatcher.__get__r r6 c C s d S r: r" r¦ r" r" r# r§ ´ s c
|
C s` |d kr| j S | j |¡}z||jd< W n2 tk
|
rZ } ztd|f |W 5 d }~X Y nX |S )Nr zGtarget %r doesn't have __dict__, should it be defining _slots_dispatch?)r rd r* r, Ú TypeError)r- r¥ r. ÚdispZaer" r" r# r§ ¸ s ÿÿýN)r0 r1 r2 r3 rW r r§ r" r" r" r# r ¢ s r c @ s e Zd ZddddddZdS )r r r r¤ c C s4 |d kr| j S t|dr |jS | j |¡}||_|S )Nr )r r r rd )r- r¥ r. r© r" r" r# r§ È s
|
zslots_dispatcher.__get__N)r0 r1 r2 r§ r" r" r" r# r Ç s r )+r3 Ú
|
__future__r r r r r r r r r r
|
r r r r rn Úattrr r r r Úregistryr r Ú r Z util.typingr Ú defaultdictÚlistr rF r$ r% r4 rH rq rr r rf r r r" r" r" r# Ú<module> sH
|
þ
|
|
g6 %
|
