HEX

File: //opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/event/__pycache__/base.cpython-37.pyc
B

��4] &�@s�dZddlmZddlZddlmZddlmZddlmZdd	lm	Z	e	�
e�Zd
d�Z
Gdd
�d
e�ZGdd�de�ZGdd�de�Zdd�Zdd�ZGdd�de	�ee��ZGdd�de�ZGdd�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�)�utilcCs|�d�o|dkS)N�_�dispatch)�
startswith)�name�r
�H/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/event/base.py�_is_event_namesrc@seZdZdZdd�ZdS)�_UnpickleDispatchz�Serializable callable that re-generates an instance of
    :class:`_Dispatch` given a particular :class:`.Events` subclass.

    cCs8x2|jD] }d|jkr|jdj�|�SqWtd��dS)Nr
z*No class with a 'dispatch' member present.)�__mro__�__dict__r
�
_for_class�AttributeError)�self�
_instance_cls�clsr
r
r�__call__)s


z_UnpickleDispatch.__call__N)�__name__�
__module__�__qualname__�__doc__rr
r
r
rr#src@sxeZdZdZdZe��Zddd�Zdd�Z	e
dd	��Ze
d
d��Zdd
�Z
dd�Zdd�Zdd�Zddd�Zdd�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.

    )�_parentrr�_empty_listenersNcsb||_�|_�rXy|j�|_Wq^tk
rT�fdd�|jD�|_|j�<Yq^Xni|_dS)Ncsi|]}t|��|j�qSr
)rr)�.0�ls)�instance_clsr
r�
<dictcomp>Wsz&_Dispatch.__init__.<locals>.<dictcomp>)rr�_empty_listener_regr�KeyError�_event_descriptors)r�parentr"r
)r"r�__init__Ms
z_Dispatch.__init__cCsBy|j|}Wntk
r*t|��YnXt||j|�|SdS)N)rr%r�setattrr)rrr!r
r
r�__getattr__^sz_Dispatch.__getattr__ccs x|jD]}t||�VqWdS)N)�_event_names�getattr)r�kr
r
rr&isz_Dispatch._event_descriptorscCs|jjS)N)�_events�_listen)rr
r
rr/psz_Dispatch._listencCs|�||�S)N)�	__class__)rr"r
r
rrtsz_Dispatch._for_classcCs|j}|�|�S)N)r0r)r�instancer"r
r
r�
_for_instancewsz_Dispatch._for_instancecCs<d|jjkr0td|jjtfd|ji�}||j_|�||�S)z�Create a 'join' of this :class:`._Dispatch` and another.

        This new dispatcher will dispatch events to both
        :class:`._Dispatch` objects.

        �_joined_dispatch_clszJoined%s�	__slots__)r0r�typer�_JoinedDispatcherr+r3)r�otherrr
r
r�_join{s
z_Dispatch._joincCst�|jffS)N)rr)rr
r
r�
__reduce__�sz_Dispatch.__reduce__TcCs<x6|jD],}t|t�rqt||j��|�j||d�qWdS)zMPopulate from the listeners in another :class:`_Dispatch`
            object.)�only_propagateN)r&�
isinstancerr,r�
for_modify�_update)rr7r:r!r
r
rr=�s

z_Dispatch._updatecCs"x|jD]}|�|���qWdS)N)r&r<�clear)rr!r
r
r�_clear�sz_Dispatch._clear)N)T)rrrrr4�weakref�WeakKeyDictionaryr$r(r*�propertyr&r/rr2r8r9r=r?r
r
r
rr3s


rc@seZdZdZdd�ZdS)�
_EventMetazKIntercept new Event subclasses and create
    associated _Dispatch classes.cCst||||�t�||||�S)N)�_create_dispatcher_classr5r()r�	classname�bases�dict_r
