§
     @go  ã                  óp  — d dl mZ d dlZd dlZd dlmZ d dlmZm	Z	m
Z
mZmZmZ d dlmZ ddlmZmZ ddlmZ dd	lmZmZmZmZmZmZ dd
lmZmZ  G d„ dee¦  «        Z G d„ de¦  «        Z  G d„ de¦  «        Z! G d„ dee¦  «        Z"d2d„Z#d3d„Z$d4d!„Z%d5d$„Z&d6d&„Z'd7d)„Z(	 	 	 	 	 d8d9d.„Z)	 	 	 	 d:d;d1„Z*dS )<é    )ÚannotationsN)Údumps)ÚAnyÚAsyncIterableÚAsyncIteratorÚIterableÚIteratorÚMapping)Ú	urlencodeé   )ÚStreamClosedÚStreamConsumed)ÚMultipartStream)ÚAsyncByteStreamÚRequestContentÚRequestDataÚRequestFilesÚResponseContentÚSyncByteStream)Úpeek_filelike_lengthÚprimitive_value_to_strc                  ó&   — e Zd Zdd„Zdd„Zdd	„Zd
S )Ú
ByteStreamÚstreamÚbytesÚreturnÚNonec                ó   — || _         d S ©N©Ú_stream©Úselfr   s     úB/var/www/piapp/venv/lib/python3.11/site-packages/httpx/_content.pyÚ__init__zByteStream.__init__   s   € ØˆŒˆˆó    úIterator[bytes]c              #  ó   K  — | j         V — d S r   r    ©r#   s    r$   Ú__iter__zByteStream.__iter__!   s   è è € ØŒlÐÐÐÐÐr&   úAsyncIterator[bytes]c               ó   K  — | j         W V — d S r   r    r)   s    r$   Ú	__aiter__zByteStream.__aiter__$   s   è è € ØŒlÐÐÐÐÐÐr&   N)r   r   r   r   ©r   r'   ©r   r+   )Ú__name__Ú
__module__Ú__qualname__r%   r*   r-   © r&   r$   r   r      sP   € € € € € ðð ð ð ðð ð ð ðð ð ð ð ð r&   r   c                  ó"   — e Zd ZdZd
d„Zdd„Zd	S )ÚIteratorByteStreamé   r   úIterable[bytes]r   r   c                óT   — || _         d| _        t          j        |¦  «        | _        d S ©NF)r!   Ú_is_stream_consumedÚinspectÚisgeneratorÚ_is_generatorr"   s     r$   r%   zIteratorByteStream.__init__+   s*   € ØˆŒØ#(ˆÔ Ý$Ô0°Ñ8Ô8ˆÔÐÐr&   r'   c              #  ó*  K  — | j         r| j        rt          ¦   «         ‚d| _         t          | j        d¦  «        rJ| j                             | j        ¦  «        }|r'|V — | j                             | j        ¦  «        }|°%d S d S | j        D ]}|V — Œd S )NTÚread)r:   r=   r   Úhasattrr!   r?   Ú
CHUNK_SIZE©r#   ÚchunkÚparts      r$   r*   zIteratorByteStream.__iter__0   sÈ   è è € ØÔ#ð 	#¨Ô(:ð 	#Ý Ñ"Ô"Ð"à#'ˆÔ Ý�4”< Ñ(Ô(ð 		à”L×%Ò% d¤oÑ6Ô6ˆEØð ;Ø���Øœ×)Ò)¨$¬/Ñ:Ô:�ð ð ;ð ;ð ;ð ;ð ;ð
 œð ð �Ø�
