
    bfy                        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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: dZ;erddl<m=Z=  G d de>          Z? G d de>          Z@deeA         deeeA         eeAeAf         f         fdZB	 d(deeAeAf         deAdeeA         fdZC G d d          ZD G d d          ZE e8eEe4jF                   G d  d!e5                      ZG G d" d#          ZHee5eAeAf         ZI G d$ d%e5          ZJ G d& d'          ZKdS ))    N)deque)TracebackType)TYPE_CHECKINGAnyAsyncIterator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)MultipartReaderMultipartWriterBodyPartReaderBadContentDispositionHeaderBadContentDispositionParamparse_content_dispositioncontent_disposition_filename)ClientResponsec                       e Zd ZdS )r0   N__name__
__module____qualname__     K/var/www/html/Alfredo/env/lib/python3.11/site-packages/aiohttp/multipart.pyr0   r0   B           Dr;   r0   c                       e Zd ZdS )r1   Nr6   r:   r;   r<   r1   r1   F   r=   r;   r1   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stringr@   c                 P    t          |           ot          t          |           k    S N)boolr!   setrB   s    r<   is_tokenz+parse_content_disposition.<locals>.is_tokenM   s    F||4V 44r;   c                 :    | d         | d         cxk    odk    nc S )Nr   "r:   rG   s    r<   	is_quotedz,parse_content_disposition.<locals>.is_quotedP   s,    ayF2J----#-----r;   c                 L     |           o|                      d          dk    S )N'   )count)rB   rH   s    r<   
is_rfc5987z-parse_content_disposition.<locals>.is_rfc5987S   s)    x:FLL$5$5$::r;   c                 ,    |                      d          S )N*)endswithrG   s    r<   is_extended_paramz4parse_content_disposition.<locals>.is_extended_paramV   s    s###r;   c                     |                      d          dz   }|sdS |                     d          r
| |d         n	| |d          }|                                S )NrS   r   FrJ   )findrT   isdigit)rB   pos	substrings      r<   is_continuous_paramz6parse_content_disposition.<locals>.is_continuous_paramY   sa    kk#" 	5&,ooc&:&:LF3r6NNstt	  """r;    )charstextr]   c                6    t          j        d| dd|           S )Nz\\([z])z\1)resub)r^   r]   s     r<   unescapez+parse_content_disposition.<locals>.unescape`   s"    v(u(((%666r;   ;r   =r   rJ   rN   rO   utf-8strictTFz\/)strrE   joinmapr`   escaper    splitwarningswarnr0   poplowerstriplstripr1   r   UnicodeDecodeError)r?   rL   rQ   rU   r[   rb   disptypepartsparamsitemkeyvalueencoding_failed_valuerH   s                   @r<   r2   r2   J   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filenameru   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 rD   )
startswith).0rw   rx   name_sufs      r<   	<genexpr>z/content_disposition_filename.<locals>.<genexpr>   sP       
 
'S%S^^H=U=U
%L
 
 
 
 
 
