Format: application/x-python-code
1 o
2
3 C'h� � @ s` d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m
4 Z
5 d dl m Z ddl
6 m
7 Z
8 ddlmZmZmZ ddlmZmZmZmZmZmZ dd lmZ dd
9 lm Z m Z m Z m Z dd l m!Z!m"Z"m#Z#m$Z$ dd l%m&Z& dd
10 l'm(Z(m)Z) ddl*m+Z+m,Z, ddl-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z: ddl;m<Z<m=Z= ddl>m?Z?m@Z@ ejAr�d dlBZBg d�ZCejDddd�ZEejDddd�ZFd7d d �ZGd8d d!�ZHd9d#d$�ZIG d%d&� d&�ZJeJ� ZKe�Ld'�ZMd(e
11 � �ZNd)�Od*d+� e�P� D ��ZQG d,d-� d-ejR�ZSG d.d/� d/e9�ZTG d0d1� d1e.�ZUejVd2ejWf ZXG d3d4� d4�ZYG d5d� deY�ZZG d6d� deY�Z[dS ):� )� annotationsN)�asynccontextmanager�contextmanager)�
12 TracebackType� )� __version__)�Auth� BasicAuth� FunctionAuth)�DEFAULT_LIMITS�DEFAULT_MAX_REDIRECTS�DEFAULT_TIMEOUT_CONFIG�Limits�Proxy�Timeout)�SUPPORTED_DECODERS)�
13 InvalidURL�RemoteProtocolError�TooManyRedirects�request_context)�Cookies�Headers�Request�Response)�codes)�AsyncBaseTransport�
14 BaseTransport)�AsyncHTTPTransport�
15 HTTPTransport)
16 �AsyncByteStream� AuthTypes� CertTypes� CookieTypes� HeaderTypes�
17 ProxyTypes�QueryParamTypes�RequestContent� RequestData�RequestExtensions� RequestFiles�SyncByteStream� TimeoutTypes)�URL� QueryParams)�
18 URLPattern�get_environment_proxies)�USE_CLIENT_DEFAULT� AsyncClient�Client�Tr2 )�bound�Ur1 �urlr, �location�return�boolc C s< | j |j krdS | jdko t| �dko |jdko t|�dkS )zA
19 Return 'True' if 'location' is a HTTPS upgrade of 'url'
20 F�http�P �https� )�host�scheme�_port_or_default)r6 r7 � rA �CC:\Users\shubh\Videos\agent\nova\Lib\site-packages\httpx/_client.py�_is_https_redirect> s
21
22 ��
23 �rC �
24 int | Nonec C s" | j d ur| j S ddd��| j�S )Nr; r= )r: r< )�port�getr? �r6 rA rA rB r@ M s
25 r@ �otherc C s( | j |j ko| j|jkot| �t|�kS )z@
26 Return 'True' if the given URLs share the same origin.
27 )r? r> r@ )r6 rH rA rA rB � _same_originS s
28
29 ��rI c @ s e Zd ZdZdS )�UseClientDefaulta<
30 For some parameters such as `auth=...` and `timeout=...` we need to be able
31 to indicate the default "unset" state, in a way that is distinctly different
32 to using `None`.
33
34 The default "unset" state indicates that whatever default is set on the
35 client should be used. This is different to setting `None`, which
36 explicitly disables the parameter, possibly overriding a client default.
37
38 For example we use `timeout=USE_CLIENT_DEFAULT` in the `request()` signature.
39 Omitting the `timeout` parameter will send a request using whatever default
40 timeout has been configured on the client. Including `timeout=None` will
41 ensure no timeout is used.
42
43 Note that user code shouldn't need to use the `USE_CLIENT_DEFAULT` constant,
44 but it is used internally when a parameter is not included.
45 N)�__name__�
46 __module__� __qualname__�__doc__rA rA rA rB rJ ^ s rJ Zhttpxz
47 python-httpx/z, c C s g | ]}|d kr|�qS )�identityrA )�.0�keyrA rA rB �
48 <listcomp>y s rR c @ s e Zd ZdZdZdZdS )� ClientStater � � N)rK rL rM �UNOPENED�OPENED�CLOSEDrA rA rA rB rS } s rS c @ �. e Zd ZdZdd
49 d �Zdd
50 d�Zddd�ZdS )�BoundSyncStreamz�
51 A byte stream that is bound to a given response instance, and that
52 ensures the `response.elapsed` is set once the response is closed.
53 �streamr* �responser �start�floatr8 �Nonec C � || _ || _|| _d S �N��_stream� _response�_start��selfr[ r\ r] rA rA rB �__init__� �
54 zBoundSyncStream.__init__�typing.Iterator[bytes]c c s � | j D ]}|V qd S ra �rc �rg �chunkrA rA rB �__iter__� s �
55 �zBoundSyncStream.__iter__c C s, t �� | j }tj|d�| j_| j�� d S �N)�seconds) �time� perf_counterre �datetime� timedeltard �elapsedrc �close�rg ru rA rA rB rv � s zBoundSyncStream.closeN)r[ r* r\ r r] r^ r8 r_ )r8 rj �r8 r_ )rK rL rM rN rh rn rv rA rA rA rB rZ � �
56
57
58 rZ c @ rY )�BoundAsyncStreamz�
59 An async byte stream that is bound to a given response instance, and that
60 ensures the `response.elapsed` is set once the response is closed.
61 r[ r r\ r r] r^ r8 r_ c C r` ra rb rf rA rA rB rh � ri zBoundAsyncStream.__init__�typing.AsyncIterator[bytes]c C s" �| j 2 z 3 d H W }|V q6 d S ra rk rl rA rA rB � __aiter__� s ��zBoundAsyncStream.__aiter__c � s4 �t �� | j }tj|d�| j_| j�� I d H d S ro ) rq rr re rs rt rd ru rc �acloserw rA rA rB r} � s �zBoundAsyncStream.acloseN)r[ r r\ r r] r^ r8 r_ )r8 r{ rx )rK rL rM rN rh r| r} rA rA rA rB rz � ry rz .c @ s� e Zd Zddddededdddd� d|d d �Zed}d d!��Zed}d"d#��Zd~d&d'�Z dd,d-�Z
62 ed�d/d0��Z e j d�d1d0��Z ed�d3d4��Z
63 e
64 j d�d5d4��Z
65 ed�d7d8��Zej d�d:d8��Zed�d;d<��Zej d�d=d<��Zed�d?d@��Zej d�dBd@��Zed�dDdE��Zej d�dGdE��Zed�dIdJ��Zej d�dLdJ��ZdddddddeddM� d�d\d]�Zd�d^d_�Zd�d�d`da�Zd�d�dbdc�Z d�d�ddde�Zd�dfdg�Zefd�dkdl�Zd�dodp�Zd�dqdr�Z d�dsdt�Z d�dudv�Z d�dxdy�Z d�dzd{�Z dS )��
66 BaseClientNF� T�utf-8� �auth�params�headers�cookies�timeout�follow_redirects�
67 max_redirects� event_hooks�base_url� trust_env�default_encodingr� �AuthTypes | Noner� �QueryParamTypes | Noner� �HeaderTypes | Noner� �CookieTypes | Noner� r+ r� r9 r� �intr� �+None | typing.Mapping[str, list[EventHook]]r� � URL | strr� r� �#str | typing.Callable[[bytes], str]r8 r_ c C s� |d u ri n|}| � t| ��| _| �|�| _t|�| _t|�| _t |�| _
68 t |�| _ || _
69 || _t|�dg ��t|�dg ��d�| _|
70 | _| | _tj| _d S �N�requestr\ )r� r\ )�_enforce_trailing_slashr, � _base_url� _build_auth�_authr- �_paramsr r� r �_cookiesr �_timeoutr� r� �listrF � _event_hooks�
71 _trust_env�_default_encodingrS rV �_state) rg r� r� r� r� r� r� r� r� r� r� r� rA rA rB rh � s
72
73
74
75 � zBaseClient.__init__c C s | j tjkS )z2
76 Check if the client being closed
77 )r� rS rX �rg rA rA rB � is_closed� s zBaseClient.is_closedc C � | j S ra )r� r� rA rA rB r� � � zBaseClient.trust_envr6 r, c C s" |j �d�r|S |j|j d d�S )N� /��raw_path)r� �endswith� copy_with�rg r6 rA rA rB r� � s z"BaseClient._enforce_trailing_slash�proxy�ProxyTypes | None�allow_env_proxies�dict[str, Proxy | None]c C sH |d u r|rdd� t � �� D �S i S t|ttf�r t|d�n|}d|iS )Nc S s( i | ]\}}||d u r
78 d nt |d��qS )NrG )r )rP rQ r6 rA rA rB �
79 <dictcomp>� s ��z-BaseClient._get_proxy_map.<locals>.<dictcomp>rG zall://)r/ �items�
80 isinstance�strr, r )rg r� r� rA rA rB �_get_proxy_map� s � zBaseClient._get_proxy_mapr c C r� ra )r� r� rA rA rB r� � r� zBaseClient.timeoutc C � t |�| _d S ra )r r� )rg r� rA rA rB r� � �dict[str, list[EventHook]]c C r� ra )r� r� rA rA rB r� r� zBaseClient.event_hooksc C s( t |�dg ��t |�dg ��d�| _d S r� )r� rF r� )rg r� rA rA rB r� s �� Auth | Nonec C r� )z�
81 Authentication class used when none is passed at the request-level.
82
83 See also [Authentication][0].
84
85 [0]: /quickstart/#authentication
86 )r� r� rA rA rB r� s zBaseClient.authr c C s | � |�| _d S ra )r� r� �rg r� rA rA rB r� s c C r� )zK
87 Base URL to use when sending requests with relative URLs.
88 )r� r� rA rA rB r� � zBaseClient.base_urlc C s | � t|��| _d S ra )r� r, r� r� rA rA rB r� & s r c C r� )z@
89 HTTP headers to include when sending requests.
90 )�_headersr� rA rA rB r� * r� zBaseClient.headersr# c C s2 t dt�d�dt�d�d��}|�|� || _d S )Ns */*�asciis
91 keep-alive)s Accepts Accept-Encodings
92 Connections
93 User-Agent)r �ACCEPT_ENCODING�encode�
94 USER_AGENT�updater� )rg r� Zclient_headersrA rA rB r� 1 s ��
95
96 r c C r� )zA
97 Cookie values to include when sending requests.
98 )r� r� rA rA rB r� > r� zBaseClient.cookiesr" c C r� ra )r r� )rg r� rA rA rB r� E r� r- c C r� )zO
99 Query parameters to include in the URL when sending requests.
100 )r� r� rA rA rB r� I r� zBaseClient.paramsr% c C r� ra )r- r� )rg r� rA rA rB r� P r� ) �content�data�files�jsonr� r� r� r� �
101 extensions�methodr� r� �RequestContent | Noner� �RequestData | Noner� �RequestFiles | Noner� �typing.Any | None� TimeoutTypes | UseClientDefaultr� �RequestExtensions | Noner c C s� | � |�}| �|�}| �| �} | �|�}| du ri n| } d| vr9t|
102 t�r(| jnt|
103 �}
104 tdi | �d|
105 � � i��} t
106 ||||||||| | d�
107 S )aR
108 Build and return a request instance.
109
110 * The `params`, `headers` and `cookies` arguments
111 are merged with any values set on the client.
112 * The `url` argument is merged with any `base_url` set on the client.
113
114 See also: [Request instances][0]
115
116 [0]: /advanced/clients/#request-instances
117 Nr� )r� r� r� r� r� r� r� r� rA ) �
118 _merge_url�_merge_headers�_merge_cookies�_merge_queryparamsr� rJ r� r �dict�as_dictr ) rg r� r6 r� r� r� r� r� r� r� r� r� rA rA rB �
119 build_requestT s.
120
121
122
123 ���zBaseClient.build_requestc C s4 t |�}|jr| jj|j�d� }| jj|d�S |S )z�
124 Merge a URL argument together with any 'base_url' on the client,
125 to create the URL used for the outgoing request.
126 r� r� )r, �is_relative_urlr� r� �lstripr� )rg r6 Z merge_urlZmerge_raw_pathrA rA rB r� � s
127 zBaseClient._merge_urlc C s& |s| j rt| j �}|�|� |S |S )z�
128 Merge a cookies argument together with any cookies on the client,
129 to create the cookies used for the outgoing request.
130 )r� r r� )rg r� �merged_cookiesrA rA rB r� � s
131
132
133
134 zBaseClient._merge_cookiesc C s t | j�}|�|� |S )z�
135 Merge a headers argument together with any headers on the client,
136 to create the headers used for the outgoing request.
137 )r r� r� )rg r� Zmerged_headersrA rA rB r� � s
138
139 zBaseClient._merge_headersc C s" |s| j rt| j �}|�|�S |S )z�
140 Merge a queryparams argument together with any queryparams on the client,
141 to create the queryparams used for the outgoing request.
142 )r� r- �merge)rg r� Zmerged_queryparamsrA rA rB r� � s
143
144
145 z BaseClient._merge_queryparamsc C sX |d u rd S t |t�rt|d |d d�S t |t�r |S t|�r%t|d�S td|����)Nr r ��username�password)�funczInvalid "auth" argument: )r� �tupler r �callabler
146 � TypeErrorr� rA rA rB r� � s
147
148
149 zBaseClient._build_authr� �#AuthTypes | UseClientDefault | Noner c C sR t |t�r| jn| �|�}|d ur|S |jj|jj}}|s |r&t||d�S t� S )Nr� ) r� rJ r� r� r6 r� r� r r )rg r� r� r� r� rA rA rB �_build_request_auth� s � z BaseClient._build_request_authr\ r c C sR | � ||�}| �||�}| �|||�}| �||�}t| j�}t||||||jd�S )z�
150 Given a request and a redirect response, return a new request that
151 should be used to effect the redirect.
152 )r� r6 r� r� r[ r� )�_redirect_method�
153 _redirect_url�_redirect_headers�_redirect_streamr r� r r� )rg r� r\ r� r6 r� r[ r� rA rA rB �_build_redirect_request� s
154 �z"BaseClient._build_redirect_requestc C sR |j }|jtjkr|dkrd}|jtjkr|dkrd}|jtjkr'|dkr'd}|S )z�
155 When being redirected we may want to change the method of the request
156 based on certain specs or browser behavior.
157 �HEAD�GET�POST)r� � status_coder � SEE_OTHER�FOUND�MOVED_PERMANENTLY)rg r� r\ r� rA rA rB r� � s zBaseClient._redirect_methodc
158 C s� |j d }zt|�}W n ty" } z td|� d�|d�d�d}~ww |jr1|js1|j|jjd�}|jr:|j� |�}|jj
159 rI|j
160 sI|j|jj
161 d�}|S )z<
162 Return the URL for the redirect to follow.
163 ZLocationz Invalid URL in location header: �.�r� N)r> )�fragment) r� r, r r r? r> r� r6 r� �joinr� )rg r� r\ r7 r6 �excrA rA rB r� s$
164 ���� zBaseClient._redirect_urlc C sx t |j�}t||j�s t|j|�s|�dd� |j�d�|d< ||jkr4|dkr4|�dd� |�dd� |�dd� |S ) zR
165 Return the headers that should be used for the redirect request.
166 �
167 AuthorizationNr� �Hostr� zContent-LengthzTransfer-Encoding�Cookie) r r� rI r6 rC �pop�netloc�decoder� )rg r� r6 r� r� rA rA rB r� " s
168 z BaseClient._redirect_headers�'SyncByteStream | AsyncByteStream | Nonec C s ||j kr |dkr dS |jS )zO
169 Return the body that should be used for the redirect request.
170 r� N)r� r[ )rg r� r� rA rA rB r� = s zBaseClient._redirect_streamc C sL d|j vr$t| jt�r| jnt| j�}tdi |j �d|�� i��|_ d S d S )Nr� rA )r� r� r� rJ r r� r� )rg r� r� rA rA rB � _set_timeoutH s
171
172 ��"�zBaseClient._set_timeout)r� r� r� r� r� r� r� r� r� r+ r� r9 r� r� r� r� r� r� r� r9 r� r� r8 r_ )r8 r9 )r6 r, r8 r, )r� r� r� r9 r8 r� )r8 r )r� r+ r8 r_ )r8 r� )r� r� r8 r_ )r8 r� )r� r r8 r_ )r8 r, )r6 r� r8 r_ )r8 r )r� r# r8 r_ )r8 r )r� r" r8 r_ )r8 r- )r� r% r8 r_ )r� r� r6 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r8 r )r6 r� r8 r, ra )r� r� r8 r� )r� r� r8 r� )r� r� r8 r� )r� r� r8 r� )r� r r� r� r8 r )r� r r\ r r8 r )r� r r\ r r8 r� )r� r r\ r r8 r, )r� r r6 r, r� r� r8 r )r� r r� r� r8 r� )r� r r8 r_ )!rK rL rM r
173 r rh �propertyr� r� r� r� r� �setterr� r� r� r� r� r� r0 r� r� r� r� r� r� r� r� r� r� r� r� r� rA rA rA rB r~ � s� �"
174
175
176 �
177 3
178 �
179 �
180
181
182
183
184 r~ c s e Zd ZdZdddddddddddedeeddddd�d|� fd-d.�Zdddddedfd}d0d1�Zdddddefd~d3d4�Z dd7d8�Z
185 ddddddde e e dd9� d�dJdK�Z e
186 ddddddde e e dd9� d�dMdN��Zde e dO�d�dSdT�Zd�dXdY�Zd�dZd[�Zd�d\d]�Zddde e e dd^�d�d_d`�Zddde e e dd^�d�dbdc�Zddde e e dd^�d�ddde�Zddddddde e e dd9� d�dfdg�Zddddddde e e dd9� d�dhdi�Zddddddde e e dd9� d�djdk�Zddde e e dd^�d�dldm�Zd�dndo�Zd�drds�Z d�d�dzd{�Z � Z S )�r2 av
187 An HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc.
188
189 It can be shared between threads.
190
191 Usage:
192
193 ```python
194 >>> client = httpx.Client()
195 >>> response = client.get('https://example.org')
196 ```
197
198 **Parameters:**
199
200 * **auth** - *(optional)* An authentication class to use when sending
201 requests.
202 * **params** - *(optional)* Query parameters to include in request URLs, as
203 a string, dictionary, or sequence of two-tuples.
204 * **headers** - *(optional)* Dictionary of HTTP headers to include when
205 sending requests.
206 * **cookies** - *(optional)* Dictionary of Cookie items to include when
207 sending requests.
208 * **verify** - *(optional)* Either `True` to use an SSL context with the
209 default CA bundle, `False` to disable verification, or an instance of
210 `ssl.SSLContext` to use a custom context.
211 * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be
212 enabled. Defaults to `False`.
213 * **proxy** - *(optional)* A proxy URL where all the traffic should be routed.
214 * **timeout** - *(optional)* The timeout configuration to use when sending
215 requests.
216 * **limits** - *(optional)* The limits configuration to use.
217 * **max_redirects** - *(optional)* The maximum number of redirect responses
218 that should be followed.
219 * **base_url** - *(optional)* A URL to use as the base when building
220 request URLs.
221 * **transport** - *(optional)* A transport class to use for sending requests
222 over the network.
223 * **trust_env** - *(optional)* Enables or disables usage of environment
224 variables for configuration.
225 * **default_encoding** - *(optional)* The default encoding to use for decoding
226 response text, if no charset information is included in a response Content-Type
227 header. Set to a callable for automatic character set detection. Default: "utf-8".
228 NTFr r� )r� r� r� r� �verify�certr� �http1�http2r� �mountsr� r� �limitsr� r� r� � transportr� r� r� r� r� r� r� r� r� r� �ssl.SSLContext | str | boolr� �CertTypes | Noner� r9 r� r r� r� r �0None | typing.Mapping[str, BaseTransport | None]r� r+ r� r r r� r� r� r� r� r� r �BaseTransport | Noner� r� r8 r_ c
229 s� t � j||||| |
230 |||�|d� �r&zdd l}W n ty% td�d �w �o+|d u }��|
231 |�}�j�� ����|d��_� ������fdd�|�� D ��_| d urb�j� dd� | �� D �� t
232 t �j�� ���_d S )Nr� r �uUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.�r� r� r� r� r r r c �: i | ]\}}t |�|d u rd n �j|�� ����d��qS �N)r� r� r� r� r r �r. �_init_proxy_transport�rP rQ r� �r� r� r r rg r� r� rA rB r� � � ����z#Client.__init__.<locals>.<dictcomp>c S � i | ] \}}t |�|�qS rA �r. �rP rQ r rA rA rB r� � � � �superrh �h2� ImportErrorr� �_init_transport�
233 _transportr� �_mountsr� r� �sorted)rg r� r� r� r� r� r� r� r� r r� r r� r� r r� r� r� r r� r r� � proxy_map�� __class__r rB rh sT � ��� � ��zClient.__init__r c C � |d ur|S t ||||||d�S r �r �rg r� r� r� r� r r r rA rA rB r � �
234 �zClient._init_transportr c C � t |||||||d�S �N)r� r� r� r� r r r� r! �rg r� r� r� r� r� r r rA rA rB r
235 � �
236 �z Client._init_proxy_transportr6 r, c C �> | j �� D ]\}}|�|�r|du r| j S | S q| jS �z�
237 Returns the transport instance that should be used for a given URL.
238 This will either be the standard connection pool, or a proxy.
239 N�r r� �matchesr �rg r6 �patternr rA rA rB �_transport_for_url� �
240
241 �zClient._transport_for_url� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� �bool | UseClientDefaultr� r� r� r c
242 C sL | durd}t j|tdd� | j||||||||| | |
243 d� }| j||
244 | d�S )a�
245 Build and send a request.
246
247 Equivalent to:
248
249 ```python
250 request = client.build_request(...)
251 response = client.send(request, ...)
252 ```
253
254 See `Client.build_request()`, `Client.send()` and
255 [Merging of configuration][0] for how the various parameters
256 are merged with client-level configuration.
257
258 [0]: /advanced/clients/#merging-of-configuration
259 N��Setting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead.rT ��
260 stacklevel� r� r6 r� r� r� r� r� r� r� r� r� �r� r� ��warnings�warn�DeprecationWarningr� �send�rg r� r6 r� r� r� r� r� r� r� r� r� r� r� �messager� rA rA rB r� s$ !��
261 zClient.request�typing.Iterator[Response]c
262 c sT � | j ||||||||| | |
263 d� }| j||
264 | dd�}z
265 |V W |�� dS |�� w �a
266 Alternative to `httpx.request()` that streams the response body
267 instead of loading it into memory at once.
268
269 **Parameters**: See `httpx.request`.
270
271 See also: [Streaming Responses][0]
272
273 [0]: /quickstart#streaming-responses
274 r5 T)r� r� r� r[ N)r� r; rv �rg r� r6 r� r� r� r� r� r� r� r� r� r� r� r� r\ rA rA rB r[ ; s. � �
275 �z
276 Client.stream�r[ r� r� r� r r[ c
277 C s� | j tjkr
278 td��tj| _ t|t�r| jn|}| �|� | � ||�}| j
279 |||g d�}z |s3|� � |W S t yG } z|�
280 � |�d}~ww )a�
281 Send a request.
282
283 The request is sent as-is, unmodified.
284
285 Typically you'll want to build one with `Client.build_request()`
286 so that any client-level configuration is merged into the request,
287 but passing an explicit `httpx.Request()` is supported as well.
288
289 See also: [Request instances][0]
290
291 [0]: /advanced/clients/#request-instances
292 �5Cannot send a request, as the client has been closed.�r� r� �historyN)r� rS rX � RuntimeErrorrW r� rJ r� r� r� �_send_handling_auth�read�
293 BaseExceptionrv �rg r� r[ r� r� r\ r� rA rA rB r; o s0 ��
294 ���z Client.sendr rD �list[Response]c
295 C s� |� |�}zLt|�} | j|||d�}z+z|�|�}W n ty, | Y W W |�� S w t|�|_|�� |}|� |� W n t
296 yP } z|�� |�d }~ww q |�� w �NT)r� rD ) Zsync_auth_flow�next�_send_handling_redirectsr; �
297 StopIterationrv r� rD rG �appendrH � rg r� r� r� rD Z auth_flowr\ � next_requestr� rA rA rB rF � s6
298 �
299
300 �
301 ���
302 zClient._send_handling_authc
303 C s� t |�| jkrtd|d��| jd D ]}||� q| �|�}z1| jd D ]}||� q%t|�|_|js7|W S | �||�}||g }|rI|� � n||_
304 |W S W n t yb } z|� � |�d }~ww q�NTz#Exceeded maximum allowed redirects.r� r� r\ )
305 �lenr� r r� �_send_single_requestr� rD �has_redirect_locationr� rG rQ rH rv �rg r� r� rD �hookr\ r� rA rA rB rM � s6 �
306
307
308
309
310
311 ����z Client._send_handling_redirectsc C s� | � |j�}t�� }t|jt�std��t|d��
312 |� |�}W d � n1 s)w Y t|jt�s6J �||_
313 t |j||d�|_| j �
314 |� | j|_t�d|j|j|j|j|j� |S )�L
315 Sends a single request, without handling any redirections.
316 z?Attempted to send an async request with a sync Client instance.r� N�r\ r] � HTTP Request: %s %s "%s %d %s")r. r6 rq rr r� r[ r* rE r �handle_requestr� rZ r� �extract_cookiesr� r� �logger�infor� � http_versionr� �
317 reason_phrase�rg r� r r] r\ rA rA rB rT � s2 � �� � zClient._send_single_request�r� r� r� r� r� r� r� c C � | j d||||||||d� S )�U
318 Send a `GET` request.
319
320 **Parameters**: See `httpx.request`.
321 r� rb r� � rg r6 r� r� r� r� r� r� r� rA rA rB rF � �z
322 Client.get� AuthTypes | UseClientDefaultc C rc )�Z
323 Send an `OPTIONS` request.
324
325 **Parameters**: See `httpx.request`.
326 �OPTIONSrb r� re rA rA rB �options) rf zClient.optionsc C rc )�V
327 Send a `HEAD` request.
328
329 **Parameters**: See `httpx.request`.
330 r� rb r� re rA rA rB �headF rf z Client.headc
331 C �$ | j d||||||||| |
332 | | d�
333 S )�V
334 Send a `POST` request.
335
336 **Parameters**: See `httpx.request`.
337 r� r0 r� �
338 rg r6 r� r� r� r� r� r� r� r� r� r� r� rA rA rB �postc � �z Client.postc
339 C rm )�U
340 Send a `PUT` request.
341
342 **Parameters**: See `httpx.request`.
343 �PUTr0 r� ro rA rA rB �put� rq z
344 Client.putc
345 C rm )�W
346 Send a `PATCH` request.
347
348 **Parameters**: See `httpx.request`.
349 �PATCHr0 r� ro rA rA rB �patch� rq z Client.patchc C rc )�X
350 Send a `DELETE` request.
351
352 **Parameters**: See `httpx.request`.
353 �DELETErb r� re rA rA rB �delete� rf z
354 Client.deletec C sF | j tjkr tj| _ | j�� | j�� D ] }|dur |�� qdS dS �z.
355 Close transport and proxies.
356 N)r� rS rX r rv r �values)rg r rA rA rB rv � s
357 ��z Client.closerg r3 c C s` | j tjkrtjdtjdi| j }t|��tj| _ | j�� | j� � D ]
358 }|d ur-|�� q#| S �Nz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.)
359 r� rS rV rW rX rE r � __enter__r r| )rg �msgr rA rA rB r~ � s ��
360 �zClient.__enter__�exc_type�type[BaseException] | None� exc_value�BaseException | None� traceback�TracebackType | Nonec C sB t j| _| j�|||� | j�� D ]
361 }|d ur |�|||� qd S ra )rS rX r� r �__exit__r r| )rg r� r� r� r rA rA rB r�
362 s ��zClient.__exit__)(r� r� r� r� r� r� r� r� r� r r� r r� r9 r� r9 r r9 r� r� r r r� r+ r� r9 r r r� r� r� r� r� r� r r r� r� r8 r_ )r� r r� r r� r9 r� r9 r r9 r r r r r8 r )r� r r� r r� r r� r9 r� r9 r r9 r r r8 r )r6 r, r8 r � r� r� r6 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r1 r� r� r� r� r8 r ) r� r� r6 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r1 r� r� r� r� r8 r> �
363 r� r r[ r9 r� r� r� r1 r8 r �
364 r� r r� r r� r9 rD rJ r8 r �r� r r� r9 rD rJ r8 r �r� r r8 r �r6 r� r� r� r� r� r� r� r� r� r� r1 r� r� r� r� r8 r �r6 r� r� r� r� r� r� r� r� rg r� r1 r� r� r� r� r8 r �r6 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rg r� r1 r� r� r� r� r8 r rx )rg r3 r8 r3 �NNN�r� r� r� r� r� r� r8 r_ ) rK rL rM rN r
365 r r rh r r
366 r. r0 r� r r[ r; rF rM rT rF rj rl rp rt rw rz rv r~ r� �
367 __classcell__rA rA r rB r2 R s /�Q � �
368 �8�7�
369 3
370 "
371 %'�!�!�!�)�)�)�
372
373 �c s e Zd ZdZddddddddddedeedddddd�d|� fd-d.�Zdddddedfd}d0d1�Zdddddefd~d3d4�Z dd7d8�Z
374 ddddddde e e dd9� d�dJdK�Z e
375 ddddddde e e dd9� d�dMdN��Zde e dO�d�dSdT�Zd�dXdY�Zd�dZd[�Zd�d\d]�Zddde e e dd^�d�d_d`�Zddde e e dd^�d�dbdc�Zddde e e dd^�d�ddde�Zddddddde e e dd9� d�dfdg�Zddddddde e e dd9� d�dhdi�Zddddddde e e dd9� d�djdk�Zddde e e dd^�d�dldm�Zd�dndo�Zd�drds�Z d�d�dzd{�Z � Z S )�r1 a�
376 An asynchronous HTTP client, with connection pooling, HTTP/2, redirects,
377 cookie persistence, etc.
378
379 It can be shared between tasks.
380
381 Usage:
382
383 ```python
384 >>> async with httpx.AsyncClient() as client:
385 >>> response = await client.get('https://example.org')
386 ```
387
388 **Parameters:**
389
390 * **auth** - *(optional)* An authentication class to use when sending
391 requests.
392 * **params** - *(optional)* Query parameters to include in request URLs, as
393 a string, dictionary, or sequence of two-tuples.
394 * **headers** - *(optional)* Dictionary of HTTP headers to include when
395 sending requests.
396 * **cookies** - *(optional)* Dictionary of Cookie items to include when
397 sending requests.
398 * **verify** - *(optional)* Either `True` to use an SSL context with the
399 default CA bundle, `False` to disable verification, or an instance of
400 `ssl.SSLContext` to use a custom context.
401 * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be
402 enabled. Defaults to `False`.
403 * **proxy** - *(optional)* A proxy URL where all the traffic should be routed.
404 * **timeout** - *(optional)* The timeout configuration to use when sending
405 requests.
406 * **limits** - *(optional)* The limits configuration to use.
407 * **max_redirects** - *(optional)* The maximum number of redirect responses
408 that should be followed.
409 * **base_url** - *(optional)* A URL to use as the base when building
410 request URLs.
411 * **transport** - *(optional)* A transport class to use for sending requests
412 over the network.
413 * **trust_env** - *(optional)* Enables or disables usage of environment
414 variables for configuration.
415 * **default_encoding** - *(optional)* The default encoding to use for decoding
416 response text, if no charset information is included in a response Content-Type
417 header. Set to a callable for automatic character set detection. Default: "utf-8".
418 NTFr r� )r� r� r� r� r� r� r� r r� r r� r� r r� r� r� r r� r� r� r� r� r� r� r� r� r� r� r r� r r� r9 r r� r� r �5None | typing.Mapping[str, AsyncBaseTransport | None]r� r+ r� r r r� r� r� r� r� r� r �AsyncBaseTransport | Noner� r� r� r8 r_ c
419 s� t � j||||| | |||�|d� �r&zdd l}W n ty% td�d �w �o+|d u }��| |�}�j�� ����|d��_� ������fdd�|�� D ��_|
420 d urb�j� dd� |
421 �� D �� t
422 t �j�� ���_d S )Nr� r r r c r
423 r r r r rA rB r� � r z(AsyncClient.__init__.<locals>.<dictcomp>c S r rA r r rA rA rB r� � r r )rg r� r� r� r� r� r� r� r r� r r� r� r r� r� r� r r� r� r r� r r r rB rh I sT � ��� �
424 ��zAsyncClient.__init__r c C r r �r r" rA rA rB r � r# zAsyncClient._init_transportr c C r$ r% r� r& rA rA rB r
425 � r' z!AsyncClient._init_proxy_transportr6 r, c C r( r) r* r, rA rA rB r. � r/ z AsyncClient._transport_for_urlr0 r� r� r� r� r� r� r� r� r� r� r� r1 r� r� r� r c
426 � sT �| durd}t j|tdd� | j||||||||| | |
427 d� }| j||
428 | d�I dH S )a�
429 Build and send a request.
430
431 Equivalent to:
432
433 ```python
434 request = client.build_request(...)
435 response = await client.send(request, ...)
436 ```
437
438 See `AsyncClient.build_request()`, `AsyncClient.send()`
439 and [Merging of configuration][0] for how the various parameters
440 are merged with client-level configuration.
441
442 [0]: /advanced/clients/#merging-of-configuration
443 Nr2 rT r3 r5 r6 r7 r< rA rA rB r� � s& �"��
444 zAsyncClient.request� typing.AsyncIterator[Response]c
445 C sf �| j ||||||||| | |
446 d� }| j||
447 | dd�I dH }z
448 |V W |�� I dH dS |�� I dH w r? )r� r; r} r@ rA rA rB r[ s. � �
449 �"zAsyncClient.streamrA r� r r[ c
450 � s� �| j tjkr td��tj| _ t|t�r| jn|}| �|� | � ||�}| j
451 |||g d�I dH }z |s:|� � I dH |W S t yQ } z |�
452 � I dH |�d}~ww )a�
453 Send a request.
454
455 The request is sent as-is, unmodified.
456
457 Typically you'll want to build one with `AsyncClient.build_request()`
458 so that any client-level configuration is merged into the request,
459 but passing an explicit `httpx.Request()` is supported as well.
460
461 See also: [Request instances][0]
462
463 [0]: /advanced/clients/#request-instances
464 rB rC N)r� rS rX rE rW r� rJ r� r� r� rF �areadrH r} rI rA rA rB r; : s2 � ��
465 ���zAsyncClient.sendr rD rJ c
466 � s� �|� |�}z^|�� I d H } | j|||d�I d H }z4z
467 |�|�I d H }W n ty9 | Y W W |�� I d H S w t|�|_|�� I d H |}|� |� W n t
468 yc } z |�� I d H |�d }~ww q|�� I d H w rK ) Zasync_auth_flow� __anext__rM �asend�StopAsyncIterationr} r� rD r� rO rH rP rA rA rB rF m s8 �
469 �
470 �
471 ���z AsyncClient._send_handling_authc
472 � s� � t |�| jkrtd|d��| jd D ] }||�I d H q| �|�I d H }z7| jd D ] }||�I d H q,t|�|_|jsA|W S | �||�}||g }|rV|� � I d H n||_
473 |W S W n t yr } z |� � I d H |�d }~ww qrR )
474 rS r� r r� rT r� rD rU r� r� rQ rH r} rV rA rA rB rM � s8 ��
475
476 ����z$AsyncClient._send_handling_redirectsc � s� �| � |j�}t�� }t|jt�std��t|d�� |� |�I dH }W d � n1 s-w Y t|jt�s:J �||_
477 t |j||d�|_| j �
478 |� | j|_t�d|j|j|j|j|j� |S )rX z?Attempted to send an sync request with an AsyncClient instance.r� NrY rZ )r. r6 rq rr r� r[ r rE r Zhandle_async_requestr� rz r� r\ r� r� r] r^ r� r_ r� r` ra rA rA rB rT � s4 � � �� � z AsyncClient._send_single_requestrb c � �$ �| j d||||||||d� I dH S )rd r� rb Nr� re rA rA rB rF � � � �zAsyncClient.getrg c � r� )rh ri rb Nr� re rA rA rB rj � r� zAsyncClient.optionsc � r� )rk r� rb Nr� re rA rA rB rl r� zAsyncClient.headc
479 � �, �| j d||||||||| |
480 | | d�
481 I dH S )rn r� r0 Nr� ro rA rA rB rp . � � �zAsyncClient.postc
482 � r� )rr rs r0 Nr� ro rA rA rB rt S r� zAsyncClient.putc
483 � r� )ru rv r0 Nr� ro rA rA rB rw x r� zAsyncClient.patchc � r� )rx ry rb Nr� re rA rA rB rz � r� zAsyncClient.deletec � sT �| j tjkr&tj| _ | j�� I dH | j�� D ]}|dur%|�� I dH qdS dS r{ )r� rS rX r r} r r| )rg r� rA rA rB r} � s � ��zAsyncClient.acloserg r5 c � sn �| j tjkrtjdtjdi| j }t|��tj| _ | j�� I d H | j� � D ]
484 }|d ur4|�� I d H q'| S r} )
485 r� rS rV rW rX rE r �
486 __aenter__r r| )rg r r� rA rA rB r� � s � ���zAsyncClient.__aenter__r� r� r� r� r� r� c � sP �t j| _| j�|||�I d H | j�� D ]}|d ur%|�|||�I d H qd S ra )rS rX r� r � __aexit__r r| )rg r� r� r� r� rA rA rB r� � s ���zAsyncClient.__aexit__)(r� r� r� r� r� r� r� r� r� r r� r r� r9 r r9 r� r� r r� r� r+ r� r9 r r r� r� r� r� r� r� r r� r� r9 r� r� r8 r_ )r� r r� r r� r9 r� r9 r r9 r r r r� r8 r )r� r r� r r� r r� r9 r� r9 r r9 r r r8 r )r6 r, r8 r r� ) r� r� r6 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r1 r� r� r� r� r8 r� r� r� r� r� r� r� r� rx )rg r5 r8 r5 r� r� ) rK rL rM rN r
487 r r rh r r
488 r. r0 r� r r[ r; rF rM rT rF rj rl rp rt rw rz r} r� r� r� rA rA r rB r1 s 0�Q � �
489 �9�7�
490 3
491 "
492 &&�!�!�!�)�)�)�
493
494 �)r6 r, r7 r, r8 r9 )r6 r, r8 rD )r6 r, rH r, r8 r9 )\�
495 __future__r rs �enum�loggingrq �typingr8 �
496 contextlibr r �typesr r r� r r r
497 �_configr r r
498 r r r � _decodersr � _exceptionsr r r r Z_modelsr r r r Z
499 _status_codesr Z_transports.baser r Z_transports.defaultr r �_typesr r r! r" r# r$ r% r& r' r( r) r* r+ Z_urlsr, r- �_utilsr. r/ �
500 TYPE_CHECKING�ssl�__all__�TypeVarr3 r5 rC r@ rI rJ r0 � getLoggerr] r� r� �keysr� �EnumrS rZ rz �Callable�AnyZ EventHookr~ r2 r1 rA rA rA rB �<module> sf <
501
502
503
504
505 � N