r
rr(�sz_EventMeta.__init__N)rrrrr(r
r
r
rrC�srCcCs�t|d�r|jj}nt}dd�|D�}td||fd|i�}||_|�||�}x2|jD](}t||t|||��t	|�
|�qVWxP|jD]F}	t|	t�r�|	tk	r�x.|	j
jjD] }
t||
j|
�|j�
|
j�q�Wq�Wt|dd�r�t|�|j_dS)zRCreate a :class:`._Dispatch` class corresponding to an
    :class:`.Events` class.r
cSsg|]}t|�r|�qSr
)r)r r-r
r
r�
<listcomp>�sz,_create_dispatcher_class.<locals>.<listcomp>z
%sDispatchr4�_dispatch_targetN)�hasattrr
r0rr5r+�
_set_dispatchr)r�_registrars�append�	__bases__�
issubclassr.r&rr,�
dispatcherrI)rrErFrGZ
dispatch_baseZevent_names�dispatch_clsZ
dispatch_instr-Zsuper_r!r
r
rrD�s$

rDcCs2x,|jjD] }t|�|�t|s
t|=q
WdS)N)r
r+rL�remove)rr-r
r
r�_remove_dispatcher�srSc@sNeZdZdZedd��Zedd��Zeddd��Zed	d
��Z	edd��Z
d
S)�Eventsz>Define event listening functions for a particular target type.cCs|d�|_||_|jS)N)r
r.)rrQr
r
rrK�s
zEvents._set_dispatchcsX�fdd�}�fdd�}t�d�rT||jj�sP|t|jj�sP|t�rT||jj�rT�SdS)Ncst�fdd�|D��S)Nc3s|]}t�j|�VqdS)N)r;r
)r �t)�targetr
r�	<genexpr>�sz;Events._accept_with.<locals>.dispatch_is.<locals>.<genexpr>)�all)�types)rVr
r�dispatch_is�sz(Events._accept_with.<locals>.dispatch_iscst�jj|�S)N)r;r
r')rU)rVr
r�dispatch_parent_is�sz/Events._accept_with.<locals>.dispatch_parent_isr
)rJr
r0r5r6)rrVrZr[r
)rVr�_accept_with�s
zEvents._accept_withFcCs|j|||d�dS)N)�	propagate�insert�named)Zbase_listen)r�	event_keyr]r^r_r
r
rr/�szEvents._listencCs|��dS)N)rR)rr`r
r
r�_remove�szEvents._removecCs|j��dS)N)r
r?)rr
r
rr?�sz
Events._clearN)FFF)rrrr�staticmethodrK�classmethodr\r/rar?r
r
r
rrT�srTc@s<eZdZdZdZdd�Zdd�Zedd��Zed	d
��Z	dS)r6z5Represent a connection between two _Dispatch objects.)�localr'rcCs||_||_|jj|_dS)N)rdr'r)rrdr'r
r
rr(sz_JoinedDispatcher.__init__cCs.t|j|�}t|j|j|�}t||j|�|S)N)r,rdrr'rr))rrr!Zjlr
r
rr*
sz_JoinedDispatcher.__getattr__cCs|jjS)N)r'r/)rr
r
rr/sz_JoinedDispatcher._listencCs|jjS)N)r'r.)rr
r
rr.sz_JoinedDispatcher._eventsN)
rrrrr4r(r*rBr/r.r
r
r
rr6sr6c@s eZdZdZdd�Zdd�ZdS)rPz�Descriptor used by target classes to
    deliver the _Dispatch class at the class level
    and produce new _Dispatch instances for target
    instances.

    cCs|j|_||_dS)N)r
�events)rrer
r
rr(#szdispatcher.__init__cCs(|dkr|jS|j�|�|jd<}|S)Nr
)r
r2r)r�objrZdispr
r
r�__get__'szdispatcher.__get__N)rrrrr(rgr
r
r
rrPsrP)r�
__future__rr@�attrrrr�r�defaultdict�listrLr�objectrrr5rCrDrS�with_metaclassrTr6rPr
r
r
r�<module>s 
k	"0