
    hP                     6   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Zd dl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mZ d dlmZmZmZ d dlmZm Z  ddl!m"Z"m#Z# dd	l$m%Z%m&Z&m'Z'm(Z(m)Z) dd
l*m+Z+m,Z,m-Z-m.Z. ddl/m0Z0 ddl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8 ddl9m:Z: ej;        dk    rd dlm<Z< nd dlm=Z=  e=dd          Z<dZ>erddl?m@Z@  G d deA          ZB G d deA          ZCdeeD         deeeD         eeDeDf         f         fdZE	 d-deeDeDf         deDdeeD         fd ZF G d! d"          ZG G d# d          ZH e8eHe4jI        $           G d% d&e5                      ZJ G d' d(          ZKee5eDeDf         ZL G d) d*e5          ZM G d+ d,          ZNdS ).    N)deque)TracebackType)TYPE_CHECKINGAnyDequeDictIteratorListMappingOptionalSequenceTupleTypeUnioncast)	parse_qslunquote	urlencode)CIMultiDictCIMultiDictProxy   )ZLibCompressorZLibDecompressor)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)      )Self)TypeVarr.   BodyPartReader)bound)MultipartReaderMultipartWriterr0   BadContentDispositionHeaderBadContentDispositionParamparse_content_dispositioncontent_disposition_filename)ClientResponsec                       e Zd ZdS )r4   N__name__
__module____qualname__     S/var/www/html/prod/cognitive/venv/lib/python3.11/site-packages/aiohttp/multipart.pyr4   r4   I           Dr?   r4   c                       e Zd ZdS )r5   Nr:   r>   r?   r@   r5   r5   M   rA   r?   r5   headerreturnc                 v   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          }	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          |	                     C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stringrD   c                 P    t          |           ot          t          |           k    S N)boolr    setrF   s    r@   is_tokenz+parse_content_disposition.<locals>.is_tokenT   s    F||4V 44r?   c                 :    | d         | d         cxk    odk    nc S )Nr   "r>   rK   s    r@   	is_quotedz,parse_content_disposition.<locals>.is_quotedW   s,    ayF2J----#-----r?   c                 L     |           o|                      d          dk    S )N'   )count)rF   rL   s    r@   
is_rfc5987z-parse_content_disposition.<locals>.is_rfc5987Z   s)    x:FLL$5$5$::r?   c                 ,    |                      d          S )N*)endswithrK   s    r@   is_extended_paramz4parse_content_disposition.<locals>.is_extended_param]   s    s###r?   c                     |                      d          dz   }|sdS |                     d          r
| |d         n	| |d          }|                                S )NrW   r   FrN   )findrX   isdigit)rF   pos	substrings      r@   is_continuous_paramz6parse_content_disposition.<locals>.is_continuous_param`   sa    kk#" 	5&,ooc&:&:LF3r6NNstt	  """r?    )charstextra   c                6    t          j        d| dd|           S )Nz\\([z])z\1)resub)rb   ra   s     r@   unescapez+parse_content_disposition.<locals>.unescapeg   s"    v(u(((%666r?   ;r   =r   rN   rR   rS   utf-8strictTFz\/)strrI   joinmaprd   escaper   splitwarningswarnr4   poplowerstriplstripr5   r   UnicodeDecodeError)rC   rP   rU   rY   r_   rf   disptypepartsparamsitemkeyvalueencoding_failed_valuerL   s                   @r@   r6   r6   Q   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||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y  <| >>V##s   J) )+KKfilenamery   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 rH   )
startswith).0r{   r|   name_sufs      r@   	<genexpr>z/content_disposition_filename.<locals>.<genexpr>   sP       
 
'S%S^^H=U=U
%L
 
 
 
 
 
r?   rW   r   rN   r`   rR   rS   ri   rj   )	sorteditems	enumeratero   rX   rk   appendrl   r   )ry   r   rx   fnparamsnumr{   r|   r~   tailr}   r   s             @r@   r7   r7      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r?   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.
    respr8   streamr2   rD   Nc                 "    || _         || _        d S rH   )r   r   )selfr   r   s      r@   __init__z!MultipartResponseWrapper.__init__   s    
 	r?   c                     | S rH   r>   r   s    r@   	__aiter__z"MultipartResponseWrapper.__aiter__       r?   )r2   r0   c                 P   K   |                                   d {V }|t          |S rH   nextStopAsyncIterationr   parts     r@   	__anext__z"MultipartResponseWrapper.__anext__   7       YY[[      <$$r?   c                 >    | j         j                                        S )z2Returns True when all response data had been read.)r   contentat_eofr   s    r@   r   zMultipartResponseWrapper.at_eof   s    y '')))r?   c                    K   | j                                          d{V }| j                                         r|                                  d{V  |S )z#Emits next multipart reader object.N)r   r   r   releaser   rz   s     r@   r   zMultipartResponseWrapper.next   sh       [%%''''''''; 	!,,..       r?   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    r@   r   z MultipartResponseWrapper.release   s4      
 i!!!!!!!!!!!r?   )r   r8   r   r2   rD   N)rD   r   rD   N)r;   r<   r=   __doc__r   r   r   r   rI   r   r   r   r   r>   r?   r@   r   r      s          " 
	      	2	3   * * * * *	%;<	=   " " " " " "r?   r   c                      e Zd ZdZdZddddeddd	ed
