;xj^ *UddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z ddlm Z ddlm Z ddlmZmZmZmZmZmZmZmZddlZddlmZmZmZmZmZddlmZm Z dd l!m"Z"dd l#m$Z$dd l%m&Z&dd l'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4dd l5m6Z6ddl7m8Z8ddl9m:Z:m;Z;ddlZ>ddl?m@Z@mAZAmBZBmCZCmDZDddlEmFZFmGZGddlHmIZIejJdkrddlKmLZLn#ddlKZKGddeKjLeMejNZLdZOerddlPmQZQddlRmSZSddlTmUZUedZVdZWeeXeYd<ejZddd Gd!d"Z[e\eMze]ze[zZ^ej_ej`zd#zZaee\eYd$<d%ead&Zbee\eYd'<d(cd)dd*d+eeefd,d-zDZgee\eYd.<d/Zhee\eYd0<d1ehd2egd3Ziee\eYd4<d5ebd6ebd2eid7Zjee\eYd8<ejkd9Zlee e\eYd:<ejkejZmee e\eYd;<dZnGd?d@e e\e0ezefe/ZoGdAdBeoZpdS)CN)IteratorMappingMutableMapping)Pattern)MappingProxyType)IO TYPE_CHECKINGAnyFinalOptionalTypeVarcastoverload) CIMultiDictCIMultiDictProxy MultiDictMultiDictProxy MultiMapping)URLquery_to_pairs)hdrs)parse_cookie_header)AbstractStreamWriter) _SENTINELDEBUGDEFAULT_CHUNK_SIZEETAG_ANYLIST_QUOTED_ETAG_RE ChainMapProxyETag HeadersMixin RequestKeyparse_http_datereifysentinel set_exception)RawRequestMessage) HttpVersion)BodyPartReaderMultipartReader)EmptyStreamReader StreamReader)DEFAULT_JSON_DECODER JSONDecoder LooseHeaders RawHeadersStrOrURL)HTTPRequestEntityTooLargeNotAppKeyWarning)StreamResponse) )SpooledTemporaryFilec6eZdZdZdefdZdefdZdefdZdS)r8aMake the spooled file satisfy the documented `FileField.file` type. `tempfile.SpooledTemporaryFile` only became an `io.IOBase` subclass in 3.11 (python/cpython#70363), and never grew the three capability predicates before then. Both underlying files (`io.BytesIO` before rollover, a `w+b` temp file after) are readable, writable and seekable. returncdSNTselfs DC:\Projects\Historical\venv\Lib\site-packages\aiohttp/web_request.pyreadablezSpooledTemporaryFile.readableF4cdSr<r=r>s r@writablezSpooledTemporaryFile.writableIrBrCcdSr<r=r>s r@seekablezSpooledTemporaryFile.seekableLrBrCN)__name__ __module__ __qualname____doc__boolrArErGr=rCr@r8r8=so   d     d     d      rCr8) BaseRequest FileFieldRequest) Application)RequestHandler)UrlMappingMatchInfo_T_FILE_SPOOL_MAX_SIZET) auto_attribsfrozenslotscZeZdZUeed<eed<eeed<eed<eeed<dS)rNnamefilenamefile content_typeheadersN)rHrIrJstr__annotations__rbytesrr=rCr@rNrNcsN IIIMMM U)OOO c """"""rCrNz!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]c#4K|]}t|VdSN)chr).0cs r@ rkss( K KSVV K K K K K KrC) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:|z)*"_QUOTED_STRING(z)=(z )(:\d{1,4})?_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_RE max_fieldsr:c,t|d|dS)NzMaximum number of form fields z exceeded.text)r3)rys r@_too_many_fieldsr}s* $P*PPP   rCceZdZUejejejejejhZ e j e gdzZ dZ eedzed<dZedzed<eZeeed<dddddddd ed ed d d edddejdededeeeezefdzdedzdedzdedzddfdZe e e e e e e e ddee!zde"e!zde#e!zdee!zdee!zdee!zdee!zdee!zddfdZ$e%dhdZ&e%didZ'e%dej(dzfd Z)e%defd!Z*e%defd"Z+e%defd#Z,e-defd$Z.e-de/fd%Z0e-dejfd&Z1e2d'ee3de3fd(Z4e2d'edefd)Z4d'eee3zdefd*Z4e2d'ee3d+e3ddfd,Z5e2d'ed+eddfd-Z5d'eee3zd+eddfd.Z5d'eee3zddfd/Z6defd0Z7de8eeezfd1Z9e-de:fd2Z;e-dee-defd5Z?e-defd6Z@e-deAfd7ZBe-defd8ZCe-dedzfd9ZDe-de/fd:ZEe-defd;ZFe-defd<ZGe-defd=ZHe-djd?ZIe-defd@ZJe-deKefdAZLe-deMfdBZNe-deOjOdzfdCZPe-deOjOdzfdDZQeRdEede8eSfdFZTeUdGedzde.sW''Aq'""AHHW$5$56''''''rC raw_headersrrr)rrrr=)r RuntimeErrorr&rr_rrtupleitemsr_replacerr __class__rrrrrrcopy) r?rrr^rrrrrdctnew_urlrkwargss r@clonezBaseRequest.clones$   QOPP P   ! !"CM ( " "w<s r@rzBaseRequest.task1s zrCc|jSrg)rr>s r@rzBaseRequest.protocol5s ~rCc,|jdS|jjSrg)r transportr>s r@rzBaseRequest.transport9s > !4~''rCc|jSrg)rr>s r@writerzBaseRequest.writer?s ##rCc|jSrg)rr>s r@rzBaseRequest.client_max_sizeCs $$rCc|jSrg)rr>s r@rzBaseRequest.client_max_fieldsGs &&rCcHtjdtd|jS)NzRequest.message is deprecatedr6 stacklevel)warningswarnDeprecationWarningrr>s r@rzBaseRequest.messageKs$ 57IVWXXXX}rCc|jSrg)rr>s r@rzBaseRequest.rel_urlPs }rCcHtjdtd|jS)Nz#request.loop property is deprecatedr)rrrrr>s r@rzBaseRequest.loopTs. 13ERS    zrCkeycdSrgr=r?rs r@ __getitem__zBaseRequest.__getitem__]s69crCcdSrgr=rs r@rzBaseRequest.__getitem__`s,/CrCc|j|Srgrrs r@rzBaseRequest.__getitem__cs{3rCvaluecdSrgr=r?rrs r@ __setitem__zBaseRequest.__setitem__fsCF3rCcdSrgr=rs r@rzBaseRequest.__setitem__is9<rCct|tsI|tjvr;tj|t jdtd||j|<dS)NzIt is recommended to use web.RequestKey instances for keys. https://docs.aiohttp.org/en/stable/web_advanced.html#request-s-storager)categoryr) isinstancer#rMraddrrr4rrs r@rzBaseRequest.__setitem__lsr#z** s+:T/T/T  & * *3 / / / M'*     ! CrCc|j|=dSrgrrs r@ __delitem__zBaseRequest.__delitem__xs K   rCc*t|jSrg)lenrr>s r@__len__zBaseRequest.__len__{s4;rCc*t|jSrg)iterrr>s r@__iter__zBaseRequest.__iter__~sDK   rCc|jdkS)z5A bool indicating if the request is handled with SSL.r)rr>s r@securezBaseRequest.secures{g%%rC.cg}|jjtjdD]}t |}d}d}i}|tj|d|cxkr|krOnPt ||}||r| d|}n| \}} } | ddkr#td| dd } | r| | z } | ||<|t |dz }d }nw||dkr1d}i}|tj||dz }n:||d krd}|dz }n&||d vr|dz }n| d|}d|cxkr|kIt#|S) aA tuple containing all parsed Forwarded header(s). Makes an effort to parse Forwarded headers as specified by RFC 7239: - It adds one (immutable) dictionary per Forwarded 'field-value', ie per proxy. The element corresponds to the data in the Forwarded field-value added by the first proxy encountered by the client. Each subsequent item corresponds to those added by later proxies. - It checks that every value has valid syntax in general as specified in section 4: either a 'token' or a 'quoted-string'. - It un-escapes found escape sequences. - It does NOT validate 'by' and 'for' contents as specified in section 6. - It does NOT validate 'host' contents (Host ABNF). - It does NOT validate 'proto' contents for valid URI scheme names. Returns a tuple containing one or more immutable dicts r=rFN,"z\1rT;z )rr^getallr FORWARDEDrappendtypesrrxmatchfindgroupsrwsublowergroupr) r?elems field_valuelengthposneed_separatorelemrrZrports r@ forwardedzBaseRequest.forwardeds(=077KK% 5% 5K%%FC"N#%D LL/55 6 6 6s####V#####*00cBB$% .)..sC88,1LLNN)eT 8s??$;$?$?uQrT{$S$SE*!TME-2TZZ\\*s5;;q>>222)- %,,%*NDLL!7!=!=>>>1HCC %,,%*N1HCC %..1HCC&**344C?s####V####@U||rCc|jrdSdS)aA string representing the scheme of the request. Hostname is resolved in this order: - overridden value by .clone(scheme=new_scheme) call. - type of connection to peer: HTTPS if socket is SSL, HTTP otherwise. 'http' or 'https'. rr)rr>s r@rzBaseRequest.schemes  % 76rCc|jS)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rr>s r@rzBaseRequest.methods |rCc|jS)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rr>s r@rzBaseRequest.versions }rCc"|jjtj}||S|j}|dSt |tr4t|dkr d|ddSt|dSt|S)aHostname of the request. Hostname is resolved in this order: - overridden value by .clone(host=new_host) call. - HOST HTTP header - local socket address the request arrived on (transport ``sockname``) - empty string if no transport information is available For example, 'example.com' or 'localhost:8080'. For historical reasons, the port number may be included. Nrercr]) rr^getrHOSTrrrrr_)r?rrs r@rzBaseRequest.hosts }$((33  K+  2 h & & $8}}!!)8A;))))x{## #8}}rCc|jdSt|jttfrt |jdSt |jS)zRemote IP of client initiated HTTP request. The IP is resolved in this order: - overridden value by .clone(remote=new_remote) call. - peername of opened socket Nr)rrlistrr_r>s r@rzBaseRequest.remotesR  # +4 d.u > > 4t/233 34+,,,rCcrtj|j|j|jS)zThe full URL of the request.)r authority)rbuildrrjoinrr>s r@rzBaseRequest.urls- y tyAAAFFt}UUUrCc|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rrr>s r@rzBaseRequest.paths }!!rCc*t|jS)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )r_rr>s r@path_qszBaseRequest.path_qs"s 4=!!!rCc|jjS)zThe URL including raw *PATH INFO* without the host or scheme. Warning, the path is unquoted and may contains non valid URL characters E.g., ``/my%2Fpath%7Cwith%21some%25strange%24characters`` )rrr>s r@raw_pathzBaseRequest.raw_path*s}!!rCMultiMapping[str]c|jjS)z7A multidict with all the variables in the query string.)rqueryr>s r@rzBaseRequest.query4s}""rCc|jjS)z:The query string in the URL. E.g., id=10 )r query_stringr>s r@rzBaseRequest.query_string9s }))rCc|jS)z4A case-insensitive multidict proxy with all headers.)rr>s r@r^zBaseRequest.headersA }rCc|jjS)z$A sequence of pairs for all headers.)rrr>s r@rzBaseRequest.raw_headersFs}((rCcdt|jtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )r$r^r rIF_MODIFIED_SINCEr>s r@if_modified_sincezBaseRequest.if_modified_sinceKs% t|//0FGGHHHrCcdt|jtjS)z{The value of If-Unmodified-Since HTTP header, or None. This header is represented as a `datetime` object. )r$r^r rIF_UNMODIFIED_SINCEr>s r@if_unmodified_sincezBaseRequest.if_unmodified_sinceSs% t|//0HIIJJJrC etag_headerc#K|tkrtdtVdStj|D]B}|ddd\}}}|rdStt ||VCdS)z'Extract `ETag` objects from raw header.F)is_weakrrr6rN)rr!rfinditerrrL)r%rr'rgarbages r@ _etag_valueszBaseRequest._etag_values[s ( " "      -5kBB  */++aA*>*>'EE MM  rC header_valuecN|sdSt||Srg)rr*)clsr+s r@_if_match_or_none_implz"BaseRequest._if_match_or_none_implps- 4S%%l33444rCcp||jtjS)zxThe value of If-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )r.r^r rIF_MATCHr>s r@if_matchzBaseRequest.if_matchys* **4<+;+;DM+J+JKKKrCcp||jtjS)z}The value of If-None-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )r.r^r r IF_NONE_MATCHr>s r@ if_none_matchzBaseRequest.if_none_matchs+ **4<+;+;Ds r@if_rangezBaseRequest.if_ranges$ t|// >>???rCc|jj S)zIs keepalive enabled by client?)r should_closer>s r@ keep_alivezBaseRequest.keep_alives=---rCct|jtjd}t d|DS)zMReturn request cookies. A read-only dictionary-like object. rec$i|] \}}||jSr=)r)rirZmorsels r@ z'BaseRequest.cookies..s O O O fv| O O OrC)rr^r rCOOKIEr)r?parseds r@cookieszBaseRequest.cookiessB%T\%5%5dk2%F%FGG O O O O OPPPrCc|jtj}d\}}| d}t j||tjtjzd\}}n#t$rtdwxYw|rt|nd}|rt|nd}||| }d}|||dz }||krtd||cxurnntdt||dS) zMThe content of Range HTTP header. Return a slice instance. )NNNz^bytes=(\d*)-(\d*)$rzrange not in acceptable formatrzstart cannot be after endz"No start or end of range specified) rr rRANGErefindallASCII IGNORECASE IndexError ValueErrorintslice)r?rngstartendpatterns r@ http_rangezBaseRequest.http_ranges2m ++ s ? C0Zbh6NOOPQR ss C C C !ABBB C"+#c(((tC"'1CJJJTE} S_qC<<$%@AAA######## !EFFFUC###s 8A&&Bc|jS)zReturn raw payload stream.)rr>s r@contentzBaseRequest.contentrrCcntjdtd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrrat_eofr>s r@has_bodyzBaseRequest.has_bodys?  24FST    =''))))rCc6|j S)rT)rrUr>s r@ can_read_bodyzBaseRequest.can_read_bodys=''))))rCc8t|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typerr,r>s r@ body_existszBaseRequest.body_existssDM""*;;;rCcK|js:|jd{V|j8dSdS)zKRelease request. Eat unread part of HTTP BODY if present. N)rrUreadanyr>s r@releasezBaseRequest.releasesp -&&(( *-'')) ) ) ) ) ) ) )-&&(( * * * * *rCcK|j|jr|j|jt } |jd{V}|||jr.t|}||jkrt|j|snmt||_|jS)z_Read request body if present. Returns bytes object with full request content. N) rrrset_read_chunk_size bytearrayr]extendrr3ra)r?bodychunk body_sizes r@readzBaseRequest.reads   #$ I 11$2GHHH;;D "m3355555555 E"""(O #D I 4#88878MNNN  %T{{D rCcvK|d{V}|jpd}||S)z1Return BODY as text using encoding from .charset.Nr)rfcharsetdecode)r? bytes_bodyencodings r@r|zBaseRequest.textsE99;;&&&&&& <*7  ***rC)loadsrlcPK|d{V}||S)zReturn BODY as JSON.Nr{)r?rlrcs r@jsonzBaseRequest.jsons3YY[[      uT{{rCcKt|j|j|j|jj|jjtS)z3Return async iterator to process BODY as multipart.)rmax_field_size max_headersmax_size_error_cls)r+rrrrrprqr3r>s r@ multipartzBaseRequest.multiparts@ M M 1>828     rCMultiDictProxy[_Post]c K|j|jS|j|jvr'tt |_|jS|j}|dvr'tt |_|jS|dkr4t }|d{V}|j}|j}|j }| d{Vx}d|cxkr |j krnnt|d|cxkrt|krnnt||jt"j}t'|t(r#|jt-d|jrt1t2} d} |t6d{Vx} rd|cxkr |j krOnnL| r'|jd| jd{Vn| t||| 23d{V} | p,| t| zt2k} | r(|jd| j!| d{V`| !| v6|t6d{Vx} | r(|jd| j"dd{Vn| "d|d}tG|j|j| ||j} |$|j| nGtK}|d{Vx} rUd|cxkr |j krnnt||&| |d{Vx} UtK}||23d{V}|&|6||'d rE|(d }|$|j|)|n+|$|j|nt-d | d{Vx}n|*d{Vx}st }n~|j+pd }|,)|}|j} t t[||dkr|nd| }n#t,$rt|dwxYwt||_|jS)zReturn POST parameters.N)rez!application/x-www-form-urlencodedmultipart/form-datarvrzMultipart field missing name.F)sizezapplication/octet-streamztext/r)defaultz8To decode nested multipart you need to use custom reader)ryrk).rr POST_METHODSrrr]rsrrrnext total_bytesr3rr}r^r r CONTENT_TYPErr*rZrIr[r8rU read_chunkrrrun_in_executorclose decode_itertellwriteseekrNrrarb startswith get_charsetrirfrhrstripr)r?r]outrsmax_sizeryrfieldfield_cttmprolledrd decoded_chunkffraw_datardrhdatars r@postzBaseRequest.posts : !:  ??e^44Gz)()HIII ~;723GHH"'-2-=-=CU-=-V-V'V'V'V'V'V'VVe= 8AAAAg.AAAAAA#)!0*.**D*DT39*U*U$U$U$U$U$U$U$U$U$'IIKKK&?&I&I I7<7H7H7O7O = = = = = = =m*0*"$'HHJJ]1C1C$C&:%;!'$*!=*.**D*D(,ci+&+&%&%&%&%&%&%&%&%&%(IIm$<$<$<$<8P.3-=-=CU-=-V-V'V'V'V'V'V'VVe=*"("&*"<">UrZrxcZ|j}||S|j}||S|||S)z"Extra info from protocol transport)rrget_extra_info)r?rZrxrrs r@rzBaseRequest.get_extra_infos=>  N&  N''g666rCc|jddd}d|jjd|jd|dS)Nasciibackslashreplace< z >)rrrirrHr)r?ascii_encodable_paths r@__repr__zBaseRequest.__repr__sZ#y//9KLLSS   U4>*TTT\TTs r@__bool__zBaseRequest.__bool__strCresponsec KdSrgr=)r?rs r@ _prepare_hookzBaseRequest._prepare_hooks rCexcc0t|j|dSrg)r'r)r?rs r@_cancelzBaseRequest._cancelsdmS)))))rCc|j |jdkrdS|jD]3\}}t|tr|j4dS)Nrv)rr]rrrNr\r)r? file_namefile_field_objects r@_finishzBaseRequest._finishsu : !26K!K!K F-1J,<,<,>,> / / (I(+Y77 /!&,,... / /rC)r:r)r:rQ)r:r)r:N)r:rtrg)urHrIrJr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETEryr"ATTRS frozensetrr_Postr`rrasetrr_r(r-rasyncioAbstractEventLooprJdictr#r rr&rr2r0rpropertyrr Transportrrrrr%rrrrrrSrrrrrrrLrrrrrrr)rrrrrrrrrrr^r1rdatetimer!r$ staticmethodr!r* classmethodr.r1r4r7r:rArKrPrRrVrXr[r^rfr|r.r/rnr+rsrrrobjectrrr5r BaseExceptionrrr=rCr@rMrMs       L     "" E.+/E>% 4 '... $K$$$"suuNCH$$$ '!%9=!!=+=+=+"=+=+# =+ - =+ # =+'=+=+=+JsOc)3./$6=+d =+Dj=+d =+ =+=+=+=+D#+(0,4"* ("*+3-5= = = i= I% =  ) = i = Io= i= y= ?=  = = = = ~XX(7,t3(((X( $,$$$X$%%%%X%'3'''X' * U  U g/ U9z"~9"999X9 /s/s///X/ sZ^3     Fz"~FbFTFFFXF >>>>>>>> ? ?rC)r:rR)r:rP)rHrIrJrMrrrr r`rr_r rr&rr2r0rJrr%rrrr rr5r __classcell__)rs@r@rOrOs   =/ : : :E37K/0777 + +C +c +d + + + + + +#+(0,4"* ("*+3-5iI%   )  i Ioiy? 4  U &&&X& &]&&&X&?N?t????????rCrO)qrriorDstringsysrrcollections.abcrrrrrtypingrr r r r r rrattr multidictrrrrryarlrrrer_cookie_helpersrabcrhelpersrrrrrr r!r"r#r$r%r&r' http_parserr( http_writerr)rsr*r+streamsr,r-typedefsr.r/r0r1r2web_exceptionsr3r4 web_responser5 version_infotempfiler8raIOBase__all__web_apprP web_protocolrQweb_urldispatcherrRrSrUrJr`srNr_rardigits ascii_lettersrbrdformatrrrangerqrrrtrvcompilerwrxr}rMrOr=rCr@rs ==========""""""SSSSSSSSSSSSSSSSSSSS %$$$$$$$000000%%%%%%+*****$$$$$$6666666644444444HGGGGGGG((((((w-------OOOx