| Server IP : 192.158.238.246 / Your IP : 3.141.38.5 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/ |
Upload File : |
B
�k�a�~ � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
Z
d dl m Z m
Z
mZmZmZmZmZmZmZmZmZmZmZmZ d dlmZm Z m Z d dl m Z m Z m!Z! ddl"m#Z#m$Z$m%Z%m&Z&m'Z' dd l(m)Z)m*Z*m+Z+m,Z, dd
l-m.Z. dd l/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6 dd l7m8Z8 d
Z9e �r>ddl:m;Z; G dd� de<�Z=G dd� de<�Z>ee? eee? ee?e?f f d�dd�Z@d'ee?e?f e?ee? d�dd�ZAG dd� d�ZBG d d � d �ZCe6eCe2jDd �G d d � d e3��ZEG d!d"� d"�ZFee3e?e?f ZGG d#d$� d$e3�ZHG d%d&� d&�ZIdS )(� N)�deque)�
TracebackType)�
TYPE_CHECKING�Any�
AsyncIterator�Deque�Dict�Iterator�List�Mapping�Optional�Sequence�Tuple�Type�Union�cast)� parse_qsl�unquote� urlencode)� CIMultiDict�CIMultiDictProxy� MultiMapping� )�CONTENT_DISPOSITION�CONTENT_ENCODING�CONTENT_LENGTH�CONTENT_TRANSFER_ENCODING� CONTENT_TYPE)�CHAR�TOKEN�parse_mimetype�reify)�
HeadersParser)� JsonPayload� LookupError�Order�Payload�
StringPayload� get_payload� payload_type)� StreamReader)�MultipartReader�MultipartWriter�BodyPartReader�BadContentDispositionHeader�BadContentDispositionParam�parse_content_disposition� content_disposition_filename)�ClientResponsec @ s e Zd ZdS )r. N)�__name__�
__module__� __qualname__� r6 r6 �D/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/multipart.pyr. A s r. c @ s e Zd ZdS )r/ N)r3 r4 r5 r6 r6 r6 r7 r/ E s r/ )�header�returnc s� t td�dd�� t td�dd�}t td�� fdd� }t td�dd �}t td�d
d �}d �ttjt��d
�t t t d�dd�}| s�d i fS | �d�^}}� |�s�t� t
| �� d i fS i }�x�|�r�|� d�} d| kr�t� t
| �� d i fS | �dd�\}
} |
� � �
� }
| �� } |
|k�r,t� t
| �� d i fS � |
��sJt� t| �� q��n\||
��r�|| ��rp|| dd� �} n� | ��s�t� t| �� q��n||
��r
|| ��r�| �dd�\} }
} | �p�d} nt� t| �� q�yt| | d�} W n& tk
�r t� t| �� w�Y nX n�d}|| ��r4d}|| dd� �d ��} nV� | ��rDd}nF|�r�| � d|d � �}||��r�|� d� ||dd� �d ��} d}|�r�t� t
| �� d i fS | ||
< q�W |� � |fS ) N)�stringr9 c S s t | �ott| �kS )N)�boolr �set)r: r6 r6 r7 �is_tokenL s z+parse_content_disposition.<locals>.is_tokenc S s | d | d kodkS S )Nr ����"r6 )r: r6 r6 r7 � is_quotedO s z,parse_content_disposition.<locals>.is_quotedc s � | �o| � d�dkS )N�'� )�count)r: )r= r6 r7 �
is_rfc5987R s z-parse_content_disposition.<locals>.is_rfc5987c S s
| � d�S )N�*)�endswith)r: r6 r6 r7 �is_extended_paramU s z4parse_content_disposition.<locals>.is_extended_paramc S s@ | � d�d }|sdS | �d�r,| |d� n
| |d � }|�� S )NrE r Fr> )�findrF �isdigit)r: �posZ substringr6 r6 r7 �is_continuous_paramX s
"z6parse_content_disposition.<locals>.is_continuous_param� )�chars)�textrM r9 c S s t �d|� d�d| �S )Nz\\([z])z\1)�re�sub)rN rM r6 r6 r7 �unescape_ s z+parse_content_disposition.<locals>.unescape�;r �=r r> rA rB zutf-8�strictTFz\/)�strr; �join�maprO �escaper �split�warnings�warnr. �pop�lower�strip�lstripr/ r �UnicodeDecodeError)r8 r@ rD rG rK rQ Zdisptype�parts�params�item�key�value�encoding�_Zfailed�_valuer6 )r= r7 r0 I sz &
r0 �filename)rb �namer9 c
s� d| � | sd S � | kr | � S || kr0| | S g }t � fdd�| �� D ��}xXt|�D ]L\}\}}|�dd�\}}|�d�r�|d d� }|t|�kr�|�|� qXP qXW |s�d S d�|�}d|kr�|�dd �\} }}| p�d
} t|| d �S |S d S ) Nz%s*c 3 s$ | ] \}}|� � �r||fV qd S )N)�
startswith)�.0rd re )�name_sufr6 r7 � <genexpr>� s z/content_disposition_filename.<locals>.<genexpr>rE r r> rL rA rB zutf-8rT ) �sorted�items� enumeraterY rF rU �appendrV r )
rb rj ra ZfnparamsZnumrd re rg �tailrf r6 )rm r7 r1 � s2
r1 c @ st e Zd ZdZdddd�dd�Zd d�d d
�Zed d�d d
�Zed�dd�Z e
ed d�dd�Z dd�dd�Z dS )�MultipartResponseWrapperzzWrapper around the MultipartReader.
It takes care about
underlying connection and close it when it needs in.
r2 r+ N)�resp�streamr9 c C s || _ || _d S )N)ru rv )�selfru rv r6 r6 r7 �__init__� s z!MultipartResponseWrapper.__init__)r9 c C s | S )Nr6 )rw r6 r6 r7 � __aiter__� s z"MultipartResponseWrapper.__aiter__)r+ r- c � s | � � I d H }|d krt�|S )N)�next�StopAsyncIteration)rw �partr6 r6 r7 � __anext__� s z"MultipartResponseWrapper.__anext__c C s | j j�� S )z2Returns True when all response data had been read.)ru �content�at_eof)rw r6 r6 r7 r � s z MultipartResponseWrapper.at_eofc � s, | j �� I dH }| j �� r(| �� I dH |S )z#Emits next multipart reader object.N)rv rz r �release)rw rc r6 r6 r7 rz � s
z MultipartResponseWrapper.nextc � s | j �� I dH dS )z_Release the connection gracefully.
All remaining content is read to the void.
N)ru r� )rw r6 r6 r7 r� � s z MultipartResponseWrapper.release)
r3 r4 r5 �__doc__rx ry r r} r; r r rz r� r6 r6 r6 r7 rt � s rt c @ s� e Zd ZdZdZededd�dd�Zed d�d d
�Z ed�d d �Z
e e d�d
d�Z dd�e
ed�dd�Zefeed�dd�Zeed�dd�Zeed�dd�Zed�dd �Zdd�d d �Zdd �e e ed �d!d"�Zdd �e e e eeef d �d#d$�Zdd �e e eeeef d �d%d&�Z e
d�d'd(�Z eed)�d*d+�Z eed)�d,d-�Z eed)�d.d/�Z eed0�d1d2�Z!e"e e d�d3d4��Z#e"e e d�d5d6��Z$dS )7r- z&Multipart reader for single body part.i zCIMultiDictProxy[str]N)�boundary�headersr~ r9 c C s` || _ || _|| _d| _| j �td �}|d k r6t|�nd | _d| _t � | _
d | _ d| _ i | _
d S )NFr )r� � _boundary�_content�_at_eof�getr �int�_length� _read_bytesr �_unread� _prev_chunk� _content_eof�_cache)rw r� r� r~ �lengthr6 r6 r7 rx s zBodyPartReader.__init__)r9 c C s | S )Nr6 )rw r6 r6 r7 ry s zBodyPartReader.__aiter__c � s | � � I d H }|d krt�|S )N)rz r{ )rw r| r6 r6 r7 r} s zBodyPartReader.__anext__c � s | � � I d H }|sd S |S )N)�read)rw rc r6 r6 r7 rz s zBodyPartReader.nextF)�decode)r� r9 c � sF | j r
dS t� }x"| j s2|�| �| j�I dH � qW |rB| �|�S |S )z�Reads body part data.
decode: Decodes data following by encoding
method from Content-Encoding header. If it missed
data remains untouched
� N)r� � bytearray�extend�
read_chunk�
chunk_sizer� )rw r� �datar6 r6 r7 r� s
zBodyPartReader.read)�sizer9 c � s� | j r
dS | jr"| �|�I dH }n| �|�I dH }| jt|�7 _| j| jkrVd| _ | j r|| j�� I dH }d|ks|td��|S )zWReads body part content chunk of the specified size.
size: chunk size
r� NTs
z3reader did not read all the data or it is malformed) r� r� �_read_chunk_from_length�_read_chunk_from_streamr� �lenr� �readline�AssertionError)rw r� �chunkZclrfr6 r6 r7 r� 0 s
zBodyPartReader.read_chunkc � s: | j d k std��t|| j | j �}| j�|�I d H }|S )Nz(Content-Length required for chunked read)r� r� �minr� r� r� )rw r� r� r� r6 r6 r7 r� F s z&BodyPartReader._read_chunk_from_lengthc � sR |t | j�d kstd��| jd k}|r<| j�|�I d H | _| j�|�I d H }| jt| j�� �7 _| jdk sxtd��| jd k s�t�| j| }d| j }|r�|� |�}n |� |t
dt | j�t |� ��}|dk�rBt � � �( t j
dtd� | j�||d � � W d Q R X ||k�r$| jd |� | _|t | j�|� }|�sBd | _| j}|| _|S )
NrB z<Chunk size must be greater or equal than boundary length + 2� zReading after EOFs
r �ignore)�categoryT)r� r� r� r� r� r� r� r� r rH �maxrZ �catch_warnings�filterwarnings�DeprecationWarningZ unread_datar� )rw r� Z first_chunkr� ZwindowrP �idx�resultr6 r6 r7 r� N s4
z&BodyPartReader._read_chunk_from_streamc � s� | j r
dS | jr | j�� }n| j�� I dH }|�| j�rz|�d�}| j}| jd }||ksb||kr�d| _ | j�|� dS n4| j�� I dH }|�| j�r�|dd� }| j�|� |S )z Reads body part by line by line.r� Ns
s --T���) r� r� �popleftr� r� rk r� �rstriprr )rw �lineZsliner� Z
last_boundary� next_liner6 r6 r7 r� p s$
zBodyPartReader.readlinec � s, | j r
dS x | j s&| �| j�I dH q W dS )z0Like read(), but reads all the data to the void.N)r� r� r� )rw r6 r6 r7 r� � s zBodyPartReader.release)rf )rf r9 c � s, | j dd�I dH }|p | jdd�}|�|�S )z;Like read(), but assumes that body part contains text data.T)r� Nzutf-8)�default)r� � get_charsetr� )rw rf r� r6 r6 r7 rN � s zBodyPartReader.textc � sH | j dd�I dH }|sdS |p(| jdd�}ttttf t�|�|���S )z<Like read(), but assumes that body parts contains JSON data.T)r� Nzutf-8)r� ) r� r� r r rU r �json�loadsr� )rw rf r� r6 r6 r7 r� � s
zBodyPartReader.jsonc � sL | j dd�I dH }|sg S |dk r(|}n | jdd�}t|�� �|�d|d�S )zFLike read(), but assumes that body parts contain form urlencoded data.T)r� Nzutf-8)r� )Zkeep_blank_valuesrf )r� r� r r� r� )rw rf r� Z
real_encodingr6 r6 r7 �form� s zBodyPartReader.formc C s | j S )z<Returns True if the boundary was reached or False otherwise.)r� )rw r6 r6 r7 r � s zBodyPartReader.at_eof)r� r9 c C s, t | jkr| �|�}t| jkr(| �|�S |S )z�Decodes data.
Decoding is done according the specified Content-Encoding
or Content-Transfer-Encoding headers value.
)r r� �_decode_content_transferr �_decode_content)rw r� r6 r6 r7 r� � s
zBodyPartReader.decodec C sb | j �td��� }|dkr*t�|tj �S |dkrDt�|dtj �S |dkrP|S td|� ���d S )NrL �deflate�gzip� �identityzunknown content encoding: )r� r� r r] �zlibZ
decompress� MAX_WBITS� RuntimeError)rw r� rf r6 r6 r7 r� � s z BodyPartReader._decode_contentc C sT | j �td��� }|dkr$t�|�S |dkr6t�|�S |dkrB|S td� |���d S )NrL �base64zquoted-printable)�binaryZ8bitZ7bitz%unknown content transfer encoding: {})
r� r� r r] r� Z b64decode�binasciiZa2b_qpr� �format)rw r� rf r6 r6 r7 r� � s
z'BodyPartReader._decode_content_transfer)r� r9 c C s$ | j �td�}t|�}|j�d|�S )z>Returns charset parameter from Content-Type header or default.rL �charset)r� r� r r �
parameters)rw r� �ctype�mimetyper6 r6 r7 r� � s zBodyPartReader.get_charsetc C s t | j�t��\}}t|d�S )z|Returns name specified in Content-Disposition header.
If the header is missing or malformed, returns None.
rj )r0 r� r� r r1 )rw rg rb r6 r6 r7 rj � s zBodyPartReader.namec C s t | j�t��\}}t|d�S )zReturns filename specified in Content-Disposition header.
Returns None if the header is missing or malformed.
ri )r0 r� r� r r1 )rw rg rb r6 r6 r7 ri � s zBodyPartReader.filename)%r3 r4 r5 r� r� �bytesr* rx r ry r} r rz r; r� r� r� r� r� r� r� rU rN r r r� r
r r� r r� r� r� r� r! rj ri r6 r6 r6 r7 r- � s2 " && r- )�orderc s8 e Zd Zeeedd�� fdd� Zedd�dd�Z� ZS )�BodyPartReaderPayloadN)re �args�kwargsr9 c sT t � j|f|�|� i }|jd k r,|j|d< |jd k r@|j|d< |rP| jd|� d S )Nrj ri �
attachmentT)r� T)�superrx rj ri Zset_content_disposition)rw re r� r� rb )� __class__r6 r7 rx � s
z BodyPartReaderPayload.__init__)�writerr9 c � sN | j }|jdd�I d H }x0|rH|�|�|��I d H |jdd�I d H }qW d S )Ni )r� )rh r� �writer� )rw r� Zfieldr� r6 r6 r7 r� s
zBodyPartReaderPayload.write)r3 r4 r5 r- r rx r� �
__classcell__r6 r6 )r� r7 r� � s r� c @ s. e Zd ZdZeZdZeZe e
e
f e dd�dd�Z e
d d�dd �Zeed ef d�d
d �Zed ed
�dd��Zed�dd�Zeed ef d�dd�Zdd�dd�Zed ef d�dd�Zded ef d�dd�Ze
d�d d �Zed�d d �Z dd�d d!�Z dd�d"d#�Z dd�d$d%�Z dd�d&d'�Z dS )(r+ zMultipart body reader.N)r� r~ r9 c C s: || _ d| �� �� | _|| _d | _d| _d| _g | _d S )Nz--FT) r� �
_get_boundary�encoder� r� �
_last_partr� �_at_bofr� )rw r� r~ r6 r6 r7 rx s zMultipartReader.__init__r- )r9 c C s | S )Nr6 )rw r6 r6 r7 ry " s zMultipartReader.__aiter__c � s | � � I d H }|d krt�|S )N)rz r{ )rw r| r6 r6 r7 r} ' s zMultipartReader.__anext__r2 )�responser9 c C s | � || |j|j��}|S )z�Constructs reader instance from HTTP response.
:param response: :class:`~aiohttp.client.ClientResponse` instance
)�response_wrapper_clsr� r~ )�clsr� �objr6 r6 r7 �
from_response/ s z MultipartReader.from_responsec C s | j S )z@Returns True if the final boundary was reached, false otherwise.)r� )rw r6 r6 r7 r = s zMultipartReader.at_eofc � sb | j r
dS | �� I dH | jr4| �� I dH d| _n| �� I dH | j rLdS | �� I dH | _| jS )z#Emits the next multipart body part.NF)r� �_maybe_release_last_partr� �_read_until_first_boundary�_read_boundary�fetch_next_partr� )rw r6 r6 r7 rz A s zMultipartReader.nextc � s6 x0| j s0| �� I dH }|dkr P |�� I dH qW dS )z=Reads all the body parts to the void till the final boundary.N)r� rz r� )rw rc r6 r6 r7 r� S s
zMultipartReader.releasec � s | � � I dH }| �|�S )z"Returns the next body part reader.N)�
_read_headers�_get_part_reader)rw r� r6 r6 r7 r� [ s z MultipartReader.fetch_next_partzCIMultiDictProxy[str])r� r9 c C s\ |� td�}t|�}|jdkrF| jdkr8t| �|| j�S | �|| j�S | �| j|| j�S dS )z�Dispatches the response by the `Content-Type` header.
Returns a suitable reader instance.
:param dict headers: Response headers
rL � multipartN)r� r r �type�multipart_reader_clsr� �part_reader_clsr� )rw r� r� r� r6 r6 r7 r� b s
z MultipartReader._get_part_readerc C sb t | jt �}|jdks td��d|jkr<td| jt ��|jd }t|�dkr^td| ��|S )Nr� z!multipart/* content type expectedr� z$boundary missed for Content-Type: %s�F z&boundary %r is too long (70 chars max))r r� r r� r� r� �
ValueErrorr� )rw r� r� r6 r6 r7 r� v s
z MultipartReader._get_boundaryc � s | j r| j �� S | j�� I d H S )N)r� r\ r� r� )rw r6 r6 r7 � _readline� s
zMultipartReader._readlinec � s\ xV| � � I d H }|dkr&td| j ��|�� }|| jkr<d S || jd krd| _d S qW d S )Nr� z#Could not find starting boundary %rs --T)r� r� r� r� r� )rw r� r6 r6 r7 r� � s
z*MultipartReader._read_until_first_boundaryc � s� | � � I d H �� }|| jkr nv|| jd kr~d| _| � � I d H }| � � I d H }|d d� dkrl| j�|� q�| j�||g� ntd|�d| j����d S )Ns --TrB zInvalid boundary z , expected )r� r� r� r� r� rr r� r� )rw r� Zepiloguer� r6 r6 r7 r� � s
z MultipartReader._read_boundaryc � sL dg}x,| j �� I d H }|�� }|�|� |sP qW t� }|�|�\}}|S )Nr� )r� r� r^ rr r" Z
parse_headers)rw �linesr� �parserr� Z raw_headersr6 r6 r7 r� � s
z MultipartReader._read_headersc � s> | j dk r:| j �� s$| j �� I dH | j�| j j� d| _ dS )z8Ensures that the last read body part is read completely.N)r� r r� r� r� )rw r6 r6 r7 r� � s
z(MultipartReader._maybe_release_last_part)!r3 r4 r5 r� rt r� r� r- r� r rU r* rx r ry r r r} � classmethodr� r; r rz r� r� r� r� r� r� r� r� r� r� r6 r6 r6 r7 r+ s,
r+ c sr e Zd ZdZd)eee dd�� fdd�
Zd d�dd �Zeee ee ee
dd
�d d �Z e e
d�d
d�Zed�dd�Zed�dd�Ze�d�Ze�d�Zeed�dd��Zeed�dd��Zd*eeee e d�dd�Z e e d �d d �Z d+eeee e d�d d �Z d,e e!e"eef e#eef f eee e d�d!d"�Z$eee d�d#d$��Z%d-eedd&�d'd(�Z&� Z'S ).r, zMultipart body writer.�mixedN)�subtyper� r9 c sr |d k r |nt �� j}y|�d�| _W n tk
rD td�d �Y nX d|� d| j� �}t� j d |d� g | _
d S )N�asciiz(boundary should contain ASCII only charsz
multipart/z ; boundary=)� content_type) �uuidZuuid4�hexr� r� �UnicodeEncodeErrorr� �_boundary_valuer� rx �_parts)rw r� r� r� )r� r6 r7 rx � s zMultipartWriter.__init__)r9 c C s | S )Nr6 )rw r6 r6 r7 � __enter__� s zMultipartWriter.__enter__)�exc_type�exc_val�exc_tbr9 c C s d S )Nr6 )rw r� r� r� r6 r6 r7 �__exit__� s zMultipartWriter.__exit__c C s
t | j�S )N)�iterr� )rw r6 r6 r7 �__iter__� s zMultipartWriter.__iter__c C s
t | j�S )N)r� r� )rw r6 r6 r7 �__len__� s zMultipartWriter.__len__c C s dS )NTr6 )rw r6 r6 r7 �__bool__� s zMultipartWriter.__bool__s \A[!#$%&'*+\-.^_`|~\w]+\Zs [\x00-\x08\x0A-\x1F\x7F]c C s^ | j }t�| j|�r |�d�S t�| j|�r4td��|�dd�}|�dd�}d|�d� d S )zyWrap boundary parameter value in quotes, if necessary.
Reads self.boundary and returns a unicode sting.
r� z*boundary value contains invalid characters� \s \\� "s \"r? ) r� rO �match�_valid_tchar_regexr� �search�_invalid_qdtext_char_regexr� �replace)rw re Zquoted_value_contentr6 r6 r7 r� � s
z MultipartWriter._boundary_valuec C s | j �d�S )Nr� )r� r� )rw r6 r6 r7 r� s zMultipartWriter.boundary)r� r� r9 c C sn |d krt � }t|t�r.|j�|� | �|�S yt||d�}W n tk
r^ td| ��Y n X | �|�S d S )N)r� z Cannot create payload from %r) r �
isinstancer& r� �update�append_payloadr( r$ � TypeError)rw r� r� �payloadr6 r6 r7 rr s
zMultipartWriter.append)r r9 c C s� |j �td��� }|r,|dkr,td|� ���|dkr8d}|j �td��� }|dkr`td�|���|dkrld}|j}|dk r�|s�|s�t|�|j t < | j
� |||f� |S ) z)Adds a new body part to multipart writer.rL )r� r� r� zunknown content encoding: r� N)rL r� zquoted-printabler� z%unknown content transfer encoding: {}r� ) r� r� r r] r� r r� r� rU r r� rr )rw r rf � te_encodingr� r6 r6 r7 r & s(
z MultipartWriter.append_payloadc C s |dkrt � }| �t||d��S )zHelper to append JSON part.N)r� )r r r# )rw r� r� r6 r6 r7 � append_jsonF s zMultipartWriter.append_jsonc C sV t |ttf�st�|dkr t� }t |t�r6t|�� �}t|dd�}| �t ||dd��S )z&Helper to append form urlencoded part.NT)Zdoseqz!application/x-www-form-urlencoded)r� r� )
r r
r r� r �listrp r r r' )rw r� r� r� r6 r6 r7 � append_formO s
zMultipartWriter.append_formc C sx d}xX| j D ]N\}}}|s(|s(|jdkr,dS |tdt| j� d |j t|j� d �7 }q W |dt| j� d 7 }|S )zSize of the payload.r NrB � )r� r� r� r� r� �_binary_headers)rw Ztotalr| rf r r6 r6 r7 r� d s .zMultipartWriter.sizeT)r� �close_boundaryr9 c � s� x�| j D ]�\}}}|�d| j d �I dH |�|j�I dH |sF|r�t|�}|r\|�|� |rj|�|� |�|�I dH |�� I dH n|�|�I dH |�d�I dH qW |r�|�d| j d �I dH dS )z Write body.s --s
Ns --
)r� r� r� r �MultipartPayloadWriter�enable_compression�enable_encoding� write_eof)rw r� r r| rf r �wr6 r6 r7 r� x s
zMultipartWriter.write)r� N)N)N)N)T)(r3 r4 r5 r� rU r rx r� r �
BaseExceptionr r� r �_Partr� r� r� r; r� rO �compiler� r� �propertyr� r� r r r& rr r r r r
r r r r� r� r� r6 r6 )r� r7 r, � s2
!
*r, c @ sd e Zd Zedd�dd�Zedd�dd�Zdejfee dd �d
d �Z
dd �d
d�Z e dd�dd�Z
dS )r
N)r� r9 c C s || _ d | _d | _d | _d S )N)�_writer� _encoding� _compress�_encoding_buffer)rw r� r6 r6 r7 rx � s z MultipartPayloadWriter.__init__)rf r9 c C s* |dkr|| _ t� | _n|dkr&d| _ d S )Nr� zquoted-printable)r r� r )rw rf r6 r6 r7 r � s
z&MultipartPayloadWriter.enable_encodingr� )rf �strategyr9 c C s. |dkrdt j nt j }t j||d�| _d S )Nr� r� )Zwbitsr )r� r� Z compressobjr )rw rf r Z zlib_moder6 r6 r7 r � s z)MultipartPayloadWriter.enable_compression)r9 c � s\ | j d k r.| j �� }|r.d | _ | �|�I d H | jdkrX| jrX| j�t�| j��I d H d S )Nr� )r �flushr� r r r r� � b64encode)rw r� r6 r6 r7 r � s
z MultipartPayloadWriter.write_eof)r� r9 c � s� | j d k r"|r"| j �|�}|s"d S | jdkr�| j}|d k s>t�|�|� |r�tt|�d�\}}|d |d � ||d d � }| _|r�t� |�}| j
� |�I d H n6| jdkr�| j
� t �
|��I d H n| j
� |�I d H d S )Nr� r� zquoted-printable)r �compressr r r� r� �divmodr� r� r r r� r� Zb2a_qp)rw r� ZbufZdiv�modZ enc_chunkZb64chunkr6 r6 r7 r� � s$
$
z MultipartPayloadWriter.write)r3 r4 r5 r rx rU r r� ZZ_DEFAULT_STRATEGYr� r r r� r� r6 r6 r6 r7 r
� s r
)ri )Jr� r� r� rO r� rZ r� � collectionsr �typesr �typingr r r r r r r
r r r
r r r r Z urllib.parser r r Z multidictr r r Zhdrsr r r r r Zhelpersr r r r! Zhttpr" r r# r$ r% r& r' r( r) Zstreamsr* �__all__Z
client_reqrepr2 �RuntimeWarningr. r/ rU r0 r1 rt r- Z try_firstr� r+ r r, r
r6 r6 r6 r7 �<module> sH @ $
"b / { : H