OwlCyberSecurity - MANAGER
Edit File: registry.cpython-311.pyc
� ������h% �����������������������������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_key�pop�values�_key_to_collection)�ref�listener_to_key�key�dispatch_regs��� �P/opt/cloudlinux/venv/lib64/python3.11/site-packages/sqlalchemy/event/registry.py�_collection_gcedr���5���s�����������,>�!>�!>���(�,�,�S�1�1�O��%�%�'�'��,��,���$�$�$�-�c�2�L����S�!�!�!��� ,�"�&�&�s�+�+�+�� ,��,�����c�����������������������|�j���������}t����������|���������}|j��������}t����������j��������|�j��������������������}||v�rdS�|||<���t ����������|���������}|||<���dS�)NFT)�_keyr���r ����weakref� _listen_fnr ���)� event_key�ownerr���r���� owner_ref� listen_refr���s��� r����_stored_in_collectionr���C���s_������ �.�C�%�c�*�L�� �I���Y�1�2�2�J��L� � ��u�(�L���(��3�O�"%�O�J���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�*�L���Y�1�2�2�J�� �I����Y��%�%�%���$��s�#��&�&�&�,�Y�7�����J�'�'�'�'�'��'�&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���) �newowner�oldowner�elements�old_listener_to_key�new_listener_to_key� listen_fnr���r���r���s ��� r����_stored_in_collection_multir&���g���s�������������|�H��|�H�,�X�6��,�X�6���� .�� .� ��[��+�+� �!�*�-��)�#�.���|�#�#���)�Z�7�7�7�7�7�%/�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�������������I�E�(��/�O���(��(� ��[��+�+� ��j�)��)�#�.�������%�%�%��� (�"�3�'��(��(r���c�������������������������e�Zd�ZdZdZdd�Zed����������������Zd��Zd��Z d��Z d ��Zd ��Z �dd�Z ed ����������������Zd��Zd��Zd��ZdS�)� _EventKeyz$Represent :func:`.listen` arguments.)�target� identifier�fn�fn_key�fn_wrap�dispatch_targetNc����������������������||�_���������||�_��������||�_��������t����������|t����������j��������������������r.t ����������|j��������������������t ����������|j��������������������f|�_ ��������nt ����������|������������|�_ ��������||�_ ��������||�_��������d�S�r���)r+���r,���r-���� isinstance�types� MethodType�id�__func__�__self__r.���r/���r0���)�selfr+���r,���r-���r0����_fn_wraps��� r����__init__z_EventKey.__init__����sl���������$�������b�%�*�+�+�� !��R�[�/�/�2�b�k�?�?�:�D�K�K��R�&�&�D�K����.����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�������d�o�%�%��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�2��K����������������� 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�)N�onceF�_once_unless_exception�named�_sa_warn)�retry_on_exception)r ���r0���r,���r����getattr�dispatch�_adjust_fn_specr?����_events�hasattrrF���r���� only_once�listen�_listen)r8����args�kwrC����once_unless_exceptionrE���r+���r,���r-����dispatch_collection�adjusted_fn� stub_functions��� r���rN���z_EventKey.listen����sy������v�v�f�e�$�$�� "���'?�� G� G�����w��&�&��� � ��O��O��� ���&�f�o�z�B�B��)�9�9�"�e�D�D��� � ��-�-���� �)�1�4�?� �� � ���=�*�-�-�� %��"�"�$�$�$��� E�(�� E� �D������O�8M������ �� ���d� "��!� "�� "�� "�� "�� "�� 2�D� �)�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�)NzNo listeners found for event z / � )r���r���r����InvalidRequestErrorr+���r,���r-���r ����items�remover?���)r8���r���r����collection_ref�listener_ref� collection�listener_fns��� r���rZ���z_EventKey.remove����s��������i���(�(�(��)�)��;�;�;���������:����� ��*�-�-�c�2�2��,8�,>�,>�,@�,@�� B�� B�(�N�L�'��)�)�J�&�,�.�.�K��%�+�*A��!�!�$�"3�"3�K�"@�"@�A�A�A�� 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_modify�insert�append)r8���� propagaterc���rE����retvalr+���r,���rS���s��� r����base_listenz_EventKey.base_listen����s��������"�1�4�?� ��%�f�o�z�B�B���� ��*�*�6�?�;�;�B�B��i� �� �� �� �� �� �*�*�6�?�;�;�B�B��i� �� �� �� �� r���c�����������������������|�j���������p|�j��������S�r���)r/���r-���r<���s��� r���r���z_EventKey._listen_fn��s�������|�&�t�w�&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�-�-�� ��L�L���)�)�)��4��5r���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�_�-�-�-��4��5r���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����defaultdict�dictr���r ���r���r���r���r&���r(����objectr*���ry���r���r����<module>r�������s"��������'��&��&��&��&��&��������������������������������������������-�[�,�T�2�2��� ��-�[�,�T�2�2��� �,��,��,������&(��(��(�".��.��.�, (�� (�� (� L��L��L��L��L���L��L��L��L��Lr���