�
�
�
ðð r&   N)r   r7   r   r   r.   )r0   r1   r2   rA   r%   r*   r3   r&   r$   r5   r5   (   sA   € € € € € Ø€Jð9ð 9ð 9ð 9ð
ð ð ð ð ð r&   r5   c                  ó"   — e Zd ZdZd
d„Zdd„Zd	S )ÚAsyncIteratorByteStreamr6   r   úAsyncIterable[bytes]r   r   c                óT   — || _         d| _        t          j        |¦  «        | _        d S r9   )r!   r:   r;   Ú
isasyncgenr=   r"   s     r$   r%   z AsyncIteratorByteStream.__init__D   s*   € ØˆŒØ#(ˆÔ Ý$Ô/°Ñ7Ô7ˆÔÐÐr&   r+   c               óR  K  — | j         r| j        rt          ¦   «         ‚d| _         t          | j        d¦  «        rW| j                             | j        ¦  «        ƒ d {V —†}|r.|W V — | j                             | j        ¦  «        ƒ d {V —†}|°,d S d S | j        2 3 d {V —†}|W V — Œ6 d S )NTÚaread)r:   r=   r   r@   r!   rK   rA   rB   s      r$   r-   z!AsyncIteratorByteStream.__aiter__I   s  è è € ØÔ#ð 	#¨Ô(:ð 	#Ý Ñ"Ô"Ð"à#'ˆÔ Ý�4”< Ñ)Ô)ð 		àœ,×,Ò,¨T¬_Ñ=Ô=Ð=Ð=Ð=Ð=Ð=Ð=ˆEØð BØ����Ø"œl×0Ò0°´ÑAÔAÐAÐAÐAÐAÐAÐA�ð ð Bð Bð Bð Bð Bð
 #œlð ð ð ð ð ð ð �dØ�
�
�
�
�
ð +˜l˜ls   ÂB&N)r   rG   r   r   r/   )r0   r1   r2   rA   r%   r-   r3   r&   r$   rF   rF   A   sA   € € € € € Ø€Jð8ð 8ð 8ð 8ð
ð ð ð ð ð r&   rF   c                  ó"   — e Zd ZdZdd„Zd	d„ZdS )
ÚUnattachedStreamz¿
    If a request or response is serialized using pickle, then it is no longer
    attached to a stream for I/O purposes. Any stream operations should result
    in `httpx.StreamClosed`.
    r   r'   c                ó   — t          ¦   «         ‚r   ©r   r)   s    r$   r*   zUnattachedStream.__iter__a   s   € Ý‰nŒnÐr&   r+   c               ó"   K  — t          ¦   «         ‚r   rO   r)   s    r$   r-   zUnattachedStream.__aiter__d   s   è è € Ý‰nŒnÐr&   Nr.   r/   )r0   r1   r2   Ú__doc__r*   r-   r3   r&   r$   rM   rM   Z   sF   € € € € € ðð ðð ð ð ðð ð ð ð ð r&   rM   Úcontentú4str | bytes | Iterable[bytes] | AsyncIterable[bytes]r   ú7tuple[dict[str, str], SyncByteStream | AsyncByteStream]c                óR  — t          | t          t          f¦  «        rat          | t          ¦  «        r|                      d¦  «        n| }t	          |¦  «        }|rdt          |¦  «        ini }|t          |¦  «        fS t          | t          ¦  «        rMt          | t          ¦  «        s8t          | ¦  «        }|€ddi}ndt          |¦  «        i}|t          | ¦  «        fS t          | t          ¦  «        rddi}|t          | ¦  «        fS t          dt          | ¦  «        ›�¦  «        ‚)Núutf-8úContent-LengthzTransfer-EncodingÚchunkedzUnexpected type for 'content', )Ú