ede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d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 )+r0   z&Multipart reader for single body part.i    mixedNsubtypedefault_charsetboundaryheadersCIMultiDictProxy[str]r   r   r   rD   c                p   || _         || _        t          |          dz   | _        || _        || _        d| _        |dk    | _        | j        rd n| j                             t          d           }|t          |          nd | _        d| _        t                      | _        d | _        d| _        i | _        d S )NrS   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)r   r   r   r   r   r   lengths          r@   r   zBodyPartReader.__init__	  s     ! ]]Q. /$3+W1A1A.RV1W1W&,&8s6{{{d%*WW,0&(r?   r   c                     | S rH   r>   r   s    r@   r   zBodyPartReader.__aiter__"  r   r?   c                 P   K   |                                   d {V }|t          |S rH   r   r   s     r@   r   zBodyPartReader.__anext__%  s5      YY[[      <$$r?   c                 F   K   |                                   d {V }|sd S |S rH   )readr   s     r@   r   zBodyPartReader.next+  s7      YY[[       	4r?   Fdecoder   c                   K   | j         rdS t                      }| j         s:|                    |                     | j                   d{V            | j         :|r|                     |          S |S )zReads body part data.

        decode: Decodes data following by encoding
                method from Content-Encoding header. If it missed
                data remains untouched
        r?   N)r   	bytearrayextend
read_chunk
chunk_sizer   )r   r   datas      r@   r   zBodyPartReader.read1  s       < 	3{{, 	@KKdoodo>>>>>>>>??? , 	@ 	%;;t$$$r?   sizec                 X  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         r/| j                                         d{V }d|k    s
J d            |S )	zWReads body part content chunk of the specified size.

        size: chunk size
        r?   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   rs   rl   ro   r   r   r   r   r   r   readline)	r   r   chunkr}   stripped_chunk	remainderover_chunk_size
over_chunkclrfs	            r@   r   zBodyPartReader.read_chunkA  sU     
 < 	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< 	E//11111111D4D  r?   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       r@   r   z&BodyPartReader._read_chunk_from_lengthp  s       |'')S'''t|d.>>??
m((44444444=!! 	 DLr?   c           
        K   || j         k    s
J d            | j        d u }|r%| j                            |           d {V | _        d}t	          |          | j         k     r|| j                            |           d {V z  }| xj        t          | j                                                  z  c_        | j        dk     s
J 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   ||k    r| j        d |         | _        |t	          | j                  |         }|sd	| _        | j        }|| _        |S )
Nz<Chunk size must be greater or equal than boundary length + 2r?   r,   zReading after EOFr   r   ignore)categoryT)r   r   r   r   r   r   r   r   unread_datar   r[   maxrp   catch_warningsfilterwarningsDeprecationWarningr   )r   r   first_chunkr   windowre   idxresults           r@   r   z&BodyPartReader._read_chunk_from_streamz  s      D&&&&I '&&&$. 	>%)]%7%7%=%=======D %jj4---4=--d333333333ET]%9%9%;%;!<!<<$q(((*=(((   %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 czz#'#3DSD#9 3t/00367E $#! 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.r?   Nr      --T)	r   r   popleftr   r   r   r   rstripr   )r   linesliner   last_boundary	next_lines         r@   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	***r?   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    r@   r   zBodyPartReader.release  se      < 	F, 	3//$/222222222 , 	3 	3 	3 	3 	3r?   )r}   r}   c                   K   |                      d           d{V }|p|                     d          }|                    |          S )z;Like read(), but assumes that body part contains text data.Tr   Nri   default)r   get_charsetr   r   r}   r   s      r@   rb   zBodyPartReader.text  sZ      YYdY++++++++ @t///@@{{8$$$r?   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   Nri   r   )	r   r   r   r   rk   r   jsonloadsr   r   s      r@   r   zBodyPartReader.json  s      YYdY++++++++ 	4@t///@@DcNDJt{{8/D/D$E$EFFFr?   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   Nri   r   z'data cannot be decoded with %s encoding)keep_blank_valuesr}   )r   r   r   r   rv   
ValueErrorr   )r   r}   r   real_encodingdecoded_datas        r@   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    r@   r   zBodyPartReader.at_eof  
    |r?   r   c                     t           | j        v r|                     |          }| j        s#t          | j        v r|                     |          S |S )zDecodes data.

        Decoding is done according the specified Content-Encoding
        or Content-Transfer-Encoding headers value.
        )r   r   _decode_content_transferr   r   _decode_content)r   r   s     r@   r   zBodyPartReader.decode  sU     %440066D! 	.&6$,&F&F''---r?   c                     | j                             t          d                                          }|dk    r|S |dv r$t	          |d                              |          S t          d|           )Nr`   identity>   gzipdeflateT)r}   suppress_deflate_headerunknown content encoding: )r   r   r   rs   r   decompress_syncRuntimeErrorr   r   r}   s      r@   r  zBodyPartReader._decode_content  s    <##$4b99??AAz!!K***#!(,   od##$
 BBBCCCr?   c                     | j                             t          d                                          }|dk    rt	          j        |          S |dk    rt          j        |          S |dv r|S t          d|           )Nr`   r   quoted-printable)binary8bit7bit#unknown content transfer encoding: )	r   r   r   rs   r   	b64decodebinasciia2b_qpr  r  s      r@   r
  z'BodyPartReader._decode_content_transfer  s    <##$=rBBHHJJx#D)))+++?4(((333KOXOOPPPr?   r   c                     | j                             t          d          }t          |          }|j                            d| j        p|          S )z>Returns charset parameter from Content-Type header or default.r`   charset)r   r   r   r!   
