?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/event/__pycache__/base.cpython-39.pyc
???????
a ��Jh�; � @ 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 ddlmZ ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m 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/d0� d0e$e �Z(G d1d2� d2e'e �Z)G d3d4� d4ee �Z*G d5d6� d6e*e �Z+dS )7a� 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)�Mapping)�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# �J/home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/event/base.py�_is_event_name2 s ��r% c @ s e Zd ZdZddd�dd�ZdS )�_UnpickleDispatchz�Serializable 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|jv rtd|jd j��|� S qtd��d S )Nr! r( z*No class with a 'dispatch' member present.)�__mro__�__dict__r r! � _for_class�AttributeError)�selfr) �clsr# r# r$ �__call__B s �� z_UnpickleDispatch.__call__N)�__name__� __module__� __qualname__�__doc__r0 r# r# r# r$ r& < s r& c @ sL e Zd ZU dZded< ddd�dd�Zd d d �d d �Zedd�dd��ZdS )�_DispatchCommonr# �Optional[Type[_ET]]r) �_DispatchCommon[_ET]�_JoinedDispatcher[_ET]��otherr c C s t � �d S �N��NotImplementedError�r. r: r# r# r$ �_joinQ s z_DispatchCommon._joinr �_InstanceLevelDispatch[_ET]r c C s t � �d S r; r< �r. r r# r# r$ � __getattr__T s z_DispatchCommon.__getattr__� Type[_HasEventsDispatch[_ET]]�r c C s t � �d S r; r< �r. r# r# r$ �_eventsW s z_DispatchCommon._eventsN) r1 r2 r3 � __slots__�__annotations__r? rB �propertyrF r# r# r# r$ r5 L s r5 c @ s� e Zd ZU dZdZded< e�� Zded< ded< d ed < d ed < d ed< ded< d<dd d�dd�Z ddd�dd�Z e dd �d d ��Z d d d!d"�d#d$�Z d%d&d'�d(d)�Zd*d&d+�d,d-�Zd.d/d0�d1d2�Zd3d �d4d5�Zd=d&dd!d7�d8d9�Zd!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]]rL z List[str]� _event_namesr6 r) z Type[_JoinedDispatcher[_ET]]�_joined_dispatch_clsrC rF NzOptional[_Dispatch[_ET]])�parent� instance_clsc sl || _ � | _� rb|d us J �z| j� | _W qh ty^ � fdd�|jD � | _| j� < Y qh0 ni | _d S )Nc s i | ]}|j t|� ��qS r# )r r )�.0�ls�rQ r# r$ � <dictcomp>� s �z&_Dispatch.__init__.<locals>.<dictcomp>)rK r) rM rL �KeyError�_event_descriptors)r. rP rQ r# rT r$ �__init__� s �� � z_Dispatch.__init__r r@ r c C s@ z| j | }W n ty( t|��Y n0 t| |j|� |S d S r; )rL rV r- �setattrr )r. r rS r# r# r$ rB � s z_Dispatch.__getattr__z Iterator[_ClsLevelDispatch[_ET]]rD c c s | j D ]}t| |�V qd S r; )rN �getattr)r. �kr# r# r$ rW � s z _Dispatch._event_descriptors�_EventKey[_ET]r �None�� event_key�kwr c K s | j j|fi |��S r; )rF �_listen�r. r_ r` r# r# r$ ra � s z_Dispatch._listenr' r( )rQ r c C s | � | |�S r; )� __class__)r. rQ r# r# r$ r, � s z_Dispatch._for_classr )�instancer c C s |j }| �|�S r; )rc r, )r. rd rQ r# r# r$ � _for_instance� s z_Dispatch._for_instancer7 r8 r9 c C s d| j jv sJ �| �| |�S )z�Create a 'join' of this :class:`._Dispatch` and another. This new dispatcher will dispatch events to both :class:`._Dispatch` objects. rO )rc r+ rO r> r# r# r$ r? � s z_Dispatch._joinzUnion[str, Tuple[Any, ...]]c C s t � | jffS r; )r& r) rE r# r# r$ � __reduce__� s z_Dispatch.__reduce__T)r: �only_propagater c C s8 |j D ],}t|t�rqt| |j��| �j||d� qdS )zIPopulate from the listeners in another :class:`_Dispatch` object.)rg N)rW � isinstancer rZ r � for_modify�_update)r. r: rg rS r# r# r$ rj � s �z_Dispatch._updatec C s | j D ]}|�| ��� qd S r; )rW ri �clear)r. rS r# r# r$ �_clear� s z_Dispatch._clear)N)T)r1 r2 r3 r4 rG rH �weakref�WeakKeyDictionaryrM rX rB rI rW ra r, re r? rf rj rl r# r# r# r$ rJ \ s. � � � rJ rC r] )r/ r c C s. | j jD ] }t| �| � t| st|= qd S r; )r! rN r �remove)r/ r[ r# r# r$ �_remove_dispatcher� s rp c @ s� e Zd ZU ded< ded< ejr0ddd�dd �Zd d �d d �Zedddd�dd��Z eddddd�dddddd d�dd��Z e dddd �d d ��Z edd d d d!�d"d#��Z d$S )%�_HasEventsDispatchr6 �_dispatch_targetr( r! r r@ r c C s d S r; r# rA r# r# r$ rB � � z _HasEventsDispatch.__getattr__r] rD c C s | � | j| j| j� dS )zOIntercept new Event subclasses and create associated _Dispatch classes.N)�_create_dispatcher_classr1 � __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$ ra � s z_HasEventsDispatch._listenrC �Type[_Dispatch[_ET]])�klass� dispatch_clsr c C s |d �| _ | |_| j S r; )r! rF )r� r� r# r# r$ � _set_dispatch s z _HasEventsDispatch._set_dispatchzTuple[type, ...]zMapping[str, Any])� classname�bases�dict_r c C sJ t | d�r| jj}nt}dd� |D �}tdtd| |fd|i��}||_| �| |�}|jD ](}t||t | || �� t | � | � qZ|j D ]B} t | t�r�| tur�| jjjD ] } t|| j| � |j� | j� q�q�t| dd��r | j} | dus�J �t | d��rd | jv �rt| �| _n t| �| _td |j tfd|i�} | |_| t� | j< dS ) zVCreate a :class:`._Dispatch` class corresponding to an :class:`.Events` class.r! c S s g | ]}t |�r|�qS r# )r% )rR r[ r# r# r$ � <listcomp>% rs z?_HasEventsDispatch._create_dispatcher_class.<locals>.<listcomp>r� z %sDispatchrG rr N�_slots_dispatchzJoined%s)�hasattrr! rc rJ r �typerN r� rY r r �appendru � issubclassrF rW r rZ rr rG �slots_dispatcher� dispatcherr1 �_JoinedDispatcherrO �globals) r/ r� r� r� Z dispatch_baseZ event_namesr� Z dispatch_instr[ Zsuper_rS Zdispatch_target_clsr� r# r# r$ rt sL �� �� �z+_HasEventsDispatch._create_dispatcher_classN)r1 r2 r3 rH �typing� TYPE_CHECKINGrB rw � classmethodr} ra � staticmethodr� rt r# r# r# r$ rq � s" � rq c @ s� e Zd ZU dZdZded< ded< ded< ddd�d d �Zd d �d d�Zddd�dd�Zdd dd�dd�Z e dd �dd��Z d S ) r� z5Represent a connection between two _Dispatch objects.��localrP r) r7 r� rP r6 r) )r� rP c C s || _ || _| j j| _d S r; r� )r. r� rP r# r# r$ rX Z s z_JoinedDispatcher.__init__r rD c C s | j | j| jffS r; )rc r� rP rE r# r# r$ rf a s z _JoinedDispatcher.__reduce__r z_JoinedListener[_ET]r c C s. t | j|�}t| j|j|�}t| |j|� |S r; )rZ r� r rP r rY )r. r rS Zjlr# r# r$ rB d s z _JoinedDispatcher.__getattr__r\ r] r^ c K s | j j|fi |��S r; )rP ra rb r# r# r$ ra l s z_JoinedDispatcher._listenrC c C s | j jS r; )rP rF rE r# r# r$ rF o s z_JoinedDispatcher._eventsN) r1 r2 r3 r4 rG rH rX rf rB ra rI rF r# r# r# r$ r� Q s r� c @ st e Zd ZdZedddd�dd��Zeddddd �d d d d d d d �dd��Zed d d�dd��Zed d�dd��ZdS )�Eventsz>Define event listening functions for a particular target type.rx r ry rz c sh ddd�� fdd� }ddd�� fdd� }t � d �rd|| jj�s`|t| jj�s`|t�rd|| jj�rd� S d S ) N� Type[Any]r )�typesr c s t � fdd�| D ��S )Nc 3 s | ]}t � j|�V qd S r; )rh r! )rR �t�r{ r# r$ � <genexpr>| rs z;Events._accept_with.<locals>.dispatch_is.<locals>.<genexpr>)�all)r� r� r# r$ � dispatch_is{ s z(Events._accept_with.<locals>.dispatch_is)r� r c s0 t d� j�j}t|t�r&t d|�j}qt|| �S )Nr8 )r r! rP rh r� )r� rP r� r# r$ �dispatch_parent_is~ s z/Events._accept_with.<locals>.dispatch_parent_isr! )r� r! rc r� r� )r/ r{ r| r� r� r# r� r$ r} w s � �� �zEvents._accept_withFr~ r\ r r] r� c C s |j ||||d� d S )Nr~ )Z base_listenr� r# r# r$ ra � s �zEvents._listen)r_ r c C s |� � d S r; )ro )r/ r_ r# r# r$ �_remove� s zEvents._removerD c C s | j �� d S r; )r! rl rv r# r# r$ rl � s z Events._clearN) r1 r2 r3 r4 r� r} ra r� rl r# r# r# r$ r� t s � r� c @ s\ e Zd ZdZdd�dd�Zedddd �d d ��Zed dd d �dd ��Zd dd d �dd �ZdS )r� z�Descriptor used by target classes to deliver the _Dispatch class at the class level and produce new _Dispatch instances for target instances. rC )�eventsc C s |j | _ || _d S r; )r! r� )r. r� r# r# r$ rX � 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 r7 c C s d S r; r# r� r# r# r$ r� � s c C sb |d u r| j S | j �|�}z||jd< W n4 ty\ } z td|f �|�W Y d }~n d }~0 0 |S )Nr! zGtarget %r doesn't have __dict__, should it be defining _slots_dispatch?)r! re r+ r- � TypeError)r. r� r/ �dispZaer# r# r$ r� � s ���N)r1 r2 r3 r4 rX r r� r# r# r# r$ r� � s r� c @ s e Zd Zdddd�dd�ZdS )r� r r� r� c C s4 |d u r| j S t|d�r |jS | j �|�}||_|S )Nr� )r! r� r� re )r. r� r/ r� r# r# r$ r� � s zslots_dispatcher.__get__N)r1 r2 r3 r� r# r# r# r$ r� � s r� ),r4 � __future__r r� r r r r r r r r r r r r r rm �attrr r r r �registryr r � r Z util.typingr � defaultdict�listr rH r% r& r5 rJ rp rq r� r� r� r� r# r# r# r$ �<module> sH � ~p#7#
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????