Ë
    sPêj”  ã                  óê   — d dl mZ d dl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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<   y)Ú_Httpx2Moduleztype[httpx.Auth]ÚAuthztype[httpx.Client]ÚClientztype[httpx.AsyncClient]ÚAsyncClientztype[httpx.URL]ÚURLztype[httpx.Response]ÚResponseztype[httpx.Timeout]ÚTimeoutztype[httpx.Limits]ÚLimitsztype[httpx.TimeoutException]ÚTimeoutExceptionztype[httpx.HTTPStatusError]ÚHTTPStatusErrorztype[httpx.StreamConsumed]ÚStreamConsumedztype[httpx.RequestNotRead]ÚRequestNotReadN)Ú__name__Ú
__module__Ú__qualname__Ú__annotations__© ó    úS/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/openai/_httpx2.pyr   r      sD   … Ø
ÓØÓØ(Ó(Ø	ÓØ"Ó"Ø Ó ØÓØ2Ó2Ø0Ó0Ø.Ó.Ø.Ô.r   r   c                 óf   — t         j                  j                  d«      } | €y t        t        | «      S )NÚhttpx2)ÚsysÚmodulesÚgetr   r   ©Úmodules    r   Ú_loaded_httpx2r%      s)   € Ü�[‰[�_‰_˜XÓ&€FØ€~ØÜ”˜vÓ&Ð&r   c                 ó(   — t         j                  dk\  S )N)é   é
   )r    Úversion_infor   r   r   Ú_supports_httpx2r*   !   s   € Ü×Ñ˜wÑ&Ð&r   c                 óª   — t        «       st        d«      ‚	 t        j                  d«      } t        t        | «      S # t        $ r t        d«      d ‚w xY w)NzwHTTPX2 requires Python 3.10 or later; install the httpx2 extra on a supported interpreter: pip install 'openai[httpx2]'r   zETo use HTTPX2, install the httpx2 extra: pip install 'openai[httpx2]')r*   ÚRuntimeErrorÚ	importlibÚimport_moduleÚImportErrorr   r   r#   s    r   Ú_require_httpx2r0   %   sa   € ÜÔÜð+ó