parametersr   )r   r   ctypemimetypes       r@   r   zBodyPartReader.get_charset  sG      r22!%(("&&y$2G2R7SSSr?   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   r6   r   r   r   r7   r   r~   ry   s      r@   r   zBodyPartReader.name  s6     .dl.>.>?R.S.STT	6+FF;;;r?   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   r$  r%  s      r@   r   zBodyPartReader.filename&  s6     .dl.>.>?R.S.STT	6+FJ???r?   r   )%r;   r<   r=   r   r   bytesr+   rk   r   r   r.   r   r   r   rI   r   r   r   r   r   r   r   rb   r   r   r   r
   r   r  r   r   r  r
  r   r"   r   r   r>   r?   r@   r0   r0     s       00J )-) ) )) )) 	) ) "#) 
) ) ) )2         HUO     ,1   D U      ,6 - -S -% - - - -^# %    *# *% * * * *X    :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 
 
 
 
(    5 U    
DE 
De 
D 
D 
D 
D
QU 
Qu 
Q 
Q 
Q 
QT3 T3 T T T T <hsm < < < U< @(3- @ @ @ U@ @ @r?   )orderc                   b     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eddfdZ	 xZ
S )BodyPartReaderPayloadr   r|   argskwargsrD   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,  ry   	__class__s        r@   r   zBodyPartReaderPayload.__init__4  s    0000000!#:!"ZF6N>%!&F: 	G(D(FFvFFFFF	G 	Gr?   ri   rj   r}   errorsc                      t          d          )NzUnable to decode.)	TypeErrorr   r}   r2  s      r@   r   zBodyPartReaderPayload.decode@  s    +,,,r?   writerc                    K   | j         }|                    d           d {V }|rN|                    |                    |                     d {V  |                    d           d {V }|Ld S d S )Ni   )r   )r   r   writer   )r   r6  fieldr   s       r@   r8  zBodyPartReaderPayload.writeC  s      &&E&22222222 	7,,u||E22333333333***66666666E  	7 	7 	7 	7 	7r?   ri   rj   )r;   r<   r=   r0   __annotations__r   r   rk   r   r8  __classcell__r1  s   @r@   r*  r*  0  s         
Gn 
GS 
GC 
GD 
G 
G 
G 
G 
G 
G- -s -c - - - - -7# 7$ 7 7 7 7 7 7 7 7r?   r*  c                   n   e Zd ZU dZeZdZeed                   e	d<   e
Zdeeef         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 )r2   zMultipart body reader.Nmultipart_reader_clsr   r   rD   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typer   r  r   _get_boundaryencoder   r   r   
_last_partr   _at_bofr   )r   r   r   s      r@   r   zMultipartReader.__init__V  s    '(=>>~"k1113V111T^66669NN   !3!3!5!55==??/3NR$&r?   r   c                     | S rH   r>   r   s    r@   r   zMultipartReader.__aiter__g  r   r?   c                 P   K   |                                   d {V }|t          |S rH   r   r   s     r@   r   zMultipartReader.__anext__j  r   r?   responser8   c                 Z    |                      | | |j        |j                            }|S )zConstructs reader instance from HTTP response.

        :param response: :class:`~aiohttp.client.ClientResponse` instance
        )response_wrapper_clsr   r   )clsrK  objs      r@   from_responsezMultipartReader.from_responser  s7     &&cc(*H,<==
 
 
r?   c                     | j         S )z@Returns True if the final boundary was reached, false otherwise.r  r   s    r@   r   zMultipartReader.at_eof  r  r?   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_partrH  _read_until_first_boundary_read_boundaryfetch_next_partrG  rC  r   
isinstancer0   r6   r   r   r   r   r   r  rt   r   r   )r   r   r~   ry   r  s        r@   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r?   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     r@   r   zMultipartReader.release  sy      , 	!$$$$$$D|,,..       	 , 	! 	! 	! 	! 	!r?   c                 d   K   |                                   d{V }|                     |          S )z"Returns the next body part reader.N)_read_headers_get_part_reader)r   r   s     r@   rY  zMultipartReader.fetch_next_part  s?       **,,,,,,,,$$W---r?   r   c                 R   |                     t          d          }t          |          }|j        dk    r@| j         t          |           || j                  S |                     || 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
        r`   rA  Nr   )r   r   r!   rD  r?  r   part_reader_clsr   rC  r   r   )r   r   r!  r"  s       r@   r^  z MultipartReader._get_part_reader  s     L"--!%((=K''(0!tDzz'4=999,,WdmDDD''. $ 5 (   r?   c                 t    | j         j        d         }t          |          dk    rt          d|z            |S )Nr   F   z&boundary %r is too long (70 chars max))rC  r   r   r  )r   r   s     r@   rE  zMultipartReader._get_boundary  s;    >,Z8x==2EPQQQr?   c                    K   | j         r| j                                         S | j                                         d {V S rH   )r   rr   r   r   r   s    r@   	_readlinezMultipartReader._readline  sJ      < 	&<##%%%]++---------r?   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)NTr?   z#Could not find starting boundary %rr   )rd  r  r   r   r   r   r   s     r@   rW  z*MultipartReader._read_until_first_boundary  s      	..********E|| 9T^L   LLNNE&&$.5000#	r?   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   TrS   zInvalid boundary z, expected )rd  r   r   r   r   r   r   r  )r   r   epiloguer   s       r@   rX  zMultipartReader._read_boundary  s     ~~''''''''//11DN""Ddnu,,,DL!^^--------H"nn........I !}%%##I.....
 ##Y$9:::::WWWT^WWXXXr?   c                    K   dg}	 | j                                          d {V }|                                }|                    |           |snLt	                      }|                    |          \  }}|S )Nr?   )r   r   rt   r   r#   parse_headers)r   linesr   parserr   raw_headerss         r@   r]  zMultipartReader._read_headers  s      	-0022222222EKKMMELL 	 %33E::r?   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)rG  r   r   r   r   r   s    r@   rV  z(MultipartReader._maybe_release_last_part  sx      ?&?))++ 0o--/////////L 7888"DOOO	 '&r?   r   )rD   r   )#r;   r<   r=   r   r   rM  r?  r   r   r;  r0   r`  r   rk   r+   r   r.   r   r   r   classmethodrP  rI   r   r   r   rY  r^  rE  r'  rd  rW  rX  r]  rV  r>   r?   r@   r2   r2   K  s8           4 ?C(4(9#:;BBB$O'S 1 'L 'T ' ' ' '"     	%)>9:	;    " 
