
    ei5                     b   d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl	m
Z
mZ d dlmZ d dlmZmZmZmZmZmZmZmZmZmZmZmZ d dlmZmZmZ d dlm Z m!Z! dd	l"m#Z# dd
l$m%Z%m&Z&m'Z' ddl(m)Z)m*Z*m+Z+m,Z,m-Z- ddl.m/Z/m0Z0m1Z1m2Z2 ddl3m4Z4 ddl5m6Z6 ddl7m8Z8 ddl9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ ddlAmBZB ejC        dk    rd dlmDZD nd dlmEZE  eEdd          ZDdZFerddlGmHZH  G d deI          ZJ G d deI          ZKdeeL         deeeL         eeLeLf         f         fd ZM	 d1d"e
eLeLf         d#eLdeeL         fd$ZN G d% d&          ZO G d' d          ZP e@ePe<jQ        (           G d) d*e=                      ZR G d+ d,          ZSee=eLeLf         ZT G d- d.e=          ZU G d/ d0          ZVdS )2    N)deque)MappingSequence)TracebackType)TYPE_CHECKINGAnyAsyncIteratorDequeDictIteratorListOptionalTupleTypeUnioncast)	parse_qslunquote	urlencode)CIMultiDictCIMultiDictProxy   )AbstractStreamWriter)DEFAULT_MAX_DECOMPRESS_SIZEZLibCompressorZLibDecompressor)CONTENT_DISPOSITIONCONTENT_ENCODINGCONTENT_LENGTHCONTENT_TRANSFER_ENCODINGCONTENT_TYPE)CHARTOKENparse_mimetypereify)HeadersParser)BadHttpMessage)internal_logger)JsonPayloadLookupErrorOrderPayloadStringPayloadget_payloadpayload_type)StreamReader)      )Self)TypeVarr3   BodyPartReader)bound)MultipartReaderMultipartWriterr5   BadContentDispositionHeaderBadContentDispositionParamparse_content_dispositioncontent_disposition_filename)ClientResponsec                       e Zd ZdS )r9   N__name__
__module____qualname__     O/var/www/html/volatility/venv/lib/python3.11/site-packages/aiohttp/multipart.pyr9   r9   O           DrD   r9   c                       e Zd ZdS )r:   Nr?   rC   rD   rE   r:   r:   S   rF   rD   r:   headerreturnc                    dt           dt          fddt           dt          fd}dt           dt          ffd}dt           dt          fd}dt           dt          fd}d                    t          t          j        t                              d	d
t           dt           dt           fd}| sd i fS |                     d          ^}} |          s%t          j	        t          |                      d i fS i }|r|                    d          }	|	s"t          j	        t          |                      <d|	vr%t          j	        t          |                      d i fS |	                    dd          \  }
}|
                                                                }
|                                }|
|v r%t          j	        t          |                      d i fS  |
          s#t          j	        t          |	                      ||
          rP ||          r ||dd                   }n |          s#t          j	        t          |	                     hn_ ||
          r ||          r|                    dd          \  }}}|pd}n#t          j	        t          |	                     	 t!          ||d          }n# t"          $ r% t          j	        t          |	                     Y w xY wd} ||          r)d} ||dd                             d                    }ne |          rd}nW|rU| d|d          } ||          r=|                    d            ||dd                             d                    }d}|r%t          j	        t          |                      d i fS |||
