� E�g�=� ��UddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZdd lmZm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'm(Z(d Z)d Z*ee+e,d<erddl m-Z-Gd�de.��Z/Gd�de0ej1��Z2dedededdfd�Z3e2j4d�deddede2ddfd�Z5Gd�d ��Z6edZ7ee7efZ8Gd!�d"��Z9Gd#�de ��Z:Gd$�d%e:��Z;Gd&�d'e;��Z<Gd(�d)e<��Z=Gd*�d+e:��Z>Gd,�d-e>��Z?Gd.�d/e>��Z@Gd0�d1e>��ZAGd2�d3e;��ZBerdd4l mCZCmDZDeDeEZFeCeEZGn dd4lHmCZCmDZDeDZFeCZGGd5�d6e:��ZIGd7�d8eI��ZJe9��ZKeK�Le;eEeMeNf��eK�Le<e0��eK�Le=ejO��eK�Le?ejP��eK�Le@ejQ��eK�LeAejRejSf��eK�Le>ejT��eK�LeJe%��eK�LeIeCe2jU���dS)9�N)�ABC�abstractmethod)�chain) �IO� TYPE_CHECKING�Any�Dict�Final�Iterable�Optional�TextIO�Tuple�Type�Union)� CIMultiDict�)�hdrs)�AbstractStreamWriter)� _SENTINEL�content_disposition_header�guess_filename�parse_mimetype�sentinel)� StreamReader)� JSONEncoder� _CIMultiDict) �PAYLOAD_REGISTRY� get_payload� payload_type�Payload� BytesPayload� StringPayload� IOBasePayload�BytesIOPayload�BufferedReaderPayload� TextIOPayload�StringIOPayload� JsonPayload�AsyncIterablePayloadi�TOO_LARGE_BYTES_BODY)�Listc��eZdZdS)� LookupErrorN)�__name__� __module__� __qualname__���_/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/aiohttp/payload.pyr-r-=s�������Dr2r-c��eZdZdZdZdZdS)�Order�normal� try_first�try_lastN)r.r/r0r6r7r8r1r2r3r5r5As������ �F��I��H�H�Hr2r5�data�args�kwargs�returnr c�,�tj|g|�Ri|��S�N)r�get)r9r:r;s r3rrGs#�� � �� 6�t� 6� 6� 6�v� 6� 6�6r2��order�factory�typerAc�@�t�|||���dS�Nr@)r�register)rBrCrAs r3�register_payloadrGKs%�����g�t�5��9�9�9�9�9r2c�Z�eZdZejd�dededdfd�Zdeddedfd �ZdS) rr@rCrAr<Nc�"�||_||_dSr>)rCrA)�selfrCrAs r3�__init__zpayload_type.__init__Rs���� ��� � � r2rBr c�>�t||j|j���|SrE)rGrCrA)rJrBs r3�__call__zpayload_type.__call__Vs ����$�)�4�:�>�>�>�>��r2) r.r/r0r5r6rrKrrMr1r2r3rrQsv������49�L����S��E��T�������Y���D��O������r2rc �h�eZdZdZdZdd�Zed�deded d d edd f d �Ze j d�de dede ddfd�Z dS)�PayloadRegistryzZPayload registry. note: we need zope.interface for more efficient adapter search ��_first�_normal�_last�_normal_lookupr<Nc�>�g|_g|_g|_i|_dSr>rP�rJs r3rKzPayloadRegistry.__init__gs%��24�� �35�� �13�� �68����r2)�_CHAINr9r:rWz!Type[chain[_PayloadRegistryItem]]r;r c��|jr+|jD]#\}}t||��r||g|�Ri|��cS�$|j�t |����x}r ||g|�Ri|��St|t ��r|S||j|j��D]#\}}t||��r||g|�Ri|��cS�$t���r>) rQ� isinstancerTr?rCr rRrSr-)rJr9rWr:r;rB�type_�lookup_factorys r3r?zPayloadRegistry.getms'�� �;� :�"&�+� :� :�����d�E�*�*�:�"�7�4�9�$�9�9�9�&�9�9�9�9�9�:�"�0�4�4�T�$�Z�Z�@�@� @�>� 9�!�>�$�8��8�8�8��8�8� 8� �d�G� $� $� ��K�$�f�T�\�4�:�>�>� 6� 6�N�G�U��$��&�&� 6��w�t�5�d�5�5�5�f�5�5�5�5�5� 6��m�m�r2r@rBrCrAc��|tjur|j�||f��dS|tjurN|j�||f��t |t��r|D] }||j|<� dS||j|<dS|tj ur|j �||f��dStd|�����)NzUnsupported order ) r5r7rQ�appendr6rRrYr rTr8rS� ValueError)rJrBrCrA�ts r3rFzPayloadRegistry.register�s��� �E�O� #� #� �K� � ���� /� /� /� /� /� �e�l� "� "� �L� � ��$�� 0� 0� 0��$��)�)� 4��5�5�A�-4�D�'��*�*�5�5�-4��#�D�)�)�)� �e�n� $� $� �J� � �w��o� .� .� .� .� .��;�%�;�;�<�<� <r2)r<N) r.r/r0�__doc__� __slots__rKrrr?r5r6� PayloadTyperFr1r2r3rOrO_s��������� A�I�9�9�9�9�7<� �������4� � � � � ����0BG��=�=�=�"�=�*-�=�9>�=� �=�=�=�=�=�=r2rOc��eZdZUdZeed<dZeeed<de ddfde dee e e eefeeeeffde edefdeed eed e d dfd �Zed eefd ���Zed eefd���Zed e fd���Zed efd���Zed eefd���Zed efd���Z ddededede d df d�Zed d eded efd���Zeded dfd���ZdS)!r �application/octet-stream�_default_content_typeN�_size�value�headers� content_type�filename�encodingr;r<c ���||_||_t��|_||_|t ur|�||jt j<n}|j�]tj dkr tj }n tj }||j��d}|�|j }||jt j<n|j |jt j<|r|j�|��dSdS)N)�� r)� _encoding� _filenamer�_headers�_valuerr� CONTENT_TYPE�sys� version_info� mimetypes�guess_file_type� guess_typere�update)rJrgrhrirjrkr;�guessers r3rKzPayload.__init__�s���"���!���&1�m�m�� ��� � �x� '� '�L�,D�/;�D�M�$�+� ,� ,� �^� '���7�*�*�#�3���#�.��"�7�4�>�2�2�1�5�L��#�#�9� �/;�D�M�$�+� ,� ,�/3�/I�D�M�$�+� ,� � *� �M� � �� )� )� )� )� )� *� *r2c��|jS)zSize of the payload.)rfrVs r3�sizez Payload.size�s ���z�r2c��|jS)zFilename of the payload.)rprVs r3rjzPayload.filename�� ���~�r2c��|jS)zCustom item headers)rqrVs r3rhzPayload.headers�s ���}�r2c��d�d�|j���D�����d��dzS)N�c�*�g|]\}}|dz|zdz��S)z: z r1)�.0�k�vs r3� <listcomp>z+Payload._binary_headers.<locals>.<listcomp>�s)��L�L�L�t�q�!�Q��X��\�F�*�L�L�Lr2�utf-8s )�joinrh�items�encoderVs r3�_binary_headerszPayload._binary_headers�sR�� �G�G�L�L�t�|�7I�7I�7K�7K�L�L�L� M� M� T� T�� � �� � r2c��|jS)zPayload encoding)rorVs r3rkzPayload.encoding�r~r2c�0�|jtjS)z Content type)rqrrsrVs r3rizPayload.content_type�s���}�T�.�/�/r2Tr��disptype� quote_fields�_charset�paramsc �J�t|f||d�|��|jtj<dS)z$Sets ``Content-Disposition`` header.)r�r�N)rrqr�CONTENT_DISPOSITION)rJr�r�r�r�s r3�set_content_dispositionzPayload.set_content_disposition�s>��3M� �3 �#/�(�3 �3 �FL�3 �3 �� �d�.�/�/�/r2�strict�errorsc��dS)z~Return string representation of the value. This is named decode() to allow compatibility with bytes objects. Nr1�rJrkr�s r3�decodezPayload.decode�s���r2�writerc�� K�dS)zLWrite payload. writer is an AbstractStreamWriter instance: Nr1�rJr�s r3�writez Payload.write�s �����r2)Tr��r�r�) r.r/r0re�str�__annotations__rfr �intrrrrr r rrrK�propertyr|rjrh�bytesr�rkri�boolr�rr�rr�r1r2r3r r �s��������!;��3�;�;�;��E�8�C�=���� �4<�"&�"&�*�*��*�� �,��S�#�X����s�C�x��0I�I� J� �*� �C��y�0�1� *��3�-�*��3�-�*��*� �*�*�*�*�>��h�s�m�����X����(�3�-�����X���������X��� �� � � ��X� ���(�3�-�����X���0�c�0�0�0��X�0�"��  �  ��  ��  ��  � �  � �  �  �  �  �� � �s� �c� �� � � ��^� � � �"6� �4� � � ��^� � � r2c�t��eZdZUeed<deeeefdededdf�fd� Z dd e d e de fd �Z d e ddfd�Z �xZS)r!rrrgr:r;r<Nc���d|vrd|d<t��j|g|�Ri|��t|t��r |j|_nPt|t tf��rt|��|_ntdt|�������|jtkrd|i}tj dtfi|��dSdS)Nrirdz%value argument must be byte-ish, not �sourcez}Sending a large body directly with raw bytes might lock the event loop. You should probably pass an io.BytesIO object instead)�superrKrY� memoryview�nbytesrfr�� bytearray�len� TypeErrorrCr*�warnings�warn�ResourceWarning�rJrgr:r;� __class__s �r3rKzBytesPayload.__init__�s���� �� '� '�%?�F�>� "�������0��0�0�0��0�0�0� �e�Z� (� (� U���D�J�J� ���y�1� 2� 2� U��U���D�J�J��S�D��K�K�S�S�T�T� T� �:�,� ,� ,���%�F� �M�,� �  � � �  � � � � � -� ,r2r�r�rkr�c�8�|j�||��Sr>)rrr�r�s r3r�zBytesPayload.decodes���{�!�!�(�F�3�3�3r2r�c��JK�|�|j���d{V��dSr>)r�rrr�s r3r�zBytesPayload.writes2�����l�l�4�;�'�'�'�'�'�'�'�'�'�'�'r2r�)r.r/r0r�r�rr�r�rrKr�r�rr�� __classcell__�r�s@r3r!r!�s��������� �M�M�M���5�)�Z�7�8��AD��PS�� �������24�4�s�4�c�4��4�4�4�4�(�"6�(�4�(�(�(�(�(�(�(�(r2r!c �X��eZdZddd�dededeedeededdf �fd �Z�xZS) r"N�rkrirgr:rkrir;r<c����|�2|�d}d}n4t|��}|j�dd��}n |�d|z}|}t��j|�|��g|�R||d�|��dS)Nr��text/plain; charset=utf-8�charset�text/plain; charset=%sr�)r� parametersr?r�rKr�) rJrgrkrir:r;� real_encoding�mimetyper�s �r3rKzStringPayload.__init__s���� � ��#� '� �:� � �)�,�7�7�� (� 3� 7� 7� �7� K� K� � ��#�7�(�B� �$�M������ �L�L�� '� '� ��  � �"�%� � � �  � � � � r2)r.r/r0r�rr rKr�r�s@r3r"r"s�������� #'�&*�  � � �� �� ��3�-�  � �s�m�  � �  � � � � � � � � � � � r2r"c�<��eZdZdeedededdf�fd� Z�xZS)r'rgr:r;r<Nc�f��t��j|���g|�Ri|��dSr>)r�rK�readr�s �r3rKzStringIOPayload.__init__:s8�������������7��7�7�7��7�7�7�7�7r2)r.r/r0rr�rrKr�r�s@r3r'r'9s]�������8�b��g�8�c�8�S�8�T�8�8�8�8�8�8�8�8�8�8r2r'c ���eZdZUejed< ddeededededdf �fd � Z d e ddfd �Z ddededefd�Z �xZ S)r#rr� attachmentrg� dispositionr:r;r<Nc����d|vrt|��|d<t��j|g|�Ri|��|j�3|�3tj|jvr"|�||j���dSdSdSdS)Nrj)rj)rr�rKrprr�rhr�)rJrgr�r:r;r�s �r3rKzIOBasePayload.__init__As���� �V� #� #�!/��!6�!6�F�:� �������0��0�0�0��0�0�0� �>� %�+�*A��'�t�|�;�;��,�,�[�4�>�,�R�R�R�R�R� &� %�*A�*A�;�;r2r�c��K�tj��} |�d|jjd���d{V��}|rD|�|���d{V��|�d|jjd���d{V��}|�D|�d|jj���d{V��dS#|�d|jj���d{V��wxYw)N�)�asyncio�get_event_loop�run_in_executorrrr�r��close)rJr��loop�chunks r3r�zIOBasePayload.writeMs�����%�'�'�� @��.�.�t�T�[�5E�u�M�M�M�M�M�M�M�M�E�� R��l�l�5�)�)�)�)�)�)�)�)�)�"�2�2�4���9I�5�Q�Q�Q�Q�Q�Q�Q�Q��� R��&�&�t�T�[�->�?�?� ?� ?� ?� ?� ?� ?� ?� ?� ?��$�&�&�t�T�[�->�?�?� ?� ?� ?� ?� ?� ?� ?� ?���s �A-B,�,(Cr�r�rkr�c�x���d���fd�|j���D����S)Nr�c3�D�K�|]}|�����V��dSr>)r�)r��rrkr�s ��r3� <genexpr>z'IOBasePayload.decode.<locals>.<genexpr>Xs1�����S�S�a�q�x�x��&�1�1�S�S�S�S�S�Sr2)r�rr� readlinesr�s ``r3r�zIOBasePayload.decodeWs<�����w�w�S�S�S�S�S�4�;�;P�;P�;R�;R�S�S�S�S�S�Sr2)r�r�)r.r/r0�io�IOBaser�rrr�rKrr�r�r�r�s@r3r#r#>s��������� �I����2>� S� S���W� S�+.� S�FI� S�UX� S� � S� S� S� S� S� S�@�"6�@�4�@�@�@�@�T�T�s�T�c�T��T�T�T�T�T�T�T�Tr2r#c ���eZdZUejed<ddd�dededee dee ded df �fd �Z e d ee fd ���Z dde de d e fd�Zded dfd�Z�xZS)r&rrNr�rgr:rkrir;r<c���|�2|�d}d}n2t|��}|j�dd��}n|�d|z}t��j|g|�R||d�|��dS)Nr�r�r�r��rirk)rr�r?r�rK)rJrgrkrir:r;r�r�s �r3rKzTextIOPayload.__init__^s���� � ��#�"��:� � �)�,�7�7��#�.�2�2�9�g�F�F����#�7�(�B� ������ � ��  � �%�� � � �  � � � � r2c�� tj|j�����j|j���z S#t $rYdSwxYwr>)�os�fstatrr�fileno�st_size�tell�OSErrorrVs r3r|zTextIOPayload.sizezs]�� ��8�D�K�.�.�0�0�1�1�9�D�K�<L�<L�<N�<N�N� N��� � � ��4�4� ���s�A A � A�Ar�r�r�c�4�|j���Sr>)rrr�r�s r3r�zTextIOPayload.decode�s���{���!�!�!r2r�c��K�tj��} |�d|jjd���d{V��}|rz|jr|�|j���n|���}|�|���d{V��|�d|jjd���d{V��}|�z|�d|jj���d{V��dS#|�d|jj���d{V��wxYw)Nr�)rk) r�r�r�rrr�ror�r�r�)rJr�r�r�r9s r3r�zTextIOPayload.write�sI�����%�'�'�� @��.�.�t�T�[�5E�u�M�M�M�M�M�M�M�M�E�� R��~�(�E�L�L�$�.�L�9�9�9������� �l�l�4�(�(�(�(�(�(�(�(�(�"�2�2�4���9I�5�Q�Q�Q�Q�Q�Q�Q�Q��� R��&�&�t�T�[�->�?�?� ?� ?� ?� ?� ?� ?� ?� ?� ?��$�&�&�t�T�[�->�?�?� ?� ?� ?� ?� ?� ?� ?� ?���s �B#C"�"(D r�)r.r/r0r�� TextIOBaser�r rr r�rKr�r�r|r�rr�r�r�s@r3r&r&[s'�������� �M���� #'�&*�  � � �� �� ��3�-�  � �s�m�  � �  � � � � � � � �8��h�s�m�����X�� "�"�s�"�c�"��"�"�"�"� @�"6� @�4� @� @� @� @� @� @� @� @r2r&c�V�eZdZUejed<edefd���Zd de de de fd�Z d S) r$rrr<c��|j���}|j�dtj��}|j�|��||z S)Nr)rrr��seekr��SEEK_END)rJ�position�ends r3r|zBytesIOPayload.size�sN���;�#�#�%�%���k���q�"�+�.�.�� � ����"�"�"��X�~�r2r�r�rkr�c�\�|j����||��Sr>�rrr�r�r�s r3r�zBytesIOPayload.decode��&���{���!�!�(�(��6�:�:�:r2Nr�) r.r/r0r��BytesIOr�r�r�r|r�r�r1r2r3r$r$�sw������� �J���� ��c�����X�� ;�;�s�;�c�;��;�;�;�;�;�;r2r$c�b�eZdZUejed<edeefd���Z d de de de fd�Z d S) r%rrr<c��� tj|j�����j|j���z S#t tf$rYdSwxYwr>)r�r�rrr�r�r�r��AttributeErrorrVs r3r|zBufferedReaderPayload.size�sd�� ��8�D�K�.�.�0�0�1�1�9�D�K�<L�<L�<N�<N�N� N����(� � � � �4�4�  ���s�A A � A!� A!r�r�rkr�c�\�|j����||��Sr>r�r�s r3r�zBufferedReaderPayload.decode�r�r2Nr�) r.r/r0r��BufferedIOBaser�r�r r�r|r�r�r1r2r3r%r%�s|������� � ���� ��h�s�m�����X��;�;�s�;�c�;��;�;�;�;�;�;r2r%c�N��eZdZddejfdedededededed d f�fd � Z�xZ S) r(r�zapplication/jsonrgrkri�dumpsr:r;r<Nc���t��j||���|��g|�R||d�|��dS)Nr�)r�rKr�)rJrgrkrir�r:r;r�s �r3rKzJsonPayload.__init__�sl��� ����� �E�%�L�L� � �� )� )� ��  � �%�� � � �  � � � � r2) r.r/r0�jsonr�rr�rrKr�r�s@r3r(r(�s�������� �.�!�Z�  � �� �� ��  � �  � �  �� � � � � � � � � � � � r2r()� AsyncIterable� AsyncIteratorc�|��eZdZUdZeeed<eed<dedededdf�fd� Z d e ddfd �Z dd e de de fd�Z �xZS)r)N�_iterrrrgr:r;r<c���t|t��s/td�t |�������d|vrd|d<t ��j|g|�Ri|��|���|_dS)NzMvalue argument must support collections.abc.AsyncIterable interface, got {!r}rird) rYr�r��formatrCr�rK� __aiter__r�r�s �r3rKzAsyncIterablePayload.__init__�s�����%��/�/� ���!�6�$�u�+�+�.�.��� � �� '� '�%?�F�>� "�������0��0�0�0��0�0�0��_�_�&�&�� � � r2r�c���K�|jrU |j����d{V��}|�|���d{V���;#t$r d|_YdSwxYwdSr>)r�� __anext__r��StopAsyncIteration)rJr�r�s r3r�zAsyncIterablePayload.write�s����� �:� "� "�.�"&�*�"6�"6�"8�"8�8�8�8�8�8�8�E� �,�,�u�-�-�-�-�-�-�-�-�-�.��&� "� "� "�!�� � � � � "���� "� "s�<A�A�Ar�r�rkr�c� �td���)NzUnable to decode.)r�r�s r3r�zAsyncIterablePayload.decode�s���+�,�,�,r2r�)r.r/r0r�r �_AsyncIteratorr��_AsyncIterablerrKrr�r�r�r�r�s@r3r)r)�s���������&*�E�8�N� #�*�*�*� ���� '�n� '�S� '�C� '�D� '� '� '� '� '� '� "�"6� "�4� "� "� "� "�-�-�s�-�c�-��-�-�-�-�-�-�-�-r2r)c�0��eZdZdedededdf�fd� Z�xZS)�StreamReaderPayloadrgr:r;r<Nc�f��t��j|���g|�Ri|��dSr>)r�rK�iter_anyr�s �r3rKzStreamReaderPayload.__init__�s:�����������)�)�;�D�;�;�;�F�;�;�;�;�;r2)r.r/r0rrrKr�r�s@r3rr�sY�������<�l�<�3�<�#�<�$�<�<�<�<�<�<�<�<�<�<r2r)Vr��enumr�r�rvr�rtr��abcrr� itertoolsr�typingrrrr r r r r rrr� multidictrr�rr�helpersrrrrr�streamsr�typedefsrr�__all__r*r�r�r+� Exceptionr-r��Enumr5rr6rGrrb�_PayloadRegistryItemrOr r!r"r'r#r&r$r%r(r�r�r�rr�collections.abcr)rrrFr�r��StringIOr�r��BufferedReader�BufferedRandomr�r8r1r2r3�<module>rse������� � � � � � � � � � � � ����� � � � � � � � �����#�#�#�#�#�#�#�#������� � � � � � � � � � � � � � � � � � � � � � � � � � �"�!�!�!�!�!�������%�%�%�%�%�%���������������"�!�!�!�!�!�/�/�/�/�/�/�/�/� �� $)��e�C�j�(�(�(��������� � � � � �)� � � ������C������ 7�c�7�#�7��7��7�7�7�7� <A�<�:�:�:� �)�_�:�$'�:�38�:� �:�:�:�:� ���������9�o� ��[�#�-�.��4=�4=�4=�4=�4=�4=�4=�4=�n^ �^ �^ �^ �^ �c�^ �^ �^ �B (� (� (� (� (�7� (� (� (�F � � � � �L� � � �>8�8�8�8�8�m�8�8�8� T�T�T�T�T�G�T�T�T�:6@�6@�6@�6@�6@�M�6@�6@�6@�r ;� ;� ;� ;� ;�]� ;� ;� ;�;�;�;�;�;�M�;�;�;�$ � � � � �,� � � �(� #�3�3�3�3�3�3�3�3�"�5�)�N�"�5�)�N�N�<�<�<�<�<�<�<�<�"�N�"�N� -� -� -� -� -�7� -� -� -�F<�<�<�<�<�.�<�<�<� #�?�$�$�����,�� �:�(F�G�G�G����-��-�-�-����/�2�;�7�7�7����-���7�7�7����.�"�*�5�5�5����/�"�2C�R�EV�1W�X�X�X����-���3�3�3����-�|�<�<�<����.� �U�^��T�T�T�T�Tr2
Memory