isinstancer   ÚstrÚencodeÚlenr   r   Údictr   r5   r   rF   Ú	TypeErrorÚtype)rR   ÚbodyÚcontent_lengthÚheadersÚcontent_length_or_nones        r$   Úencode_contentrd   i   s3  € õ �'�E¥3˜<Ñ(Ô(ð 9Ý*4°W½cÑ*BÔ*BÐOˆw�~Š~˜gÑ&Ô&Ð&ÈˆÝ˜T™œˆØ=AÐIÐ#¥S¨Ñ%8Ô%8Ð9Ð9ÀrˆØ�
 4Ñ(Ô(Ð(Ð(å	�G�XÑ	&Ô	&ð 9­z¸'Å4Ñ/HÔ/Hð 9õ
 "6°gÑ!>Ô!>Ðà!Ð)Ø*¨IÐ6ˆGˆGà'­Ð-CÑ)DÔ)DÐEˆGØÕ*¨7Ñ3Ô3Ð3Ð3å	�G�]Ñ	+Ô	+ð 9Ø&¨	Ð2ˆØÕ/°Ñ8Ô8Ð8Ð8å
ÐGµd¸7±m´mÐGÐGÑ
HÔ
HÐHr&   Údatar   ú!tuple[dict[str, str], ByteStream]c                ó°  ‡— g }|                       ¦   «         D ]g\  Š}t          |t          t          f¦  «        r"|                     ˆfd„|D ¦   «         ¦  «         ŒC|                     ‰t          |¦  «        f¦  «         Œht          |d¬¦  «                             d¦  «        }t          t          |¦  «        ¦  «        }d}||dœ}|t          |¦  «        fS )Nc                ó2   •— g | ]}‰t          |¦  «        f‘ŒS r3   )r   )Ú.0ÚitemÚkeys     €r$   ú
<listcomp>z*encode_urlencoded_data.<locals>.<listcomp>Œ   s'   ø€ ÐUÐUÐUÀt Õ%;¸DÑ%AÔ%AÐBÐUÐUÐUr&   T)ÚdoseqrV   z!application/x-www-form-urlencoded©rW   zContent-Type)ÚitemsrY   ÚlistÚtupleÚextendÚappendr   r   r[   rZ   r\   r   )re   Ú
plain_dataÚvaluer`   ra   Úcontent_typerb   rk   s          @r$   Úencode_urlencoded_datarw   †   så   ø€ ð €JØ—j’j‘l”lð Dð D‰
ˆˆUÝ�e�d¥E˜]Ñ+Ô+ð 	DØ×ÒÐUÐUÐUÐUÈuÐUÑUÔUÑVÔVÐVÐVà×Ò˜sÕ$:¸5Ñ$AÔ$AÐBÑCÔCÐCÐCÝ�Z tÐ,Ñ,Ô,×3Ò3°GÑ<Ô<€DÝ�˜T™œ‘^”^€NØ6€LØ!/ÀÐNÐN€GØ•J˜tÑ$Ô$Ð$Ð$r&   Úfilesr   Úboundaryúbytes | Noneú&tuple[dict[str, str], MultipartStream]c                óV   — t          | ||¬¦  «        }|                     ¦   «         }||fS )N)re   rx   ry   )r   Úget_headers)re   rx   ry   Ú	multipartrb   s        r$   Úencode_multipart_datar   –   s4   € õ   T°ÀÐJÑJÔJ€IØ×#Ò#Ñ%Ô%€GØ�IÐÐr&   ÚtextrZ   c                ó”   — |                       d¦  «        }t          t          |¦  «        ¦  «        }d}||dœ}|t          |¦  «        fS )NrV   ztext/plain; charset=utf-8rn   ©r[   rZ   r\   r   )r€   r`   ra   rv   rb   s        r$   Úencode_textrƒ   ž   sI   € Ø�;Š;�wÑÔ€DÝ�˜T™œ‘^”^€NØ.€LØ!/ÀÐNÐN€GØ•J˜tÑ$Ô$Ð$Ð$r&   Úhtmlc                ó”   — |                       d¦  «        }t          t          |¦  «        ¦  «        }d}||dœ}|t          |¦  «        fS )NrV   ztext/html; charset=utf-8rn   r‚   )r„   r`   ra   rv   rb   s        r$   Úencode_htmlr†   ¦   sI   € Ø�;Š;�wÑÔ€DÝ�˜T™œ‘^”^€NØ-€LØ!/ÀÐNÐN€GØ•J˜tÑ$Ô$Ð$Ð$r&   Újsonr   c                ó®   — t          | ¦  «                             d¦  «        }t          t          |¦  «        ¦  «        }d}||dœ}|t	          |¦  «        fS )NrV   zapplication/jsonrn   )Ú
json_dumpsr[   rZ   r\   r   )r‡   r`   ra   rv   rb   s        r$   Úencode_jsonrŠ   ®   sS   € Ý�dÑÔ×"Ò" 7Ñ+Ô+€DÝ�˜T™œ‘^”^€NØ%€LØ!/ÀÐNÐN€GØ•J˜tÑ$Ô$Ð$Ð$r&   úRequestContent | NoneúRequestData | NoneúRequestFiles | Noneú
Any | Nonec                ó8  — |�@t          |t          ¦  «        s+d}t          j        |t          ¦  «         t          |¦  «        S | �t          | ¦  «        S |rt          |pi ||¦  «        S |rt          |¦  «        S |�t          |¦  «        S i t          d¦  «        fS )z€
    Handles encoding the given `content`, `data`, `files`, and `json`,
    returning a two-tuple of (<headers>, <stream>).
    Nz5Use 'content=<...>' to upload raw bytes/text content.r&   )