<   ||                                |fS )NstringrI   c                 P    t          |           ot          t          |           k    S N)boolr#   setrK   s    rE   is_tokenz+parse_content_disposition.<locals>.is_tokenZ   s    F||4V 44rD   c                 :    | d         | d         cxk    odk    nc S )Nr   "rC   rP   s    rE   	is_quotedz,parse_content_disposition.<locals>.is_quoted]   s,    ayF2J----#-----rD   c                 L     |           o|                      d          dk    S )N'   )count)rK   rQ   s    rE   
is_rfc5987z-parse_content_disposition.<locals>.is_rfc5987`   s)    x:FLL$5$5$::rD   c                 ,    |                      d          S )N*)endswithrP   s    rE   is_extended_paramz4parse_content_disposition.<locals>.is_extended_paramc   s    s###rD   c                     |                      d          dz   }|sdS |                     d          r
| |d         n	| |d          }|                                S )Nr\   r   FrS   )findr]   isdigit)rK   pos	substrings      rE   is_continuous_paramz6parse_content_disposition.<locals>.is_continuous_paramf   sa    kk#" 	5&,ooc&:&:LF3r6NNstt	  """rD    )charstextrf   c                6    t          j        d| dd|           S )Nz\\([z])z\1)resub)rg   rf   s     rE   unescapez+parse_content_disposition.<locals>.unescapem   s"    v(u(((%666rD   ;r   =r   rS   rW   rX   utf-8strictTFz\/)strrN   joinmapri   escaper"   splitwarningswarnr9   poplowerstriplstripr:   r   UnicodeDecodeError)rH   rU   rZ   r^   rd   rk   disptypepartsparamsitemkeyvalueencoding_failed_valuerQ   s                   @rE   r;   r;   W   s   5 5 5 5 5 5.# .$ . . . .;3 ;4 ; ; ; ; ; ;$# $$ $ $ $ $#C #D # # # # -/GGC	44H4H,I,I 7 7 7s 7c 7c 7 7 7 7  Rx||C((Hu8H 1&99:::RxF
 @yy|| 	M5f==>>>d??M5f==>>>8OZZQ''
Uiikk!!&==M5f==>>>8Ox}} +	 M4T::;;;  %% '	 y  qt--Xe__ 8>>??? s##  	 z%   %*[[a%8%8"!U#.w8>>???x::%   8>>???
 Fy # qt!3!3E!:!:;;% 	# # "..E!H..9V$$ #IIaLLL$HVAbD\%8%8%?%?@@E"F  9&AABBBRxsA  @D >>V##s   <K +K=<K=filenamer~   namec                 2  
 d|z  
| sd S 
| v r| 
         S || v r| |         S g }t          
fd|                                 D                       }t          |          D ]i\  }\  }}|                    dd          \  }}|                    d          r
|d d         }|t          |          k    r|                    |           i |sd S d                    |          }d|v r/|                    dd          \  }	}}|	pd	}	t          ||	d
          S |S )Nz%s*c              3   P   K   | ] \  }}|                               ||fV  !d S rM   )
startswith).0r   r   name_sufs      rE   	<genexpr>z/content_disposition_filename.<locals>.<genexpr>   sP       
 
'S%S^^H=U=U
%L
 
 
 
 
 
rD   r\   r   rS   re   rW   rX   rn   ro   )	sorteditems	enumeratert   r]   rp   appendrq   r   )r~   r   r}   fnparamsnumr   r   r   tailr   r   s             @rE   r<   r<      si    t|H t	V		h	d| 
 
 
 
+1<<>>
 
 
 
 
 "+8!4!4 	 	C#uiiQ''GAt}}S!! !CRCys3xxU#### 	4%<<!&S!!4!4Ha*7H5(H555rD   c                   ~    e Zd ZdZ	 	 	 	 	 	 ddZdd	Zded
         fdZdefdZ	de
ed
                  fdZddZdS )MultipartResponseWrapperzzWrapper around the MultipartReader.

    It takes care about
    underlying connection and close it when it needs in.
    respr=   streamr7   rI   Nc                 "    || _         || _        d S rM   )r   r   )selfr   r   s      rE   __init__z!MultipartResponseWrapper.__init__   s    
 	rD   c                     | S rM   rC   r   s    rE   	__aiter__z"MultipartResponseWrapper.__aiter__       rD   )r7   r5   c                 P   K   |                                   d {V }|t          |S rM   nextStopAsyncIterationr   parts     rE   	__anext__z"MultipartResponseWrapper.__anext__   7       YY[[      <$$rD   c                 >    | j         j                                        S )z2Returns True when all response data had been read.)r   contentat_eofr   s    rE   r   zMultipartResponseWrapper.at_eof   s    y '')))rD   c                    K   | j                                          d{V }| j                                         r|                                  d{V  |S )z#Emits next multipart reader object.N)r   r   r   releaser   r   s     rE   r   zMultipartResponseWrapper.next   sh       [%%''''''''; 	!,,..       rD   c                 H   K   | j                                          d{V  dS )z_Release the connection gracefully.

        All remaining content is read to the void.
        N)r   r   r   s    rE   r   z MultipartResponseWrapper.release  s4      
 i!!!!!!!!!!!rD   )r   r=   r   r7   rI   N)rI   r   rI   N)r@   rA   rB   __doc__r   r   r   r   rN   r   r   r   r   rC   rD   rE   r   r      s          " 
	      	2	3   * * * * *	%;<	=   " " " " " "rD   r   c                   p   e Zd ZdZdZddeddeddd	ed
ede	e         de
ddfdZdedefdZdefdZde	e         fdZdddedefdZefde
defdZde
defdZde
defdZdefdZd/dZddde	e         defdZddde	e         de	eeef                  fd Zddde	e         deeeef                  fd!Zdefd"Zd#edefd$Zdefd%Z d#edefd&Z!d#ede"e         fd'Z#d#edefd(Z$d#ede"e         fd)Z%d#edefd*Z&d+edefd,Z'e(de	e         fd-            Z)e(de	e         fd.            Z*dS )0r5   z&Multipart reader for single body part.i    mixedN)subtypedefault_charsetmax_decompress_sizeboundaryheadersCIMultiDictProxy[str]r   r   r   r   rI   c                ~   || _         || _        t          |          dz   | _        || _        || _        d| _        |dk    | _        | j        rd n| j                             t          d           }|t          |          nd | _        d| _        t                      | _        d | _        d| _        i | _        || _        d S )NrX   F	form-datar   )r   	_boundarylen_boundary_len_content_default_charset_at_eof_is_form_datagetr   int_length_read_bytesr   _unread_prev_chunk_content_eof_cache_max_decompress_size)r   r   r   r   r   r   r   lengths           rE   r   zBodyPartReader.__init__  s     ! ]]Q. /$3+W1A1A.RV1W1W&,&8s6{{{d%*WW,0&($7!!!rD   r   c                     | S rM   rC   r   s    rE   r   zBodyPartReader.__aiter__.  r   rD   c                 P   K   |                                   d {V }|t          |S rM   r   r   s     rE   r   zBodyPartReader.__anext__1  s5      YY[[      <$$rD   c                 F   K   |                                   d {V }|sd S |S rM   )readr   s     rE   r   zBodyPartReader.next7  s7      YY[[       	4rD   Fdecoder   c                D  K   | j         rdS t                      }| j         s:|                    |                     | j                   d{V            | j         :|rCt                      }|                     |          2 3 d{V }|                    |           6 |S |S )zReads body part data.

        decode: Decodes data following by encoding
                method from Content-Encoding header. If it missed
                data remains untouched
        rD   N)r   	bytearrayextend
read_chunk
chunk_sizedecode_iter)r   r   datadecoded_datads        rE   r   zBodyPartReader.read=  s       < 	3{{, 	@KKdoodo>>>>>>>>??? , 	@ 	 $;;L++D11 ' ' ' ' ' ' 'a##A&&&& 2s    Bsizec                 ^  K   | j         rdS | j        r|                     |           d{V }n|                     |           d{V }| j                            t                    }|rT|                                dk    r;d                    |	                                          }t          |          dz  }|dk    r|                                 sd|z
  }d}| j        r0| j        d|         }| j        t          |          d         | _        t          |          |k    r3|| j                            dt          |          z
             d{V z  }|sd| _         |d                    |	                                          z  }||z  }t          |          dz  }|dk    r|                                 | xj        t          |          z  c_        | j        | j        k    rd| _         | j         r2| j                                         d{V dk    rt#          d          |S )	zWReads body part content chunk of the specified size.

        size: chunk size
        rD   Nbase64   r   T   
z3Reader did not read all the data or it is malformed)r   r   _read_chunk_from_length_read_chunk_from_streamr   r   r    rx   rq   rt   r   r   r   r   r   r   readline
ValueError)r   r   chunkr   stripped_chunk	remainderover_chunk_size
over_chunks           rE   r   zBodyPartReader.read_chunkP  sR     
 < 	3< 	=66t<<<<<<<<EE66t<<<<<<<<E <##$=>> 	4((H44 XXekkmm44NN++a/Iq..."#i- 
# K!%!12B?2B!CJ'+'7J8I8I'JD$z??o55(:(:1s:;N(O(O"O"O"O"O"O"OOJ! (#'DL#((:+;+;+=+=">">>#//!3	! q...$ 	CJJ&t|++DL< 	T$-"8"8":":::::::gEERSSSrD   c                    K   | j         
J d            t          || j         | j        z
            }| j                            |           d {V }| j                                        rd| _        |S )Nz(Content-Length required for chunked readT)r   minr   r   r   r   r   )r   r   r   r   s       rE   r   z&BodyPartReader._read_chunk_from_length|  s       |'')S'''t|d.>>??
m((44444444=!! 	 DLrD   c           
        K   || j         k    s
J d            | j        d u }|r(d| j                            |           d {V z   | _        d}t	          |          | j         k     r|| j                            |           d {V z  }| xj        t          | j                                                  z  c_        | j        dk    rt          d          | j        rnt	          |          | j         k     t	          |          |k    r,| j        	                    ||d                     |d |         }| j        J | j        |z   }d| j
        z   }|r|                    |          }nF|                    |t          dt	          | j                  t	          |          z
                      }|dk    rt          j                    5  t          j        dt                      | j        	                    ||d                     d d d            n# 1 swxY w Y   | j        d |         | _        |t	          | j                  |         }|sd	| _        | j        |rdndd          }|| _        |S )
Nz<Chunk size must be greater or equal than boundary length + 2r   rD   rX   zReading after EOFr   ignore)categoryT)r   r   r   r   r   r   r   r   r   unread_datar   r`   maxru   catch_warningsfilterwarningsDeprecationWarningr   )r   r   first_chunkr   windowrj   idxresults           rE   r   z&BodyPartReader._read_chunk_from_stream  s      D&&&&I '&&&$. 	H&t}/A/A$/G/G)G)G)G)G)G)GGD %jj4---4=--d333333333ET]%9%9%;%;!<!<< 1$$ !4555   %jj4--- u::M%%eDEEl333%4%LE+++!E)& 	M++c""CC++c3q#d.>*?*?#c((*J#K#KLLC!88(** 8 8';MNNNN))&,7778 8 8 8 8 8 8 8 8 8 8 8 8 8 8  $/5D3t/00367E $#!{"9!!";";< s   	>HHHc                 6  K   | j         rdS | j        r| j                                        }n| j                                         d{V }|                    | j                  rV|                    d          }| j        }| j        dz   }||k    s||k    r#d| _         | j                            |           dS n]| j                                         d{V }|                    | j                  r
|dd         }| j                            |           |S )z Reads body part by line by line.rD   Nr      --T)	r   r   popleftr   r   r   r   rstripr   )r   linesliner   last_boundary	next_lines         rE   r   zBodyPartReader.readline  s8     < 	3< 	2<''))DD//11111111D??4>** 	+ KK((E~H NU2M  E]$:$:###D)))s %;
 #m4466666666I##DN33 !CRCyL	***rD   c                 |   K   | j         rdS | j         s)|                     | j                   d{V  | j         'dS dS )z0Like read(), but reads all the data to the void.N)r   r   r   r   s    rE   r   zBodyPartReader.release  se      < 	F, 	3//$/222222222 , 	3 	3 	3 	3 	3rD   )r   r   c                   K   |                      d           d{V }|p|                     d          }|                    |          S )z;Like read(), but assumes that body part contains text data.Tr   Nrn   default)r   get_charsetr   r   r   r   s      rE   rg   zBodyPartReader.text  sZ      YYdY++++++++ @t///@@{{8$$$rD   c                  K   |                      d           d{V }|sdS |p|                     d          }t          t          t          t
          f         t          j        |                    |                              S )z<Like read(), but assumes that body parts contains JSON data.Tr   Nrn   r  )	r   r  r   r   rp   r   jsonloadsr   r  s      rE   r  zBodyPartReader.json  s      YYdY++++++++ 	4@t///@@DcNDJt{{8/D/D$E$EFFFrD   c                2  K   |                      d           d{V }|sg S ||}n|                     d          }	 |                                                    |          }n # t          $ r t          d|z            w xY wt          |d|          S )zFLike read(), but assumes that body parts contain form urlencoded data.Tr   Nrn   r  z'data cannot be decoded with %s encoding)keep_blank_valuesr   )r   r  r   r   r{   r   r   )r   r   r   real_encodingr   s        rE   formzBodyPartReader.form  s      YYdY++++++++ 	I$MM ,,W,==M	X;;==//>>LL! 	X 	X 	XFVWWW	X ""
 
 
 	
