� ���g��4�ddlZddlmZGd�d��ZdS)�N�)�packetc�,�eZdZdZdZdd�Zdd�Zd�ZdS) �PayloadzEngine.IO payload.�Nc�J�|pg|_|�|�|��dSdS�N)�packets�decode)�selfr �encoded_payloads �`/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/engineio/payload.py�__init__zPayload.__init__ s3���}�"�� � � &� �K�K�� (� (� (� (� (� '� &�c���d}|jD]"}|r|dz }||�d���z }�#|�/dt|��zdz|�dd ��zd z}|S) z$Encode the payload for transmission.��T)�b64Nz___eio[z]("�"z\"z");)r �encode�str�replace)r � jsonp_indexr �pkts rrzPayload.encodes������<� 4� 4�C�� *��6�)�� �s�z�z�d�z�3�3� 3�O�O� � "�'�!�+�.�.�/�#�$�.�5�5�c�5�A�A�B�$� $�O� �rc�X�g|_t|��dkrdS|�d��r+tj�|��dd}|�d��}t|��|jkrtd���d�|D��|_dS)zDecode a transmitted payload.rNzd=�drzToo many packets in payloadc�8�g|]}tj|�����S))�encoded_packet)r�Packet)�.0rs r� <listcomp>z"Payload.decode.<locals>.<listcomp>-s5��?�?�?�*�� �^�D�D�D�?�?�?r) r �len� startswith�urllib�parse�parse_qs�split�max_decode_packets� ValueError)r r �encoded_packetss rr zPayload.decodes����� � �� � �1� $� $� �F� � %� %�d� +� +� )�$�l�3�3��!�!�!$�&�&'�)�O�*�/�/��7�7�� �� � �$�"9� 9� 9��:�;�;� ;�?�?�.=�?�?�?�� � � r)NNr )�__name__� __module__� __qualname__�__doc__r(rrr �rrrrsW����������)�)�)�)� � � � �?�?�?�?�?rr)r$rrrr/rr�<module>r0sR�� � � � �������(?�(?�(?�(?�(?�(?�(?�(?�(?�(?r
Memory