rY   r
   ÚwarningsÚwarnÚDeprecationWarningrd   r   rw   rŠ   r   )rR   re   rx   r‡   ry   Úmessages         r$   Úencode_requestr”   ¶   s¯   € ð Ð¥
¨4µÑ 9Ô 9Ðð JˆÝŒ�gÕ1Ñ2Ô2Ð2Ý˜dÑ#Ô#Ð#àÐÝ˜gÑ&Ô&Ð&Ø	ð !Ý$ T Z¨R°¸ÑAÔAÐAØ	ð !Ý% dÑ+Ô+Ð+Ø	Ð	Ý˜4Ñ Ô Ð à�z˜#‰ŒÐÐr&   úResponseContent | Noneú
str | Nonec                ó¬   — | �t          | ¦  «        S |�t          |¦  «        S |�t          |¦  «        S |�t          |¦  «        S i t	          d¦  «        fS )zc
    Handles encoding the given `content`, returning a two-tuple of
    (<headers>, <stream>).
    Nr&   )rd   rƒ   r†   rŠ   r   )rR   r€   r„   r‡   s       r$   Úencode_responser˜   Ù   se   € ð ÐÝ˜gÑ&Ô&Ð&Ø	Ð	Ý˜4Ñ Ô Ð Ø	Ð	Ý˜4Ñ Ô Ð Ø	Ð	Ý˜4Ñ Ô Ð à�z˜#‰ŒÐÐr&   )rR   rS   r   rT   )re   r   r   rf   )re   r   rx   r   ry   rz   r   r{   )r€   rZ   r   rf   )r„   rZ   r   rf   )r‡   r   r   rf   )NNNNN)rR   r‹   re   rŒ   rx   r�   r‡   rŽ   ry   rz   r   rT   )NNNN)
rR   r•   r€   r–   r„   r–   r‡   rŽ   r   rT   )+Ú
__future__r   r;   r�   r‡   r   r‰   Útypingr   r   r   r   r	   r
   Úurllib.parser   Ú_exceptionsr   r   Ú
_multipartr   Ú_typesr   r   r   r   r   r   Ú_utilsr   r   r   r5   rF   rM   rd   rw   r   rƒ   r†   rŠ   r”   r˜   r3   r&   r$   ú<module>r       s¸  ðØ "Ð "Ð "Ð "Ð "Ð "à €€€Ø €€€Ø $Ð $Ð $Ð $Ð $Ð $ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð #Ð "Ð "Ð "Ð "Ð "à 5Ð 5Ð 5Ð 5Ð 5Ð 5Ð 5Ð 5Ø 'Ð 'Ð 'Ð 'Ð 'Ð 'ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð AÐ @Ð @Ð @Ð @Ð @Ð @Ð @ðð ð ð ð � .ñ ô ð ðð ð ð ð ˜ñ ô ð ð2ð ð ð ð ˜oñ ô ð ð2ð ð ð ð �¨ñ ô ð ðIð Ið Ið Ið:%ð %ð %ð %ð ð ð ð ð%ð %ð %ð %ð%ð %ð %ð %ð%ð %ð %ð %ð &*Ø#Ø!%ØØ!ð ð  ð  ð  ð  ðH '+ØØØð	ð ð ð ð ð ð r&   