s   'A' 'Bc                     | j         S )z<Returns True if the boundary was reached or False otherwise.r   r   s    rE   r   zBodyPartReader.at_eof  
    |rD   r   c                 L    t           | j        v r|                     |          S |S )z>Apply Content-Transfer-Encoding decoding if header is present.)r    r   _decode_content_transferr   r   s     rE    _apply_content_transfer_decodingz/BodyPartReader._apply_content_transfer_decoding  s(    $4400666rD   c                 .    | j          ot          | j        v S )z5Check if Content-Encoding decoding should be applied.)r   r   r   r   s    rE   _needs_content_decodingz&BodyPartReader._needs_content_decoding  s     %%J*:dl*JJrD   c                     |                      |          }|                                 r|                     |          S |S )a  Decodes data synchronously.

        Decodes data according the specified Content-Encoding
        or Content-Transfer-Encoding headers value.

        Note: For large payloads, consider using decode_iter() instead
        to avoid blocking the event loop during decompression.
        )r  r  _decode_contentr  s     rE   r   zBodyPartReader.decode
  sD     44T::'')) 	.''---rD   c                   K   |                      |          }|                                 r%|                     |          2 3 d{V }|W V  6 dS |W V  dS )a$  Async generator that yields decoded data chunks.

        Decodes data according the specified Content-Encoding
        or Content-Transfer-Encoding headers value.

        This method offloads decompression to an executor for large payloads
        to avoid blocking the event loop.
        N)r  r  _decode_content_async)r   r   r   s      rE   r   zBodyPartReader.decode_iter  s       44T::'')) 	55d;;       a <;; JJJJJJs   Ac                     | j                             t          d                                          }|dk    r|S |dv r+t	          |d                              || j                  S t          d|           Nre   identity>   gzipdeflateT)r   suppress_deflate_header)