ð 	
ð
nÜ×(Ñ(¨Ó2ˆô ”˜vÓ&Ð&øô ò nÜÐbÓcÐimÐmðnús	   —< ¼Ac                óN   — t        «       }|d uxr t        | |j                  «      S ©N)r%   Ú
isinstancer   ©Úvaluer$   s     r   Úis_httpx2_sync_clientr6   4   s%   € ÜÓ€FØ˜ÐÒB¤*¨U°F·M±MÓ"BÐBr   c                óN   — t        «       }|d uxr t        | |j                  «      S r2   )r%   r3   r   r4   s     r   Úis_httpx2_async_clientr8   9   s'   € ÜÓ€FØ˜ÐÒG¤*¨U°F×4FÑ4FÓ"GÐGr   c                óä   — t        «       }|�4t        | |j                  «      rt        j                  t	        | «      «      S t        | t        j                  «      r| S t        j                  | «      S r2   )r%   r3   r   ÚhttpxÚstrr4   s     r   Únormalize_httpx_urlr<   >   sR   € ÜÓ€FØÐœj¨°·
±
Ô;Ü�y‰yœ˜U›Ó$Ð$Ü�%œŸ™Ô#ØˆÜ�9‰9�UÓÐr   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r2   )r%   r:   r   r#   s    r   Úhttp_response_typesr>   G   s/   € ÜÓ€FØ€~Ü—‘Ð Ð Ü�N‰N˜FŸO™OÐ,Ð,r   c                ó�   — t        «       }|�9t        | |j                  «      r#t        j                  di | j	                  «       ¤ŽS | S ©Nr   )r%   r3   r   r:   Úas_dictr4   s     r   Únormalize_httpx_timeoutrB   N   s:   € ÜÓ€FØÐœj¨°·±Ô?Ü�}‰}Ñ/˜uŸ}™}›Ñ/Ð/Ø€Lr   c                óŠ   — t        | t        j                  «      r( t        «       j                  di | j	                  «       ¤ŽS | S r@   )r3   r:   r   r0   rA   ©r5   s    r   Únormalize_httpx2_timeoutrE   U   s4   € Ü�%œŸ™Ô'Ø(ŒÓ ×(Ñ(Ñ;¨5¯=©=«?Ñ;Ð;Ø€Lr   c                ól   — t        | «      t        j                  u rt        «       j                  «       S | S r2   )Útyper:   r   r0   rD   s    r   Únormalize_httpx2_authrH   [   s)   € ÜˆEƒ{”e—j‘jÑ ÜÓ ×%Ñ%Ó'Ð'Ø€Lr   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r2   )r%   r:   r   r#   s    r   Útimeout_exceptionsrJ   a   s5   € ÜÓ€FØ€~Ü×&Ñ&Ð(Ð(Ü×"Ñ" F×$;Ñ$;Ð<Ð<r   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r2   )r%   r:   r   r#   s    r   Ústatus_exceptionsrL   h   s5   € ÜÓ€FØ€~Ü×%Ñ%Ð'Ð'Ü×!Ñ! 6×#9Ñ#9Ð:Ð:r   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r2   )r%   r:   r   r#   s    r   Ústream_consumed_exceptionsrN   o   ó5   € ÜÓ€FØ€~Ü×$Ñ$Ð&Ð&Ü× Ñ  &×"7Ñ"7Ð8Ð8r   c                 ót   — t        «       } | €t        j                  fS t        j                  | j                  fS r2   )r%   r:   r   r#   s    r   Úrequest_not_read_exceptionsrQ   v   rO   r   c                óP  — t        «       }| j                  dt        «      }t        |«      | d<   | j                  dt        «      }t        |t        j                  «      r5|j                  |j                  |j                  |j                  ¬«      | d<   | j                  dd«       |S )NÚtimeoutÚlimits)Úmax_connectionsÚmax_keepalive_connectionsÚkeepalive_expiryÚfollow_redirectsT)r0   r"   r   rE   r	   r3   r:   r   rU   rV   rW   Ú
setdefault)Úkwargsr$   rS   rT   s       r   Ú_set_httpx2_defaultsr[   }   s“   € ÜÓ€FØ�j‰j˜¤OÓ4€GÜ0°Ó9€Fˆ9Ñà�Z‰Z˜Ô";Ó<€FÜ�&œ%Ÿ,™,Ô'Ø!Ÿ=™=Ø"×2Ñ2Ø&,×&FÑ&FØ#×4Ñ4ð )ó 
ˆˆxÑð ×ÑÐ(¨$Ô/Ø€Mr   c                 ó<   — t        | «      } |j                  di | ¤ŽS )zICreate an experimental HTTPX2 client with the SDK's recommended defaults.r   )r[   r   ©rZ   r$   s     r   ÚDefaultHttpx2Clientr^   Ž   s    € ä! &Ó)€FØˆ6�=‰=Ñ"˜6Ñ"Ð"r   c                 ó<   — t        | «      } |j                  di | ¤ŽS )zOCreate an experimental async HTTPX2 client with the SDK's recommended defaults.r   )r[   r   r]   s     r   ÚDefaultAsyncHttpx2Clientr`   ”   s"   € ä! &Ó)€FØˆ6×ÑÑ' Ñ'Ð'r   )Úreturnz_Httpx2Module | None)ra   Úbool)ra   r   )r5   Úobjectra   rb   )r5   zstr | httpx.URLra   z	httpx.URL)ra   z tuple[type[httpx.Response], ...])r5   úfloat | httpx.Timeout | Nonera   rd   )r5   ú
httpx.Authra   re   )ra   z(tuple[type[httpx.TimeoutException], ...])ra   z'tuple[type[httpx.HTTPStatusError], ...])ra   z&tuple[type[httpx.StreamConsumed], ...])ra   z&tuple[type[httpx.RequestNotRead], ...])rZ   zdict[str, Any]ra   r   )rZ   r   ra   zhttpx.Client)rZ   r   ra   zhttpx.AsyncClient)Ú
__future__r   r    r-   Útypingr   r   r   r:   Ú
_constantsr   r	   r   r%   r*   r0   r6   r8   r<   r>   rB   rE   rH   rJ   rL   rN   rQ   r[   r^   r`   r   r   r   ú<module>ri      s}   ðÝ "ã 
Û ß &Ñ &ã ç Bô/�Hô /ó'ó'ó'óCó
Hó
ó-óóóó=ó;ó9ó9óó"#ô(r   