Format: application/x-python-code
1 o
2
3 C'h� � @ sT d dl mZ d dlZd dlZd dlmZ d dlmZm Z m
4 Z
5 m Z m Z m
6 Z
7 d dlmZ ddlmZmZ ddlmZ dd lmZmZmZmZmZmZ dd
8 l m Z m Z d gZ G d d � d ee�Z G d
9 d� de�Z!G dd� de�Z"G dd� dee�Z#d:dd�Z$d;d d �Z%d<d#d$�Z&d=d'd(�Z'd>d*d+�Z(d?d.d/�Z) d@dAd4d5�Z* dBdCd8d9�Z+dS )D� )� annotationsN)�dumps)�Any�
10 AsyncIterable�
11 AsyncIterator�Iterable�Iterator�Mapping)� urlencode� )� StreamClosed�StreamConsumed)�MultipartStream)�AsyncByteStream�RequestContent� RequestData� RequestFiles�ResponseContent�SyncByteStream)�peek_filelike_length�primitive_value_to_str�
12 ByteStreamc @ s* e Zd Zddd�Zddd �Zdd d �Zd
13 S )r �stream�bytes�return�Nonec C s
14 || _ d S �N��_stream��selfr � r! �DC:\Users\shubh\Videos\agent\nova\Lib\site-packages\httpx/_content.py�__init__ s
15 zByteStream.__init__�Iterator[bytes]c c s � | j V d S r r �r r! r! r" �__iter__# � � zByteStream.__iter__�AsyncIterator[bytes]c C s �| j V d S r r r% r! r! r" � __aiter__& r' zByteStream.__aiter__N)r r r r �r r$ �r r( )�__name__�
16 __module__� __qualname__r# r& r) r! r! r! r" r s
17
18 c @ �$ e Zd ZdZd dd�Zd
19 d d
20 �Zd S )�IteratorByteStream� r �Iterable[bytes]r r c C � || _ d| _t�|�| _d S �NF)r �_is_stream_consumed�inspect� isgenerator�
21 _is_generatorr r! r! r" r# - � zIteratorByteStream.__init__r$ c c sn � | j r
22 | jr
23 t� �d| _ t| jd�r,| j�| j�}|r*|V | j�| j�}|s d S d S | jD ]}|V q/d S )NT�read)r5 r8 r
24 �hasattrr r: �
25 CHUNK_SIZE�r �chunk�partr! r! r" r& 2 s � �
26 �zIteratorByteStream.__iter__N)r r2 r r r* )r, r- r. r< r# r& r! r! r! r" r0 * �
27 r0 c @ r/ )�AsyncIteratorByteStreamr1 r �AsyncIterable[bytes]r r c C r3 r4 )r r5 r6 �
28 isasyncgenr8 r r! r! r" r# F r9 z AsyncIteratorByteStream.__init__r( c C s� �| j r
29 | jr
30 t� �d| _ t| jd�r2| j�| j�I d H }|r0|V | j�| j�I d H }|s d S d S | j2 z 3 d H W }|V q56 d S )NT�aread)r5 r8 r
31 r; r rD r< r= r! r! r" r) K s � ��z!AsyncIteratorByteStream.__aiter__N)r rB r r r+ )r, r- r. r< r# r) r! r! r! r" rA C r@ rA c @ s$ e Zd ZdZd
32 dd�Zd dd�Zd S ) �UnattachedStreamz�
33 If a request or response is serialized using pickle, then it is no longer
34 attached to a stream for I/O purposes. Any stream operations should result
35 in `httpx.StreamClosed`.
36 r r$ c C s t � �r �r r% r! r! r" r& c s zUnattachedStream.__iter__r( c C s �t � �r rF r% r! r! r" r) f s �zUnattachedStream.__aiter__Nr* r+ )r, r- r. �__doc__r& r) r! r! r! r" rE \ s
37 rE �content�4str | bytes | Iterable[bytes] | AsyncIterable[bytes]r �7tuple[dict[str, str], SyncByteStream | AsyncByteStream]c C s� t | ttf�r't | t�r| �d�n| }t|�}|r dt|�ini }|t|�fS t | t�rJt | t�sJt| �}|d u r>ddi}ndt|�i}|t | �fS t | t
38 �rYddi}|t | �fS t dt
39 | �����)N�utf-8�Content-LengthzTransfer-Encoding�chunkedz Unexpected type for 'content', )�
40 isinstancer �str�encode�lenr r �dictr r0 r rA � TypeError�type)rH �body�content_length�headersZcontent_length_or_noner! r! r" �encode_contentk s
41
42 rX �datar �!tuple[dict[str, str], ByteStream]c s� g }| � � D ]!\� }t|ttf�r |�� fdd�|D �� q|�� t|�f� qt|dd��d�}t t
43 |��}d}||d�}|t |�fS )Nc s g | ]}� t |�f�qS r! )r )�.0�item��keyr! r" �
44 <listcomp>� s z*encode_urlencoded_data.<locals>.<listcomp>T)�doseqrK z!application/x-www-form-urlencoded�rL z Content-Type) �itemsrN �list�tuple�extend�appendr r
45 rP rO rQ r )rY Z
46 plain_data�valuerU rV � content_typerW r! r] r" �encode_urlencoded_data� s
47 ri �filesr �boundary� bytes | None�&tuple[dict[str, str], MultipartStream]c C s t | ||d�}|�� }||fS )N)rY rj rk )r Z get_headers)rY rj rk � multipartrW r! r! r" �encode_multipart_data� s ro �textrO c C �0 | � d�}tt|��}d}||d�}|t|�fS )NrK ztext/plain; charset=utf-8ra �rP rO rQ r )rp rU rV rh rW r! r! r" � encode_text� �
48
49
50 rs �htmlc C rq )NrK ztext/html; charset=utf-8ra rr )ru rU rV rh rW r! r! r" � encode_html� rt rv �jsonr c C s< t | dddd��d�}tt|��}d}||d�}|t|�fS )NF)�,�:)� ensure_ascii�
51 separators� allow_nanrK zapplication/jsonra )�
52 json_dumpsrP rO rQ r )rw rU rV rh rW r! r! r" � encode_json� s ��
53 r~ �RequestContent | None�RequestData | None�RequestFiles | None�
54 Any | Nonec C sz |durt |t�sd}tj|tdd� t|�S | dur t| �S |r)t|p%i ||�S |r/t|�S |dur7t|�S i t d�fS )z�
55 Handles encoding the given `content`, `data`, `files`, and `json`,
56 returning a two-tuple of (<headers>, <stream>).
57 Nz5Use 'content=<...>' to upload raw bytes/text content.� )�
58 stacklevel� )
59 rN r �warnings�warn�DeprecationWarningrX ro ri r~ r )rH rY rj rw rk �messager! r! r" �encode_request� s r� �ResponseContent | None�
60 str | Nonec C sL | durt | �S |durt|�S |durt|�S |dur t|�S i td�fS )zc
61 Handles encoding the given `content`, returning a two-tuple of
62 (<headers>, <stream>).
63 Nr� )rX rs rv r~ r )rH rp ru rw r! r! r" �encode_response� s
64 r� )rH rI r rJ )rY r r rZ )rY r rj r rk rl r rm )rp rO r rZ )ru rO r rZ )rw r r rZ )NNNNN) rH r rY r� rj r� rw r� rk rl r rJ )NNNN)
65 rH r� rp r� ru r� rw r� r rJ ),�
66 __future__r r6 r� rw r r} �typingr r r r r r � urllib.parser
67 � _exceptionsr r
68 Z
69 _multipartr �_typesr r r r r r �_utilsr r �__all__r r0 rA rE rX ri ro rs rv r~ r� r� r! r! r! r" �<module> s@
70
71
72
73
74
75 �$