max_lengthunknown content encoding: )r   r   r   rx   r   decompress_syncr   RuntimeErrorr   r   r   s      rE   r  zBodyPartReader._decode_content(  s    <##$4b99??AAz!!K***#!(,   odt/HoIIJ
 BBBCCCrD   c                   K   | j                             t          d                                          }|dk    r|W V  d S |dv r8t	          |d          }|                    || j                   d {V W V  d S t          d|           r  )r   r   r   rx   r   
decompressr   r#  )r   r   r   r   s       rE   r  z$BodyPartReader._decode_content_async4  s      <##$4b99??AAz!!JJJJJJ,,, !(,  A Td6OPPPPPPPPPPPPPPFHFFGGGrD   c                     | j                             t          d                                          }|dk    rt	          j        |          S |dk    rt          j        |          S |dv r|S t          d|           )Nre   r   quoted-printable)binary8bit7bit#unknown content transfer encoding: )	r   r   r    rx   r   	b64decodebinasciia2b_qpr#  r$  s      rE   r  z'BodyPartReader._decode_content_transferA  s    <##$=rBBHHJJx#D)))+++?4(((333KOXOOPPPrD   r  c                     | j                             t          d          }t          |          }|j                            d| j        p|          S )z>Returns charset parameter from Content-Type header or default.re   charset)r   r   r!   r$   
parametersr   )r   r  ctypemimetypes       rE   r  zBodyPartReader.get_charsetM  sG      r22!%(("&&y$2G2R7SSSrD   c                     t          | j                            t                              \  }}t	          |d          S )z|Returns name specified in Content-Disposition header.

        If the header is missing or malformed, returns None.
        r   r;   r   r   r   r<   r   r   r~   s      rE   r   zBodyPartReader.nameS  s6     .dl.>.>?R.S.STT	6+FF;;;rD   c                     t          | j                            t                              \  }}t	          |d          S )zReturns filename specified in Content-Disposition header.

        Returns None if the header is missing or malformed.
        r   r6  r7  s      rE   r   zBodyPartReader.filename\  s6     .dl.>.>?R.S.STT	6+FJ???rD   r   )+r@   rA   rB   r   r   r   bytesr0   rp   r   r   r   r3   r   r   r   rN   r   r   r   r   r   r   rg   r   r   r  r   r   r  r   r  r  r   r	   r   r  r  r  r  r%   r   r   rC   rD   rE   r5   r5     s(       00J )-#>8 8 88 )8 	8 8 "#8 !8 
8 8 8 86         HUO     ,1   D U    & ,6 * *S *% * * * *X# %    +# +% + + + +Z    :3 3 3 3 7; % % %hsm %s % % % % 7; G G Ghsm GxSRUX?W G G G G 7; 
 
 
hsm 
tE#s(O?T 
 
 
 
