*GjddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z ddlmZddlmZmZmZmZmZddlmZmZmZddlmZmZdd lmZdd lm Z m!Z!dd l"m#Z#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)m*Z*m+Z+m,Z,m-Z-dd l.m/Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;ddldkrddlm?Z?n eddZ?ej>dkrddl m@Z@n eeAeBddfZ@ede@ZCdZDerddlEmFZFGddeGZHGd d!eGZId"eJdzd#eKeJdzeLeJeJfffd$ZM d5d&e eJeJfd'eJd#eJdzfd(ZNGd)d*ZOGd+dZPe;ePe7jQ,Gd-d.e8ZRGd/d0ZSeKe8eJeJfZTGd1d2e8ZUGd3d4ZVdS)6N)deque) AsyncIteratorIteratorMappingSequence) TracebackType) TYPE_CHECKINGAnyTypeVarUnioncast) parse_qslunquote urlencode) CIMultiDictCIMultiDictProxy)AbstractStreamWriter)ZLibCompressorZLibDecompressor)CONTENT_DISPOSITIONCONTENT_ENCODINGCONTENT_LENGTHCONTENT_TRANSFER_ENCODING CONTENT_TYPE)CHARDEFAULT_CHUNK_SIZETOKENparse_mimetypereify) HeadersParser)BadHttpMessage)internal_logger) JsonPayload LookupErrorOrderPayload StringPayload get_payload payload_type) StreamReader) )Selfr.BodyPartReader)bound)r, )Bufferzmemoryview[int]zmemoryview[bytes]_Buffer)MultipartReaderMultipartWriterr/BadContentDispositionHeaderBadContentDispositionParamparse_content_dispositioncontent_disposition_filename)ClientResponseceZdZdS)r6N__name__ __module__ __qualname__Y/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/aiohttp/multipart.pyr6r6CDrAr6ceZdZdS)r7Nr<r@rArBr7r7GrCrAr7headerreturncdtdtfddtdtfd}dtdtffd }dtdtfd}dtdtfd}dttjt d d td tdtfd }|sdifS|d ^}}|s%tj t|difSi}|r| d} | s"tj t|.is_tokenNsF||4V 44rAc:|d|dcxkodkncS)Nr"r@rMs rB is_quotedz,parse_content_disposition..is_quotedQs,ayF2J----#-----rAcL|o|ddkS)N')count)rHrNs rB is_rfc5987z-parse_content_disposition..is_rfc5987Ts)x:FLL$5$5$::rAc,|dS)N*)endswithrMs rBis_extended_paramz4parse_content_disposition..is_extended_paramWss###rAc|ddz}|sdS|dr ||dn ||d}|S)NrYrFrP)findrZisdigit)rHpos substrings rBis_continuous_paramz6parse_content_disposition..is_continuous_paramZsakk#" 5&,ooc&:&:LF3r6NNstt   """rA)charstextrcc6tjd|dd|S)Nz\\([z])z\1)resub)rdrcs rBunescapez+parse_content_disposition..unescapeas"v(u(((%666rA;r=rrPrTrUutf-8strictTFz\/)strrKjoinmaprfescapersplitwarningswarnr6poplowerstriplstripr7rUnicodeDecodeError)rErRrWr[rarhdisptypepartsparamsitemkeyvalueencoding_failed_valuerNs @rBr8r8Ks555555.#.$....;3;4;;;;;;$#$$$$$$#C#D####-/GGC 44H4H,I,I777s7c7c7777 Rx||C((Hu 8H   1&99:::RxF @yy||  M5f== > > >  d?? M5f== > > >8OZZQ'' Uiikk!!  &== M5f== > > >8Ox}}+ M4T:: ; ; ;   % %' y  qt--Xe__  8>>???  s # # z%   %*[[a%8%8"!U#.w 8>>??? x::%    8>>???  Fy # qt!3!3E!:!:;;% # #"..E!H..9V$$#IIaLLL$HVAbD\%8%8%?%?@@E"F  9&AABBBRxs A @D >>  V ##s<K+K=<K=filenamer{namec2 d|z |sdS |vr| S||vr||Sg}t fd|D}t|D]i\}\}}|dd\}}|dr |dd}|t |kr||i|sdSd|}d|vr/|dd\} }}| pd } t|| d S|S) Nz%s*c3PK|] \}}|||fV!dSrJ) startswith).0r}r~name_sufs rB z/content_disposition_filename..sP  'S%S^^H=U=U %L      rArYrrPrbrTrUrkrl) sorteditems enumeraterqrZrmappendrnr) r{rrzfnparamsnumr}r~rtailrrs @rBr9r9sit|H t V  h d|    +1<<>>     "+8!4!4   C#uiiQ''GAt}}S!! !CRCys3xx U#### 4 %<|jjS)z2Returns True when all response data had been read.)rcontentat_eofrs rBrzMultipartResponseWrapper.at_eofsy '')))rAcK|jd{V}|jr|d{V|S)z#Emits next multipart reader object.N)rrrreleaserr|s rBrzMultipartResponseWrapper.nextsh[%%'''''''' ;     !,,..  rAcHK|jd{VdS)z_Release the connection gracefully. All remaining content is read to the void. N)rrrs rBrz MultipartResponseWrapper.releases4 i!!!!!!!!!!!rA)rr:rr4rFN)rFrrFN) r=r>r?__doc__rrr rrKrrrr@rArBrrs "   2 3***** 2 3d :""""""rArceZdZdZdZddeejedde ddd e d e d e dzd e d e de eddfdZdedefdZde fdZde dzfdZdddede fdZefde de fdZde de fdZde de fdZde fdZd1dZddd e dzde fd!Zddd e dzdee efdzfd"Zddd e dzdee e e ffd#Z!defd$Z"d%e#de#e zfd&Z$defd'Z%d%e#de#e zfd(Z&d%e#de'e#e zfd)Z(d%e#de#e zfd*Z)d%e#de'e#e zfd+Z*d%e#de#e zfd,Z+d-e de fd.Z,e-de dzfd/Z.e-de dzfd0Z/dS)2r/z&Multipart reader for single body part.i mixedN)subtypedefault_charsetmax_decompress_sizeclient_max_sizemax_size_error_clsboundaryheadersCIMultiDictProxy[str]rrrrrrrFc||_||_t|dz|_||_||_d|_|dk|_|jrdn|jtd} | t| nd|_ d|_ t|_d|_d|_i|_||_||_||_dS)NrUF form-datar)r _boundarylen _boundary_len_content_default_charset_at_eof _is_form_datagetrint_length _read_bytesr_unread _prev_chunk _content_eof_cache_max_decompress_size_client_max_size_max_size_error_cls) rrrrrrrrrlengths rBrzBodyPartReader.__init__s ! ]]Q. / $ 3+W1A1A.RV1W1W&,&8s6{{{d %*WW )-&( $7! /#5   rArc|SrJr@rs rBrzBodyPartReader.__aiter__&rrAcPK|d{V}|t|SrJrrs rBrzBodyPartReader.__anext__)s5YY[[       <$ $ rAcFK|d{V}|sdS|SrJ)readrs rBrzBodyPartReader.next/s7YY[[       4 rAFdecoderc K|jrdSt}|jsl|||jd{Vt ||jkr||j|jl|rut}||23d{V}||t ||jkr||jO6|S|S)zReads body part data. decode: Decodes data following by encoding method from Content-Encoding header. If it missed data remains untouched rAN) r bytearrayextend read_chunk chunk_sizerrr decode_iter)rrdata decoded_datads rBrzBodyPartReader.read5s= < 3{{, F KKdoodo>>>>>>>> ? ? ?4yy4000..t/DEEE, F  $;;L++D11 J J J J J J Ja##A&&&|$$t'<<<2243HIII=2  s2Dsizec^K|jrdS|jr||d{V}n||d{V}|jt }|rT|dkr;d| }t|dz}|dkr| sd|z }d}|j r0|j d|}|j t|d|_ t||kr3||j dt|z d{Vz }|sd|_|d| z }||z }t|dz}|dkr| |xjt|z c_|j|jkrd|_|jr2|j d{Vdkrt#d|S) zWReads body part content chunk of the specified size. size: chunk size rANbase64rT z3Reader did not read all the data or it is malformed)rr_read_chunk_from_length_read_chunk_from_streamrrrrurnrqrrrrrrreadline ValueError)rrchunkrstripped_chunk remainderover_chunk_size over_chunks rBrzBodyPartReader.read_chunkLsR < 3 < =66t<<<<<<<>  4((H44 XXekkmm44NN++a/Iq..."#i- #K!%!12B?2B!CJ'+'7J8I8I'JD$z??o55 (:(:1s:;N(O(O"O"O"O"O"O"OOJ!(#'DL#((:+;+;+=+=">">>#//!3 !q...$ CJJ&  t| + +DL < T$-"8"8":":::::::gEERSS S rAcK|j Jdt||j|jz }|j|d{V}|jrd|_|S)Nz(Content-Length required for chunked readT)rminrrrrr)rrrrs rBrz&BodyPartReader._read_chunk_from_lengthxs|'')S'''t|d.>>?? m((44444444 =   ! ! DL rAc K||jks Jd|jdu}|r(d|j|d{Vz|_d}t ||jkr||j|d{Vz }|xjt |jz c_|jdkrtd|jrnt ||jkt ||kr,|j ||d|d|}|jJ|j|z}d|j z}|r| |}nF| |tdt |jt |z }|dkrtj5tjdt |j ||ddddn #1swxYwY|jd||_|t |j|}|sd |_|j|rdndd}||_|S) Nz*?*?#c((*J#K#KLLC !88(** 8 8';MNNNN ))&,777 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 $/5D 3t/00367E $# !{"9!!";";<  s >HHHc6K|jrdS|jr|j}n|jd{V}||jrV|d}|j}|jdz}||ks||kr#d|_|j|dSn]|jd{V}||jr |dd}|j||S)z Reads body part by line by line.rANr--T) rrpopleftrrrrrstripr)rlinesliner last_boundary next_lines rBrzBodyPartReader.readlines8 < 3 < 2<''))DD//11111111D ??4> * * +KK((E~H NU2M  E]$:$:#  ##D)))s%; #m4466666666I##DN33 !CRCy L   * * * rAc|K|jrdS|js)||jd{V|j'dSdS)z0Like read(), but reads all the data to the void.N)rrrrs rBrzBodyPartReader.releasese <  F, 3//$/22 2 2 2 2 2 2 2, 3 3 3 3 3rA)rrcK|dd{V}|p|d}||S)z;Like read(), but assumes that body part contains text data.TrNrkdefault)r get_charsetrrrrs rBrdzBodyPartReader.textsZYYdY++++++++@t///@@{{8$$$rAcK|dd{V}|sdS|p|d}tttt ft j||S)z>LL! X X XFVWW W X ""    s 'A''Bc|jS)zApply Content-Transfer-Encoding decoding if header is present.)rr_decode_content_transfer)rrs rB _apply_content_transfer_decodingz/BodyPartReader._apply_content_transfer_decodings( $ 4 40066 6 rAc.|j o t|jvS)z5Check if Content-Encoding decoding should be applied.)rrrrs rB_needs_content_decodingz&BodyPartReader._needs_content_decodings%%J*:dl*JJrAc||}|r||S|S)aDecodes data synchronously. Decodes data according the specified Content-Encoding or Content-Transfer-Encoding headers value. Note: For large payloads, consider using decode_iter() instead to avoid blocking the event loop during decompression. )rr_decode_content)rrdecodeds rBrzBodyPartReader.decodesD77==  ' ' ) ) 1''00 0rAcK||}|r%||23d{V}|WV 6dS|WVdS)a$Async generator that yields decoded data chunks. Decodes data according the specified Content-Encoding or Content-Transfer-Encoding headers value. This method offloads decompression to an executor for large payloads to avoid blocking the event loop. N)rr_decode_content_async)rrrrs rBrzBodyPartReader.decode_iters77==  ' ' ) ) 55g>>       a?>>MMMMMMsAc|jtd}|dkr|S|dvr+t |d||jStd|)Nrbidentity>gzipdeflateTrsuppress_deflate_header max_lengthunknown content encoding: )rrrrurdecompress_syncr RuntimeErrorrrrs rBrzBodyPartReader._decode_content$s<##$4b99??AA z ! !K * * *#!(,odt/HoII J BBBCCCrAcK|jtd}|dkr|WVdS|dvrmt |d}|||jd{VWV|jr.|d|jd{VWV|j,dSdStd|) Nrbr>rrTr r"rAr$) rrrrur decompressrdata_availabler&)rrrrs rBrz$BodyPartReader._decode_content_async0s!<##$4b99??AA z ! !JJJJJJ , , , !(,A Td6O PPPPPPPP P P P P" TLL9RLSSSSSSSSSSSS" T T T T TFHFFGG GrAc|jtd}|dkrt j|S|dkrt j|S|dvr|Std|)Nrbrquoted-printable)binary8bit7bit#unknown content transfer encoding: ) rrrrur b64decodebinasciia2b_qpr&r's rBrz'BodyPartReader._decode_content_transferAs<##$=rBBHHJJ x  #D)) ) + + +?4(( ( 3 3 3KOXOOPP PrArc|jtd}t|}|jd|jp|S)z>Returns charset parameter from Content-Type header or default.rbcharset)rrrr parametersr)rrctypemimetypes rBrzBodyPartReader.get_charsetMsG   r22!%(("&&y$2G2R7SSSrAct|jt\}}t |dS)z|Returns name specified in Content-Disposition header. If the header is missing or malformed, returns None. rr8rrrr9rrr{s rBrzBodyPartReader.nameSs6 .dl.>.>?R.S.STT 6+FF;;;rAct|jt\}}t |dS)zReturns filename specified in Content-Disposition header. Returns None if the header is missing or malformed. rr:r;s rBrzBodyPartReader.filename\s6 .dl.>.>?R.S.STT 6+FJ???rAr)0r=r>r?rrrsysmaxsizerbytesr+rmrtype Exceptionrr.rrrrKrrrrrrrdrr r listtuplerrr3rrrrrrrrrr rrr@rArBr/r/sa00J&*#5"{.86666)6 6  6t6!66!O6 6666> EDL ,1DU.,6**S*%****X#%+#+%++++Z:333348%%%cDj%C%%%%48GGGcDjGDcNT %!&F:   G (D ( F Fv F F F F F G GrArkrlrerrorsc td)NzUnable to decode. TypeErrorrrrNs rBrzBodyPartReaderPayload.decodews+,,,rAc$Ktd)aRRaises 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.rPrRs rBas_byteszBodyPartReaderPayload.as_byteszsTUUUrAwritercK|j}|td{Vx}r^||23d{V}||d{V#6|td{Vx}\dSdS)N)r)rrrrwrite)rrUfieldrrs rBrWzBodyPartReaderPayload.writes "--3E-FFFFFFFFFe & ,,U33 & & & & & & &all1oo%%%%%%%%4#--3E-FFFFFFFFFe & & & & &sA%rkrl)r=r>r?r/__annotations__r rrmrr?rTrrW __classcell__rMs@rBrFrFfs  Gn GS GC GD G G G G G G--s-c-----VVsVcVQVVVVV&"6&4&&&&&&&&rArFceZdZUdZeZdZeddzed<e Z e j dde ddeeefded ed ed ed eed dfdZded efdZd ede fdzfdZeddd efdZd efdZd ede fdzfdZd!dZd ede ffdZddd ede ffdZd efdZ d e!fdZ"d!dZ#d!dZ$d"dZ%d!d Z&dS)#r4zMultipart body reader.Nmultipart_reader_clsirmax_field_size max_headersrrrrrarbrrFct|t|_|jjdks Jdd|jjvrt d|tz||_d|z|_ ||_ ||_ d|_ d|_ ||_||_||_d|_d|_g|_dS)N multipartz!multipart/* content type expectedrz$boundary missed for Content-Type: %s--FT)rr _mimetyper@r6rr _get_boundaryencoderrrr _last_part_max_field_size _max_headersrr_at_bofr)rrrrrarbrs rBrzMultipartReader.__init__s( (=>>~"k1113V111 T^6 6 669NN  !3!3!5!55==?? / ,0CG-'#5   $& rArc|SrJr@rs rBrzMultipartReader.__aiter__rrAcPK|d{V}|t|SrJrrs rBrzMultipartReader.__anext__rrAresponser:cZ||||j|j}|S)zConstructs reader instance from HTTP response. :param response: :class:`~aiohttp.client.ClientResponse` instance )response_wrapper_clsrr)clsroobjs rB from_responsezMultipartReader.from_responses7&& cc(*H,<==   rAc|jS)z@Returns True if the final boundary was reached, false otherwise.rrs rBrzMultipartReader.at_eofrrAc K|jrdS|d{V|jr"|d{Vd|_n|d{V|jrdS|d{V}|j|jjdkrt|trt|j t\}}| ddkr|dd{V}t!|dkrt#d||_|d{V}||_|jS) z#Emits the next multipart body part.NFrr _charset_ zInvalid default charset)r_maybe_release_last_partrl_read_until_first_boundary_read_boundaryfetch_next_partrirfr isinstancer/r8rrrrrr&rvrr)rrrr{r5s rBrzMultipartReader.nexts < 4++--------- < (1133 3 3 3 3 3 3 3 DLL%%'' ' ' ' ' ' ' ' < 4))++++++++ O #&+5540062$,2B2BCV2W2WXXIAvzz&!![00!% 3 3333333w<<"$$&'@AAA(/ (>(>(@(@%!1133333333rAcK|jsA|d{V}|dS|d{V|j?dSdS)z=Reads all the body parts to the void till the final boundary.N)rrrrs rBrzMultipartReader.releasesy, !$$$$$$D|,,.. , ! ! ! ! !rAcdK|d{V}||S)z"Returns the next body part reader.N) _read_headers_get_part_reader)rrs rBr}zMultipartReader.fetch_next_parts?**,,,,,,,,$$W---rArc |td}t|}|jdkrr|j7t|||j|j|j|j|j S|||j|j|j|j|j S| |j ||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 rbrdNr`)rrrr)rrrr@r^rrrjrkrpart_reader_clsrrfrr)rrr7r8s rBrz MultipartReader._get_part_readers L"--!%(( =K ' '(0!tDzzM$($9#'#7 $ 1'+'? ,, $ 5#3 -#'#; - '' . $ 5 $ 5#'#;( rAct|jjd}t|dkrtd|z|S)NrFz&boundary %r is too long (70 chars max))rfr6rr)rrs rBrgzMultipartReader._get_boundary-s;>,Z8 x==2  EPQQ QrAcK|jr|jS|jd{VSrJ)rrtrrrs rB _readlinezMultipartReader._readline4sJ < &<##%% %]++---------rAcK |d{V}|dkrtd|jz|}||jkrdS||jdzkr d|_dSp)NTrAz#Could not find starting boundary %rr)rrrrrrrs rBr{z*MultipartReader._read_until_first_boundary9s ..********E|| 9T^LLLNNE&&$.5000#  rAcK|d{V}||jkrdS||jdzkrd|_|d{V}|d{V}|dddkr|j|dS|j||gdStd|d|j)NrTrUzInvalid boundary z , expected )rrrrrrrr)rrepiloguers rBr|zMultipartReader._read_boundaryGs~~''''''''//11 DN " " D dnu, , ,DL!^^--------H"nn........I !}%% ##I.....  ##Y$9:::::WWWT^WWXX XrAc`Kg} |j|jd{V}|d}|||sn(t ||jkrtd{t|j}| |\}}|S)NT)max_line_lengthrzToo many headers received)ra) rrrjrrrrkr"r! parse_headers)rlinesrparserr raw_headerss rBrzMultipartReader._read_headers^s B-00AU0VVVVVVVVELL))E LL    5zzD---$%@AAA Bd.BCCC%33E::rAcK|je|js|jd{V|j|jjd|_dSdS)z8Ensures that the last read body part is read completely.N)rirrrrrs rBrzz(MultipartReader._maybe_release_last_partlsx ? &?))++ 0o--///////// L   7 8 8 8"DOOO ' &rAr)rFr)'r=r>r?rrrqr^r@rZr/rr=r>rrrmr+rrArr.rr r classmethodrtrKrrrr}rrgr?rr{r|rrzr@rArBr4r4s  4<@$01D8???$O #{".8'''c"''  '  ''!O' ''''<  .0 1D 8 "  "   [ !  .0 1D 8!!!!F!!!!.  .0 1....(((  .0 1((((Ts.....    YYYY.    ######rAr4cfeZdZUdZded<dZd(dededzddffd Zd)d Zd e e dzd e dzd e dzddfdZ de efdZdefdZdefdZejdZejdZedefdZedefdZd*dedeeefdzdefdZdedefdZ d*dedeeefdzdefdZ d*de!e"eefeeefzdeeefdzdefdZ#ededzfdZ$d+d ed!edefd"Z%d+d ed!ede&fd#Z' d,d$e(d%eddfd&Z)d-d'Z*xZ+S).r5zMultipart body writer.NrTrrrrFc8||ntjj} |d|_n#t $rt ddwxYwd|d|j}t d|g|_ |dk|_ dS)Nasciiz(boundary should contain ASCII only charsz multipart/z ; boundary=) content_typer) uuiduuid4hexrhrUnicodeEncodeErrorr_boundary_valuerKr_partsr)rrrr7rMs rBrzMultipartWriter.__init__s'3889I  S%__W55DNN! S S SGHHd R SGWGG1EGG E222#% $ 3s :Ac|SrJr@rs rB __enter__zMultipartWriter.__enter__rrAexc_typeexc_valexc_tbcdSrJr@)rrrrs rB__exit__zMultipartWriter.__exit__s rAc*t|jSrJ)iterrrs rB__iter__zMultipartWriter.__iter__sDK   rAc*t|jSrJ)rrrs rB__len__zMultipartWriter.__len__s4;rAcdS)NTr@rs rB__bool__zMultipartWriter.__bool__strAs\A[!#$%&'*+\-.^_`|~\w]+\Zs[\x00-\x08\x0A-\x1F\x7F]cN|j}tj|j|r|dStj|j|rtd|dd}|dd}d|dzdzS)zzWrap boundary parameter value in quotes, if necessary. Reads self.boundary and returns a unicode string. rz*boundary value contains invalid characters\s\\"s\"rQ) rrfmatch_valid_tchar_regexrsearch_invalid_qdtext_char_regexrreplace)rr~quoted_value_contents rBrzMultipartWriter._boundary_values& 8D+U 3 3 )<<(( ( 9T4e < < KIJJ J %}}UG<<3;;D&II)00999C??rAc6|jdS)Nr)rrrs rBrzMultipartWriter.boundarys~$$W---rArsrc8|t}t|tr/|j|||S t ||}||S#t$rtd|zwxYw)NrzCannot create payload from %r) rr~r'rupdateappend_payloadr)r%rQ)rrsrpayloads rBrzMultipartWriter.appends ?!mmG c7 # # 4 K  w ' ' '&&s++ + 4%c7;;;**7333 G G G ?# EFFF Gs A<<Brcd}d}|jrmttth|jzrJt |jvr.dt|j}| d|n|j td }|r|dvrtd||dkrd}|j td }|d vrtd ||d krd}|j }| |s|st||jt<|j|||f|S) z)Adds a new body part to multipart writer.Nzsection-r)rrb)rrrr$r)rbrr,r-r0r-)rrrrrkeysrrrrLrrur&rrmr)rrr te_encodingrrs rBrzMultipartWriter.append_payloads#"&   <&~7PQ/&&(()  )#'/994#dk"2"244// $/GGG**+;R@@FFHHH LH,KKK"#J#J#JKKK:%%"/--.GLLRRTTK"NNN"#V#V#VWWWh&&" .:s  b# m  "))(F;; <kkmm        rA)rnrrRs```rBrzMultipartWriter.decode4sQ ww      "&       rAcKg}|jD]\}}}|d|jzdz||j|||d{V}|||d|d|jzdzd|S)zReturn bytes representation of the multipart data. This method is async-safe and calls as_bytes on underlying payloads. rrN-- rA)rrrrrTrn)rrrNrzrrr part_bytess rBrTzMultipartWriter.as_bytesCs  "[ " "MD"c LL/'9 : : : LL- . . . $}}Xv>>>>>>>>J LL $ $ $ LL ! ! ! !  UT^+i7888xxrArUclose_boundarycK|jD]'\}}}|jr&t|jvsJd|jtvsJ|d|jzdzd{V||jd{V|s|rst|}|r|||r| |||d{V| d{Vn||d{V|dd{V)|r(|d|jzdzd{VdSdS)z Write body.zname=rrNr) rrrrrWrrMultipartPayloadWriterenable_compressionenable_encoding write_eof)rrUrrrrws rBrWzMultipartWriter.write^s,0; ( ( 'D(K! D*dl::::$,/B"CCCCC,,ut~5?@@ @ @ @ @ @ @ @,,t344 4 4 4 4 4 4 4 ); )*6223((2223%%k222jjmm#######kkmm########jj(((((((((,,w'' ' ' ' ' ' ' ' '  C,,ut~5 ABB B B B B B B B B B C CrAcK|jrdSd|_t|jD]b\}\}}}|jsR|jsK |d{V3#t $r"}tjd||dYd}~Zd}~wwxYwcdS)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) _consumedrr autocloseconsumedcloserAr#error)rrrrexcs rBrzMultipartWriter.close{s >  F "+4;!7!7   C$1> $- **,,&&&&&&&& #)?cTX   sA B$BB)rN)rFr5rJrY)Tr),r=r>r?rrZ _autoclosermrrr@ BaseExceptionrrr_PartrrrrKrrfcompilerrpropertyrrr rr'rrrrrCrrrr?rTrrWrr[r\s@rBr5r5xs  LLLJ444t4t444444$ }%, % $       !(5/!!!!     $$$ABB!+,H!I!I @@@@X@>.#...X. 4 4# 4S(9D(@ 4G 4 4 4 4$g$'$$$$N=AFFF!(c!2T!9F FFFF-1  eCHo &c): : c"T)       *cDjX(   s  c       scQV8DHCC*C<@C CCCC:rAr5cdeZdZdeddfdZdeddfdZ d dededzddfd Zdd Z d e ddfd Z dS)rrUrFNc>||_d|_d|_d|_dSrJ)_writer _encoding _compress_encoding_buffer)rrUs rBrzMultipartPayloadWriter.__init__s% %)0426rArch|dkr||_t|_dS|dkr d|_dSdS)Nrr,)rrr)rrs rBrz&MultipartPayloadWriter.enable_encodingsE x  %DN$-KKD ! ! ! + + +/DNNN, +rArstrategyc4t|d||_dS)NT)rr!r)rr)rrrs rBrz)MultipartPayloadWriter.enable_compressions'($(   rAc,K|j=|j}|r"d|_||d{V|jdkr@|jr;|jt j|jd{VdSdSdS)Nr)rflushrWrrrr b64encoders rBrz MultipartPayloadWriter.write_eofs > %N((**E (!%jj''''''''' >X % %$ Rl(()9$:O)P)PQQQQQQQQQQQ & % R RrArctK|j&|r$|j|d{V}|sdS|jdkr|j}|J|||rxt t |d\}}|d|dz||dzdc}|_|r8tj|}|j |d{VdSdSdS|jdkr4|j tj |d{VdS|j |d{VdS)Nrr,r,) rcompressrrrdivmodrrrrrWr2b2a_qp)rrbufdivmod enc_chunkb64chunks rBrWzMultipartPayloadWriter.writes > % "n55e<<<<<<<<F >X % %'C??? JJu    7!#c((A..S47 #' NCa N0 407%/ ::H,,,X66666666666  7 777^1 1 1,$$X_U%;%;<< < < < < < < < < <,$$U++ + + + + + + + + +rA)rNr) r=r>r?rrrmrrrrr?rWr@rArBrrs7377777 000000AE   36:      R R R R,,4,,,,,,rAr)r)Wrr2r rfr=rrr collectionsrcollections.abcrrrrtypesrtypingr r r r r urllib.parserrr multidictrrabcrcompression_utilsrrhdrsrrrrrhelpersrrrrr httpr!http_exceptionsr"logr#rr$r%r&r'r(r)r*streamsr+ version_infor.r2r?rr3__all__ client_reqrepr:RuntimeWarningr6r7rmrCrr8r9rr/ try_firstrFr4rr5rr@rArBr s  FFFFFFFFFFFF;;;;;;;;;;;;;;666666666633333333%%%%%%????????LKKKKKKKKKKKKK++++++ "!!!!!w 76!1 2 2 2Dw&&&&&&& 5)%68KK LF ')6 * * * .------     .           d$ $Jd$ 3:tCH~ %&d$d$d$d$P,6 CH %(4ZB,",",",",",",","^a@a@a@a@a@a@a@a@H nEO444!&!&!&!&!&G!&!&54!&Hg#g#g#g#g#g#g#g#T gsC ZZZZZgZZZz7,7,7,7,7,7,7,7,7,7,rA