�
���g� � � � d dl Z d dlZd dlZd dlZd dlZddlmZ e j d� � Zg Z d� Z
da G d� d� � Z dS )� N� )�packetzengineio.clientc �� � t dd� D ]*}|� � � s|� � � �+t t � � rt | |� � S t j | |� � S )zdSIGINT handler.
Disconnect all active clients and then invoke the original signal handler.
N)�connected_clients�is_asyncio_based�
disconnect�callable�original_signal_handler�signal�default_int_handler)�sig�frame�clients �d/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/engineio/base_client.py�signal_handlerr sy � �
$�A�A�A�&� � ���&�&�(�(� � � � � � � ���'�(�(� 6�&�s�E�2�2�2� �)�#�u�5�5�5� c �d � e Zd Zg d�Z G d� d� � Z dd�Zd � Zdd
�Zd � Zd � Z d
� Z
d� Z dS )�
BaseClient)�connectr �messagec � � e Zd ZdZdZdZdZdS )�BaseClient.reasonzDisconnection reasons.zclient disconnectzserver disconnectztransport errorN)�__name__�
__module__� __qualname__�__doc__�CLIENT_DISCONNECT�SERVER_DISCONNECT�TRANSPORT_ERROR� r r �reasonr ! s% � � � � � �$�$� /�� /��+���r r! FN� Tc �h � |rSt �Lt j � � t j � � k r$t j t j t � � a i | _ d | _ d | _ d | _
d | _ d | _ d | _
d | _ || _ |d u| _ || _ d | _ d | _ d | _ d | _ d| _ || _ |pi | _ || _ |�|t4 j _ t; |t< � � s|| _ n�t@ | _ | j j! tD j# k rv|r%| j �$ tD j% � � n$| j �$ tD j& � � | j �' tE j( � � � � || _) d S �N� disconnected)*r
� threading�current_thread� main_threadr �SIGINTr �handlers�base_url�
transports�current_transport�sid�upgrades�
ping_interval� ping_timeout�http�
external_http�
handle_sigint�ws�read_loop_task�write_loop_task�queue�state�
ssl_verify�websocket_extra_options�timestamp_requestsr �Packet�json�
isinstance�bool�logger�default_logger�level�logging�NOTSET�setLevel�INFO�ERROR�
addHandler�
StreamHandler�request_timeout) �selfrA r> rK � http_sessionr: r4 r; r< s r �__init__zBaseClient.__init__* s� � � � D� 4� <��(�*�*�i�.C�.E�.E�E�E�&,�m�F�M�4B�'D� 'D� #���
� ��
� ���!%�� ���� ��
� !��� ��� �� � )�� 5��� *������ "��� #�� ���
�#��
�$���'>�'D�"��$�"4�� � � �!%�F�M� ��&�$�'�'� @� �D�K�K�(�D�K��{� �G�N�2�2�� 8��K�(�(�� �6�6�6�6��K�(�(�� �7�7�7�� �&�&�w�'<�'>�'>�?�?�?� .�� � � r c � � dS )NFr �rL s r r zBaseClient.is_asyncio_basedU s � ��ur c �d � �� �� j vrt d� � ��� fd�}|�|S ||� � dS )a� Register an event handler.
:param event: The event name. Can be ``'connect'``, ``'message'`` or
``'disconnect'``.
:param handler: The function that should be invoked to handle the
event. When this parameter is not given, the method
acts as a decorator for the handler function.
Example usage::
# as a decorator:
@eio.on('connect')
def connect_handler():
print('Connection request')
# as a method:
def message_handler(msg):
print('Received message: ', msg)
eio.send('response')
eio.on('message', message_handler)
z
Invalid eventc � �� | �j �< | S �N)r* )�handler�eventrL s ��r � set_handlerz"BaseClient.on.<locals>.set_handlerq s �� �#*�D�M�%� ��Nr N)� event_names�
ValueError)rL rU rT rV s `` r �onz
BaseClient.onX sc ��� �, ��(� (� (� �_�-�-� -� � � � � � � �?� � �� �G� � � � � r c � � | j S )z�Return the name of the transport currently in use.
The possible values returned by this function are ``'polling'`` and
``'websocket'``.
)r- rP s r � transportzBaseClient.transporty s
� � �%�%r c �" � d| _ d | _ d S r$ )r9 r. rP s r �_resetzBaseClient._reset� s � �#��
�����r c �$ � |� d� � }t j � |� � }|dk rd}n|dk rd}nt d� � �|j dv r|dz
}d � ||j ||j |j rd
nd |� � � S )
z&Generate the Engine.IO connection URL.�/�pollingr2 � websocketr5 zinvalid transport)�https�wss�szC{scheme}://{netloc}/{path}/?{query}{sep}transport={transport}&EIO=4�&� )�scheme�netloc�path�query�sepr[ ) �strip�urllib�parse�urlparserX rg �formatrh rj )rL �url�
engineio_pathr[ �
parsed_urlrg s r �_get_engineio_urlz BaseClient._get_engineio_url� s� � �%�+�+�C�0�0�
��\�*�*�3�/�/�
� � � !� !��F�F�
�+�
%�
%��F�F� � 0�1�1� 1� � � 0� 0� 0� �c�M�F�3�4:�F�!�*�*;�&�j�.>� )� /�7���R� '� 5;� 5)� 5)� )r c �Z � | j sdS dt t j � � � � z S )z.Generate the Engine.IO query string timestamp.rf z&t=)r< �str�timerP s r �_get_url_timestampz BaseClient._get_url_timestamp� s+ � ��&� ��2��s�4�9�;�;�'�'�'�'r )FNr" NTTNTrS ) r r r rW r! rN r rY r[ r] rt rx r r r r r s� � � � � � �6�6�6�K�,� ,� ,� ,� ,� ,� ,� ,� AB�CG�BF�)/� )/� )/� )/�V� � � � � � �B&� &� &�� � �)� )� )�*(� (� (� (� (r r )
rD r r& rw rm rf r � getLoggerrB r r r
r r r r �<module>rz s� �� ����
�
�
�
� � � � � � � � �
�
�
�
� � � � � � �"��"�#4�5�5��� � 6� 6� 6� � �@(� @(� @(� @(� @(� @(� @(� @(� @(� @(r