(    U u    K K K K K
5 U    e e0D     
DE 
De 
D 
D 
D 
DH H-:N H H H H
QU 
Qu 
Q 
Q 
Q 
QT3 T3 T T T T <hsm < < < U< @(3- @ @ @ U@ @ @rD   )orderc                   x     e Zd ZU eed<   dedededdf fdZdd
ededefdZdd
edede	fdZ
deddfdZ xZS )BodyPartReaderPayloadr   r   argskwargsrI   Nc                      t                      j        |g|R i | i }|j        
|j        |d<   |j        
|j        |d<   |r | j        di | d S d S )Nr   r   
attachmentT)r@  T)superr   r   r   set_content_disposition)r   r   r=  r>  r~   	__class__s        rE   r   zBodyPartReaderPayload.__init__k  s    0000000!#:!"ZF6N>%!&F: 	G(D(FFvFFFFF	G 	GrD   rn   ro   r   errorsc                      t          d          )NzUnable to decode.	TypeErrorr   r   rD  s      rE   r   zBodyPartReaderPayload.decodew  s    +,,,rD   c                 $   K   t          d          )aR  Raises TypeError as body parts should be consumed via write().

        This is intentional: BodyPartReader payloads are designed for streaming
        large data (potentially gigabytes) and must be consumed only once via
        the write() method to avoid memory exhaustion. They cannot be buffered
        in memory for reuse.
        z:Unable to read body part as bytes. Use write() to consume.rF  rH  s      rE   as_byteszBodyPartReaderPayload.as_bytesz  s       TUUUrD   writerc                   K   | j         }|                    d           d {V x}rY|                    |          2 3 d {V }|                    |           d {V  #6 |                    d           d {V x}Wd S d S )Ni   )r   )r   r   r   write)r   rK  fieldr   r   s        rE   rM  zBodyPartReaderPayload.write  s      "--5-999999999e 	& ,,U33 & & & & & & &all1oo%%%%%%%% 4 #--5-999999999e 	& 	& 	& 	& 	&s   A rn   ro   )r@   rA   rB   r5   __annotations__r   r   rp   r   r9  rJ  r   rM  __classcell__rC  s   @rE   r<  r<  f  s         
Gn 
GS 
GC 
GD 
G 
G 
G 
G 
G 
G- -s -c - - - - -V Vs Vc VQV V V V V&"6 &4 & & & & & & & &rD   r<  c                   ~   e Zd ZU dZeZdZeed                   e	d<   e
Zddddeeef         ded	ed
eddf
dZdedefdZdeed e
f                  fdZedddefd            ZdefdZdeed e
f                  fdZddZded e
f         fdZddded e
f         fdZdefdZdefdZddZ ddZ!d dZ"ddZ#dS )!r7   zMultipart body reader.Nmultipart_reader_clsi     max_field_sizemax_headersr   r   rW  rX  rI   c                   t          |t                             | _        | j        j        dk    s
J d            d| j        j        vrt          d|t                   z            || _        d|                                 z                                   | _	        || _
        d | _        d | _        || _        || _        d| _        d| _        g | _        d S )N	multipartz!multipart/* content type expectedr   z$boundary missed for Content-Type: %s--FT)r$   r!   	_mimetypetyper2  r   r   _get_boundaryencoder   r   r   
_last_part_max_field_size_max_headersr   _at_bofr   )r   r   r   rW  rX  s        rE   r   zMultipartReader.__init__  s     ((=>>~"k1113V111T^66669NN   !3!3!5!55==??,0CG-'$&rD   r   c                     | S rM   rC   r   s    rE   r   zMultipartReader.__aiter__  r   rD   c                 P   K   |                                   d {V }|t          |S rM   r   r   s     rE   r   zMultipartReader.__anext__  r   rD   responser=   c                 Z    |                      | | |j        |j                            }|S )zConstructs reader instance from HTTP response.

        :param response: :class:`~aiohttp.client.ClientResponse` instance
        )response_wrapper_clsr   r   )clsrf  objs      rE   from_responsezMultipartReader.from_response  s7     &&cc(*H,<==
 
 
rD   c                     | j         S )z@Returns True if the final boundary was reached, false otherwise.r  r   s    rE   r   zMultipartReader.at_eof  r  rD   c                    K   | j         rdS |                                  d{V  | j        r"|                                  d{V  d| _        n|                                  d{V  | j         rdS |                                  d{V }| j        | j        j        dk    rt          |t                    rt          |j                            t                              \  }}|                    d          dk    r|                    d           d{V }t!          |          dk    rt#          d          |                                                                | _        |                                  d{V }|| _        | j        S )	z#Emits the next multipart body part.NFr   r   	_charset_       zInvalid default charset)r   _maybe_release_last_partrc  _read_until_first_boundary_read_boundaryfetch_next_partr`  r\  r   
isinstancer5   r;   r   r   r   r   r   r#  ry   r   r   )r   r   r   r~   r1  s        rE   r   zMultipartReader.next  s     
 < 	4++---------< 	(11333333333 DLL%%'''''''''< 	4))++++++++ O#&+55400 6 2$,2B2BCV2W2WXXIAvzz&!![00 !% 3 3333333w<<"$$&'@AAA(/(>(>(@(@%!1133333333rD   c                    K   | j         sA|                                  d{V }|dS |                                 d{V  | j         ?dS dS )z=Reads all the body parts to the void till the final boundary.N)r   r   r   r   s     rE   r   zMultipartReader.release  sy      , 	!$$$$$$D|,,..       	 , 	! 	! 	! 	! 	!rD   c                 d   K   |                                   d{V }|                     |          S )z"Returns the next body part reader.N)_read_headers_get_part_reader)r   r   s     rE   rt  zMultipartReader.fetch_next_part  s?       **,,,,,,,,$$W---rD   r   c                 l   |                     t          d          }t          |          }|j        dk    rM| j         t          |           || j                  S |                     || j        | j        | j                  S |                     | j	        || j        | j
        j        | j                  S )zDispatches the response by the `Content-Type` header.

        Returns a suitable reader instance.

        :param dict headers: Response headers
        re   rZ  NrV  )r   r   )r   r!   r$   r]  rT  r   ra  rb  part_reader_clsr   r\  r   r   )r   r   r3  r4  s       rE   ry  z MultipartReader._get_part_reader  s     L"--!%((=K''(0!tDzz'4=999,,#3 -	 -    ''. $ 5 (   rD   c                 t    | j         j        d         }t          |          dk    rt          d|z            |S )Nr   F   z&boundary %r is too long (70 chars max))r\  r2  r   r   )r   r   s     rE   r^  zMultipartReader._get_boundary  s;    >,Z8x==2EPQQQrD   c                    K   | j         r| j                                         S | j                                         d {V S rM   )r   rw   r   r   r   s    rE   	_readlinezMultipartReader._readline%  sJ      < 	&<##%%%]++---------rD   c                    K   	 |                                   d {V }|dk    rt          d| j        z            |                                }|| j        k    rd S || j        dz   k    r	d| _        d S p)NTrD   z#Could not find starting boundary %rr   )r  r   r   r   r   r   r   s     rE   rr  z*MultipartReader._read_until_first_boundary*  s      	..********E|| 9T^L   LLNNE&&$.5000#	rD   c                   K   |                                   d {V                                 }|| j        k    rd S || j        dz   k    rd| _        |                                   d {V }|                                   d {V }|d d         dk    r| j                            |           d S | j                            ||g           d S t          d|d| j                  )Nr   TrX   zInvalid boundary z, expected )r  r   r   r   r   r   r   r   )r   r   epiloguer   s       rE   rs  zMultipartReader._read_boundary8  s     ~~''''''''//11DN""Ddnu,,,DL!^^--------H"nn........I !}%%##I.....
 ##Y$9:::::WWWT^WWXXXrD   c                 `  K   g }	 | j                             | j                   d {V }|                    d          }|                    |           |sn(t          |          | j        k    rt          d          {t          | j                  }|	                    |          \  }}|S )NT)max_line_lengthr   zToo many headers received)rW  )
r   r   ra  r   r   r   rb  r'   r&   parse_headers)r   linesr   parserr   raw_headerss         rE   rx  zMultipartReader._read_headersO  s      	B-00AU0VVVVVVVVELL))ELL 5zzD---$%@AAA	B d.BCCC%33E::rD   c                    K   | j         e| j                                         s| j                                          d{V  | j                            | j         j                   d| _         dS dS )z8Ensures that the last read body part is read completely.N)r`  r   r   r   r   r   s    rE   rq  z(MultipartReader._maybe_release_last_part]  sx      ?&?))++ 0o--/////////L 7888"DOOO	 '&rD   r   )rI   r   )$r@   rA   rB   r   r   rh  rT  r   r   rP  r5   r{  r   rp   r0   r   r   r3   r   r   r   classmethodrk  rN   r   r   r   rt  ry  r^  r9  r  rr  rs  rx  rq  rC   rD   rE   r7   r7     se           4 ?C(4(9#:;BBB$O #' ' 'c"' '
 ' ' 
' ' ' '4     	%)>9:	;    " 
"   [    !	%)>9:	;! ! ! !F! ! ! !.	 .0	1. . . .( 
 .0	1   >s    . . . . .
   Y Y Y Y.   # # # # # #rD   r7   c                       e Zd ZU dZded<   dZd(dedee         ddf fd	Zd)d
Z	dee
e                  dee         dee         ddfdZdee         fdZdefdZdefdZ ej        d          Z ej        d          Zedefd            Zedefd            Zd*dedeeeef                  defdZdedefdZ 	 d*dedeeeef                  defdZ!	 d*de"e#e$eef                  eeef         f         deeeef                  defdZ%edee         fd            Z&d+d ed!edefd"Z'd+d ed!ede(fd#Z)	 d,d$e*d%eddfd&Z+d-d'Z, xZ-S ).r8   zMultipart body writer.Nr   Tr   r   r   rI   c                 8   ||nt          j                    j        }	 |                    d          | _        n# t
          $ r t          d          d w xY wd| d| j         }t                      	                    d |           g | _
        |dk    | _        d S )Nasciiz(boundary should contain ASCII only charsz
multipart/z; boundary=)content_typer   )uuiduuid4hexr_  r   UnicodeEncodeErrorr   _boundary_valuerA  r   _partsr   )r   r   r   r3  rC  s       rE   r   zMultipartWriter.__init__p  s    '3889I	S%__W55DNN! 	S 	S 	SGHHdR	SGWGG1EGGE222#%$3s	   : Ac                     | S rM   rC   r   s    rE   	__enter__zMultipartWriter.__enter__  r   rD   exc_typeexc_valexc_tbc                     d S rM   rC   )r   r  r  r  s       rE   __exit__zMultipartWriter.__exit__  s	     	rD   c                 *    t          | j                  S rM   )iterr  r   s    rE   __iter__zMultipartWriter.__iter__  s    DK   rD   c                 *    t          | j                  S rM   )r   r  r   s    rE   __len__zMultipartWriter.__len__  s    4;rD   c                     dS )NTrC   r   s    rE   __bool__zMultipartWriter.__bool__  s    trD   s   \A[!#$%&'*+\-.^_`|~\w]+\Zs   [\x00-\x08\x0A-\x1F\x7F]c                 N   | j         }t          j        | j        |          r|                    d          S t          j        | j        |          rt          d          |                    dd          }|                    dd          }d|                    d          z   dz   S )zzWrap boundary parameter value in quotes, if necessary.

        Reads self.boundary and returns a unicode string.
        r  z*boundary value contains invalid characters   \s   \\   "s   \"rT   )	r   ri   match_valid_tchar_regexr   search_invalid_qdtext_char_regexr   replace)r   r   quoted_value_contents      rE   r  zMultipartWriter._boundary_value  s    & 8D+U33 	)<<(((9T4e<< 	KIJJJ  %}}UG<<3;;D&II)00999C??rD   c                 6    | j                             d          S )Nr  )r   r   r   s    rE   r   zMultipartWriter.boundary  s    ~$$W---rD   rj  r   c                 8   |t                      }t          |t                    r/|j                            |           |                     |          S 	 t          ||          }|                     |          S # t          $ r t          d|z            w xY w)Nr   zCannot create payload from %r)	r   ru  r,   r   updateappend_payloadr.   r*   rG  )r   rj  r   payloads       rE   r   zMultipartWriter.append  s    ?!mmGc7## 		4Kw'''&&s+++4%c7;;; **7333  G G G ?# EFFFGs   A< <Br  c                    d}d}| j         rmt          t          t          h|j                                        z  rJ t          |j        vr.dt          | j                   }|	                    d|           n|j        
                    t          d                                          }|r|dvrt          d|           |dk    rd}|j        
                    t          d                                          }|d	vrt          d
|           |dk    rd}|j        }| |s|st          |          |j        t          <   | j                            |||f           |S )z)Adds a new body part to multipart writer.Nzsection-r   )r   re   )r  r  r  r!  r  )re   r   r(  r)  r,  r)  )r   r   r   r    r   keysr   r   r  rB  r   rx   r#  r   rp   r   )r   r  r   te_encodingr   r   s         rE   r  zMultipartWriter.append_payload  s   "&%) 	< &~7PQ/&&(()  
 #'/994#dk"2"244//$/GGG **+;R@@FFHHH LH,KKK"#J#J#JKKK:%% "/--.GLLRRTTK"NNN"#V#V#VWWWh&&" <D[25d))/GX{;<<<rD   c                 j    |t                      }|                     t          ||                    S )zHelper to append JSON part.Nr  )r   r  r)   )r   rj  r   s      rE   append_jsonzMultipartWriter.append_json  s3     ?!mmG"";sG#D#D#DEEErD   c                 6   t          |t          t          f          sJ |t                      }t          |t                    r!t	          |                                          }t          |d          }|                     t          ||d                    S )z&Helper to append form urlencoded part.NT)doseqz!application/x-www-form-urlencoded)r   r  )	ru  r   r   r   listr   r   r  r-   )r   rj  r   r   s       rE   append_formzMultipartWriter.append_form  s     #'233333?!mmGc7## 	$syy{{##CD)))""g4W  
 
 	
rD   c                 
   d}| j         D ][\  }}}|j        }|s|s| dS |t          dt          | j                  z   dz   |z   t          |j                  z   dz             z  }\|dt          | j                  z   dz   z  }|S )zSize of the payload.r   NrX   r   )r  r   r   r   r   _binary_headers)r   totalr   r   r  	part_sizes         rE   r   zMultipartWriter.size  s     +/; 	 	'D(K	I ; )*;ttSdn%%&  d*++	,
   EE 	S(((1,,rD   rn   ro   r   rD  c                 X     d                      fd j        D                       S )zReturn string representation of the multipart data.

        WARNING: This method may do blocking I/O if parts contain file payloads.
        It should not be called in the event loop. Use as_bytes().decode() instead.
        re   c              3      K   | ]F\  }}}d j         z   dz   |j                                      z   |                                z   V  GdS )r[  z
N)r   r  r   )r   r   _e_ter   rD  r   s       rE   r   z)MultipartWriter.decode.<locals>.<genexpr>+  s       
 
 b# m "))(F;;< kkmm	
 
 
 
 
 
rD   )rq   r  rH  s   ```rE   r   zMultipartWriter.decode%  sQ     ww 
 
 
 
 
 
 "&
 
 
 
 
 	
rD   c                   K   g }| j         D ]\  }}}|                    d| j        z   dz              |                    |j                   |                    ||           d{V }|                    |           |                    d           |                    d| j        z   dz              d                    |          S )zReturn bytes representation of the multipart data.

        This method is async-safe and calls as_bytes on underlying payloads.
        r   r   N   --
rD   )r  r   r   r  rJ  rq   )r   r   rD  r}   r   r  r  
part_bytess           rE   rJ  zMultipartWriter.as_bytes4  s      
   "[ 	" 	"MD"cLL/'9::: LL-...  $}}Xv>>>>>>>>JLL$$$ LL!!!! 	UT^+i7888xxrD   rK  close_boundaryc                   K   | j         D ]'\  }}}| j        r&t          |j        v sJ d|j        t                   v sJ |                    d| j        z   dz              d{V  |                    |j                   d{V  |s|rst          |          }|r|                    |           |r|	                    |           |                    |           d{V  |
                                 d{V  n|                    |           d{V  |                    d           d{V  )|r(|                    d| j        z   dz              d{V  dS dS )zWrite body.zname=r   r   Nr  )r  r   r   r   rM  r   r  MultipartPayloadWriterenable_compressionenable_encoding	write_eof)r   rK  r  r   r   r  ws          rE   rM  zMultipartWriter.writeO  s      ,0; 	( 	('D(K! D*dl::::$,/B"CCCCC,,ut~5?@@@@@@@@@,,t3444444444 	); 	)*622 3((222 3%%k222jjmm#######kkmm########jj(((((((((,,w'''''''''' 	C,,ut~5	ABBBBBBBBBBB	C 	CrD   c                   K   | j         rdS d| _         t          | j                  D ]b\  }\  }}}|j        sR|j        sK	 |                                 d{V  3# t          $ r"}t          j        d||d           Y d}~Zd}~ww xY wcdS )a  
        Close all part payloads that need explicit closing.

        IMPORTANT: This method must not await anything that might not finish
        immediately, as it may be called during cleanup/cancellation. Schedule
        any long-running operations without awaiting them.
        NTz%Failed to close multipart part %d: %s)exc_info)		_consumedr   r  	autocloseconsumedclose	Exceptionr(   error)r   r   r   r   excs        rE   r  zMultipartWriter.closel  s       > 	F "+4;!7!7 	 	C$1> $- **,,&&&&&&&&    #)?cTX        		 	s   A
B$BB)r   N)rI   r8   rM   rO  )Tr   ).r@   rA   rB   r   rP  
_autocloserp   r   r   r  r   BaseExceptionr   r  r   _Partr  r   r  rN   r  ri   compiler  r  propertyr  r   r   r   r,   r   r  r  r   r   r   r  r   r   r9  rJ  r   rM  r  rQ  rR  s   @rE   r8   r8   i  s          LLLJ4 4 4# 4RV 4 4 4 4 4 4$   4./ -( '	
 
   !(5/ ! ! ! !         $     $$ABB!+,H!I!I@ @ @ @ X@> .# . . . X.4 4# 4c1B(C 4w 4 4 4 4$g $' $ $ $ $N @DF FF!)'#s(*;!<F	F F F F 04
 
8E#s(O,gc3h.??@
 '#s(+,
 
	
 
 
 
* hsm    X(
 
s 
c 
 
 
 
 
 s c QV    8 DHC C*C<@C	C C C C:       rD   r8   c                   j    e Zd ZdeddfdZdeddfdZ	 ddedee         ddfd	Z	dd
Z
deddfdZdS )r  rK  rI   Nc                 >    || _         d | _        d | _        d | _        d S rM   )_writer	_encoding	_compress_encoding_buffer)r   rK  s     rE   r   zMultipartPayloadWriter.__init__  s%    (,3759rD   r   c                 h    |dk    r|| _         t                      | _        d S |dk    r	d| _         d S d S )Nr   r(  )r  r   r  )r   r   s     rE   r  z&MultipartPayloadWriter.enable_encoding  sE    x%DN$-KKD!!!+++/DNNN ,+rD   r  strategyc                 4    t          |d|          | _        d S )NT)r   r  r  )r   r  )r   r   r  s      rE   r  z)MultipartPayloadWriter.enable_compression  s'     ($(
 
 
rD   c                 ,  K   | j         =| j                                         }|r"d | _         |                     |           d {V  | j        dk    r@| j        r;| j                            t          j        | j                             d {V  d S d S d S )Nr   )r  flushrM  r  r  r  r   	b64encoder  s     rE   r  z MultipartPayloadWriter.write_eof  s      >%N((**E (!%jj'''''''''>X%%$ Rl(()9$:O)P)PQQQQQQQQQQQ &%R RrD   r   c                 t  K   | j         &|r$| j                             |           d {V }|sd S | j        dk    r| j        }|J |                    |           |rxt          t          |          d          \  }}|d |dz           ||dz  d          c}| _        |r8t          j        |          }| j	        
                    |           d {V  d S d S d S | j        dk    r4| j	        
                    t          j        |                     d {V  d S | j	        
                    |           d {V  d S )Nr   r1   r(  )r  compressr  r  r   divmodr   r   r  r  rM  r.  b2a_qp)r   r   bufdivmod	enc_chunkb64chunks          rE   rM  zMultipartPayloadWriter.write  s     >% "n55e<<<<<<<< F>X%%'C???JJu 7!#c((A..S47	#'	NCa		N0	40 7%/	::H,,,X666666666667 77 7 ^111,$$X_U%;%;<<<<<<<<<<<,$$U+++++++++++rD   )r  Nr   )r@   rA   rB   r   r   rp   r  r   r   r  r  r9  rM  rC   rD   rE   r  r    s        :3 : : : : :0 0 0 0 0 0 DH
 

3;C=
	
 
 
 
	R 	R 	R 	R, ,4 , , , , , ,rD   r  )r   )Wr   r.  r  ri   sysr  ru   collectionsr   collections.abcr   r   typesr   typingr   r   r	   r
   r   r   r   r   r   r   r   r   urllib.parser   r   r   	multidictr   r   abcr   compression_utilsr   r   r   hdrsr   r   r   r    r!   helpersr"   r#   r$   r%   httpr&   http_exceptionsr'   logr(   r  r)   r*   r+   r,   r-   r.   r/   streamsr0   version_infor3   r4   __all__client_reqrepr=   RuntimeWarningr9   r:   rp   r;   r<   r   r5   	try_firstr<  r7   r  r8   r  rC   rD   rE   <module>r     s6      				 



         - - - - - - - -                                  7 6 6 6 6 6 6 6 6 6 3 3 3 3 3 3 3 3 % % % % % %         
              8 7 7 7 7 7 7 7 7 7 7 7       + + + + + +                              " ! ! ! ! !w76!1222D  .------	 	 	 	 	. 	 	 		 	 	 	 	 	 	 	d$SMd$
8C=$sCx.()d$ d$ d$ d$P ,6 CH%(c]   B," ," ," ," ," ," ," ,"^U@ U@ U@ U@ U@ U@ U@ U@p
 nEO444!& !& !& !& !&G !& !& 54!&HX# X# X# X# X# X# X# X#v 	gsC Z Z Z Z Zg Z Z Zz7, 7, 7, 7, 7, 7, 7, 7, 7, 7,rD   