"   [    !	%)>9:	;! ! ! !F! ! ! !.	 .0	1. . . .( 
 .0	1   4s    . . . . .
   Y Y Y Y.
 
 
 
# # # # # #r?   r2   c                   |    e Zd ZU dZded<   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dfd%Z' xZ(S )+r3   zMultipart body writer.Nr   r   r   r   rD   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hexrF  r   UnicodeEncodeErrorr  _boundary_valuer/  r   _partsr   )r   r   r   r!  r1  s       r@   r   zMultipartWriter.__init__  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 rH   r>   r   s    r@   	__enter__zMultipartWriter.__enter__0  r   r?   exc_typeexc_valexc_tbc                     d S rH   r>   )r   r|  r}  r~  s       r@   __exit__zMultipartWriter.__exit__3  s	     	r?   c                 *    t          | j                  S rH   )iterry  r   s    r@   __iter__zMultipartWriter.__iter__;  s    DK   r?   c                 *    t          | j                  S rH   )r   ry  r   s    r@   __len__zMultipartWriter.__len__>  s    4;r?   c                     dS )NTr>   r   s    r@   __bool__zMultipartWriter.__bool__A  s    tr?   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.
        rr  z*boundary value contains invalid characters   \s   \\   "s   \"rO   )	r   rd   match_valid_tchar_regexr   search_invalid_qdtext_char_regexr  replace)r   r|   quoted_value_contents      r@   rx  zMultipartWriter._boundary_valueG  s    & 8D+U33 	)<<(((9T4e<< 	KIJJJ  %}}UG<<3;;D&II)00999C??r?   c                 6    | j                             d          S )Nrr  )r   r   r   s    r@   r   zMultipartWriter.boundaryg  s    ~$$W---r?   rO  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   rZ  r'   r   updateappend_payloadr)   r%   r4  )r   rO  r   payloads       r@   r   zMultipartWriter.appendk  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   r`   )r  r  r  r  r  )r`   r   r  r  r  r  )r   r   r   r   r   keysr   r   ry  r0  r   rs   r  r   rk   r   )r   r  r}   te_encodingr   r   s         r@   r  zMultipartWriter.append_payloadz  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{;<<<r?   c                 j    |t                      }|                     t          ||                    S )zHelper to append JSON part.Nr  )r   r  r$   )r   rO  r   s      r@   append_jsonzMultipartWriter.append_json  s3     ?!mmG"";sG#D#D#DEEEr?   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   rs  )	rZ  r   r   r   listr   r   r  r(   )r   rO  r   r   s       r@   append_formzMultipartWriter.append_form  s     #'233333?!mmGc7## 	$syy{{##CD)))""g4W  
 
 	
