Ë
|
¸^i¢¢ ã óö d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
|
Z
|
m Z d dl m Z d dlmZmZmZmZmZmZmZmZmZmZmZ d dlmZm Z m Z d dl m Z m Z dd l!m"Z" dd
|
l#m$Z$m%Z%m&Z& dd l'm(Z(m)Z)m*Z*m+Z+m,Z, dd l-m.Z.m/Z/m0Z0m1Z1 dd l2m3Z3 ddl4m5Z5 ddl6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z= ddl>m?Z? ej dk\ rd dlmAZA nd dlmBZB eBdd¬« ZAdZCerddlDmEZE G d deF« ZG G d d eF« ZHd eeI d eeeI eeIeIf f fd ZJ d/d e
|
eIeIf d!eId eeI fd"ZK G d# d$« ZL G d% d« ZM e=eMe9j ¬&« G d' d(e:« « ZO G d) d*« ZPee:eIeIf ZQ G d+ d,e:« ZR G d- d.« ZSy)0é N)Údeque)ÚMappingÚSequence)Ú TracebackType) Ú TYPE_CHECKINGÚAnyÚ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)Úinternal_logger)Ú JsonPayloadÚ LookupErrorÚOrderÚPayloadÚ StringPayloadÚ get_payloadÚ payload_type)Ú StreamReader)é é )ÚSelf)ÚTypeVarr1 ÚBodyPartReader)Úbound)ÚMultipartReaderÚMultipartWriterr3 ÚBadContentDispositionHeaderÚBadContentDispositionParamÚparse_content_dispositionÚ content_disposition_filename)ÚClientResponsec ó e Zd Zy)r7 N©Ú__name__Ú
|
__module__Ú __qualname__© ó õd H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/multipart.pyr7 r7 M ó ØrB r7 c ó e Zd Zy)r8 Nr= rA rB rC r8 r8 Q rD rB r8 ÚheaderÚreturnc ó dt dt fddt dt fd}dt dt ffd }dt dt fd}dt dt fd}dj t t j
|
t « « d d
|
t d t dt fd }| sd i fS | j d « ^}} |« s"t j t | « « d i fS i }|r*|j d« } | s t j t | « « 5d| vr"t j t | « « d i fS | j dd« \ }
|
} |
|
j « j « }
|
| j « } |
|
|v r"t j t | « « d i fS |
|
« s t j t | « « ë ||
|
« r> || « r || dd « } n | « st j t | « « 1 ||
|
« rT || « r | j dd« \ } } } | xs d} n t j t | « « ~ t! | | d« } nd} || « r d} || dd j d« « } nL | « rd}nA|r?| d |d } ||« r-|j d« ||dd j d« « } d}|r"t j t | « « d i fS | ||
|
< |r*|j « |fS # t" $ r" t j t | « « Y iw xY w)NÚstringrG c ó@ t | « xr t t | « k\ S ©N)Úboolr" Úset©rI s rC Úis_tokenz+parse_content_disposition.<locals>.is_tokenX s ÜF|Ò4¤¬¨V«Ñ 4Ð4rB c ó. | d | d cxk( xr dk( S c S )Nr éÿÿÿÿú"rA rN s rC Ú is_quotedz,parse_content_disposition.<locals>.is_quoted[ s ØayF 2JÖ-¨#Ñ-Ð-Ñ-Ð-rB c ó@ | « xr | j d« dk( S )Nú'é )Úcount)rI rO s rC Ú
|
is_rfc5987z-parse_content_disposition.<locals>.is_rfc5987^ s! ø ÙÓ Ò: F§L¡L°Ó$5¸Ñ$:Ð:rB c ó$ | j d« S )NÚ*)ÚendswithrN s rC Úis_extended_paramz4parse_content_disposition.<locals>.is_extended_parama s ØsÓ#Ð#rB c ó | j d« dz }|sy| j d« r| |d n| |d }|j « S )NrZ r FrQ )Úfindr[ Úisdigit)rI ÚposÚ substrings rC Úis_continuous_paramz6parse_content_disposition.<locals>.is_continuous_paramd sH Økk#Ó Ñ"ÙØØ&,§o¡o°cÔ&:F3rNÀÀsÀtÀ Ø× Ñ Ó"Ð"rB Ú )ÚcharsÚtextrd c ó8 t j d| dd| « S )Nz\\([z])z\1)ÚreÚsub)re rd s rC Úunescapez+parse_content_disposition.<locals>.unescapek s Üvvug RÐ(¨%°Ó6Ð6rB ú;r ú=r rQ rU rV úutf-8ÚstrictTFz\/)ÚstrrL ÚjoinÚmaprg Úescaper! ÚsplitÚwarningsÚwarnr7 ÚpopÚlowerÚstripÚlstripr8 r ÚUnicodeDecodeError)rF rS rX r\ rb ri ÚdisptypeÚpartsÚparamsÚitemÚkeyÚvalueÚencodingÚ_ÚfailedÚ_valuerO s @rC r9 r9 U s ø ð5ð 5¤ó 5ð.#ð .¤$ó .ð;3ð ;¤4õ ;ð$¤#ð $¬$ó $ð#¤Cð #¬Dó #ð -/¯G©G´C¼¿ ¹ Ä4Ó4HÓ,Iò 7sð 7¤cð 7Ìcó 7ñ ØRxà || CÓ(ÐHuÙ HÔ Ü Ô1°&Ó9Ô:ØRxà FÚ
|
Øyy|áÜ MMÔ5°fÓ=Ô >Ø à d?Ü MMÔ5°fÓ=Ô >Ø8OàZZ QÓ'
|
UØiik× Ñ Ó!Ø à &=Ü MMÔ5°fÓ=Ô >Ø8Oá}Ü MMÔ4°TÓ:Ô ;Ø á Ô %ÙÔ Ù q¨ Ó-Ù e_Ü Ô 8¸Ó >Ô?Ùá sÔ #Ù%Ô Ø%*§[¡[°°aÓ%8Ñ"!UØ#Ò. wä Ô 8¸Ó >Ô?Ùð Ü x°Ó:ð FÙÔ Ø Ù q¨ ×!3Ñ!3°EÓ!:Ó;Ù% Ø Ùð "7 ! E¨!¡H :Ð.Ù VÔ$ØIIaLÙ $ V¨A¨b \×%8Ñ%8¸Ó%?Ó @EØ "FáÜ Ô 9¸&Ó AÔBØRxàs óA ðD >>Ó VÐ #Ð#øô5 &ò Ü Ô 8¸Ó >Ô?Úð ús É L Ì 'MÍMr| Únamec óÊ
|
d|z
|
| sy
|
| v r|
|
S || v r| | S g }t
|
fd| j « D « « }t |« D ]T \ }\ }}|j dd« \ }}|j d« r|d d }|t |« k( r|j |« T n |sy dj |« }d|v r)|j dd« \ } }}| xs d } t || d
|
« S |S ) Nz%s*c 3 óP K | ] \ }}|j « s||f y wrK )Ú
|
startswith)Ú.0r~ r Úname_sufs rC ú <genexpr>z/content_disposition_filename.<locals>.<genexpr>È s) øè ø ò
|
Ù 'S %¸S¿^¹^ÈHÕ=US%Lñ
|
ùs & &rZ r rQ rc rU rV rl rm ) ÚsortedÚitemsÚ enumeraterr r[ rn Úappendro r ) r| r r{ ÚfnparamsÚnumr~ r r Útailr r s @rC r: r: ¼ s ø ð t|HÙ ØØ VÑ ØhÑ Ð Ø Ød|ÐàÜó
|
Ø+1¯<©<«>ô
|
ó
|
ô "+¨8Ó!4ò Ñ C #uØii QÓ'GAtØ}}SÔ!ØCRyØs3xÒ Ø UÕ#áð ñ ØØØ %<Ø!&§¡¨S°!Ó!4Ñ HaØ Ò* 7HÜ5 (¨HÓ5Ð 5Ø rB c ój e Zd ZdZ d dZd dZded fdZdefdZ de
|
ed fd Z d d
|
Z y)ÚMultipartResponseWrapperzzWrapper around the MultipartReader.
|
|
It takes care about
|
underlying connection and close it when it needs in.
|
rG Nc ó || _ || _ y rK )ÚrespÚstream)Úselfr r s rC Ú__init__z!MultipartResponseWrapper.__init__ä s ð
|
Ø rB c ó | S rK rA ©r s rC Ú __aiter__z"MultipartResponseWrapper.__aiter__ì ó Ø rB )r5 r3 c óR K | j « d { }|t |S 7 wrK ©ÚnextÚStopAsyncIteration©r Úparts rC Ú __anext__z"MultipartResponseWrapper.__anext__ï ó+ è ø ð YY[× Ø <Ü$Ð $Ø ð !úó '%'c óJ | j j j « S )z2Returns True when all response data had been read.)r ÚcontentÚat_eofr s rC r¨ z MultipartResponseWrapper.at_eof÷ s àyy× Ñ ×'Ñ'Ó)Ð)rB c ó¾ K | j j « d{ }| j j « r| j « d{ |S 7 87 w)z#Emits next multipart reader object.N)r r r¨ Úrelease©r r} s rC r z MultipartResponseWrapper.nextû sJ è ø ð [[×%Ñ%Ó'×'Ø ;;× Ñ Ô Ø,,.× Ð Ø ð (øà ús! A A¡1A ÁAÁA ÁA c óT K | j j « d{ y7 w)z_Release the connection gracefully.
|
|
All remaining content is read to the void.
|
N)r rª r s rC rª z MultipartResponseWrapper.release s è ø ð
|
ii× Ñ Ó!×!Ò!ús ( &¡()r r; r r5 rG N)rG r ©rG N) r> r? r@ Ú__doc__r r r r£ rL r¨ r r rª rA rB rC r r Ý si ñð à ð ð "ð ð
|
ó óðà Ð2Ñ 3óð*ó *ðà %Ð;Ñ<Ñ =óô"rB r c óÌ e Zd ZdZdZddeddeddd ed
|
ed e e d e
|
d dfdZ de d e fdZ d efdZd e e fdZddded efdZefde
|
d efdZde
|
d efdZde
|
d efdZd efdZd+d Zdd d e e d efd Zdd d e e d e eeef fd Zdd d e e d ee eef fd!Z d efd"Z d#ed efd$Z d#ed efd%Z d#ed efd&Z!d'ed efd(Z"e#d e e fd)« Z$e#d e e fd*« Z%y),r3 z&Multipart reader for single body part.i ÚmixedN)ÚsubtypeÚdefault_charsetÚmax_decompress_sizeÚboundaryÚheadersúCIMultiDictProxy[str]r§ r± r² r³ rG c ól || _ || _ t |« dz | _ || _ || _ d| _ |dk( | _ | j rd n | j j t d « }| t |« nd | _ d| _ t « | _ d | _ d| _ i | _ || _ y )NrV 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 rC r zBodyPartReader.__init__ s© ð Ø!Ü ]¨QÑ .ÔØ Ø /Ô Ø Ø $¨ Ñ 3Ôà ×+Ò+°· ± ×1AÑ1AÄ.ÐRVÓ1WØ&,Ð&8s6{¸d Ø ÔÜ%*£W Ø,0ÔØ ÔØ&( Ø$7Õ!rB r c ó | S rK rA r s rC r zBodyPartReader.__aiter__, r rB c óR K | j « d { }|t |S 7 wrK r r¡ s rC r£ zBodyPartReader.__anext__/ s) è ø ØYY[× Ø <Ü$Ð $Ø ð !úr¥ c óH K | j « d { }|sy |S 7 wrK )Úreadr« s rC r zBodyPartReader.next5 s$ è ø ØYY[× ÙØØ ð !ús "
|
"F©ÚdecoderÏ c ó K | j ryt « }| j s?|j | j | j « d{ « | j s?|r| j |« d{ S |S 7 27 w)z»Reads body part data.
|
|
decode: Decodes data following by encoding
|
method from Content-Encoding header. If it missed
|
data remains untouched
|
rB N)r¾ Ú bytearrayÚextendÚ
|
read_chunkÚ
|
chunk_sizerÏ )r rÏ Údatas rC rÍ zBodyPartReader.read; sh è ø ð <<ØÜ{Ø,,Ø KKdoo¨d¯o©oÓ >×>Ô ?ð ,,á Ø TÓ*×*Ð *Ø ð ?øà*ús* A BÁBÁBÁ%BÁ;BÁ<BÂBÚsizec óD K | j ry| j r| j |« d{ }n| j |« d{ }| j j t « }|r)|j « dk( rdj |j « « }t |« dz }|dk7 rã| j « sÓd|z
|
}d}| j r,| j d| }| j t |« d | _ t |« |k7 r2|| j j dt |« z
|
« d{ z }|sd| _ |dj |j « « z }||z }t |« dz }|dk7 r| j « sÓ| xj t |« z c_ | j | j k( rd| _ | j r0| j j! « d{ dk7 r t# d« |S 7 æ7 Ï7 Ü7 w) zWReads body part content chunk of the specified size.
|
|
size: chunk size
|
rB 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 rv ro rr rº r¨ rÅ r¼ rÍ rà ÚreadlineÚ
|
ValueError)r rÖ Úchunkr Ústripped_chunkÚ remainderÚover_chunk_sizeÚ
|
over_chunks rC rÓ zBodyPartReader.read_chunkK sÔ è ø ð
|
<<ØØ <<Ø ×6Ñ6°tÓ<×<Eà ×6Ñ6°tÓ<×<Eð <<×#Ñ#Ô$=Ó>Ú Ó(¨HÓ4Ø XX e§k¡k£mÓ 4NÜNÓ+¨aÑ/Iàq.¨¯©¬ Ø"# i¡-Ø
|
à×#Ò#Ø!%×!1Ñ!1Ð2B°?Ð!CJØ'+×'7Ñ'7¼¸J»Ð8IÐ'JDÔ$äz? oÒ5Ø ¨¯ © ×(:Ñ(:¸1¼sÀ:»Ñ;NÓ(O×"OÑOJá!Ø#'DLà #§(¡(¨:×+;Ñ+;Ó+=Ó">Ñ>ØÑ#Ü Ó /°!Ñ 3 ð! q.¨¯© ð$ ×ÒC JÑ&ÕØ × Ñ t||Ò +Ø DLØ << $§-¡-×"8Ñ"8Ó":× :¸gÒ EÜ Ð RÓSÐ SØ ðE =ùà<ùð$ #Pøð ;úsN .H °H±H Á
|
HÁ C4H Ä?H Å AH ÆA'H ÈH ÈH ÈH È H È H c ó K | j J d« t || j | j z
|
« }| j j |« d { }| j j « rd| _ |S 7 'w)Nz(Content-Length required for chunked readT)r Úminrà r¼ rÍ r¨ r¾ )r rÖ rÔ rß s rC rÛ z&BodyPartReader._read_chunk_from_lengthw sq è ø ð ||Ð'ÐSÐ)SÓSÐ'Üt||¨d×.>Ñ.>Ñ >Ó?
|
Ømm×(Ñ(¨Ó4×4Ø ==× Ñ Ô !Ø DLØ ð 5ús ABÁA?Á(Bc
|
óì K || j k\ sJ d« | j d u }|r+d| j j |« d { z | _ d}t |« | j k r|| j j |« d { z }| xj
|
t | j j « « z c_ | j
|
dkD r t d« | j
|
rnt |« | j k rt |« |kD r#| j j ||d « |d | }| j J | j |z }d| j z }|r|j |« }n;|j |t dt | j « t |« z
|
« « }|dk\ rt j « 5 t j dt ¬« | j j ||d « d d d « | j d | | _ |t | j « | }|sd | _ | j |rdndd }|| _ |S 7 7 Ø# 1 sw Y `xY ww)
|
Nz<Chunk size must be greater or equal than boundary length + 2rÚ rB rV zReading after EOFr Úignore)ÚcategoryT)r» rÅ r¼ rÍ rº rÆ rÁ r¨ rÞ Ú unread_datar¹ r^ Úmaxrs Úcatch_warningsÚfilterwarningsÚDeprecationWarningr¾ )r rÖ Ú first_chunkrß Úwindowrh ÚidxÚresults rC rÜ z&BodyPartReader._read_chunk_from_stream sC è ø ð D×&Ñ&Ò &ð Jà Ió JØ &à×&Ñ&¨$Ð. Ù à &¨t¯}©}×/AÑ/AÀ$Ó/G×)GÑ GDÔ àô %j4×-Ñ-Ò-Ø 4==×-Ñ-¨dÓ3×3Ñ 3EØ × Ò ¤ T§]¡]×%9Ñ%9Ó%;Ó!<Ñ <Õ Ø× Ñ 1Ò$Ü Ð!4Ó5Ð5Ø× Ò Øô %j4×-Ñ-Ó-ô u:Ò Ø MM× %Ñ % e¨D¨E lÔ 3Ø%4LEà× Ñ Ð+Ð+Ð+Ø×!Ñ! EÑ)ØÑ&Ù Ø++cÓ"Cà++c¤3 q¬#¨d×.>Ñ.>Ó*?Ä#ÀcÃ(Ñ*JÓ#KÓLCØ !8ä×(Ñ(Ó*ñ 8Ü×'Ñ'¨Ô;MÕNØ ×)Ñ)¨&°°¨,Ô7÷ 8ð $× /Ñ /°°Ð 5DÔ Ø3t× /Ñ /Ó0°3Ð7EÙØ # Ø×!Ñ!¡{¡!¸Ð";Ð<Ø ÔØ ðE *Hùð 4ù÷& 8ð 8üsF AI4ÁI"Á AI4 I%ÂA;I4Ä
|
CI4Ç:I(È AI4É%I4É(I1É-I4c óh K | j ry| j r| j j « }n"| j j « d{ }|j | j « r[|j d« }| j }| j dz }||k( s||k( r#d| _ | j j |« y|S | j j « d{ }|j | j « r|dd }| j j |« |S 7 Ù7 Cw)z Reads body part by line by line.rB NrÚ ó --Téþÿÿÿ) r¾ rÄ Úpopleftr¼ rÝ r r¹ Úrstripr )r ÚlineÚsliner´ Ú last_boundaryÚ next_lines rC rÝ zBodyPartReader.readline® sý è ø à <<Øà <<Ø<<×'Ñ'Ó)Dà ×/Ñ/Ó1×1Dà ??4>>Ô *ð KK Ó(EØ~~HØ NN¨UÑ 2MàÒ E¨]Ò$:Ø # Ø ×#Ñ# DÔ)Øð ð #mm× 4Ñ 4Ó 6×6IØ×#Ñ# D§N¡NÔ3ØCRyØ LL× Ñ Ô *à ð' 2øð 7ús& AD2ÁD.ÁBD2Ã,D0Ã-AD2Ä0D2c ó¤ K | j ry| j s1| j | j « d{ | j s0yy7 w)z0Like read(), but reads all the data to the void.N)r¾ rÓ rÔ r s rC rª zBodyPartReader.releaseË s9 è ø à <<Ø Ø,,Ø// $§/¡/Ó2× 2Ð 2ð ,,Ø 2ús 8AºA»AÁ A)r r c ó K | j d¬« d{ }|xs | j d¬« }|j |« S 7 +w)z;Like read(), but assumes that body part contains text data.TrÎ Nrl ©Údefault)rÍ Ú get_charsetrÏ ©r r rÕ s rC re zBodyPartReader.textÒ sG è ø àYY dYÓ+×+ð Ò@t× /Ñ /¸Ð /Ó @Ø{{8Ó$Ð$ð ,ús AA,Ac óò K | j d¬« d{ }|sy|xs | j d¬« }t t t t
|
f t j |j |« « « S 7 \w)z<Like read(), but assumes that body parts contains JSON data.TrÎ Nrl rý ) rÍ rÿ r r
|
rn r ÚjsonÚloadsrÏ r s rC r zBodyPartReader.jsonÚ sc è ø àYY dYÓ+×+ÙØØÒ@t× /Ñ /¸Ð /Ó @ÜDcN¤D§J¡J¨t¯{©{¸8Ó/DÓ$EÓFÐFð ,ús A7A5A A7c ó
|
K | j d¬« d{ }|sg S ||}n| j d¬« } |j « j |« }t |d|¬« S 7 M# t $ r t d|z « w xY ww)zFLike read(), but assumes that body parts contain form urlencoded data.TrÎ Nrl rý z'data cannot be decoded with %s encoding)Úkeep_blank_valuesr )rÍ rÿ rö rÏ ry rÞ r )r r rÕ Ú real_encodingÚ decoded_datas rC ÚformzBodyPartReader.formâ s è ø àYY dYÓ+×+ÙØIØ Ð Ø $Mà × ,Ñ ,°WÐ ,Ó =Mð XØ ;;=×/Ñ/° Ó>Lô Ø Ø "Ø"ô
|
ð
|
ð ,ùô "ò XÜ Ð FÈ Ñ VÓWÐ Wð Xüs& BA& B¹ A( ÁBÁ(B Â Bc ó | j S )z<Returns True if the boundary was reached or False otherwise.©r¾ r s rC r¨ zBodyPartReader.at_eofö ó à||ÐrB rÕ c óÆ K t | j v r| j |« }| j s+t | j v r| j |« d{ S |S 7 w)zDecodes data.
|
|
Decoding is done according the specified Content-Encoding
|
or Content-Transfer-Encoding headers value.
|
N)r rµ Ú_decode_content_transferr¿ r Ú_decode_content)r rÕ s rC rÏ zBodyPartReader.decodeú sW è ø ô %¨¯ © Ñ 4Ø×0Ñ0°Ó6Dà×!Ò!Ô&6¸$¿,¹,Ñ&FØ ×-Ñ-¨dÓ3×3Ð 3Ø ð 4ús AA!ÁA ÁA!c óü K | j j t d« j « }|dk( r|S |dv r0t |d¬« j || j ¬« d { S t d| « 7 w)Nrc Úidentity> ÚgzipÚdeflateT)r Úsuppress_deflate_header)Ú
|
max_lengthúunknown content encoding: )rµ rÀ r rv r Ú
|
decompressrÈ Ú RuntimeError©r rÕ r s rC r z BodyPartReader._decode_content s è ø Ø<<×#Ñ#Ô$4°bÓ9×?Ñ?ÓAØ zÒ !ØKØ Ð*Ñ *Ü)Ø!Ø(,ô÷ j¨$×*CÑ*CjÓD÷Eð Eô
|
Ð 7¸°zÐBÓCÐCð Eús A%A<Á'A:Á(A<c óî | j j t d« j « }|dk( rt j
|
|« S |dk( rt j |« S |dv r|S t d| « )Nrc rØ úquoted-printable)ÚbinaryÚ8bitÚ7bitú#unknown content transfer encoding: ) rµ rÀ r rv rØ Ú b64decodeÚbinasciiÚa2b_qpr r s rC r z'BodyPartReader._decode_content_transfer st Ø<<×#Ñ#Ô$=¸rÓB×HÑHÓJà xÒ Ü×#Ñ# DÓ)Ð )Ø Ð+Ò +Ü?? 4Ó(Ð (Ø Ð3Ñ 3ØKä Ð!DÀXÀJÐ OÓPÐ PrB rþ c ó¬ | j j t d« }t |« }|j j d| j
|
xs |« S )z>Returns charset parameter from Content-Type header or default.rc Úcharset)rµ rÀ r r# Ú
|
parametersr½ )r rþ ÚctypeÚmimetypes rC rÿ zBodyPartReader.get_charset sF à × Ñ ¤ ¨rÓ2Ü! %Ó(Ø×"Ñ"×&Ñ& y°$×2GÑ2GÒ2RÈ7ÓSÐSrB c óp t | j j t « « \ }}t |d« S )z|Returns name specified in Content-Disposition header.
|
|
If the header is missing or malformed, returns None.
|
r ©r9 rµ rÀ r r: ©r r r| s rC r zBodyPartReader.name% s/ ô .¨d¯l©l×.>Ñ.>Ô?RÓ.SÓT 6Ü+¨F°FÓ;Ð;rB c óp t | j j t « « \ }}t |d« S )zReturns filename specified in Content-Disposition header.
|
|
Returns None if the header is missing or malformed.
|
Úfilenamer( r) s rC r+ zBodyPartReader.filename. s/ ô .¨d¯l©l×.>Ñ.>Ô?RÓ.SÓT 6Ü+¨F°JÓ?Ð?rB r )&r> r? r@ r® rÔ r Úbytesr. rn r rÁ r r1 r r£ r rL rÍ rÓ rÛ rÜ rÝ rª re r
|
r r r r r r¨ rÏ r r rÿ r$ r r+ rA rB rC r3 r3 s Ù0àJð Ø)-Ø#>ò8àð8ð )ð8ð ð 8ð ð 8ð " # ð8ð !ð8ð
|
ó8ð6ð ó ð ó ð H UOó ð ,1ò Dð °Uó ð ,6ñ * Sð *¸%ó *ðX°#ð ¸%ó ð+°#ð +¸%ó +ðZ ó ó:3ð 7;ò % h¨s¡mð %¸só %ð 7;ò G h¨s¡mð G¸xÈÈSÐRUÈXÉÑ?Wó Gð 7;ò
|
h¨s¡mð
|
¸tÀEÈ#ÈsÈ(ÁOÑ?Tó
|
ð( ó ð ð ¨5ó ð
|
D¨%ð
|
D°Eó
|
Dð
|
Q¨Uð
|
Q°uó
|
QðT 3ð T¨3ó Tð ð<hsmò <ó ð<ð ð@( 3-ò @ó ñ@rB )Úorderc óx e Zd ZU eed< dedededdf fd Zdded edefd
|
Zdded ede fd Z
|
d e ddfd Z xZ S )ÚBodyPartReaderPayloadr r ÚargsÚkwargsrG Nc óÆ t | |g|¢i |¤ i }|j |j |d< |j |j |d< |r | j di |¤ y y )Nr r+ )Ú
|
attachmentT)Úsuperr r r+ Úset_content_disposition)r r r0 r1 r| Ú __class__s rC r z BodyPartReaderPayload.__init__= si ø Ü ÑÐ0 Ò0¨Ò0à!#Ø ::Ð !Ø "ZZF6NØ >>Ð %Ø!&§ ¡ F:Ñ á Ø (D× (Ñ (Ñ F¸vÓ Fð rB r Úerrorsc ó t d« )NzUnable to decode.©Ú TypeError©r r r7 s rC rÏ z BodyPartReaderPayload.decodeI s ÜÐ+Ó,Ð,rB c ó K t d« w)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.r9 r; s rC Úas_bytesz BodyPartReaderPayload.as_bytesL s è ø ô ÐTÓUÐUùs Úwriterc ó K | j }|j d¬« d { }|rN|j |j |« d { « d { |j d¬« d { }|rMy y 7 U7 17 '7 w)Ni )rÖ )r rÓ ÚwriterÏ )r r> Úfieldrß s rC r@ zBodyPartReaderPayload.writeV sr è ø Ø Ø×&Ñ&¨EÐ&Ó2×2ÙØ,, U§\¡\°%Ó%8× 8Ó9× 9Ð 9Ø ×*Ñ*°Ð*Ó6×6Eô ð 3øà 8øÐ 9øØ6úsK "B¤A:¥%BÁ
|
A<Á BÁA>ÁBÁ0B Á1BÁ8BÁ<BÁ>BÂ B©rl rm )r> r? r@ r3 Ú__annotations__r r rn rÏ r, r= r r@ Ú __classcell__©r6 s @rC r/ r/ 8 s| ø
à Óð
|
Gnð
|
G°Sð
|
GÀCð
|
GÈDõ
|
Gñ-sð -°cð -Èó -ñV sð V¸cð VÐQVó Vð7Ð"6ð 7¸4÷ 7rB r/ c ó0 e Zd ZU dZeZdZeed e d< e
|
Z de e e f deddfdZdedefd Zdeed e
|
f fd
|
Zed d defd « ZdefdZdeed e
|
f fdZddZded e
|
f fdZddded e
|
f fdZde fdZ de fdZ ddZ ddZ ddZ!ddZ"y) r5 zMultipart body reader.NÚmultipart_reader_clsrµ r§ rG c óz t |t « | _ | j j dk( sJ d« d| j j vrt d|t z « || _ d| j « z j « | _ || _
|
d | _ d | _ d| _ d| _ g | _ y )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 rC r zMultipartReader.__init__i s¯ Ü'¨´ Ñ(=Ó>Ø~~×"Ñ" kÒ1ÐVÐ3VÓVÐ1Ø T^^× 6Ñ 6Ñ 6Ü Ø6¸Ä Ñ9NÑNóð ð Ø ×!3Ñ!3Ó!5Ñ5×=Ñ=Ó?Ø Ø/3Ô ØNRØ Ø Ø$& rB r c ó | S rK rA r s rC r zMultipartReader.__aiter__z r rB c óR K | j « d { }|t |S 7 wrK r r¡ s rC r£ zMultipartReader.__anext__} r¤ r¥ Úresponser; c ó` | j | | |j |j « « }|S )zConstructs reader instance from HTTP response.
|
|
:param response: :class:`~aiohttp.client.ClientResponse` instance
|
)Úresponse_wrapper_clsrµ r§ )ÚclsrS Úobjs rC Ú from_responsez MultipartReader.from_response
s3 ð ×&Ñ&Ø c(×*Ñ*¨H×,<Ñ,<Ó=ó
|
ð
|
rB c ó | j S )z@Returns True if the final boundary was reached, false otherwise.r
|
r s rC r¨ zMultipartReader.at_eof r rB c ó. K | j ry| j « d{ | j r | j « d{ d| _ n| j « d{ | j ry| j « d{ }| j Õ| j j dk( r¼t |t « r¬t |j j t « « \ }}|j d« dk( rm|j d« d{ }t! |« dkD r t# d« |j% « j' « | _ | j « d{ }|| _ | j S 7 b7 A7 $7 7 w7 %w) z#Emits the next multipart body part.NFr¸ r Ú _charset_é é zInvalid default charset)r¾ Ú_maybe_release_last_partrP Ú_read_until_first_boundaryÚ_read_boundaryÚfetch_next_partrO rK r± Ú
|
isinstancer3 r9 rµ rÀ r rÓ rº r rw rÏ r½ )r r¢ r r| r# s rC r zMultipartReader.next sM è ø ð
|
<<ØØ×+Ñ+Ó-×-Ð-Ø <<Ø×1Ñ1Ó3× 3Ð 3Ø DLà×%Ñ%Ó'× 'Ð 'Ø <<Øà×)Ñ)Ó+×+ð OOÐ #Ø×&Ñ&¨+Ò5Ü4¤ Ô0ä1°$·,±,×2BÑ2BÔCVÓ2WÓXIAvØzz&Ó! [Ò0ð !%§¡°Ó 3×3Üw< "Ò$Ü&Ð'@ÓAÐAØ(/¯ © «×(>Ñ(>Ó(@Ô%Ø !× 1Ñ 1Ó 3×3Ø ØÐ ð5 .ùà 3ùð (ùð ,ùð 4øð 4úsk !F£F¤#FÁFÁ FÁ'F Á($F F B FÄFÄAFÅ-FÅ.FÆFÆ FÆFÆFÆFc ó® K | j sA| j « d{ }|y|j « d{ | j s@yy7 .7 w)z=Reads all the body parts to the void till the final boundary.N)r¾ r rª r« s rC rª zMultipartReader.releaseº sD è ø à,,Ø ×$DØ|ØØ,,.× Ð ð ,,Ø$øð !ús% A¢A£A½A¾AÁAÁAc ó` K | j « d{ }| j |« S 7 w)z"Returns the next body part reader.N)Ú _read_headersÚ_get_part_reader)r rµ s rC ra z MultipartReader.fetch_next_part s/ è ø ð ×*Ñ*Ó,×,Ø×$Ñ$ WÓ-Ð-ð -ús .,.r¶ c óz |j t d« }t |« }|j dk( rD| j t | « || j
|
« S | j || j
|
« S | j | j || j
|
| j j | j ¬« S )zDispatches the response by the `Content-Type` header.
|
|
Returns a suitable reader instance.
|
|
:param dict headers: Response headers
|
rc rI )r± r² ) rÀ r r# rL rG r¼ Úpart_reader_clsr¹ rK r± r½ )r rµ r% r& s rC rf z MultipartReader._get_part_readerÉ s£ ð L¨"Ó-Ü! %Ó(à ==KÒ 'Ø×(Ñ(Ð0Ø!tDz '¨4¯=©=Ó9Ð9Ø×,Ñ,¨W°d·m±mÓDÐ Dà×'Ñ'ØØØ Ø ×.Ñ.Ø $× 5Ñ 5ð (ó ð rB c óp | j j d }t |« dkD rt d|z « |S )Nr´ éF z&boundary %r is too long (70 chars max))rK r$ rº rÞ )r r´ s rC rM z MultipartReader._get_boundaryã s8 Ø>>×,Ñ,¨ZÑ8Ü x=2Ò Ü Ð EÈÑ PÓQÐ QàrB c ó K | j r| j j « S | j j « d { S 7 wrK )rÄ ru r¼ rÝ r s rC Ú _readlinezMultipartReader._readlineê s9 è ø Ø <<Ø<<×#Ñ#Ó%Ð %Ø]]×+Ñ+Ó-×-Ð-Ð-ús AA ÁA ÁA c óð K | j « d { }|dk( rt d| j z « |j « }|| j k( ry || j dz k( rd| _ y p7 \w)NTrB z#Could not find starting boundary %rró )rl rÞ r¹ rö r¾ ©r rß s rC r_ z*MultipartReader._read_until_first_boundaryï sw è ø ØØ ..Ó*×*EØ|Ü Ø9¸T¿^¹^ÑLóð ð LLNEØÒ&ØØ$..¨5Ñ0Ò0Ø # Øð Ø*ús A6A4A A6c óÎ K | j « d { j « }|| j k( ry || j dz k( ryd| _ | j « d { }| j « d { }|d d dk( r | j j |« y | j j ||g« y t d|d| j « 7 È7 {7 ew)Nró TrV zInvalid boundary z , expected )rl rö r¹ r¾ rÄ r rÒ rÞ )r rß Úepiloguerú s rC r` z MultipartReader._read_boundaryý sË è ø Ø~~Ó'×'×/Ñ/Ó1Ø DNNÒ "Ø Ø dnn uÑ,Ò ,Ø DLØ !^^Ó -×-HØ "nnÓ .×.Ið !} Ò%Ø ×#Ñ# IÕ.ð
|
×#Ñ# Y°Ð$9Õ:ä Ð 0°° ¸ÀTÇ^Á^ÐDVÐ WÓXÐ Xð) (øð
|
.øØ.ús5 C%C AC%Á%C!Á&C%Á=C#Á>A"C%Ã!C%Ã#C%c óä K g } | j j « d { }|j d« }|j |« |snHt « }|j |« \ }}|S 7 Jw)NrÚ )r¼ rÝ rö r r% Ú parse_headers)r Úlinesrß Úparserrµ Ú raw_headerss rC re z MultipartReader._read_headers sp è ø ØØØ --×0Ñ0Ó2×2EØLL Ó)EØ LLÔ ÙØð ô Ø %× 3Ñ 3°EÓ :Ñ Øð 3ús !A0£A.¤A A0c ó K | j s| j j « s"| j j « d{ | j j | j j « d| _ yy7 <w)z8Ensures that the last read body part is read completely.N)rO r¨ rª rÄ rÒ r s rC r^ z(MultipartReader._maybe_release_last_part sa è ø à ??Ð &Ø??×)Ñ)Ô+Øoo×-Ñ-Ó/×/Ð/Ø LL× Ñ §¡× 7Ñ 7Ô 8Ø "DOð 'à/ús ABÁBÁ=Br )rG r¶ )#r> r? r@ r® r rU rG r r rC r3 rh r rn r. r r1 r r r£ Ú classmethodrX rL r¨ r rª ra rf rM r, rl r_ r` re r^ rA rB rC r5 r5 ^ s:
Ù ð 4Ðð ?CÐ( 4Ð(9Ñ#:Ñ;ÓBà$Oð' ¨¨S¨Ñ 1ð '¸Lð 'ÈTó 'ð"ð ó ðà %Ð)¨>Ð9Ñ:Ñ ;óð ð à"ð ð
|
"ò ó ð ð ó ð! à %Ð)¨>Ð9Ñ:Ñ ;ó! óF!ð.à Ð .Ð0Ñ 1ó.ðà(ðð
|
Ð .Ð0Ñ 1óð4só ð. ó .ó
|
ó Yó.
|
ô#rB r5 c ó0 e Zd ZU dZded< dZd%dedee ddf fd Zd&d Z d
|
ee
|
e d ee d ee ddfd Z dee fdZdefdZdefdZ ej, d« Z ej, d« Zedefd« Zedefd« Zd'de dee eef de fdZ de de fdZ d'de dee eef de fdZ! d'de"e#e$eef e eef f dee eef de fdZ%edee fd « Z&d(d ed edefd Z'd(d ed ede(fd Z) d)d!e*d"eddfd#Z+d*d$Z, xZ-S )+r6 zMultipart body writer.Nr Tr± r´ rG c ó ||n t j « j } |j d« | _ d| d| j }t | % d |¬« g | _
|
|dk( | _ y # t
|
$ r t d« d w xY w)NÚasciiz(boundary should contain ASCII only charsz
|
multipart/z ; boundary=)Ú content_typer¸ ) ÚuuidÚuuid4ÚhexrN r¹ ÚUnicodeEncodeErrorrÞ Ú_boundary_valuer4 r Ú_partsr¿ )r r± r´ r% r6 s rC r zMultipartWriter.__init__3 s ø Ø 'Ð 38¼¿¹» ×9IÑ9Ið SØ %__¨WÓ 5DNð WI [°×1EÑ1EÐ0FÐGä ѨEÐÔ2à#% Ø $¨ Ñ 3Õøô "ò SÜ Ð GÓHÈdÐ Rð Sús ¥A0 Á0Bc ó | S rK rA r s rC Ú __enter__zMultipartWriter.__enter__E r rB Úexc_typeÚexc_valÚexc_tbc ó y rK rA )r r r
r s rC Ú__exit__zMultipartWriter.__exit__H s ð rB c ó, t | j « S rK )Úiterr r s rC Ú__iter__zMultipartWriter.__iter__P s ÜDKKÓ Ð rB c ó, t | j « S rK )rº r r s rC Ú__len__zMultipartWriter.__len__S s Ü4;;Ó Ð rB c ó y)NTrA r s rC Ú__bool__zMultipartWriter.__bool__V s ØrB s \A[!#$%&'*+\-.^_`|~\w]+\Zs [\x00-\x08\x0A-\x1F\x7F]c óH | j }t j | j |« r|j d« S t j
|
| j |« r t d« |j dd« }|j dd« }d|j d« z dz S )zzWrap boundary parameter value in quotes, if necessary.
|
|
Reads self.boundary and returns a unicode string.
|
rz z*boundary value contains invalid charactersó \s \\ó "s \"rR ) r¹ rg ÚmatchÚ_valid_tchar_regexrÏ ÚsearchÚ_invalid_qdtext_char_regexrÞ Úreplace)r r Úquoted_value_contents rC r z MultipartWriter._boundary_value\ s ð& Ü 88D×+Ñ+¨UÔ 3Ø<< Ó(Ð (ä 99T×4Ñ4°eÔ <Ü Ð IÓJÐ Jð %}}¨U°GÓ <Ð Ø 3× ;Ñ ;¸DÀ&Ó IÐ àÐ)×0Ñ0°Ó9Ñ9¸CÑ?Ð?rB c ó8 | j j d« S )Nrz )r¹ rÏ r s rC r´ zMultipartWriter.boundary| s à~~×$Ñ$ WÓ-Ð-rB rW rµ c ó |
|
t « }t |t « r,|j j |« | j |« S t ||¬« }| j |« S # t $ r t d|z « w xY w)N©rµ z Cannot create payload from %r) r rb r* rµ ÚupdateÚappend_payloadr, r( r: )r rW rµ Úpayloads rC r zMultipartWriter.append s Ø ?Ü!mGä c7Ô #Ø KK× Ñ wÔ 'Ø×&Ñ& sÓ+Ð +ð 4Ü% c°7Ô;ð ×*Ñ*¨7Ó3Ð3øô ò GÜ Ð ?À#Ñ EÓFÐFð Gús Á
|
A( Á(B r c ó¶ d}d}| j rlt t t h|j j « z rJ t |j vrêdt | j « }|j d|¬« n¾|j j t d« j « }|r|dvrt d| « |dk( rd}|j j t d« j « }|d vrt d
|
| « |d k( rd}|j }| |s |s t |« |j t < | j j |||f« |S ) z)Adds a new body part to multipart writer.Nzsection-r¸ )r rc )r r r r r )rc rØ r r r r )r¿ r r r rµ Úkeysr rº r r5 rÀ rv r rÖ rn r )r r r Ú te_encodingr rÖ s rC r z MultipartWriter.append_payload sU à"&Ø%) Ø × Ò ô &¤~Ô7PÐQØ//×&Ñ&Ó(ò)ð ð)ô #¨'¯/©/Ñ9Ø!¤# d§k¡kÓ"2Ð!3Ð4Ø×/Ñ/° À$Ð/ÕGð ×*Ñ*Ô+;¸RÓ@×FÑFÓHHÙHÐ,KÑ KÜ"Ð%?À¸zÐ#JÓKÐKØ:Ò%Ø ð "//×-Ñ-Ô.GÈÓL×RÑRÓTKØÐ"NÑNÜ"Ð%HÈÈ Ð#VÓWÐWØhÒ&Ø " ð <<DØÐ ©±[Ü25°d³)¤Ñ/à ×ÑG X¨{Ð;Ô<ØrB c óR |
|
t « }| j t ||¬« « S )zHelper to append JSON part.r )r r r' )r rW rµ s rC Ú append_jsonzMultipartWriter.append_jsonµ s( ð ?Ü!mGà×"Ñ"¤;¨s¸GÔ#DÓEÐErB c óð t |t t f« sJ |
|
t « }t |t « rt |j « « }t |d¬« }| j t ||d¬« « S )z&Helper to append form urlencoded part.T)Údoseqz!application/x-www-form-urlencoded)rµ r{ ) rb r r r Úlistr r r r+ )r rW rµ rÕ s rC Ú append_formzMultipartWriter.append_form¾ sn ô #¤¬'Ð 2Ô3Ð3Ð3à ?Ü!mGä c7Ô #Üsyy{Ó#CÜ DÔ)à×"Ñ"Ü ØgÐ4Wô ó
|
ð
|
rB c ó d}| j D ]] \ }}}|j }|s|s| y|t dt | j « z dz |z t |j
|
« z dz « z }_ |dt | j « z dz z }|S )zSize of the payload.r NrV rÙ )r rÖ rÁ rº r¹ Ú_binary_headers)r Útotalr¢ r r¡ Ú part_sizes rC rÖ zMultipartWriter.sizeÓ s³ ð Ø+/¯;©;ò Ñ 'D(KØ IÙ;¨)Ð*;Ùà SØÜdnnÓ%ñ&àñð ñ ô d×*Ñ*Ó+ñ ,ð
|
ñ óñ Eð ð S Ó(Ñ(¨1Ñ,Ñ,Ø rB r r7 c óT dj fd j D « « S )zâReturn 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.
|
rc c 3 ó¦ K | ]H \ }}}d j z dz |j j « z |j « z J yw)rJ z
|
N)r´ r© rÏ )r r¢ Ú_eÚ_ter r7 r s rC r z)MultipartWriter.decode.<locals>.<genexpr>î sb øè ø ò
|
ñ b#ð Ømmñ àñ ð ×"Ñ"×)Ñ)¨(°FÓ;ñ <ð kkmõ ñ
|
ùs AA)ro r r; s ```rC rÏ zMultipartWriter.decodeè s) ú ð wwõ
|
ð "&§¡ô
|
ó
|
ð
|
rB c ó K g }| j D ]~ \ }}}|j d| j z dz « |j |j « |j ||« d{ }|j |« |j d« |j d| j z dz « dj |« S 7 Zw)zReturn bytes representation of the multipart data.
|
|
This method is async-safe and calls as_bytes on underlying payloads.
|
ró rÚ Nó --
|
rB )r r r¹ r© r= ro )r r r7 r{ r¢ r® r¯ Ú
|
part_bytess rC r= zMultipartWriter.as_bytes÷ s´ è ø ð
|
ð "[[ò "MD"cà LL § ¡ Ñ/°'Ñ9Ô :ð LL×-Ñ-Ô .ð $}}¨X°vÓ >×>JØ LLÔ $ð LLÕ !ð "ð UT^^Ñ+¨iÑ7Ô8àxxÐ ð ?ús A'CÁ)CÁ*ACr> Úclose_boundaryc óæ K | j D ]# \ }}}| j r+t |j v sJ d|j t v sJ |j d| j
|
z dz « d{ |j |j « d{ |s|rct |« }|r|j |« |r|j |« |j |« d{ |j « d{ n|j |« d{ |j d« d{ & |r*|j d| j
|
z dz « d{ yy7 ð7 Ï7 7 m7 U7 >7 w)z Write body.zname=ró rÚ Nr± ) r r¿ r rµ r@ r¹ r© ÚMultipartPayloadWriterÚenable_compressionÚenable_encodingÚ write_eof)r r> r³ r¢ r r¡ Úws rC r@ zMultipartWriter.write sO è ø ð ,0¯;©;ó (Ñ 'D(KØ×!Ò!ä*¨d¯l©lÑ:Ð:Ð:Ø $§,¡,Ô/BÑ"CÑCÐCÐCà,,u t§~¡~Ñ 5¸Ñ ?Ó@× @Ð @Ø,,t× 3Ñ 3Ó4× 4Ð 4á;Ü*¨6Ó2ÙØ×(Ñ(¨Ô2Ù Ø×%Ñ% kÔ2Øjj m×#Ð#Økkm×#Ñ#àjj Ó(×(Ð(à,,wÓ'× 'Ò 'ð) (ñ, Ø,,u t§~¡~Ñ 5¸ Ñ AÓB× BÑ Bð ð! AøØ 4øð $øØ#øà(øà 'øð Cús A0E1Á2E#Á3"E1ÂE%ÂA E1Ã#E'Ã$E1Ã;E)Ã<E1ÄE+ÄE1Ä.E-Ä/-E1Å E/Å E1Å%E1Å'E1Å)E1Å+E1Å-E1Å/E1c ó> K | j ryd| _ t | j « D ]< \ }\ }}}|j r|j r$ |j « d{ > y7 # t $ r#}t j d||d¬« Y d}~id}~ww xY ww)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 rC r¿ zMultipartWriter.close/ s è ø ð >>Ø Ø ô "+¨4¯;©;Ó!7ò Ñ C $1Ø>>¨$¯-«-ðØ **,×&Ñ&ñ ð 'ùÜ ò Ü#×)Ñ)Ø?ÀÀcÐTX÷ò ûðüsH A B Á B ÁA.Á$A,Á%A.Á)B Á,A.Á. BÁ7BÂB ÂBÂB )r° N)rG r6 rK rB )Tr ).r> r? r@ r® rC Ú
|
_autoclosern r r r r Ú BaseExceptionr r r Ú_Partr rÁ r rL r rg Úcompiler r Úpropertyr r´ r r r* r r r£ r r r r§ rÖ rÏ r, r= r r@ r¿ rD rE s @rC r6 r6 , s? ø
Ù à LàJñ4 ð 4¸À#¹ ð 4ÐRVõ 4ó$ð à4 Ñ.Ñ/ð ð -Ñ(ð ð Ñ'ð ð
|
|
ó ð!( 5/ó !ð ó ð$ó ð $Ð$AÓBÐØ!+ §¡Ð,HÓ!IÐ à ð @ ò @ó ð @ð> ð.#ò .ó ð.ñ 4#ð 4¨°¸¸c¸Ñ1BÑ(Cð 4Èwó 4ð $ gð $°'ó $ðN @DñFØðFØ!)¨'°#°s°(Ñ*;Ñ!<ðFà óFð 04ñ
|
à 8E # s (OÑ,¨g°c¸3°hÑ.?Ð?Ñ @ð
|
ð ' # s (Ñ+Ñ,ð
|
ð
|
ó
|
ð* ðhsmò ó ðñ(
|
sð
|
°cð
|
Èó
|
ñ sð ¸cð ÐQVó ð8 DHñCØ*ðCØ<@ðCà óC÷:rB r6 c ób e Zd ZdeddfdZdeddfdZ d dedee ddfdZ d d Z
|
d
|
e ddfd Z y)rµ r> rG Nc ó< || _ d | _ d | _ d | _ y rK )Ú_writerÚ _encodingÚ _compressÚ_encoding_buffer)r r> s rC r z MultipartPayloadWriter.__init__J s Ø Ø(,Ø37Ø59Õ rB r c óV |dk( r|| _ t « | _ y |dk( rd| _ y y )NrØ r )rË rÑ rÍ )r r s rC r· z&MultipartPayloadWriter.enable_encodingP s0 Ø xÒ Ø %DNÜ$-£KDÕ !Ø Ð+Ò +Ø /DNð ,rB Ústrategyc ó* t |d|¬« | _ y )NT)r r rÏ )r rÌ )r r rÏ s rC r¶ z)MultipartPayloadWriter.enable_compressionW s ô (Ø Ø$(Ø ô
|
rB c ó^ K | j <| j j « }|r d | _ | j |« d { | j dk( rN| j rA| j
|
j t j | j « « d { y y y 7 b7 w)NrØ )rÌ Úflushr@ rË rÍ rÊ rØ Ú b64encodern s rC r¸ z MultipartPayloadWriter.write_eof` s è ø Ø >>Ð %ØNN×(Ñ(Ó*EÙØ!%Øjj Ó'×'Ð'à >>XÒ %Ø×$Ò$Øll×(Ñ(¬×)9Ñ)9¸$×:OÑ:OÓ)PÓQ×QÑQð %ð &ð (øð Rús% AB-ÁB)ÁAB-Â!B+Â"B-Â+B-rß c ó K | j (|r&| j j |« d { }|sy | j dk( r| j }|J |j |« |rjt t |« d« \ }}|d |dz ||dz d c}| _ |r9t j |« }| j j |« d { y y y | j dk( r7| j j t j |« « d { y | j j |« d { y 7 7 t7 .7 w)NrØ r/ r ) rÌ ÚcompressrË rÍ rÒ Údivmodrº rØ rÓ rÊ r@ r Úb2a_qp)r rß ÚbufÚdivÚmodÚ enc_chunkÚb64chunks rC r@ z MultipartPayloadWriter.writek s' è ø Ø >>Ð %ÙØ "nn× 5Ñ 5°eÓ <×<Ù Øà >>XÒ %Ø×'Ñ'CØ?Ð "?Ø JJuÔ áÜ!¤# c£(¨AÓ.SØ47¸ ¸#À¹'°NÀCÈÈaÉÈ ÀNÐ0 4Ô0Ù Ü %× /Ñ /° Ó :HØ ,,×,Ñ,¨XÓ6×6Ñ6ð ð ð ^^Ð 1Ò 1Ø,,×$Ñ$¤X§_¡_°UÓ%;Ó<× <Ñ <à,,×$Ñ$ UÓ+× +Ñ +ð% =ùð 7øà <øà +úsG -E¯D>°B Eà Eà AEÄEÄ#EÄ8EÄ9EÅEÅEÅE)r Nr ) r> r? r@ r r rn r· r rÁ r¶ r¸ r, r@ rA rB rC rµ rµ I sj ð:Ð 3ð :¸ó :ð 0¨ð 0°ó 0ð DHñ
|
Øð
|
Ø3;¸C±=ð
|
à ó
|
ó Rð, ð ,¨4ô ,rB rµ )r+ )TrØ r r rg Úsysr| rs Ú collectionsr Úcollections.abcr r Útypesr Útypingr 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% Úlogr& r r' r( r) r* r+ r, r- Ústreamsr. Ú version_infor1 r2 Ú__all__Ú client_reqrepr; ÚRuntimeWarningr7 r8 rn r9 r: r r3 Ú try_firstr/ r5 rÅ r6 rµ rA rB rC ú<module>rð s ðÛ Û Û Û Û
|
Û Û Ý ß -Ý ÷ ÷ ÷ ñ ÷ 7Ñ 6ç 3å %÷ñ ÷
|
õ ÷ 8Ó 7Ý Ý ÷÷ ñ õ "à×ÑwÒ Þå á 6Ð!1Ô 2Dð ñ Ý-ô .ô ô ô ðd$Ø SMðd$à
|
8C=$s Cx.Ð (Ñ)ód$ðP ,6ñ Ø CHÑ ð Ø%(ð à c]ó ÷B,"ñ ,"÷^i@ñ i@ñX n E§O¡OÔ4ô"7Gó "7ó 5ð"7÷JH#ñ H#ðV gsCÐ Ñ ôZgô Z÷z7,ò 7,rB
|