r;   rS   r   rJ   r\   rN   rO   re   rf   )	sorteditems	enumeraterk   rT   rg   appendrh   r   )ru   r~   rt   fnparamsnumrw   rx   rz   tailry   r   s             @r<   r3   r3      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.
    respr4   streamr-   r@   Nc                 "    || _         || _        d S rD   )r   r   )selfr   r   s      r<   __init__z!MultipartResponseWrapper.__init__   s    
 	r;   c                     | S rD   r:   r   s    r<   	__aiter__z"MultipartResponseWrapper.__aiter__       r;   )r-   r/   c                 P   K   |                                   d {V }|t          |S rD   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   rv   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   r4   r   r-   r@   N)r@   r   r@   N)r7   r8   r9   __doc__r   r   r   r   rE   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          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 )*r/   z&Multipart reader for single body part.i    mixedNsubtypedefault_charsetboundaryheadersCIMultiDictProxy[str]r   r   r   r@   c                B   || _         || _        || _        || _        d| _        |dk    | _        | j        rd n| j                             t          d           }|t          |          nd | _	        d| _
        t                      | _        d | _        d| _        i | _        d S )NF	form-datar   )r   	_boundary_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     ! /$3+W1A1A.RV1W1W&,&8s6{{{d%*WW,0&(r;   c                     | S rD   r:   r   s    r<   r   zBodyPartReader.__aiter__  r   r;   c                 P   K   |                                   d {V }|t          |S rD   r   r   s     r<   r   zBodyPartReader.__anext__  s5      YY[[      <$$r;   c                 F   K   |                                   d {V }|sd S |S rD   )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.read)  s       < 	3{{, 	@KKdoodo>>>>>>>>??? , 	@ 	%;;t$$$r;   sizec                 l  K   | j         rdS | j        r|                     |           d{V }n|                     |           d{V }| 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;   NT   
z3reader did not read all the data or it is malformed)r   r   _read_chunk_from_length_read_chunk_from_streamr   lenr   readline)r   r   chunkclrfs       r<   r   zBodyPartReader.read_chunk9  s      
 < 	3< 	=66t<<<<<<<<EE66t<<<<<<<<E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_lengthO  s       |'')S'''t|d.>>??
m((44444444=!! 	 DLr;   c           
        K   |t          | j                  dz   k    s
J d            | j        d u }|r%| j                            |           d {V | _        | j                            |           d {V }| xj        t          | j                                                  z  c_        | j        dk     s
J 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 )
NrO   z<Chunk size must be greater or equal than boundary length + 2   zReading after EOFr   r   ignore)categoryT)r   r   r   r   r   r   r   r   rW   maxrl   catch_warningsfilterwarningsDeprecationWarningunread_datar   )r   r   first_chunkr   windowra   idxresults           r<   r   z&BodyPartReader._read_chunk_from_streamY  sV      C''!++++I ,++&$. 	>%)]%7%7%=%=======Dm((........S!5!5!7!7888 1$$$&9$$$+++!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   >FF#&F#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;   )ry   ry   c                   K   |                      d           d{V }|p|                     d          }|                    |          S )z;Like read(), but assumes that body part contains text data.Tr   Nre   default)r   get_charsetr   r   ry   r   s      r<   r^   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   Nre   r   )	r   r   r   r	   rg   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   Nre   r   z'data cannot be decoded with %s encoding)keep_blank_valuesry   )r   r   r   r   rr   
ValueErrorr   )r   ry   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)ry   suppress_deflate_headerunknown content encoding: )r   r   r   ro   r   decompress_syncRuntimeErrorr   r   ry   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\   base64quoted-printable)binary8bit7bitz%unknown content transfer encoding: {})
r   r   r   ro   r  	b64decodebinasciia2b_qpr	  formatr
  s      r<   r   z'BodyPartReader._decode_content_transfer  s    <##$=rBBHHJJx#D)))+++?4(((333K:AA(KK  r;   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~   r2   r   r   r   r3   r   rz   ru   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   )%r7   r8   r9   r   r   bytesr,   rg   r   r   r   r   r   r   rE   r   r   r   r   r   r   r   r^   r	   r   r   r   r   r   r   r   r  r   r   r#   r~   r}   r:   r;   r<   r/   r/      s}       00J )-) ) )) )) 	) ) "#) 
) ) ) )0=)9:        HUO     ,1   D U      ,6  S %    ,# %     #  %        D    :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U u    T3 T3 T T T T <hsm < < < U< @(3- @ @ @ U@ @ @r;   r/   )orderc                   @     e Zd Zdedededdf fdZdeddfdZ xZS )	BodyPartReaderPayloadrx   argskwargsr@   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   rx   r"  r#  ru   	__class__s        r<   r   zBodyPartReaderPayload.__init__	  s    0000000!#:!"ZF6N>%!&F: 	G(D(FFvFFFFF	G 	Gr;   writerc                    K   | j         }|                    d           d {V }|rN|                    |                    |                     d {V  |                    d           d {V }|Ld S d S )Ni   )r   )r|   r   writer   )r   r)  fieldr   s       r<   r+  zBodyPartReaderPayload.write  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;   )r7   r8   r9   r/   r   r   r+  __classcell__r(  s   @r<   r!  r!    s        
Gn 
GS 
GC 
GD 
G 
G 
G 
G 
G 
G7# 7$ 7 7 7 7 7 7 7 7r;   r!  c                   R   e Zd ZdZeZdZeZde	e
e
f         deddfdZded         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 )r-   zMultipart body reader.Nr   r   r@   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: %sz--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__(  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 rD   r:   r   s    r<   r   zMultipartReader.__aiter__9  s	     r;   c                 P   K   |                                   d {V }|t          |S rD   r   r   s     r<   r   zMultipartReader.__anext__>  r   r;   responser4   c                 Z    |                      | | |j        |j                            }|S )zConstructs reader instance from HTTP response.

        :param response: :class:`~aiohttp.client.ClientResponse` instance
        )response_wrapper_clsr   r   )clsr:  objs      r<   from_responsezMultipartReader.from_responseF  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_eofT  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_partr7  _read_until_first_boundary_read_boundaryfetch_next_partr6  r2  r   
isinstancer/   r2   r   r   r   r   r   r	  rp   r   r   )r   r   rz   ru   r  s        r<   r   zMultipartReader.nextX  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<   rH  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\   r1  Nr   )r   r   r"   r3  multipart_reader_clsr   part_reader_clsr   r2  r   r   )r   r   r  r  s       r<   rM  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))r2  r  r   r   )r   r   s     r<   r4  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 rD   )r   rn   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   )rT  r   r   r   r   r   r   s     r<   rF  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   TrO   zInvalid boundary z, expected )rT  r   r   r   r   r   r   r   )r   r   epiloguer   s       r<   rG  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   rp   r   r$   parse_headers)r   linesr   parserr   raw_headerss         r<   rL  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)r6  r   r   r   r   r   s    r<   rE  z(MultipartReader._maybe_release_last_part  sx      ?&?))++ 0o--/////////L 7888"DOOO	 '&r;   r   )r@   r   )!r7   r8   r9   r   r   r<  rO  r/   rP  r   rg   r,   r   r   r   r   r   r   classmethodr?  rE   r   r   r   rH  rM  r4  r  rT  rF  rG  rL  rE  r:   r;   r<   r-   r-     s          4  $O'S 1 'L 'T ' ' ' '"	'	(   
	%)>9:	;    " 
"   [    !	%)>9:	;! ! ! !F! ! ! !.	 .0	1. . . .( 
 .0	1   4s    . . . . .
   Y Y Y Y.
 
 
 
# # # # # #r;   r-   c                   Z    e Zd Z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dfdZ% xZ&S )$r.   zMultipart body writer.r   Nr   r   r@   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hexr5  r   UnicodeEncodeErrorr   _boundary_valuer&  r   _partsr   )r   r   r   r  r(  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 rD   r:   r   s    r<   	__enter__zMultipartWriter.__enter__  r   r;   exc_typeexc_valexc_tbc                     d S rD   r:   )r   rl  rm  rn  s       r<   __exit__zMultipartWriter.__exit__  s	     	r;   c                 *    t          | j                  S rD   )iterri  r   s    r<   __iter__zMultipartWriter.__iter__  s    DK   r;   c                 *    t          | j                  S rD   )r   ri  r   s    r<   __len__zMultipartWriter.__len__  s    4;r;   c                     dS )NTr:   r   s    r<   __bool__zMultipartWriter.__bool__  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.
        rb  z*boundary value contains invalid characters   \s   \\   "s   \"rK   )	r   r`   match_valid_tchar_regexr   search_invalid_qdtext_char_regexr   replace)r   rx   quoted_value_contents      r<   rh  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??r;   c                 6    | j                             d          S )Nrb  )r   r   r   s    r<   r   zMultipartWriter.boundary9  s    ~$$W---r;   r>  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   rI  r(   r   updateappend_payloadr*   r&   	TypeError)r   r>  r   payloads       r<   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~   r\   )r  r  r  r  r  )r\   r  r  r  z#unknown content transfer encoding: r  )r   r   r   r   r   keysr   r   ri  r'  r   ro   r	  r   rg   r   )r   r  ry   te_encodingr~   r   s         r<   r  zMultipartWriter.append_payloadL  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   r>  r   s      r<   append_jsonzMultipartWriter.append_jsonr  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   rc  )	rI  r   r   r   listr   r   r  r)   )r   r>  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   NrO      )ri  r   r   r   r   _binary_headers)r   totalr   ry   r  s        r<   r   zMultipartWriter.size  s     +/; 	 	'D(K ; $)*;ttSdn%%& ) d*++	,
   EE 	S(((1,,r;   Tr)  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   --
)ri  r   r   r   r+  r   r  MultipartPayloadWriterenable_compressionenable_encoding	write_eof)r   r)  r  r   ry   r  ws          r<   r+  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)r@   r.   rD   )T)'r7   r8   r9   r   rg   r   r   rk  r   BaseExceptionr   rp  r
   _Partrs  r   ru  rE   rw  r`   compiler|  r~  propertyrh  r   r   r   r(   r   r  r  r   r   r   r  r   r+  r-  r.  s   @r<   r.   r.     s         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&C C# Ct Ct C C C C C C C Cr;   r.   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  r)  r@   Nc                 >    || _         d | _        d | _        d | _        d S rD   )_writer	_encoding	_compress_encoding_buffer)r   r)  s     r<   r   zMultipartPayloadWriter.__init__  s%    (,3759r;   ry   c                 h    |dk    r|| _         t                      | _        d S |dk    r	d| _         d S d S )Nr  r  )r  r   r  )r   ry   s     r<   r  z&MultipartPayloadWriter.enable_encoding  sE    x%DN$-KKD!!!+++/DNNN ,+r;   r  strategyc                 4    t          |d|          | _        d S )NT)ry   r  r  )r   r  )r   ry   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  flushr+  r  r  r  r  	b64encoderV  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  r+  r  b2a_qp)r   r   bufdivmod	enc_chunkb64chunks          r<   r+  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   )r7   r8   r9   r   r   rg   r  zlibZ_DEFAULT_STRATEGYr   r  r  r  r+  r:   r;   r<   r  r    s        :s :t : : : :0 0 0 0 0 0 (9P
 

36
	
 
 
 
	R 	R 	R 	R, ,4 , , , , , ,r;   r  )r}   )Lr  r  r   r`   rd  rl   r  collectionsr   typesr   typingr   r   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,   __all__client_reqrepr4   RuntimeWarningr0   r1   rg   r2   r3   r   r/   	try_firstr!  r-   r  r.   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                        " ! ! ! ! !  .------	 	 	 	 	. 	 	 		 	 	 	 	 	 	 	`$SM`$
8C=$sCx.()`$ `$ `$ `$H ,6 CH%(c]   B," ," ," ," ," ," ," ,"^G@ G@ G@ G@ G@ G@ G@ G@T nEO4447 7 7 7 7G 7 7 547*J# J# J# J# J# J# J# J#Z 	gsC PC PC PC PC PCg PC PC PCf7, 7, 7, 7, 7, 7, 7, 7, 7, 7,r;   