o Fhݛ@spddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z m Z ddl m Z ddlmZmZmZmZmZmZmZmZmZmZmZddlmZmZmZddlmZm Z dd l!m"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.dd l/m0Z0dd l1m2Z2ddl3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:ddl;mZ>n ddlm?Z?e?dddZ>dZ@erddlAmBZBGdddeCZDGdddeCZEdeeFdeeeFeeFeFfffddZG d1d!e eFeFfd"eFdeeFfd#d$ZHGd%d&d&ZIGd'ddZJe:eJe6jKd(Gd)d*d*e7ZLGd+d,d,ZMee7eFeFfZNGd-d.d.e7ZOGd/d0d0ZPdS)2N)deque)MappingSequence) TracebackType) TYPE_CHECKINGAnyDequeDictIteratorListOptionalTupleTypeUnioncast) parse_qslunquote urlencode) CIMultiDictCIMultiDictProxy)ZLibCompressorZLibDecompressor)CONTENT_DISPOSITIONCONTENT_ENCODINGCONTENT_LENGTHCONTENT_TRANSFER_ENCODING CONTENT_TYPE)CHARTOKENparse_mimetypereify) HeadersParser)internal_logger) JsonPayload LookupErrorOrderPayload StringPayload get_payload payload_type) StreamReader) )Self)TypeVarr.BodyPartReader)bound)MultipartReaderMultipartWriterr0BadContentDispositionHeaderBadContentDispositionParamparse_content_dispositioncontent_disposition_filename)ClientResponsec@ eZdZdS)r4N__name__ __module__ __qualname__r>r>D/var/www/html/venv/lib/python3.10/site-packages/aiohttp/multipart.pyr4Hr4c@r9)r5Nr:r>r>r>r?r5Lr@r5headerreturncsdtdtfdddtdtfdd}dtdtffdd }dtdtfd d }dtdtfd d }d ttjtddtdtdtfdd}|sJdifS|d^}}|s`t t |difSi}|rO| d} d| vryt t |difS| dd\} } | } | } | |vrt t |difS| st t| qb|| r|| r|| dd} n| st t| qbn|| r|| r| dd\} } } | pd} nt t| qbzt| | d} Wn^tyt t| Yqbwd}|| rd}|| ddd} n+| rd}n#|r;| d|d}||r;| d||ddd} d}|rIt t |difS| || <|se| |fS)NstringrBcSst|o tt|kSN)boolrsetrCr>r>r?is_tokenSsz+parse_content_disposition..is_tokencSs |d|dko dkSS)Nr"r>rGr>r>r? is_quotedVs z,parse_content_disposition..is_quotedcs|o |ddkS)N')countrGrHr>r? is_rfc5987Yz-parse_content_disposition..is_rfc5987cSs |dS)N*)endswithrGr>r>r?is_extended_param\ z4parse_content_disposition..is_extended_paramcSs@|dd}|s dS|dr||dn||d}|S)NrRrFrI)findrSisdigit)rCpos substringr>r>r?is_continuous_param_s "z6parse_content_disposition..is_continuous_param)charstextr\cSstd|dd|S)Nz\\([z])z\1)resub)r]r\r>r>r?unescapefrQz+parse_content_disposition..unescape;r=rrIrLrMutf-8strictTFz\/)strrEjoinmapr^escapersplitwarningswarnr4poplowerstriplstripr5rUnicodeDecodeError)rArKrPrTrZr`disptypepartsparamsitemkeyvalueencoding_failed_valuer>rOr?r6Ps*         >r6filenamersnamec sd||sdS|vr|S||vr||Sg}tfdd|D}t|D]%\}\}}|dd\}}|drD|dd}|t|krP||q+|sUdSd|}d|vrq|dd \} }}| pjd } t|| d S|S) Nz%s*c3s&|]\}}|r||fVqdSrD) startswith).0rurvname_sufr>r? s  z/content_disposition_filename..rRrrIr[rLrMrcrd) sorteditems enumeraterirSreappendrfr) rsr|rrfnparamsnumrurvrxtailrwr>rr?r7s4       r7c@speZdZdZ      ddd Zdd d Zded fd dZdefddZ de ed fddZ dddZ dS)MultipartResponseWrapperzzWrapper around the MultipartReader. It takes care about underlying connection and close it when it needs in. respr8streamr2rBNcCs||_||_dSrD)rr)selfrrr>r>r?__init__s z!MultipartResponseWrapper.__init__cC|SrDr>rr>r>r? __aiter__z"MultipartResponseWrapper.__aiter__)r2r0c |IdH}|durt|SrDnextStopAsyncIterationrpartr>r>r? __anext__ z"MultipartResponseWrapper.__anext__cCs |jjS)z2Returns True when all response data had been read.)rcontentat_eofrr>r>r?r zMultipartResponseWrapper.at_eofcs.|jIdH}|jr|IdH|S)z#Emits next multipart reader object.N)rrrreleaserrtr>r>r?rs  zMultipartResponseWrapper.nextcs|jIdHdS)z_Release the connection gracefully. All remaining content is read to the void. N)rrrr>r>r?rsz MultipartResponseWrapper.release)rr8rr2rBN)rBrrBN) r;r<r=__doc__rrrrrErr rrr>r>r>r?rs$     rc @seZdZdZdZddddeddd ed ed eed df d dZ de d e fddZ d efddZ d eefddZ ddded efddZefded efddZded efddZded efd d!Zd efd"d#Zd>d$d%Zdd&d'eed efd(d)Zdd&d'eed eeeeffd*d+Zdd&d'eed eeeeffd,d-Zd efd.d/Zd0ed efd1d2Zd0ed efd3d4Zd0ed efd5d6Z d7ed efd8d9Z!e"d eefd:d;Z#e"d eefdr>r?rs   zBodyPartReader.__init__rcCrrDr>rr>r>r?r!rzBodyPartReader.__aiter__crrDrrr>r>r?r$s zBodyPartReader.__anext__cs|IdH}|s dS|SrD)readrr>r>r?r*s zBodyPartReader.nextFdecodercsH|jrdSt}|js|||jIdH|jr |r"||S|S)zReads body part data. decode: Decodes data following by encoding method from Content-Encoding header. If it missed data remains untouched N)r bytearrayextend read_chunk chunk_sizer)rrdatar>r>r?r0s zBodyPartReader.readsizec sf|jrdS|jr||IdH}n||IdH}|jt}|r|dkrd| }t |d}|dkr| sd|}d}|j rW|j d|}|j t |d|_ t ||krl||j dt |IdH7}|sqd|_|d| 7}||7}t |d}|dkr| r=|jt |7_|j|jkrd|_|jr|j IdH}d|ksJd|S) zWReads body part content chunk of the specified size. size: chunk size rNbase64rT z3reader did not read all the data or it is malformed)rr_read_chunk_from_length_read_chunk_from_streamrrrrmrfrirrrrrrreadline) rrchunkrwstripped_chunk remainderover_chunk_size over_chunkclrfr>r>r?r@sB      zBodyPartReader.read_chunkcsL|jdus Jdt||j|j}|j|IdH}|jr$d|_|S)Nz(Content-Length required for chunked readT)rminrrrrr)rrrrr>r>r?ros z&BodyPartReader._read_chunk_from_lengthcs||jks Jd|jdu}|r|j|IdH|_d}t||jkrO||j|IdH7}|jt|j7_|jdksDJd|jrHnt||jks$t||kre|j||d|d|}|jduslJ|j|}d|j }|r~| |}n| |t dt|jt|}|dkrt t jdtd|j||dWdn1swY||kr|jd||_|t|j|}|sd |_|j}||_|S) Nzr>r?rysJ         z&BodyPartReader._read_chunk_from_streamcs|jrdS|jr|j}n|jIdH}||jr?|d}|j}|jd}||ks2||kr=d|_|j|dS|S|jIdH}||jrS|dd}|j||S)z Reads body part by line by line.rNr--T) rrpopleftrrr}rrstripr)rlinesliner last_boundary next_liner>r>r?rs(        zBodyPartReader.readlinecs2|jrdS|js||jIdH|jr dSdS)z0Like read(), but reads all the data to the void.N)rrrrr>r>r?rs zBodyPartReader.release)rwrwcs.|jddIdH}|p|jdd}||S)z;Like read(), but assumes that body part contains text data.TrNrcdefault)r get_charsetrrrwrr>r>r?r]s zBodyPartReader.textcsJ|jddIdH}|sdS|p|jdd}ttttft||S)zr>r?rs zBodyPartReader.jsoncsr|jddIdH}|sgS|dur|}n|jdd}z ||}Wn ty1td|wt|d|dS)zFLike read(), but assumes that body parts contain form urlencoded data.TrNrcrz'data cannot be decoded with %s encoding)keep_blank_valuesrw)rrrrrp ValueErrorr)rrwr real_encoding decoded_datar>r>r?forms"   zBodyPartReader.formcC|jS)zr>r?rzBodyPartReader.at_eofrcCs2t|jvr ||}|jst|jvr||S|S)zDecodes data. Decoding is done according the specified Content-Encoding or Content-Transfer-Encoding headers value. )rr_decode_content_transferrr_decode_content)rrr>r>r?rs   zBodyPartReader.decodecCsF|jtd}|dkr|S|dvrt|dd|Std|)Nr[identity>gzipdeflateT)rwsuppress_deflate_headerunknown content encoding: )rrrrmrdecompress_sync RuntimeErrorrrrwr>r>r?rszBodyPartReader._decode_contentcCsP|jtd}|dkrt|S|dkrt|S|dvr!|Std|)Nr[rquoted-printable)binary8bit7bit#unknown content transfer encoding: ) rrrrmr b64decodebinasciia2b_qprrr>r>r?r s  z'BodyPartReader._decode_content_transferrcCs*|jtd}t|}|jd|jp|S)z>Returns charset parameter from Content-Type header or default.r[charset)rrrr parametersr)rrctypemimetyper>r>r?rszBodyPartReader.get_charsetcCt|jt\}}t|dS)z|Returns name specified in Content-Disposition header. If the header is missing or malformed, returns None. r|r6rrrr7rrxrsr>r>r?r| zBodyPartReader.namecCr)zReturns filename specified in Content-Disposition header. Returns None if the header is missing or malformed. r{rr r>r>r?r{%r zBodyPartReader.filenamer)%r;r<r=rrbytesr+rer rr.rrrrErrrrrrrr]r rrr r rrrrrrr!r|r{r>r>r>r?r0sN / , ((   )ordercszeZdZUeed<dedededdffdd Zdd ed edefd dZdd ed ede fddZ deddfddZ Z S)BodyPartReaderPayloadrzrvargskwargsrBNcsbtj|g|Ri|i}|jdur|j|d<|jdur#|j|d<|r/|jdi|dSdS)Nr|r{ attachmentT)rT)superrr|r{set_content_disposition)rrvrrrs __class__r>r?r4s    zBodyPartReaderPayload.__init__rcrdrwerrorscCstd)NzUnable to decode. TypeErrorrrwrr>r>r?r@szBodyPartReaderPayload.decodecs td)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.rrr>r>r?as_bytesCszBodyPartReaderPayload.as_byteswritercsR|j}|jddIdH}|r'|||IdH|jddIdH}|sdSdS)Ni)r)rzrwriter)rrfieldrr>r>r?rMs zBodyPartReaderPayload.writercrd) r;r<r=r0__annotations__rrrerr rr __classcell__r>r>rr?r /s   r c@s4eZdZUdZeZdZeede d<e Z de e e fdeddfddZd edefd d Zdeede ffd d ZedddefddZdefddZdeede ffddZd)ddZdede ffddZdddede ffddZde fddZdefdd Zd)d!d"Zd)d#d$Z d*d%d&Z!d)d'd(Z"dS)+r2zMultipart body reader.Nmultipart_reader_clsrrrBcCs~t|t|_|jjdksJdd|jjvrtd|t||_d||_ ||_ d|_ d|_ d|_ d|_g|_dS)N multipartz!multipart/* content type expectedrz$boundary missed for Content-Type: %s--FT)r r _mimetypetyperrr _get_boundaryencoderrr _last_partr_at_bofr)rrrr>r>r?r`s   zMultipartReader.__init__rcCrrDr>rr>r>r?rqrzMultipartReader.__aiter__crrDrrr>r>r?rtrzMultipartReader.__anext__responser8cCs||||j|j}|S)zConstructs reader instance from HTTP response. :param response: :class:`~aiohttp.client.ClientResponse` instance )response_wrapper_clsrr)clsr)objr>r>r? from_response|s zMultipartReader.from_responsecCr)z@Returns True if the final boundary was reached, false otherwise.rrr>r>r?rrzMultipartReader.at_eofcs|jrdS|IdH|jr|IdHd|_n|IdH|jr'dS|IdH}|jduro|jjdkrot |t rot |j t\}}| ddkro|dIdH}t|dkratd||_|IdH}||_|jS) z#Emits the next multipart body part.NFrr| _charset_ zInvalid default charset)r_maybe_release_last_partr(_read_until_first_boundary_read_boundaryfetch_next_partr'r#r isinstancer0r6rrrrrrrnrr)rrrxrsrr>r>r?rs0   zMultipartReader.nextcs>|js|IdH}|durdS|IdH|jrdSdS)z=Reads all the body parts to the void till the final boundary.N)rrrrr>r>r?rszMultipartReader.releasecs|IdH}||S)z"Returns the next body part reader.N) _read_headers_get_part_reader)rrr>r>r?r4s zMultipartReader.fetch_next_partrcCsd|td}t|}|jdkr#|jdurt|||jS|||jS|j|j||j|jj |j dS)zDispatches the response by the `Content-Type` header. Returns a suitable reader instance. :param dict headers: Response headers r[r!Nr) rrr r$r rpart_reader_clsrr#rr)rrrrr>r>r?r7s   z MultipartReader._get_part_readercCs(|jjd}t|dkrtd||S)NrFz&boundary %r is too long (70 chars max))r#rrr)rrr>r>r?r%s   zMultipartReader._get_boundarycs"|jr |jS|jIdHSrD)rrlrrrr>r>r? _readlines zMultipartReader._readlinecsX |IdH}|dkrtd|j|}||jkrdS||jdkr+d|_dSq)NTrz#Could not find starting boundary %rr)r:rrrrrrr>r>r?r2s z*MultipartReader._read_until_first_boundarycs|IdH}||jkrdS||jdkrCd|_|IdH}|IdH}|dddkr9|j|dS|j||gdStd|d|j)NrTrMzInvalid boundary z , expected )r:rrrrrrr)rrepiloguerr>r>r?r3s zMultipartReader._read_boundarycsJg} |jIdH}|}|||snqt}||\}}|SrD)rrrnrr" parse_headers)rlinesrparserr raw_headersr>r>r?r6 s zMultipartReader._read_headerscsD|jdur |js|jIdH|j|jjd|_dSdS)z8Ensures that the last read body part is read completely.N)r'rrrrrr>r>r?r1s   z(MultipartReader._maybe_release_last_partr)rBr)#r;r<r=rrr*r r rrr0r8rrer+rr.rrr classmethodr-rErrrr4r7r%r r:r2r3r6r1r>r>r>r?r2UsF     #        r2cseZdZUdZded<dZd9dedeeddffd d Zd:d d Z d ee e dee dee ddfddZ deefddZdefddZdefddZedZedZedefddZedefddZd;dedeeeefdefd d!Zd"edefd#d$Z d;dedeeeefdefd%d&Z! d;de"e#e$eefeeeffdeeeefdefd'd(Z%edeefd)d*Z&dd7d8Z+Z,S)?r3zMultipart body writer.NrzTrrrrBcsv|dur|ntj}z|d|_Wn tytddwd|d|j}tj d|dg|_ |dk|_ dS)Nasciiz(boundary should contain ASCII only charsz multipart/z ; boundary=) content_typer) uuiduuid4hexr&rUnicodeEncodeErrorr_boundary_valuerr_partsr)rrrrrr>r?r*s  zMultipartWriter.__init__cCrrDr>rr>r>r? __enter__<rzMultipartWriter.__enter__exc_typeexc_valexc_tbcCsdSrDr>)rrKrLrMr>r>r?__exit__?szMultipartWriter.__exit__cC t|jSrD)iterrIrr>r>r?__iter__GrUzMultipartWriter.__iter__cCrOrD)rrIrr>r>r?__len__JrUzMultipartWriter.__len__cCsdS)NTr>rr>r>r?__bool__MrzMultipartWriter.__bool__s\A[!#$%&'*+\-.^_`|~\w]+\Zs[\x00-\x08\x0A-\x1F\x7F]cCs^|j}t|j|r|dSt|j|rtd|dd}|dd}d|ddS)zzWrap boundary parameter value in quotes, if necessary. Reads self.boundary and returns a unicode string. rBz*boundary value contains invalid characters\s\\"s\"rJ) rr^match_valid_tchar_regexrsearch_invalid_qdtext_char_regexrreplace)rrvquoted_value_contentr>r>r?rHSs   zMultipartWriter._boundary_valuecCs |jdS)NrB)rrrr>r>r?rsrzMultipartWriter.boundaryr,rcCsd|durt}t|tr|j|||Szt||d}Wn ty,td|w||S)NrzCannot create payload from %r) rr5r'rupdateappend_payloadr)r%r)rr,rpayloadr>r>r?rws      zMultipartWriter.appendr_cCsd}d}|jr(ttth|j@rJt|jvr'dt|j}|j d|dnH|j td }|r>|dvr>t d||dkrDd}|j td }|d vrXt d ||d kr^d}|j }|durp|sp|spt||jt<|j|||f|S) z)Adds a new body part to multipart writer.Nzsection-r)r|r[)rrrrr)r[rrrrr)rrrrrkeysrrrIrrrmrrrer)rr_rw te_encodingr|rr>r>r?r^s4  zMultipartWriter.append_payloadcCs |durt}|t||dS)zHelper to append JSON part.Nr\)rr^r$)rr,rr>r>r? append_jsonszMultipartWriter.append_jsoncCsVt|ttfs J|durt}t|trt|}t|dd}|t||ddS)z&Helper to append form urlencoded part.NT)doseqz!application/x-www-form-urlencoded)rrC) r5rrrlistrrr^r()rr,rrr>r>r? append_forms   zMultipartWriter.append_formcCsxd}|jD])\}}}|j}|s|s|durdS|tdt|jd|t|jd7}q|dt|jd7}|S)zSize of the payload.rNrMr)rIrrrr_binary_headers)rtotalrrwra part_sizer>r>r?rs( zMultipartWriter.sizercrdrwrcsdfddjDS)zReturn string representation of the multipart data. WARNING: This method may do blocking I/O if parts contain file payloads. It should not be called in the event loop. Use as_bytes().decode() instead. r[c3s:|]\}}}djd|j|VqdS)r"z N)rrfr)r~r_e_terwrrr>r?rs  z)MultipartWriter.decode..)rfrIrr>rkr?rszMultipartWriter.decodecs|g}|jD](\}}}|d|jd||j|||IdH}|||dq|d|jdd|S)zReturn bytes representation of the multipart data. This method is async-safe and calls as_bytes on underlying payloads. rrN-- r)rIrrrfrrf)rrwrrrrrirj part_bytesr>r>r?rs    zMultipartWriter.as_bytesrclose_boundarycs|jD]d\}}}|jrt|jvsJd|jtvsJ|d|jdIdH||jIdH|s6|rXt|}|rA|||rH| |||IdH| IdHn||IdH|dIdHq|rz|d|jdIdHdSdS)z Write body.zname=rrNrl) rIrrrrrrfMultipartPayloadWriterenable_compressionenable_encoding write_eof)rrrnrrwrawr>r>r?r s(  zMultipartWriter.writec s|jrdSd|_t|jD]2\}\}}}|js@|js@z |IdHWqty?}ztjd||ddWYd}~qd}~wwqdS)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) _consumedrrI autocloseconsumedclose Exceptionr#error)rrrrxexcr>r>r?rx$s  zMultipartWriter.close)rN)rBr3rDr)Tr)-r;r<r=rr _autocloserer rrJr BaseExceptionrrNr _PartrQrrRrErSr^compilerWrYpropertyrHrrrr'rr^rbrrr rerrr rrrxrr>r>rr?r3#s`       $'   r3c@sjeZdZdeddfddZdeddfddZ dded eeddfd d Z dd dZ de ddfddZ dS)rorrBNcCs||_d|_d|_d|_dSrD)_writer _encoding _compress_encoding_buffer)rrr>r>r?r?s zMultipartPayloadWriter.__init__rwcCs0|dkr ||_t|_dS|dkrd|_dSdS)Nrr)rrr)rrwr>r>r?rqEs   z&MultipartPayloadWriter.enable_encodingrstrategycCst|d|d|_dS)NT)rwrr)rr)rrwrr>r>r?rpLs  z)MultipartPayloadWriter.enable_compressioncsf|jdur|j}|rd|_||IdH|jdkr/|jr1|jt|jIdHdSdSdS)Nr)rflushrrrrr b64encoder;r>r>r?rrUs   z MultipartPayloadWriter.write_eofrcs|jdur|r|j|IdH}|sdS|jdkr[|j}|dus#J|||rWtt|d\}}|d|d||dd}|_|rYt|}|j |IdHdSdSdS|jdkrn|j t |IdHdS|j |IdHdS)Nrr,r) rcompressrrrdivmodrrrrrrb2a_qp)rrbufdivmod enc_chunkb64chunkr>r>r?r`s*    $  zMultipartPayloadWriter.write)rNr) r;r<r=rrrerqr rrprrr rr>r>r>r?ro>s  ro)r{)Qrrrr^sysrDrj collectionsrcollections.abcrrtypesrtypingrrrr r r r r rrr urllib.parserrr multidictrrcompression_utilsrrhdrsrrrrrhelpersrrr r!httpr"logr#r_r$r%r&r'r(r)r*streamsr+ version_infor.r/__all__ client_reqrepr8RuntimeWarningr4r5rer6r7rr0 try_firstr r2r~r3ror>r>r>r?sn  4   $     d  !/ .%L