File: //usr/local/lib/python3.10/dist-packages/httpx/__pycache__/_models.cpython-310.pyc
o
���g�� � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z d dl m
Z
d dlmZmZ ddlmZmZmZmZ ddlmZmZmZmZmZm Z m Z m Z ddl m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z& dd l'm(Z( dd
l)m*Z* dd l+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6 dd l7m8Z8 dd
l9m:Z:m;Z; g d�Z<ddhZ=d3dd�Z>d4d5dd �Z?d4d6d d �Z@d7d!d"�ZAd8d$d%�ZBd9d)d*�ZCG d+d,� d,e jDeEeEf �ZFG d-d.� d.�ZGG d/d0� d0�ZHG d1d2� d2e jDeEeEf �ZIdS ):� )� annotationsN)�Mapping)�Cookie� CookieJar� )�
ByteStream�UnattachedStream�encode_request�encode_response)�SUPPORTED_DECODERS� ByteChunker�ContentDecoder�IdentityDecoder� LineDecoder� MultiDecoder� TextChunker� TextDecoder)�CookieConflict�HTTPStatusError�RequestNotRead�ResponseNotRead� StreamClosed�StreamConsumed�request_context)�(get_multipart_boundary_from_content_type)�codes) �AsyncByteStream� CookieTypes� HeaderTypes�QueryParamTypes�RequestContent� RequestData�RequestExtensions� RequestFiles�ResponseContent�ResponseExtensions�SyncByteStream)�URL)�to_bytes_or_str�to_str)�Cookies�Headers�Request�Response�
authorizationzproxy-authorization�encoding�str�return�boolc C s& zt �| � W dS ty Y dS w )z7
Return `True` if `encoding` is a known codec.
FT)�codecs�lookup� LookupError�r/ � r7 �8/usr/local/lib/python3.10/dist-packages/httpx/_models.py�_is_known_encoding8 s ��r9 �key� str | bytes�
str | None�bytesc C s t | t�r| S | �|p d�S )zE
Coerce str/bytes into a strictly byte-wise HTTP header key.
�ascii)�
isinstancer= �encode)r: r/ r7 r7 r8 �_normalize_header_keyC s rA �valuec C s8 t | t�r| S t | t�stdt| �� ���| �|pd�S )zG
Coerce str/bytes into a strictly byte-wise HTTP header value.
z'Header value must be str or bytes, not r> )r? r= r0 � TypeError�typer@ )rB r/ r7 r7 r8 �_normalize_header_valueJ s
rE � content_typec C s t j�� }| |d< |jd d�S )N� content-type)�failobj)�email�message�Message�get_content_charset)rF �msgr7 r7 r8 �_parse_content_type_charsetU s
rN �list[dict[str, str]]c
C s� g }d}| � |�} | s
|S t�d| �D ]M}z
|�dd�\}}W n ty- |d}}Y nw d|� d�i}|�d�D ] }z |�d�\}} W n
tyO Y n w | � |�||� |�< q:|�|� q|S ) a7
Returns a list of parsed link headers, for more info see:
https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Link
The generic syntax of those is:
Link: < uri-reference >; param1=value1; param2="value2"
So for instance:
Link; '<http:/.../front.jpeg>; type="image/jpeg",<http://.../back.jpeg>;'
would return
[
{"url": "http:/.../front.jpeg", "type": "image/jpeg"},
{"url": "http://.../back.jpeg"},
]
:param value: HTTP Link entity-header field
:return: list of parsed link headers
z '"z, *<�;r � �urlz<> '"�=)�strip�re�split�
ValueError�append) rB �links�
replace_chars�valrR �params�link�paramr: r7 r7 r8 �_parse_header_links] s*
� � r_ �items�4typing.Iterable[tuple[typing.AnyStr, typing.AnyStr]]�4typing.Iterator[tuple[typing.AnyStr, typing.AnyStr]]c c s: � | D ]\}}t |�� �tv rtd|d�}||fV qd S )Nz[secure])�
match_type_of)r) �lower�SENSITIVE_HEADERSr( )r` �k�vr7 r7 r8 � _obfuscate_sensitive_headers� s � �rh c @ s� e Zd ZdZ dAdBd d
�ZedCd d
��ZejdDdd
��ZedEdd��ZdFdd�Z dGdd�Z
dHdd�Z dId d �Z dJdKd"d#�Z
dLdMd(d)�ZdJdNd*d+�ZdOd,d-�ZdPd.d/�ZdQd0d1�ZdRd2d3�ZdSd4d5�ZdTd7d8�ZdUd:d;�ZdVd=d>�ZdCd?d@�ZdS )Wr+ z9
HTTP headers, as a case-insensitive multi-dict.
N�headers�HeaderTypes | Noner/ r< r1 �Nonec C s� g | _ t|t�rt|j �| _ nDt|t�r3|�� D ]\}}t||�}t||�}| j �||� � |f� qn |d urS|D ]\}}t||�}t||�}| j �||� � |f� q9|| _
d S �N) �_listr? r+ �listr r` rA rE rX rd � _encoding)�selfri r/ rf rg � bytes_key� bytes_valuer7 r7 r8 �__init__� s
�
zHeaders.__init__r0 c
C sj | j du r2dD ]'}| jD ]\}}z |�|� |�|� W q ty& Y nw || _ | j S qd| _ | j S )zn
Header encoding is mandated as ascii, but we allow fallbacks to utf-8
or iso-8859-1.
N)r> �utf-8z
iso-8859-1)ro �raw�decode�UnicodeDecodeError)rp r/ r: rB r7 r7 r8 r/ � s
�� zHeaders.encodingrB c C �
|| _ d S rl )ro �rp rB r7 r7 r8 r/ � �
�list[tuple[bytes, bytes]]c C � dd� | j D �S )zH
Returns a list of the raw header items, as byte pairs.
c S s g | ] \}}}||f�qS r7 r7 )�.0�raw_key�_rB r7 r7 r8 �
<listcomp>� � z Headers.raw.<locals>.<listcomp>�rm �rp r7 r7 r8 ru � s z Headers.raw�typing.KeysView[str]c s � fdd�� j D ��� S )Nc s i | ] \}}}|� � j�d �qS rl �rv r/ �r} r r: rB r� r7 r8 �
<dictcomp>� s z Headers.keys.<locals>.<dictcomp>)rm �keysr� r7 r� r8 r� � s z Headers.keys�typing.ValuesView[str]c C �^ i }| j D ]%\}}}|�| j�}|�| j�}||v r&|| d|� �7 < q|||< q|�� S )N�, )rm rv r/ �values�rp � values_dictr r: rB �str_key� str_valuer7 r7 r8 r� � s
zHeaders.values�typing.ItemsView[str, str]c C r� )z�
Return `(key, value)` items of headers. Concatenate headers
into a single comma separated value when a key occurs multiple times.
r� )rm rv r/ r` r� r7 r7 r8 r` � s
z
Headers.items�list[tuple[str, str]]c s � fdd�� j D �S )z�
Return a list of `(key, value)` pairs of headers. Allow multiple
occurrences of the same key without concatenating into a single
comma separated value.
c s* g | ]\}}}|� � j�|� � j�f�qS r7 r� r� r� r7 r8 r� � s ��z'Headers.multi_items.<locals>.<listcomp>r� r� r7 r� r8 � multi_items� s
�zHeaders.multi_itemsr: �default�
typing.Anyc C s" z| | W S t y | Y S w )z�
Return a header value. If multiple occurrences of the header occur
then concatenate them together with commas.
)�KeyError)rp r: r� r7 r7 r8 �get� s
�z Headers.getF� split_commasr2 � list[str]c sZ |� � ��j�� � �fdd��jD �}|s|S g }|D ]}|�dd� |�d�D �� q|S )z�
Return a list of all header values for a given key.
If `split_commas=True` is passed, then any comma separated header
values are split into multiple return strings.
c s* g | ]\}}}|� � � kr|��j��qS r7 )rd rv r/ )r} r �item_key�
item_value��get_header_keyrp r7 r8 r� s
�z$Headers.get_list.<locals>.<listcomp>c S s g | ]}|� � �qS r7 )rT )r} �itemr7 r7 r8 r� s �,)rd r@ r/ rm �extendrV )rp r: r� r� � split_valuesrB r7 r� r8 �get_list� s � zHeaders.get_listc C s: t |�}|�� D ] }|| v r| �|� q| j�|j� d S rl )r+ r� �poprm r� )rp ri r: r7 r7 r8 �update s
�zHeaders.updatec C s t | | jd�S )Nr6 )r+ r/ r� r7 r7 r8 �copy s z Headers.copyc s< |� � ��j�� � �fdd��jD �}|rd�|�S t|��)z�
Return a single header value.
If there are multiple headers with the same key, then we concatenate
them with commas. See: https://tools.ietf.org/html/rfc7230#section-3.2.2
c s& g | ]\}}}|� kr|� �j��qS r7 r� )r} r �
header_key� header_value��normalized_keyrp r7 r8 r� % s
�z'Headers.__getitem__.<locals>.<listcomp>r� )rd r@ r/ rm �joinr� )rp r: r` r7 r� r8 � __getitem__ s �
zHeaders.__getitem__c s� |� | jpd�}|� | jpd�}|�� � � fdd�t| j�D �}t|dd� �D ]}| j|= q(|r?|d }|� |f| j|< dS | j�|� |f� dS )zs
Set the header `key` to `value`, removing any duplicate entries.
Retains insertion order.
rt c s" g | ]
\}\}}}|� kr|�qS r7 r7 �r} �idxr r� ��
lookup_keyr7 r8 r� 9 s
�z'Headers.__setitem__.<locals>.<listcomp>r Nr )r@ ro rd � enumeraterm �reversedrX )rp r: rB �set_key� set_value�
found_indexesr� r7 r� r8 � __setitem__0 s
�
zHeaders.__setitem__c sN |� � �| j�� � fdd�t| j�D �}|st|��t|�D ]}| j|= q dS )z*
Remove the header `key`.
c s& g | ]\}\}}}|� � � kr|�qS r7 )rd r� ��del_keyr7 r8 r� N s
�z'Headers.__delitem__.<locals>.<listcomp>N)rd r@ r/ r� rm r� r� )rp r: � pop_indexesr� r7 r� r8 � __delitem__H s
�
�zHeaders.__delitem__c C s$ |� � �| j�}|dd� | jD �v S )Nc S s g | ]\}}}|�qS r7 r7 )r} r r: r7 r7 r8 r� \ s z(Headers.__contains__.<locals>.<listcomp>)rd r@ r/ rm )rp r: r� r7 r7 r8 � __contains__Z s zHeaders.__contains__�typing.Iterator[typing.Any]c C s t | �� �S rl )�iterr� r� r7 r7 r8 �__iter__^ � zHeaders.__iter__�intc C �
t | j�S rl )�lenrm r� r7 r7 r8 �__len__a �
zHeaders.__len__�otherc C sR zt |�}W n
ty Y dS w dd� | jD �}dd� |jD �}t|�t|�kS )NFc S � g | ] \}}}||f�qS r7 r7 r� r7 r7 r8 r� j r� z"Headers.__eq__.<locals>.<listcomp>c S r� r7 r7 r� r7 r7 r8 r� k r� )r+ rW rm �sorted)rp r� �
other_headers� self_list�
other_listr7 r7 r8 �__eq__d s �zHeaders.__eq__c C sv | j j}d}| jdkrd| j��}tt| �� ��}t|�}t|�t|�k}|r1|� d|�|� d�S |� d|�|� d�S )NrQ r> z , encoding=�(�))� __class__�__name__r/ rn rh r� �dictr� )rp �
class_name� encoding_str�as_list�as_dict�no_duplicate_keysr7 r7 r8 �__repr__n s
zHeaders.__repr__�NN)ri rj r/ r< r1 rk �r1 r0 �rB r0 r1 rk )r1 r{ )r1 r� )r1 r� )r1 r� )r1 r� rl )r: r0 r� r� r1 r� )F)r: r0 r� r2 r1 r� )ri rj r1 rk )r1 r+ )r: r0 r1 r0 �r: r0 rB r0 r1 rk )r: r0 r1 rk )r: r� r1 r2 )r1 r� �r1 r� )r� r� r1 r2 )r� �
__module__� __qualname__�__doc__rs �propertyr/ �setterru r� r� r` r� r� r� r� r� r� r� r� r� r� r� r� r� r7 r7 r7 r8 r+ � s6 �
r+ c
@ sv e Zd Zdddddddddd� d0dd �Zd1d d �Zed2d"d#��Zd2d$d%�Zd2d&d'�Zd3d(d)�Z d4d+d,�Z
d5d.d/�Z dS )6r, N) r\ ri �cookies�content�data�files�json�stream�
extensions�methodr0 rR � URL | strr\ �QueryParamTypes | Noneri rj r� �CookieTypes | Noner� �RequestContent | Noner� �RequestData | Noner� �RequestFiles | Noner� �typing.Any | Noner� �'SyncByteStream | AsyncByteStream | Noner� �RequestExtensions | Noner1 rk c
C s� |� � | _|d u r
t|�nt||d�| _t|�| _| d u r i nt| �| _|r-t|�� | � |
d u rc| j�
d�} t |||| t | rF| �
| jj�nd d�d�\}}
| �|� |
| _t|
t�ra| �� d S d S |
| _d S )N)r\ rG )rF )r� r� r� r� �boundary)�upperr� r' rR r+ ri r� r� r* �set_cookie_headerr� r r r@ r/ �_preparer� r? r �read)
rp r� rR r\ ri r� r� r� r� r� r� r� rF r7 r7 r8 rs s2
��
�
�
zRequest.__init__�default_headers�dict[str, str]c C s� |� � D ]\}}|�� dkrd| jv rq| j�||� qg }d| jv }d| jv p,d| jv }|s<| jjr<|�d| jjf� |sH| jdv rH|�d� t || jj
�| _d S )N�transfer-encodingzContent-Length�HostzTransfer-Encodings Host)�POST�PUT�PATCH)s Content-Length� 0) r` rd ri �
setdefaultrR �hostrX �netlocr� r+ ru )rp r� r: rB � auto_headers�has_host�has_content_lengthr7 r7 r8 r� � s
�
zRequest._preparer= c C � t | d�st� �| jS �N�_content)�hasattrr r r� r7 r7 r8 r� � �
zRequest.contentc C sH t | d�s!t| jtj�sJ �d�| j�| _t| jt�s!t| j�| _| jS )�6
Read and return the request content.
r � )r r? r� �typing�Iterabler� r r r� r7 r7 r8 r� � s
z Request.readc � sZ �t | d�s*t| jtj�sJ �d�dd� | j2 �I dH �| _t| jt�s*t| j�| _| jS )r r r
c � � �g | z3 d H W }|�q6 S rl r7 �r} �partr7 r7 r8 r� � � � z!Request.aread.<locals>.<listcomp>N)r r? r� r �
AsyncIterabler� r r r� r7 r7 r8 �aread� s �
z
Request.areadc C s, | j j}t| j�}d|� d| j�d|�d�S )N�<r� r� z)>)r� r� r0 rR r� )rp r� rR r7 r7 r8 r� � s
zRequest.__repr__�dict[str, typing.Any]c C � dd� | j �� D �S )Nc S � i | ] \}}|d vr||�qS ))r� r� r7 �r} �namerB r7 r7 r8 r� � �
�z(Request.__getstate__.<locals>.<dictcomp>��__dict__r` r� r7 r7 r8 � __getstate__� � �zRequest.__getstate__�statec C s0 |� � D ]
\}}t| ||� qi | _t� | _d S rl )r` �setattrr� r r� �rp r r rB r7 r7 r8 � __setstate__� s zRequest.__setstate__)r� r0 rR r� r\ r� ri rj r� r� r� r� r� r� r� r� r� r� r� r� r� r� r1 rk �r� r� r1 rk �r1 r= r� �r1 r �r r r1 rk ) r� r� r� rs r� r� r� r� r r� r r! r7 r7 r7 r8 r, ~ s& �
:
r, c @ s8 e Zd Zddddddddddd�
d�dd �Zd�d d �Zed�d"d#��Zejd�d%d#��Zed�d'd(��Zejd�d*d(��Zed�d,d-��Z ed�d.d/��Z
ed�d1d2��Z ed�d4d5��Z ed�d6d7��Z
ed�d8d9��Zejd�d:d9��Zed�d;d<��Zd�d>d?�Zed�dAdB��Zed�dCdD��Zed�dEdF��Zed�dGdH��Zed�dIdJ��Zed�dKdL��Zed�dMdN��Zd�dOdP�Zd�dRdS�Zed�dUdV��Zed�dXdY��Zed�dZd[��Z d�d\d]�Z d�d_d`�Z d�dbdc�Z d�ddde�Z d�d�didj�Z!d�d�dldm�Z"d�dndo�Z#d�d�dpdq�Z$d�drds�Z%d�dtdu�Z& d�d�dwdx�Z' d�d�dzd{�Z(d�d|d}�Z) d�d�d~d�Z*d�d�d��Z+dS )�r- Nrt )
ri r� �text�htmlr� r� �requestr� �history�default_encoding� status_coder� ri rj r� �ResponseContent | Noner& r< r' r� r� r� r� r( �Request | Noner� �ResponseExtensions | Noner) �list[Response] | Noner* �#str | typing.Callable[[bytes], str]r1 rk c
C s� || _ t|�| _|| _d | _| d u ri nt| �| _|
d u r g nt|
�| _d| _ d| _
| | _ |d u rLt ||||�\}}| �
|� || _t|t�rK| �� n|| _d| _d S )NFr )r+ r+ ri �_request� next_requestr� r� rn r) � is_closed�is_stream_consumedr* r
r� r� r? r r� �_num_bytes_downloaded) rp r+ ri r� r& r' r� r� r( r� r) r* r7 r7 r8 rs s$
�
zResponse.__init__r� r� c C s< |� � D ]\}}|�� dkrd| jv rq| j�||� qd S )Nr� zcontent-length)r` rd ri r� )rp r� r: rB r7 r7 r8 r� ; s
�zResponse._prepare�datetime.timedeltac C s t | d�s td��| jS )ze
Returns the time taken for the complete request/response
cycle to complete.
�_elapsedzK'.elapsed' may only be accessed after the response has been read or closed.)r � RuntimeErrorr7 r� r7 r7 r8 �elapsedB s
�zResponse.elapsedr9 c C rx rl )r7 )rp r9 r7 r7 r8 r9 O rz r, c C s | j du r td��| j S )zR
Returns the request instance associated to the current response.
Nz7The request instance has not been set on this response.)r1 r8 r� r7 r7 r8 r( S s
�zResponse.requestrB c C rx rl )r1 ry r7 r7 r8 r( ^ rz r0 c C s2 z| j d }W n
ty Y dS w |jddd�S )N� http_versionzHTTP/1.1r> �ignore��errors)r� r� rv )rp r: r7 r7 r8 r: b s �zResponse.http_versionc C s< z| j d }W n ty t�| j� Y S w |jddd�S )N�
reason_phraser> r; r< )r� r� r �get_reason_phraser+ rv )rp r> r7 r7 r8 r> k s �zResponse.reason_phraser' c C s | j jS )zA
Returns the URL for which the request was made.
)r( rR r� r7 r7 r8 rR t s z Response.urlr= c C r r )r r r r� r7 r7 r8 r� { r zResponse.contentc C sR t | d�s&| j}|sd| _| jS t| jpdd�}d�|�| j�|�� g�| _| jS )N�_textrQ rt r6 )r r� r@ r r/ r� rv �flush)rp r� �decoderr7 r7 r8 r& � s
� z
Response.textc C sZ t | d�s*| j}|du st|�s%t| jt�r| j}n t | d�r%| �| j�}|p(d| _| jS )a�
Return an encoding to use for decoding the byte content into text.
The priority for determining this is given by...
* `.encoding = <>` has been set explicitly.
* The encoding as specified by the charset parameter in the Content-Type header.
* The encoding as determined by `default_encoding`, which may either be
a string like "utf-8" indicating the encoding to use, or may be a callable
which enables charset autodetection.
ro Nr rt )r �charset_encodingr9 r? r* r0 r ro )rp r/ r7 r7 r8 r/ � s
zResponse.encodingc C s t | d�r td��|| _dS )z�
Set the encoding to use for decoding the byte content into text.
If the `text` attribute has been accessed, attempting to set the
encoding will throw a ValueError.
r@ z?Setting encoding after `text` has been accessed is not allowed.N)r rW ro ry r7 r7 r8 r/ � s
�
c C s | j �d�}|du r dS t|�S )zO
Return the encoding, as specified by the Content-Type header.
z Content-TypeN)ri r� rN )rp rF r7 r7 r8 rC � s zResponse.charset_encodingr
c C s� t | d�sPg }| jjddd�}|D ] }|�� �� }z t| }|�|� � W q ty. Y qw t|�dkr=|d | _ | j S t|�dkrLt
|d�| _ | j S t � | _ | j S )z�
Returns a decoder instance which can be used to decode the raw byte
content, depending on the Content-Encoding used in the response.
�_decoderzcontent-encodingT)r� r r )�children) r ri r� rT rd r rX r� r� rD r r )rp �decodersr� rB � decoder_clsr7 r7 r8 �_get_content_decoder� s&
�
� �z Response._get_content_decoderr2 c C � t �| j�S )zU
A property which is `True` for 1xx status codes, `False` otherwise.
)r �is_informationalr+ r� r7 r7 r8 rJ � � zResponse.is_informationalc C rI )zU
A property which is `True` for 2xx status codes, `False` otherwise.
)r �
is_successr+ r� r7 r7 r8 rL � rK zResponse.is_successc C rI )a
A property which is `True` for 3xx status codes, `False` otherwise.
Note that not all responses with a 3xx status code indicate a URL redirect.
Use `response.has_redirect_location` to determine responses with a properly
formed URL redirection.
)r � is_redirectr+ r� r7 r7 r8 rM � s
zResponse.is_redirectc C rI )zU
A property which is `True` for 4xx status codes, `False` otherwise.
)r �is_client_errorr+ r� r7 r7 r8 rN � rK zResponse.is_client_errorc C rI )zU
A property which is `True` for 5xx status codes, `False` otherwise.
)r �is_server_errorr+ r� r7 r7 r8 rO � rK zResponse.is_server_errorc C rI )z]
A property which is `True` for 4xx and 5xx status codes, `False` otherwise.
)r �is_errorr+ r� r7 r7 r8 rP � rK zResponse.is_errorc C s( | j tjtjtjtjtjfv od| jv S )zs
Returns True for 3xx responses with a properly formed URL redirection,
`False` otherwise.
�Location)r+ r �MOVED_PERMANENTLY�FOUND� SEE_OTHER�TEMPORARY_REDIRECT�PERMANENT_REDIRECTri r� r7 r7 r8 �has_redirect_location s ��
�z Response.has_redirect_locationc C sp | j }|du r td��| jr| S | jrd}nd}| jd }dddd d
�}|�|d �}|j| |d �}t||| d
��)z>
Raise the `HTTPStatusError` if one occurred.
NzYCannot call `raise_for_status` as the request instance has not been set on this response.z�{error_type} '{0.status_code} {0.reason_phrase}' for url '{0.url}'
Redirect location: '{0.headers[location]}'
For more information check: https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/{0.status_code}z�{error_type} '{0.status_code} {0.reason_phrase}' for url '{0.url}'
For more information check: https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/{0.status_code}�d zInformational responsezRedirect responsez Client errorz Server error)r � � � zInvalid status code)�
error_type)r( �response)r1 r8 rL rW r+ r� �formatr )rp r( rJ � status_class� error_typesr\ r7 r7 r8 �raise_for_status s* ���
� zResponse.raise_for_status�kwargsc K s t j| jfi |��S rl )�jsonlib�loadsr� )rp rb r7 r7 r8 r� ? s z
Response.jsonr* c C s$ t | d�st� | _| j�| � | jS )N�_cookies)r r* re �extract_cookiesr� r7 r7 r8 r� B s
zResponse.cookies� dict[str | None, dict[str, str]]c C s* | j �d�}|du r i S dd� t|�D �S )zI
Returns the parsed header links of the response, if any
r] Nc S s" i | ]
}|� d �p
|� d�|�qS )�relrR )r� )r} r] r7 r7 r8 r� R s ��z"Response.links.<locals>.<dictcomp>)ri r� r_ )rp �headerr7 r7 r8 rY I s �zResponse.linksc C s | j S rl )r5 r� r7 r7 r8 �num_bytes_downloadedW s z Response.num_bytes_downloadedc C s d| j � d| j� d�S )Nz <Response [� �]>)r+ r> r� r7 r7 r8 r� [ s zResponse.__repr__r c C r )Nc S r ))r� r� r3 rD r7 r r7 r7 r8 r� _ r z)Response.__getstate__.<locals>.<dictcomp>r r� r7 r7 r8 r ^ r zResponse.__getstate__r c C s6 |� � D ]
\}}t| ||� qd| _i | _t� | _d S )NT)r` r r3 r� r r� r r7 r7 r8 r! e s
zResponse.__setstate__c C s t | d�s
d�| �� �| _| jS )�7
Read and return the response content.
r r
)r r� �
iter_bytesr r� r7 r7 r8 r� l s
z
Response.read�
chunk_size�
int | None�typing.Iterator[bytes]c c s� � t | d�r,|du rt| j�n|}tdt| j�t|d��D ] }| j||| � V q dS | �� }t|d�}t| jd��9 | � � D ]}|�
|�}|�
|�D ]}|V qLq@|� � }|�
|�D ]}|V q\|� � D ]}|V qfW d � dS 1 sww Y dS �z�
A byte-iterator over the decoded response content.
This allows us to handle gzip, deflate, brotli, and zstd encoded responses.
r Nr r �ro �r( ) r r� r �range�maxrH r r r1 �iter_rawrv rA �rp ro �irB �chunker� raw_bytes�decoded�chunkr7 r7 r8 rn t s* �
�
� �"�zResponse.iter_bytes�typing.Iterator[str]c c s� � t | jpdd�}t|d�}t| jd��9 | �� D ]}|�|�}|�|�D ]}|V q%q|�� }|�|�D ]}|V q5|�� D ]}|V q?W d � dS 1 sPw Y dS �z�
A str-iterator over the decoded response content
that handles both gzip, deflate, etc but also detects the content's
string encoding.
rt r6 rs rt N)r r/ r r r1 rn rv rA �rp ro rB rz � byte_content� text_contentr} r7 r7 r8 � iter_text� s �
� �"�zResponse.iter_textc c sr � t � }t| jd��% | �� D ]
}|�|�D ]}|V qq|�� D ]}|V q!W d � d S 1 s2w Y d S �Nrt )r r r1 r� rv rA �rp rB r& �liner7 r7 r8 �
iter_lines� s � � �"�zResponse.iter_linesc c s� � | j rt� �| jr
t� �t| jt�std��d| _ d| _t |d�}t
| j d��" | jD ]}| jt |�7 _|�
|�D ]}|V q<q,W d � n1 sMw Y |�� D ]}|V qV| �� dS )�@
A byte-iterator over the raw response content.
z5Attempted to call a sync iterator on an async stream.Tr rs rt N)r4 r r3 r r? r� r& r8 r5 r r r1 r� rv rA �close�rp ro rz �raw_stream_bytesr} r7 r7 r8 rw � s* �
�� � zResponse.iter_rawc C s` t | jt�s
td��| js.d| _t| jd�� | j�� W d � dS 1 s'w Y dS dS )��
Close the response and release the connection.
Automatically called if the response body is read to completion.
z3Attempted to call an sync close on an async stream.Trt N)r? r� r& r8 r3 r r1 r� r� r7 r7 r8 r� � s "��zResponse.closec � s2 �t | d�sd�dd� | �� 2 �I dH �| _| jS )rm r r
c � r
rl r7 r r7 r7 r8 r� � r z"Response.aread.<locals>.<listcomp>N)r r� � aiter_bytesr r� r7 r7 r8 r � s �
zResponse.aread�typing.AsyncIterator[bytes]c C s �t | d�r,|du rt| j�n|}tdt| j�t|d��D ] }| j||| � V q dS | �� }t|d�}t| jd��> | � � 2 z3 dH W }|�
|�}|�
|�D ]}|V qPq@6 |� � }|�
|�D ]}|V qa|� � D ]}|V qkW d � dS 1 s|w Y dS rr ) r r� r ru rv rH r r r1 � aiter_rawrv rA rx r7 r7 r8 r� � s, �
�
�� �"�zResponse.aiter_bytes�typing.AsyncIterator[str]c C s� �t | jpdd�}t|d�}t| jd��> | �� 2 z3 dH W }|�|�}|�|�D ]}|V q)q6 |�� }|�|�D ]}|V q:|�� D ]}|V qDW d � dS 1 sUw Y dS r )r r/ r r r1 r� rv rA r� r7 r7 r8 �
aiter_text� s" �
�� �"�zResponse.aiter_textc C s| �t � }t| jd��* | �� 2 z3 d H W }|�|�D ]}|V qq6 |�� D ]}|V q&W d � d S 1 s7w Y d S r� )r r r1 r� rv rA r� r7 r7 r8 � aiter_lines s ��� �"�zResponse.aiter_linesc C s� �| j rt� �| jr
t� �t| jt�std��d| _ d| _t |d�}t
| j d��' | j2 z3 dH W }| jt |�7 _|�
|�D ]}|V q@q,6 W d � n1 sRw Y |�� D ]}|V q[| �� I dH dS )r� z6Attempted to call an async iterator on an sync stream.Tr rs rt N)r4 r r3 r r? r� r r8 r5 r r r1 r� rv rA �acloser� r7 r7 r8 r�
s* �
�� � zResponse.aiter_rawc � sh �t | jt�s td��| js2d| _t| jd�� | j�� I dH W d � dS 1 s+w Y dS dS )r� z3Attempted to call an async close on an sync stream.Trt N)r? r� r r8 r3 r r1 r� r� r7 r7 r8 r� ) s � "��zResponse.aclose)r+ r� ri rj r� r, r& r< r' r< r� r� r� r� r( r- r� r. r) r/ r* r0 r1 rk r" )r1 r6 )r9 r6 r1 rk )r1 r, )rB r, r1 rk r� )r1 r' r# )r1 r< r� )r1 r
�r1 r2 )r1 r- )rb r� r1 r� )r1 r* )r1 rg r� r$ r% rl )ro rp r1 rq )ro rp r1 r~ �r1 r~ )r1 rk )ro rp r1 r� )ro rp r1 r� )r1 r� ),r� r� r� rs r� r� r9 r� r( r: r> rR r� r& r/ rC rH rJ rL rM rN rO rP rW ra r� r� rY rj r� r r! r� rn r� r� rw r� r r� r� r� r� r� r7 r7 r7 r8 r- s� �
7
%
� �
� r- c @ s� e Zd ZdZd9d:dd�Zd;d d �Zd<dd�Zd=d>dd�Z d?d@d d �Z dAdBd d �Z dAdCd d!�Z
d9d:d"d#�Z dDd$d%�Z dEd&d'�Z
dFd(d)�ZdGd+d,�ZdHd.d/�ZdId1d2�ZdJd3d4�ZG d5d6� d6ejj�ZG d7d8� d8�ZdS )Kr* z-
HTTP Cookies, as a mutable mapping.
Nr� r� r1 rk c C s� |d u s t |t�r%t� | _t |t�r!|�� D ] \}}| �||� qd S d S t |t�r=t� | _|D ]
\}}| �||� q0d S t |t�rTt� | _|jD ]}| j�|� qId S || _d S rl ) r? r� r �jarr` �setrn r* �
set_cookie)rp r� r: rB �cookier7 r7 r8 rs < s$
�
�
�
zCookies.__init__r] r- c C s( | � |�}| �|j�}| j�||� dS )zO
Loads any cookies based on the response `Set-Cookie` headers.
N)�_CookieCompatResponse�_CookieCompatRequestr( r� rf )rp r] �urllib_response�urllib_requestr7 r7 r8 rf M s
zCookies.extract_cookiesr( r, c C s | � |�}| j�|� dS )zM
Sets an appropriate 'Cookie:' HTTP header on the `Request`.
N)r� r� �add_cookie_header)rp r( r� r7 r7 r8 r� V s
zCookies.set_cookie_headerrQ �/r r0 rB �domain�pathc C s� i dd�d|�d|�dd�dd�d |�d
t |��d |�d ��d
|�dt |��dd�dd�dd�dd�dd�dddi�dd�}tdi |��}| j�|� dS )zU
Set a cookie value by name. May optionally include domain and path.
�versionr r rB �portN�port_specifiedFr� �domain_specified�domain_initial_dot�.r� �path_specified�secure�expires�discardT�comment� comment_url�rest�HttpOnly�rfc2109r7 )r2 �
startswithr r� r� )rp r rB r� r� rb r� r7 r7 r8 r� ] sJ �������
� �
� � �
�����z Cookies.setr� r< c C sn d}| j D ])}|j|kr.|du s|j|kr.|du s |j|kr.|dur+d|� �}t|��|j}q|du r5|S |S )z�
Get a cookie by name. May optionally include domain and path
in order to specify exactly which cookie to retrieve.
Nz!Multiple cookies exist with name=)r� r r� r� r rB )rp r r� r� r� rB r� rJ r7 r7 r8 r� w s
�z Cookies.getc s\ � dur�dur| j �� ���S � ��fdd�| j D �}|D ]
}| j �|j|j|j� q dS )z�
Delete a cookie by name. May optionally include domain and path
in order to specify exactly which cookie to delete.
Nc s> g | ]}|j �kr � d u s|j� kr �d u s|j�kr|�qS rl )r r� r� �r} r� �r� r r� r7 r8 r� � s
�z"Cookies.delete.<locals>.<listcomp>)r� �clearr� r� r )rp r r� r� �remover� r7 r� r8 �delete� s
��zCookies.deletec C sD g }|dur |� |� |dur|dusJ �|� |� | jj|� dS )z�
Delete all cookies. Optionally include a domain and path in
order to only delete a subset of all the cookies.
N)rX r� r� )rp r� r� �argsr7 r7 r8 r� � s
z
Cookies.clearc C s$ t |�}|jD ]}| j�|� qd S rl )r* r� r� )rp r� r� r7 r7 r8 r� � s
�zCookies.updatec C s | � ||�S rl )r� �rp r rB r7 r7 r8 r� � r� zCookies.__setitem__c C s | � |�}|d u r
t|��|S rl )r� r� r� r7 r7 r8 r� � s
zCookies.__getitem__c C s
| � |�S rl )r� )rp r r7 r7 r8 r� � r� zCookies.__delitem__r� c C r� rl )r� r� r� r7 r7 r8 r� � r� zCookies.__len__r~ c C r| )Nc s s � | ]}|j V qd S rl )r r� r7 r7 r8 � <genexpr>� s � z#Cookies.__iter__.<locals>.<genexpr>�r� r� r7 r7 r8 r� � s zCookies.__iter__r2 c C s | j D ]} dS dS )NTFr� )rp r r7 r7 r8 �__bool__� s
zCookies.__bool__c C s" d� dd� | jD ��}d|� d�S )Nr� c S s* g | ]}d |j � d|j� d|j� d��qS )z<Cookie rS z for z />)r rB r� r� r7 r7 r8 r� � s ��z$Cookies.__repr__.<locals>.<listcomp>z <Cookies[rl )r� r� )rp � cookies_reprr7 r7 r8 r� � s �� zCookies.__repr__c s0 e Zd ZdZd
� fdd� Zd� fd d � Z� ZS )z Cookies._CookieCompatRequest��
Wraps a `Request` instance up in a compatibility interface suitable
for use with `CookieJar` operations.
r( r, r1 rk c s* t � jt|j�t|j�|jd� || _d S )N)rR ri r� )�superrs r0 rR r� ri r� r( )rp r( �r� r7 r8 rs � s �
z%Cookies._CookieCompatRequest.__init__r: r0 rB c s t � �||� || jj|< d S rl )r� �add_unredirected_headerr( ri )rp r: rB r� r7 r8 r� � s z4Cookies._CookieCompatRequest.add_unredirected_header�r( r, r1 rk r� )r� r� r� r� rs r� �
__classcell__r7 r7 r� r8 r� � s r� c @ s$ e Zd ZdZd dd�Zd
d d
�Zd S )z Cookies._CookieCompatResponser� r] r- r1 rk c C rx rl )r] )rp r] r7 r7 r8 rs � r� z&Cookies._CookieCompatResponse.__init__�email.message.Messagec C s, t j�� }| jj�� D ]\}}|||< q |S rl )rI rJ rK r] ri r� )rp �infor: rB r7 r7 r8 r� � s
z"Cookies._CookieCompatResponse.infoN�r] r- r1 rk )r1 r� )r� r� r� r� rs r� r7 r7 r7 r8 r� � s
r� rl )r� r� r1 rk r� r� )rQ r� )
r r0 rB r0 r� r0 r� r0 r1 rk )NNN)
r r0 r� r< r� r< r� r< r1 r< r� )r r0 r� r< r� r< r1 rk )r� r< r� r< r1 rk )r r0 rB r0 r1 rk )r r0 r1 r0 )r r0 r1 rk r� r� r� r� )r� r� r� r� rs rf r� r� r� r� r� r� r� r� r� r� r� r� r� �urllibr( r, r� r� r7 r7 r7 r8 r* 7 s0
� �
r* )r/ r0 r1 r2 rl )r: r; r/ r< r1 r= )rB r; r/ r< r1 r= )rF r0 r1 r< )rB r0 r1 rO )r` ra r1 rb )J�
__future__r r3 �datetime�
email.messagerI r� rc rU r �urllib.requestr� �collections.abcr �http.cookiejarr r r r r r r
� _decodersr r r
r r r r r � _exceptionsr r r r r r r �
_multipartr �
_status_codesr �_typesr r r r r r! r" r# r$ r% r& �_urlsr' �_utilsr( r) �__all__re r9 rA rE rN r_ rh �MutableMappingr0 r+ r, r- r* r7 r7 r7 r8 �<module> sH ($
4
% t 8