r?   c                    d}| j         D ]^\  }}}|s	|s|j         dS |t          dt          | j                  z   dz   |j        z   t          |j                  z   dz             z  }_|dt          | j                  z   dz   z  }|S )zSize of the payload.r   NrS   r   )ry  r   r   r   r   _binary_headers)r   totalr   r}   r  s        r@   r   zMultipartWriter.size  s     +/; 	 	'D(K ; $)*;ttSdn%%& ) d*++	,
   EE 	S(((1,,r?   ri   rj   r}   r2  c                 X     d                      fd j        D                       S )Nr`   c              3      K   | ]F\  }}}d j         z   dz   |j                                      z   |                                z   V  GdS )rB  z
N)r   r  r   )r   r   _e_ter}   r2  r   s       r@   r   z)MultipartWriter.decode.<locals>.<genexpr>  s       
 
 b# m "))(F;;< kkmm	
 
 
 
 
 
r?   )rl   ry  r5  s   ```r@   r   zMultipartWriter.decode  sO    ww 
 
 
 
 
 
 "&
 
 
 
 
 	
r?   Tr6  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   Ns   --
)ry  r   r   r   r8  r   r  MultipartPayloadWriterenable_compressionenable_encoding	write_eof)r   r6  r  r   r}   r  ws          r@   r8  zMultipartWriter.write  s     +/; 	( 	('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r?   )r   N)rD   r3   rH   r:  )T))r;   r<   r=   r   r;  rk   r   r   r{  r   BaseExceptionr   r  r	   _Partr  r   r  rI   r  rd   compiler  r  propertyrx  r   r   r   r'   r   r  r  r   r   r   r  r   r   r8  r<  r=  s   @r@   r3   r3     sE          LLL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 
 
 
 
 
C C# Ct Ct C C C C C C C Cr?   r3   c                   j    e Zd ZdeddfdZdeddfdZdej        fdede	ddfd	Z
dd
ZdeddfdZdS )r  r6  rD   Nc                 >    || _         d | _        d | _        d | _        d S rH   )_writer	_encoding	_compress_encoding_buffer)r   r6  s     r@   r   zMultipartPayloadWriter.__init__  s%    (,3759r?   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     r@   r  z&MultipartPayloadWriter.enable_encoding  sE    x%DN$-KKD!!!+++/DNNN ,+r?   r  strategyc                 4    t          |d|          | _        d S )NT)r}   r  r  )r   r  )r   r}   r  s      r@   r  z)MultipartPayloadWriter.enable_compression  s'     ($(
 
 
r?   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  flushr8  r  r  r  r   	b64encoderf  s     r@   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r?   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   r,   r  )r  compressr  r  r   divmodr   r   r  r  r8  r  b2a_qp)r   r   bufdivmod	enc_chunkb64chunks          r@   r8  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+++++++++++r?   r   )r;   r<   r=   r   r   rk   r  zlibZ_DEFAULT_STRATEGYr   r  r  r'  r8  r>   r?   r@   r  r    s        :s :t : : : :0 0 0 0 0 0 (9P
 

36
	
 
 
 
	R 	R 	R 	R, ,4 , , , , , ,r?   r  )r   )Or   r  r   rd   sysrt  rp   r  collectionsr   typesr   typingr   r   r   r   r	   r
   r   r   r   r   r   r   r   urllib.parser   r   r   	multidictr   r   compression_utilsr   r   hdrsr   r   r   r   r   helpersr   r    r!   r"   httpr#   r  r$   r%   r&   r'   r(   r)   r*   streamsr+   version_infor.   r/   __all__client_reqrepr8   RuntimeWarningr4   r5   rk   r6   r7   r   r0   	try_firstr*  r2   r  r3   r  r>   r?   r@   <module>r     s      				 



                                             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  .------	 	 	 	 	. 	 	 		 	 	 	 	 	 	 	`$SM`$
8C=$sCx.()`$ `$ `$ `$H ,6 CH%(c]   B," ," ," ," ," ," ," ,"^i@ i@ i@ i@ i@ i@ i@ i@X	 nEO4447 7 7 7 7G 7 7 5474H# H# H# H# H# H# H# H#V 	gsC \C \C \C \C \Cg \C \C \C~7, 7, 7, 7, 7, 7, 7, 7, 7, 7,r?   