Ë
    Fü´j  ã                  óú   — d dl mZ d dlZd dlmZmZmZ d dlZddlm	Z	m
Z
  G d„ de«      Zdd„Zdd	„Zdd
„Zdd„Zdd„Zdd„Zdd„Zd d„Zd d„Zd d„Zd!d„Zd!d„Zd"d„Zd#d„Zd$d„Zd%d„Zd&d„Zd'd„Zd(d„Zd)d„Zy)*é    )ÚannotationsN)ÚAnyÚProtocolÚcasté   )ÚDEFAULT_TIMEOUTÚDEFAULT_CONNECTION_LIMITSc                  ó†   — e Zd ZU ded<   ded<   ded<   ded<   d	ed
<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   y)Ú_LegacyHttpxModuleztype[httpx2.Auth]ÚAuthztype[httpx2.Client]ÚClientztype[httpx2.AsyncClient]ÚAsyncClientztype[httpx2.URL]ÚURLztype[httpx2.Response]ÚResponseztype[httpx2.Timeout]ÚTimeoutztype[httpx2.Limits]ÚLimitsztype[httpx2.TimeoutException]ÚTimeoutExceptionztype[httpx2.RequestError]ÚRequestErrorztype[httpx2.HTTPStatusError]ÚHTTPStatusErrorztype[httpx2.StreamConsumed]ÚStreamConsumedztype[httpx2.RequestNotRead]ÚRequestNotReadN)Ú__name__Ú
__module__Ú__qualname__Ú__annotations__© ó    úL/root/workspace/ytshorts/venv/lib/python3.12/site-packages/openai/_httpx2.pyr   r      sJ   … Ø
ÓØÓØ)Ó)Ø	ÓØ#Ó#Ø!Ó!ØÓØ3Ó3Ø+Ó+Ø1Ó1Ø/Ó/Ø/Ô/r   r   c                 óh   — t         j                  j                  d«      } | �t        t        | «      S d S )NÚhttpx)ÚsysÚmodulesÚgetr   r   ©Úmodules    r   Ú_loaded_legacy_httpxr&      s,   € Ü�[‰[�_‰_˜WÓ%€FØ/5Ð/AŒ4Ô" FÓ+ÐKÀtÐKr   c                ó6   — t        | t        j                  «      S ©N)Ú
isinstanceÚhttpx2r   ©Úvalues    r   Úis_httpx2_sync_clientr-      s   € Ü�eœVŸ]™]Ó+Ð+r   c                ó6   — t        | t        j                  «      S r(   )r)   r*   r   r+   s    r   Úis_httpx2_async_clientr/   #   s   € Ü�eœV×/Ñ/Ó0Ð0r   c                óN   — t        «       }|d uxr t        | |j                  «      S r(   )r&   r)   r   ©r,   r%   s     r   Úis_legacy_httpx_sync_clientr2   '   s%   € Ü!Ó#€FØ˜ÐÒB¤*¨U°F·M±MÓ"BÐBr   c                óN   — t        «       }|d uxr t        | |j                  «      S r(   )r&   r)   r   r1   s     r   Úis_legacy_httpx_async_clientr4   ,   s'   € Ü!Ó#€FØ˜ÐÒG¤*¨U°F×4FÑ4FÓ"GÐGr   c                óè   — t        | t        j                  «      r| S t        «       }| }|�4t        ||j                  «      rt        j                  t	        |«      «      S t        j                  | «      S r(   )r)   r*   r   r&   Ústr)r,   r%   Úlegacy_values      r   Únormalize_httpx_urlr8   1   sX   € Ü�%œŸ™Ô$Øˆä!Ó#€FØ €LØÐœj¨°v·z±zÔBÜ�z‰zœ#˜lÓ+Ó,Ð,ä�:‰:�eÓÐr   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r(   )r&   r*   r   r$   s    r   Úhttp_response_typesr:   =   s-   € Ü!Ó#€FØ!' ŒF�O‰OÐÐW´f·o±oÀvÇÁÐ5WÐWr   c                ó�   — t        «       }|�9t        | |j                  «      r#t        j                  di | j	                  «       ¤ŽS | S ©Nr   )r&   r)   r   r*   Úas_dictr1   s     r   Únormalize_httpx_timeoutr>   B   s:   € Ü!Ó#€FØÐœj¨°·±Ô?Ü�~‰~Ñ0 §¡£Ñ0Ð0Ø€Lr   c                ó   — t        | «      S r(   )r>   r+   s    r   Únormalize_httpx2_timeoutr@   I   s   € Ü" 5Ó)Ð)r   c                ó’   — t        «       }|�:t        | t        j                  «      r  |j                  di | j	                  «       ¤ŽS | S r<   )r&   r)   r*   r   r=   r1   s     r   Únormalize_legacy_httpx_timeoutrB   M   s<   € Ü!Ó#€FØÐœj¨´·±Ô?Øˆv�~‰~Ñ0 §¡£Ñ0Ð0Ø€Lr   c                ót   — t        «       }|�+t        | «      |j                  u rt        j                  «       S | S r(   )r&   Útyper   r*   r1   s     r   Únormalize_httpx2_authrE   T   s0   € Ü!Ó#€FØÐœd 5›k¨V¯[©[Ñ8Ü�{‰{‹}ÐØ€Lr   c                ót   — t        «       }|�+t        | «      t        j                  u r|j                  «       S | S r(   )r&   rD   r*   r   r1   s     r   Únormalize_legacy_httpx_authrG   [   s0   € Ü!Ó#€FØÐœd 5›k¬V¯[©[Ñ8Ø�{‰{‹}ÐØ€Lr   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r(   )r&   r*   r   r$   s    r   Útimeout_exceptionsrI   b   s4   € Ü!Ó#€FØ)/¨ŒF×#Ñ#Ð%Ðo¼f×>UÑ>UÐW]×WnÑWnÐ=oÐor   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r(   )r&   r*   r   r$   s    r   Úrequest_exceptionsrK   g   s3   € Ü!Ó#€FØ%+ ^ŒF×ÑÐ!Ðc¼&×:MÑ:MÈv×ObÑObÐ9cÐcr   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r(   )r&   r*   r   r$   s    r   Ústatus_exceptionsrM   l   s4   € Ü!Ó#€FØ(.¨ŒF×"Ñ"Ð$Ðl¼V×=SÑ=SÐU[×UkÑUkÐ<lÐlr   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r(   )r&   r*   r   r$   s    r   Ústream_consumed_exceptionsrO   q   ó4   € Ü!Ó#€FØ'- ~ŒF×!Ñ!Ð#Ði¼F×<QÑ<QÐSY×ShÑShÐ;iÐir   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r(   )r&   r*   r   r$   s    r   Úrequest_not_read_exceptionsrR   v   rP   r   c                óR  — t        | j                  dt        «      «      | d<   | j                  dt        «      }t	        «       }|�Lt        ||j                  «      r6t        j                  |j                  |j                  |j                  ¬«      }|| d<   | j                  dd«       y )NÚtimeoutÚlimits)Úmax_connectionsÚmax_keepalive_connectionsÚkeepalive_expiryÚfollow_redirectsT)r@   r#   r   r	   r&   r)   r   r*   rV   rW   rX   Ú
setdefault)ÚkwargsrU   r%   s      r   Ú_set_httpx2_defaultsr\   {   sŽ   € Ü0°·±¸IÄÓ1WÓX€Fˆ9Ñà�Z‰Z˜Ô";Ó<€FÜ!Ó#€FØÐœj¨°·±Ô?Ü—‘Ø"×2Ñ2Ø&,×&FÑ&FØ#×4Ñ4ô
ˆð
 €Fˆ8ÑØ
×ÑÐ(¨$Õ/r   c                 óB   — t        | «       t        j                  di | ¤ŽS )z<Create an HTTPX2 client with the SDK's recommended defaults.r   )r\   r*   r   ©r[   s    r   ÚDefaultHttpx2Clientr_   Š   s   € ä˜Ô Ü�=‰=Ñ"˜6Ñ"Ð"r   c                 óB   — t        | «       t        j                  di | ¤ŽS )zBCreate an async HTTPX2 client with the SDK's recommended defaults.r   )r\   r*   r   r^   s    r   ÚDefaultAsyncHttpx2Clientra   �   s   € ä˜Ô Ü×ÑÑ' Ñ'Ð'r   )Úreturnz_LegacyHttpxModule | None)r,   Úobjectrb   Úbool)r,   zstr | httpx2.URLrb   z
httpx2.URL)rb   z!tuple[type[httpx2.Response], ...])r,   úfloat | httpx2.Timeout | Nonerb   re   )r,   úhttpx2.Authrb   rf   )rb   z)tuple[type[httpx2.TimeoutException], ...])rb   z%tuple[type[httpx2.RequestError], ...])rb   z(tuple[type[httpx2.HTTPStatusError], ...])rb   z'tuple[type[httpx2.StreamConsumed], ...])rb   z'tuple[type[httpx2.RequestNotRead], ...])r[   zdict[str, Any]rb   ÚNone)r[   r   rb   zhttpx2.Client)r[   r   rb   zhttpx2.AsyncClient) Ú
__future__r   r!   Útypingr   r   r   r*   Ú
_constantsr   r	   r   r&   r-   r/   r2   r4   r8   r:   r>   r@   rB   rE   rG   rI   rK   rM   rO   rR   r\   r_   ra   r   r   r   ú<module>rk      s�   ðÝ "ã 
ß &Ñ &ã ç Bô0˜ô 0óLó
,ó1óCó
Hó
	óXó
ó*óóóópó
dó
mó
jó
jó
0ó#ô(r   