�
���g�) � �t � d dl Z d dlZd dlZddlmZ ddlmZ ddlmZ ddlmZ G d� dej � � Z dS ) � N� )�base_socket)�
exceptions)�packet)�payloadc �R � e Zd Zd� Zd� Zd� Zd� Zd� Zd� Zdd
�Z d� Z
d� Zd
� Zd� Z
d S )�AsyncSocketc � �D K � t j | j � � � | j j | j j z � � � d{V ��g}| j � � � n2# t j t j f$ r t j � � �w xY w|dgk rg S | j � � � }| j � � � |�| j �
d� � n,|� |� � n# t j $ r Y nw xY w�||S )z'Wait for packets to send to the client.N)�asyncio�wait_for�queue�get�server�
ping_interval�ping_timeout� task_done�TimeoutError�CancelledErrorr �
QueueEmpty�
get_nowait�
put_nowait�append)�self�packets�pkts �e/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/engineio/async_socket.py�pollzAsyncSocket.poll s] � � � � *�$�-��
��� � ���)�D�K�,D�D�F� F� F� F� F� F� F� F� G�G�
�J� � �"�"�"�"���$�g�&<�=� *� *� *��'�)�)�)� *�����t�f����I� �
��j�+�+�-�-���
�$�$�&�&�&��;��J�)�)�$�/�/�/�����s�#�#�#�#���%�
�
�
���
���� � �s% �A#A( �(/B�%AD
�4D
�
D�Dc � �� K � | j j � d| j t j |j t |j t � � s|j nd� � |j t j
k r| � � � dS |j t j k r:| j �
d| j |j | j j �� � � d{V �� dS |j t j k r9| � t j t j � � � � � d{V �� dS |j t j k r/| � dd| j j j �� � � d{V �� dS t/ j � � �) zReceive packet from the client.z%s: Received packet %s data %s�<binary>�message�� run_asyncNFT��wait�abort�reason)r �logger�info�sidr �packet_names�packet_type�
isinstance�data�bytes�PONG�
schedule_ping�MESSAGE�_trigger_event�async_handlers�UPGRADE�send�Packet�NOOP�CLOSE�closer&