Format: application/x-python-code
1 o
2
3 C'h�6 � @ s� U d Z ddlmZ ddlZddlZddlmZ ejr"ddlZddl Z ddl
4 m Z m Z m
5 Z
6 mZ ddlmZmZmZmZmZmZmZmZmZmZmZmZm Z m Z ddl m Z m Z dd l!m"Z"m#Z#m$Z$m%Z% dd
7 l&m'Z' d d l(m)Z)m*Z* ej+d
8 dd�Z,ej+ddd�Z-ej.ej/e0e0e0f ej/e0e0ej.e1e2f f ej/e0e0de0f f Z3ddgZ4i a5de6d< d dd�Z7ej8d!dd��Z9G dd� de%�Z:G d d� de*�Z;G d d � d e"�Z<G d d� de)�Z=dS )"a�
9 Custom transports, with nicely configured defaults.
10
11 The following additional keyword arguments are currently supported by httpcore...
12
13 * uds: str
14 * local_address: str
15 * retries: int
16
17 Example usages...
18
19 # Disable HTTP/2 on a single specific domain.
20 mounts = {
21 "all://": httpx.HTTPTransport(http2=True),
22 "all://*example.org": httpx.HTTPTransport()
23 }
24
25 # Using advanced httpcore configuration, with connection retries.
26 transport = httpx.HTTPTransport(retries=1)
27 client = httpx.Client(transport=transport)
28
29 # Using advanced httpcore configuration, with unix domain sockets.
30 transport = httpx.HTTPTransport(uds="socket.uds")
31 client = httpx.Client(transport=transport)
32 � )� annotationsN)�
33 TracebackType� )�DEFAULT_LIMITS�Limits�Proxy�create_ssl_context)� ConnectError�ConnectTimeout�LocalProtocolError� NetworkError� PoolTimeout�
34 ProtocolError�
35 ProxyError� ReadError� ReadTimeout�RemoteProtocolError�TimeoutException�UnsupportedProtocol�
36 WriteError� WriteTimeout)�Request�Response)�AsyncByteStream� CertTypes�
37 ProxyTypes�SyncByteStream)�URL� )�AsyncBaseTransport�
38 BaseTransport�T�
39 HTTPTransport)�bound�A�AsyncHTTPTransport�,dict[type[Exception], type[httpx.HTTPError]]�HTTPCORE_EXC_MAP�returnc C s` dd l } | jt| jt| jt| jt| jt| jt| jt| jt| j t | j
40 t
41 | j t | j t | j
42 t
43 | jtiS �Nr )�httpcorer r
44 r r r
45 r r r r r r r r r )r* � r+ �OC:\Users\shubh\Videos\agent\nova\Lib\site-packages\httpx/_transports/default.py�_load_httpcore_exceptionsJ s �r- �typing.Iterator[None]c
46 c s� � t t�dkr
47 t� azd V W d S tyF } z*d }t�� D ]\}}t| |�s(q |d u s1t||�r3|}q |d u r9� t| �}||�| �d } ~ ww r) )�lenr' r- � Exception�items�
48 isinstance�
49 issubclass�str)�excZ
50 mapped_excZfrom_excZto_exc�messager+ r+ r, �map_httpcore_exceptions_ s& �
51 �
52 ��r7 c @ �* e Zd Zd
53 dd�Zddd �Zdd
54 d �Zd S )�ResponseStream�httpcore_stream�typing.Iterable[bytes]r( �Nonec C �
55 || _ d S �N��_httpcore_stream��selfr: r+ r+ r, �__init__z �
56 zResponseStream.__init__�typing.Iterator[bytes]c c s@ � t � � | jD ]}|V qW d � d S 1 sw Y d S r> �r7 r@ �rB �partr+ r+ r, �__iter__} s �
57 �"�zResponseStream.__iter__c C s t | jd�r
58 | j�� d S d S )N�close)�hasattrr@ rJ �rB r+ r+ r, rJ � s �zResponseStream.closeN)r: r; r( r< )r( rE �r( r< )�__name__�
59 __module__� __qualname__rC rI rJ r+ r+ r+ r, r9 y �
60
61 r9 c @ �^ e Zd Zdddddedddddf d/dd�Zd0d d �Z d1d2d&d'�Zd3d+d,�Zd4d-d.�ZdS )5r" TNFr �verify�ssl.SSLContext | str | bool�cert�CertTypes | None� trust_env�bool�http1�http2�limitsr �proxy�ProxyTypes | None�uds�
62 str | None�
63 local_address�retries�int�socket_options�%typing.Iterable[SOCKET_OPTION] | Noner( r< c
64 C sN dd l } t|ttf�rt|d�n|}t|||d�}
65 |d u r2| j|
66 |j|j|j |||| |
67 | d�
68 | _
69 d S |j j dv ra| j
70 | j|j j|j j|j j|j jd�|j|jj|
71 |j|j|j|j ||| d� | _
72 d S |j j dv r�zdd l}W n tyy td �d �w | j| j|j j|j j|j j|j jd�|j|
73 |j|j|j ||d
74 �| _
75 d S td |j j �d ���)
76 Nr ��url�rS rU rW �
77 � ssl_context�max_connections�max_keepalive_connections�keepalive_expiryrY rZ r^ r` ra rc ��http�https��scheme�host�port�target) � proxy_url�
78 proxy_auth�
79 proxy_headersri �proxy_ssl_contextrj rk rl rY rZ rc �Zsocks5Zsocks5h�{Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.�ru rv ri rj rk rl rY rZ zOProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got �.)r* r2 r4 r r r �ConnectionPoolrj rk rl �_poolrf rq Z HTTPProxy�
80 raw_scheme�raw_hostrs �raw_path�raw_auth�headers�rawri �socksio� ImportErrorZ
81 SOCKSProxy�
82 ValueError�rB rS rU rW rY rZ r[ r\ r^ r` ra rc r* ri r� r+ r+ r, rC � s� � � � ���� ���zHTTPTransport.__init__rB r! c C s | j �� | S r> )r~ � __enter__rL r+ r+ r, r� � s
83 zHTTPTransport.__enter__�exc_type�type[BaseException] | None� exc_value�BaseException | None� traceback�TracebackType | Nonec C s< t � � | j�|||� W d � d S 1 sw Y d S r> )r7 r~ �__exit__�rB r� r� r� r+ r+ r, r� � s "�zHTTPTransport.__exit__�requestr r c C s� t |jt�sJ �dd l}|j|j|j|jj|jj |jj
84 |jj d�|j j
85 |j|jd�}t� � | j�|�}W d � n1 s>w Y t |jtj�sLJ �t|j|j t|j�|jd�S �Nr rp )�methodrf r� �content�
86 extensions)� status_coder� �streamr� )r2 r� r r* r r� r rf r r� rs r� r� r� r� r7 r~ �handle_request�typing�Iterabler �statusr9 �rB r� r* �req�respr+ r+ r, r� � s0 �� ��z HTTPTransport.handle_requestc C s | j �� d S r> )r~ rJ rL r+ r+ r, rJ s zHTTPTransport.close�rS rT rU rV rW rX rY rX rZ rX r[ r r\ r] r^ r_ r` r_ ra rb rc rd r( r< )rB r! r( r! �NNN�r� r� r� r� r� r� r( r< �r� r r( r rM ) rN rO rP r rC r� r� r� rJ r+ r+ r+ r, r" � �( �
87 Q �
88 c @ r8 )�AsyncResponseStreamr: �typing.AsyncIterable[bytes]r( r< c C r= r> r? rA r+ r+ r, rC
89 rD z AsyncResponseStream.__init__�typing.AsyncIterator[bytes]c C sJ �t � � | j2 z 3 d H W }|V q6 W d � d S 1 s w Y d S r> rF rG r+ r+ r, � __aiter__
90 s ��"�z AsyncResponseStream.__aiter__c � s& �t | jd�r| j�� I d H d S d S )N�aclose)rK r@ r� rL r+ r+ r, r� s � �zAsyncResponseStream.acloseN)r: r� r( r< )r( r� rM )rN rO rP rC r� r� r+ r+ r+ r, r� rQ r� c @ rR )5r% TNFr rS rT rU rV rW rX rY rZ r[ r r\ r] r^ r_ r` ra rb rc rd r( r< c
91 C sB dd l } t|ttf�rt|d�n|}t|||d�}
92 |d u r2| j|
93 |j|j|j |||| |
94 | d�
95 | _
96 d S |j j dv ra| j
97 | j|j j|j j|j j|j jd�|j|jj|j|
98 |j|j|j ||| d� | _
99 d S |j j dv r�zdd l}W n tyy td �d �w | j| j|j j|j j|j j|j jd�|j|
100 |j|j|j ||d
101 �| _
102 d S td ��) Nr re rg rh rm rp ) ru rv rw rx ri rj rk rl rY rZ rc ry rz r{ zdProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got {proxy.url.scheme!r}.)r* r2 r4 r r r ZAsyncConnectionPoolrj rk rl r~ rf rq ZAsyncHTTPProxyr r� rs r� r� r� r� ri r� r� ZAsyncSOCKSProxyr� r� r+ r+ r, rC s~ � � � ���� ��zAsyncHTTPTransport.__init__rB r$ c � s �| j �� I d H | S r> )r~ �
103 __aenter__rL r+ r+ r, r� i s �z AsyncHTTPTransport.__aenter__r� r� r� r� r� r� c � sD �t � � | j�|||�I d H W d � d S 1 sw Y d S r> )r7 r~ � __aexit__r� r+ r+ r, r� m s �"�z AsyncHTTPTransport.__aexit__r� r r c � s� �t |jt�s J �dd l}|j|j|j|jj|jj |jj
104 |jj d�|j j
105 |j|jd�}t� � | j�|�I d H }W d � n1 sBw Y t |jtj�sPJ �t|j|j t|j�|jd�S r� )r2 r� r r* r r� r rf r r� rs r� r� r� r� r7 r~ �handle_async_requestr� �
106 AsyncIterabler r� r� r� r+ r+ r, r� v s2 ��� ��z'AsyncHTTPTransport.handle_async_requestc � s �| j �� I d H d S r> )r~ r� rL r+ r+ r, r� � s �zAsyncHTTPTransport.acloser� )rB r$ r( r$ r� r� r� rM ) rN rO rP r rC r� r� r� r� r+ r+ r+ r, r% r� )r( r& )r( r. )>�__doc__�
107 __future__r �
108 contextlibr� �typesr �
109 TYPE_CHECKING�sslZhttpx�_configr r r r � _exceptionsr r
110 r r r
111 r r r r r r r r r Z_modelsr r �_typesr r r r Z_urlsr �baser r �TypeVarr! r$ �Union�Tuplerb �bytes� bytearrayZ
112 SOCKET_OPTION�__all__r' �__annotations__r- �contextmanagerr7 r9 r" r� r% r+ r+ r+ r, �<module> s@ @ ��
113