⚝
One Hat Cyber Team
⚝
Your IP:
3.143.218.47
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
opt
/
alt
/
python311
/
lib64
/
python3.11
/
__pycache__
/
View File Name :
asynchat.cpython-311.pyc
� ����VFzͤ���������������������������d�Z�ddlZddlmZ�ddlmZ�dZ�eeed���������������G�d��d ej��������������������Z �G�d ��d������������Z d��ZdS�) a���A class supporting chat-style (command/response) protocols. This class adds support for 'chat' style protocols - where one side sends a 'command', and the other sends a response (examples would be the common internet protocols - smtp, nntp, ftp, etc..). The handle_read() method looks at the input stream for the current 'terminator' (usually '\r\n' for single-line responses, '\r\n.\r\n' for multi-line output), calling self.found_terminator() on its receipt. for example: Say you build an async nntp client using this class. At the start of the connection, you'll have self.terminator set to '\r\n', in order to process the single-line greeting. Just before issuing a 'LIST' command you'll set it to '\r\n.\r\n'. The output of the LIST command will be accumulated (using your own 'collect_incoming_data' method) up to the terminator, and then control will be returned to you - by calling your self.found_terminator() method. �����N)�deque)�_deprecatedznThe {name} module is deprecated and will be removed in Python {remove}. The recommended replacement is asyncio)��������)�removec�������������������������e�Zd�ZdZdZdZdZdZdd�Zd��Z d��Z d ��Zd ��Zd��Z d��Zd ��Zd��Zd��Zd��Zd��Zd��Zd��Zd��Zd��Zd��ZdS�)� async_chatz�This is an abstract class. You must derive from this class, and add the two methods collect_incoming_data() and found_terminator()i���r���zlatin-1Nc�����������������������d|�_���������g�|�_��������t������������������������|�_��������t����������j�����������������������������|�||�������������d�S��N�����)�ac_in_buffer�incomingr���� producer_fifo�asyncore� dispatcher�__init__)�self�sock�maps��� �//opt/alt/python311/lib64/python3.11/asynchat.pyr���zasync_chat.__init__J���sB��������� ��� ��#�W�W�����$�$�T�4��5�5�5�5�5r���c������������������ �����t����������d��������������Nzmust be implemented in subclass��NotImplementedError�r����datas��� r����collect_incoming_dataz async_chat.collect_incoming_dataX����������!�"C�D�D�Dr���c������������������:�����|�j������������������������������|�������������d�S��N)r����appendr���s��� r����_collect_incoming_dataz!async_chat._collect_incoming_data[���s������� ���T�"�"�"�"�"r���c������������������N�����d����������������������|�j��������������������}|�j��������d�d��=�|S�r���)�joinr���)r����ds��� r���� _get_datazasync_chat._get_data^���s(�������H�H�T�]�#�#���M�!�!�!���r���c������������������ �����t����������d�������������r���r����r���s��� r����found_terminatorzasync_chat.found_terminatorc���r���r���c������������������������t����������|t����������������������r|�j��������rt����������||�j��������������������}n*t����������|t ����������������������r|dk�����rt ����������d�������������||�_��������dS�)zdSet the input delimiter. Can be a fixed string of any length, an integer, or None. r���z-the number of received bytes must be positiveN)� isinstance�str�use_encoding�bytes�encoding�int� ValueError� terminator)r����terms��� r����set_terminatorzasync_chat.set_terminatorf���sj������ ��d�C� � �� N�T�%6�� N���t�}�-�-�D�D� ��c� "� "�� N�t�a�x�x��L�M�M�M�����r���c�����������������������|�j���������S�r ���)r2���r(���s��� r����get_terminatorzasync_chat.get_terminatorq���s ��������r���c������������������ ���� �|�����������������������|�j��������������������}n1#�t����������$�r�Y�d�S�t����������$�r�|�������������������������������������Y�d�S�w�xY�wt����������|t����������������������r!|�j��������rt����������t����������|�j ��������������������}|�j ��������|z���|�_ ��������|�j ���������r�t����������|�j ��������������������}|������������������������������������}|s#|�� ��������������������|�j ���������������������d|�_ ���������n�t����������|t����������������������r�|}||k�����r2|�� ��������������������|�j ���������������������d|�_ ��������|�j��������|z ��|�_���������nM|�� ��������������������|�j ��������d�|�����������������������|�j ��������|d�����������|�_ ��������d|�_��������|�������������������������������������n�t����������|������������}|�j �����������������������������|������������}|dk����rT|dk����r"|�� ��������������������|�j ��������d�|�����������������������|�j ��������||z���d�����������|�_ ��������|�������������������������������������nxt%����������|�j ��������|������������}|r@||k����r8|�� ��������������������|�j ��������d�|������������������������|�j ��������|�d�����������|�_ ��������d�S�|�� ��������������������|�j ���������������������d|�_ ��������|�j �����������d�S�d�S�)Nr���r������)�recv�ac_in_buffer_size�BlockingIOError�OSError�handle_errorr+���r,���r-���r.���r/���r ����lenr6���r���r0���r2���r)����find�find_prefix_at_end)r���r����lbr2����n�terminator_len�indexs��� r����handle_readzasync_chat.handle_ready���s������ ��9�9�T�3�4�4�D�D���� �� �� ��F�F��� �� �� ��������F�F� ������d�C� � �� -�T�%6�� -���d�m�,�,�D� �-��4�������3 0��T�&�'�'�B��,�,�.�.�J���0 0��*�*�4�+<�=�=�=�$'��!�!��J��,�,��, 0�����6�6��.�.�t�/@�A�A�A�(+�D�%�&*�o��&:�D�O�O��.�.�t�/@��!��/D�E�E�E�(,�(9�!�"�"�(=�D�%�&'�D�O��)�)�+�+�+�+��"%�Z�����)�.�.�z�:�:���B�;�;��q�y�y���2�2�4�3D�V�e�V�3L�M�M�M�(,�(9�%��:N�:O�:O�(P�D�%���)�)�+�+�+�+��/�t�/@�*�M�M�E��� 0� �B�;�;� �6�6�t�7H��5�&��7Q�R�R�R�04�0A�5�&�'�'�0J�D�-�����2�2�4�3D�E�E�E�,/��)�g����3 0��3 0��3 0��3 0��3 0s������ A�A� Ac������������������.�����|��������������������������������������d�S�r ���)� initiate_sendr(���s��� r����handle_writezasync_chat.handle_write����s�������������r���c������������������.�����|��������������������������������������d�S�r ���)�closer(���s��� r����handle_closezasync_chat.handle_close����s������� � �����r���c����������������������t����������|t����������t����������t����������f������������st ����������dt����������|�������������������������|�j��������}t����������|������������|k����rGt����������dt����������|������������|������������D�]'}|�j ��������� ��������������������||||z���������������������������(n|�j ��������� ��������������������|�������������|�������������������������������������d�S�)Nz#data argument must be byte-ish (%r)r���)r+���r.���� bytearray� memoryview� TypeError�type�ac_out_buffer_sizer>����ranger���r!���rG���)r���r����sabs�is��� r����pushzasync_chat.push����s��������$�� �:� >�?�?�� (��A� ��J�J�(��(�� (��&���t�9�9�t����1�c�$�i�i��.�.�� :�� :���"�)�)�$�q��4��x�.�9�9�9�9� :�� ��%�%�d�+�+�+��������r���c������������������b�����|�j������������������������������|�������������|�������������������������������������d�S�r ���)r���r!���rG���)r����producers��� r����push_with_producerzasync_chat.push_with_producer����s1��������!�!�(�+�+�+��������r���c�����������������������dS�)z4predicate for inclusion in the readable for select()������r(���s��� r����readablezasync_chat.readable����s ��������qr���c������������������ �����|�j���������p|�j���������S�)z4predicate for inclusion in the writable for select())r���� connectedr(���s��� r����writablezasync_chat.writable����s�������!�9�$�.�&8�9r���c������������������:�����|�j������������������������������d�������������dS�)zAautomatically close this channel once the outgoing queue is emptyN)r���r!���r(���s��� r����close_when_donezasync_chat.close_when_done����s��������!�!�$�'�'�'�'�'r���c����������������������|�j����������rE|�j���������r?|�j���������d���������}|s |�j���������d=�|�|�������������������������������������d�S�|�j��������} �|d�|����������}nI#�t����������$�r<�|�����������������������������������}|r|�j������������������������������|�������������n|�j���������d=�Y���w�xY�wt����������|t����������������������r|�j ��������rt����������||�j��������������������} �|����������������������|������������}n%#�t����������$�r�|�������������������������������������Y�d�S�w�xY�w|rA|t����������|������������k�����s|t����������|������������k�����r||d�����������|�j���������d<���n|�j���������d=�d�S�d�S�d�S�)Nr���)r���r^���rK���rQ���rO����more� appendleftr+���r,���r-���r.���r/����sendr<���r=���r>���)r����first�obsr����num_sents��� r���rG���zasync_chat.initiate_send����s������� ��% �T�^��% ��&�q�)�E��� ��&�q�)��=��%�%�'�'�'��F���)�C� ��T�c�T�{������ �� �� ��z�z�|�|����.��&�1�1�$�7�7�7�7��*�1�-��� ������$��$�$�� 2��):�� 2��T�4�=�1�1�� ��9�9�T�?�?������ �� �� ��!�!�#�#�#���� ������� .��c�$�i�i�'�'�3��U���+;�+;�,1�(�)�)�,<�D�&�q�)�)��*�1�-��F�K% ��% ��% ��% s%���� A��AB�B�C$��$D�Dc������������������Z�����d|�_���������|�j��������d�d��=�|�j��������������������������������������������d�S�r���)r ���r���r����clearr(���s��� r����discard_bufferszasync_chat.discard_buffers��s3����������M�!�!�!���� � �"�"�"�"�"r���)NN)�__name__� __module__�__qualname__�__doc__r:���rQ���r-���r/���r���r���r"���r&���r)���r4���r6���rE���rH���rK���rU���rX���r\���r_���ra���rG���rk���r[���r���r���r ���r ���;���sI�������������F��F� ����� ��L��H�6��6��6��6�E��E��E�#��#��#������ E��E��E� �� �� ������F0��F0��F0�P���������� �� �� �����������:��:��:�(��(��(�&��&��&�P#��#��#��#��#r���r ���c�������������������������e�Zd�Zdd�Zd��ZdS�)�simple_producer����c������������������"�����||�_���������||�_��������d�S�r ���)r����buffer_size)r���r���rt���s��� r���r���zsimple_producer.__init__��s�������� �&����r���c�����������������������t����������|�j��������������������|�j��������k����r/|�j��������d�|�j������������������}|�j��������|�j��������d�����������|�_��������|S�|�j��������}d|�_��������|S�r���)r>���r���rt���)r����results��� r���rc���zsimple_producer.more��s\�������t�y�>�>�D�,�,�,��Y�0�� 0�0�1�F�� �$�"2�"3�"3�4�D�I��M��Y�F��D�I��Mr���N)rr���)rl���rm���rn���r���rc���r[���r���r���rq���rq�����s7��������������'��'��'��'���������r���rq���c�����������������������t����������|������������dz ��}|rA|����������������������|d�|����������������������s$|dz��}|r|����������������������|d�|�����������������������$|S�)NrZ���)r>����endswith)�haystack�needle�ls��� r���r@���r@���6��sk�������F���a��A� ���H�%�%�f�R�a�R�j�1�1��� �Q�������H�%�%�f�R�a�R�j�1�1����Hr���)ro���r����collectionsr����warningsr����_DEPRECATION_MSGrl���r���r ���rq���r@���r[���r���r����<module>r������s������8���(������������������ �� �� �� �� �� �N������H�&�w��7��7��7��7�X#��X#��X#��X#��X#��$��X#��X#��X#�v���������������@ �� �� �� �� r���