*Gj{| UddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z ddlm Z ddlm Z ddlmZmZmZmZmZmZmZddlmZddlZddlmZmZmZmZmZddlm Z d d l!m"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/m0Z0m1Z1m2Z2m3Z3m4Z4d dl5m6Z6d dl7m8Z8d dl9m:Z:m;Z;d dlZ>d dl?m@Z@mAZAmBZBmCZCmDZDd dlEmFZFmGZGd dlHmIZIdZJerd dlKmLZLd dlMmNZNd dlOmPZPedZQejRdddGddZSeTeUzeVzeSzZWejXejYzdzZZeeTe[d<d eZd!Z\eeTe[d"<d#]d$^d%d&e_e`d'd(zDZaeeTe[d)<d*ZbeeTe[d+<d,ebd-ead.ZceeTe[d/<d0e\d1e\d-ecd2ZdeeTe[d3<ejed4Zfee eTe[d5<ejeedZgee eTe[d6<Gd7d8e eTe0ezefe/ZhGd9d:ehZidS);N)IteratorMappingMutableMapping)Pattern)MappingProxyType) TYPE_CHECKINGAnyFinalOptionalTypeVarcastoverload) parse_qsl) CIMultiDictCIMultiDictProxy MultiDictMultiDictProxy MultiMapping)URL)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) BaseRequest FileFieldRequest) Application)RequestHandler)UrlMappingMatchInfo_TT) auto_attribsfrozenslotscXeZdZUeed<eed<ejed<eed<eeed<dS)r6namefilenamefile content_typeheadersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderr[/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/aiohttp/web_request.pyr6r6EsP IIIMMM  c """"""rMr6z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]c#4K|]}t|VdSN)chr).0cs rN rXUs( K KSVV K K K K K KrM) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:|z)*"_QUOTED_STRING(z)=(z )(:\d{1,4})?_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_REceZdZUejejejejejhZ e j e gdzZ dZ eedzed<dZedzed<eZeeed<ddddddded ed d d ed ddejdedeeeezefdzdedzdedzdedzddfdZe e e e e e e ddee!zde"e!zde#e!zdee!zdee!zdee!zdee!zddfdZ$e%dedZ&e%dfdZ'e%dej(dzfdZ)e%defdZ*e%defd Z+e,defd!Z-e,de.fd"Z/e,dejfd#Z0e1d$ee2de2fd%Z3e1d$edefd&Z3d$eee2zdefd'Z3e1d$ee2d(e2ddfd)Z4e1d$ed(eddfd*Z4d$eee2zd(eddfd+Z4d$eee2zddfd,Z5defd-Z6de7eeezfd.Z8e,de9fd/Z:e,de;ee,defd3Z?e,de@fd4ZAe,defd5ZBe,dedzfd6ZCe,de.fd7ZDe,defd8ZEe,defd9ZFe,defd:ZGe,dgd<ZHe,defd=ZIe,deJefd>ZKe,deLfd?ZMe,deNjNdzfd@ZOe,deNjNdzfdAZPeQdBede7eRfdCZSeTdDedzde;eRd0fdzfdEZUe,de;eRd0fdzfdFZVe,de;eRd0fdzfdGZWe,deNjNdzfdHZXe,de9fdIZYe,de.sW''Aq'""AHHW$5$56''''''rM raw_headersr{r|r})ryrzrL)rp RuntimeErrorr%rrHrrtupleitemsrg_replacert __class__rjrhrirsrurqcopy) rrrrDr{r|r}rydctnew_urlr~kwargss rNclonezBaseRequest.clones"   QOPP P   ! !"CM ( " "w< !4~''rMc|jSrT)rirs rNwriterzBaseRequest.writers ##rMc|jSrT)rtrs rNryzBaseRequest.client_max_sizes $$rMcHtjdtd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningrgrs rNr~zBaseRequest.messages$ 57IVWXXXX}rMc|jSrT)rnrs rNrzBaseRequest.rel_urls }rMcHtjdtd|jS)Nz#request.loop property is deprecatedr)rrrrurs rNrzBaseRequest.loops. 13ERS    zrMkeycdSrTrLrrs rN __getitem__zBaseRequest.__getitem__(s69crMcdSrTrLrs rNrzBaseRequest.__getitem__+s,/CrMc|j|SrTrqrs rNrzBaseRequest.__getitem__.s{3rMvaluecdSrTrLrrrs rN __setitem__zBaseRequest.__setitem__1sCF3rMcdSrTrLrs rNrzBaseRequest.__setitem__4s9<rMct|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"r5rxaddrrr3rqrs rNrzBaseRequest.__setitem__7sr#z** s+:T/T/T  & * *3 / / / M'*     ! CrMc|j|=dSrTrrs rN __delitem__zBaseRequest.__delitem__Cs K   rMc*t|jSrT)lenrqrs rN__len__zBaseRequest.__len__Fs4;rMc*t|jSrT)iterrqrs rN__iter__zBaseRequest.__iter__IsDK   rMc|jdkS)z5A bool indicating if the request is handled with SSL.https)r{rs rNsecurezBaseRequest.secureNs{g%%rM.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 rLrFN,"z\1rT;z )rgrDgetallr FORWARDEDrappendtypesrrematchfindgroupsrdsublowergroupr) relems field_valuelengthposneed_separatorelemrr@rports rN forwardedzBaseRequest.forwardedSs(=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||rMc|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'. rhttp)rvrs rNr{zBaseRequest.schemes  % 76rMc|jS)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rlrs rNrzBaseRequest.methods |rMc|jS)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rmrs rNrzBaseRequest.versions }rMc"|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. NrRrPr]) rgrDgetrHOSTrrrrrH)rr|rs rNr|zBaseRequest.hosts }$((33  K+  2 h & & $8}}!!)8A;))))x{## #8}}rMc|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)rwrlistrrHrs rNr}zBaseRequest.remotesR  # +4 d.u > > 4t/233 34+,,,rMcrtj|j|j|jS)zThe full URL of the request.)r{ authority)rbuildr{r|joinrnrs rNrzBaseRequest.urls- y tyAAAFFt}UUUrMc|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rnrrs rNrzBaseRequest.paths }!!rMc*t|jS)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rHrnrs rNpath_qszBaseRequest.path_qss 4=!!!rMc|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`` )rgrrs rNraw_pathzBaseRequest.raw_paths}!!rMMultiMapping[str]c|jjS)z7A multidict with all the variables in the query string.)rnqueryrs rNrzBaseRequest.querys}""rMc|jjS)z:The query string in the URL. E.g., id=10 )rn query_stringrs rNrzBaseRequest.query_strings }))rMc|jS)z4A case-insensitive multidict proxy with all headers.)rkrs rNrDzBaseRequest.headers  }rMc|jjS)z$A sequence of pairs for all headers.)rgrrs rNrzBaseRequest.raw_headerss}((rMcdt|jtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )r#rDrrIF_MODIFIED_SINCErs rNif_modified_sincezBaseRequest.if_modified_sinces% t|//0FGGHHHrMcdt|jtjS)z{The value of If-Unmodified-Since HTTP header, or None. This header is represented as a `datetime` object. )r#rDrrIF_UNMODIFIED_SINCErs rNif_unmodified_sincezBaseRequest.if_unmodified_sinces% t|//0HIIJJJrM etag_headerc#K|tkrtdtVdStj|D]B}|ddd\}}}|rdStt ||VCdS)z'Extract `ETag` objects from raw header.F)is_weakrrrrN)rr rfinditerrbool)rrrrgarbages rN _etag_valueszBaseRequest._etag_values&s ( " "      -5kBB  */++aA*>*>'EE MM  rM header_valuecN|sdSt||SrT)rr)clsrs rN_if_match_or_none_implz"BaseRequest._if_match_or_none_impl;s- 4S%%l33444rMcp||jtjS)zxThe value of If-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )rrDrrIF_MATCHrs rNif_matchzBaseRequest.if_matchDs* **4<+;+;DM+J+JKKKrMcp||jtjS)z}The value of If-None-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )rrDrr IF_NONE_MATCHrs rN if_none_matchzBaseRequest.if_none_matchLs+ **4<+;+;D>???rMc|jj S)zIs keepalive enabled by client?)rg should_closers rN keep_alivezBaseRequest.keep_alive\s=---rMct|jtjd}t d|DS)zMReturn request cookies. A read-only dictionary-like object. rRc$i|] \}}||jSrL)r)rVr@morsels rN z'BaseRequest.cookies..ks O O O fv| O O OrM)rrDrrCOOKIEr)rparseds rNcookieszBaseRequest.cookiesasB%T\%5%5dk2%F%FGG O O O O OPPPrMc|jtj}d\}}| d}t j||tjd\}}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) rkrrRANGErefindallASCII IndexError ValueErrorintslice)rrngstartendpatterns rN http_rangezBaseRequest.http_rangems*m ++ s ? C0Zbh??B ss C C C !ABBB C"+#c(((tC"'1CJJJTE} S_qC<<$%@AAA######## !EFFFUC###s +AA3c|jS)zReturn raw payload stream.)rjrs rNcontentzBaseRequest.contentrrMcntjdtd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrrjat_eofrs rNhas_bodyzBaseRequest.has_bodys?  24FST    =''))))rMc6|j S)r=)rjr>rs rN can_read_bodyzBaseRequest.can_read_bodys=''))))rMc8t|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typerjr+rs rN body_existszBaseRequest.body_existssDM""*;;;rMcK|js:|jd{V|j8dSdS)zKRelease request. Eat unread part of HTTP BODY if present. N)rjr>readanyrs rNreleasezBaseRequest.releasesp -&&(( *-'')) ) ) ) ) ) ) )-&&(( * * * * *rMcK|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) rprtrjset_read_chunk_size bytearrayrFextendrr2bytes)rbodychunk body_sizes rNreadzBaseRequest.reads   #$ I 11$2GHHH;;D "m3355555555 E"""(O #D I 4#88878MNNN  %T{{D rMcvK|d{V}|jpd}||S)z1Return BODY as text using encoding from .charset.Nr)rPcharsetdecode)r bytes_bodyencodings rNtextzBaseRequest.textsE99;;&&&&&& <*7  ***rM)loadsrWcPK|d{V}||S)zReturn BODY as JSON.N)rV)rrWrMs rNjsonzBaseRequest.jsons3YY[[      uT{{rMcKt|j|j|j|jj|jjtS)z3Return async iterator to process BODY as multipart.)rymax_field_size max_headersmax_size_error_cls)r*rkrjrtrhr[r\r2rs rN multipartzBaseRequest.multiparts@ M M 1>828     rMMultiDictProxy[_Post]c` K|j|jS|j|jvr'tt |_|jS|j}|dvr'tt |_|jSt }|dkr|d{V}|j}d}|d{Vx}X|j tj }t|tr|jt!d|jr|jdt(jd{V}|t.d{Vx} r|| 23d{V} |jd|j| d{V|t5| z }d|cxkr|kr8nP|jd|jd{Vt9|6|t.d{Vx} |jd|jdd{V|d}t=|j|jt?t@j!|||j } |"|j| nTtG} |d{Vx} rb|t5| z }d|cxkr|krnnt9|| $| |d{Vx} btG} || 23d{V}| $|6||%drE|&d }|"|j| '|n+|"|j| nt!d |d{Vx}Xno|(d{V}|rS|j)pd }|$tU|+'|d | t||_|jS)zReturn POST parameters.N)rRz!application/x-www-form-urlencodedmultipart/form-datararzMultipart field missing name.)sizezapplication/octet-streamztext/r)defaultz8To decode nested multipart you need to use custom readerT)keep_blank_valuesrU),rorl POST_METHODSrrrCr^rtnextrDrr CONTENT_TYPErr)r@r2rArurun_in_executortempfile TemporaryFile read_chunkr decode_iterwritercloser2seekr6r rJrKrrJrK startswith get_charsetrSrPrRrrstrip)rrCoutr^max_sizerbfieldfield_cttmprN decoded_chunkffraw_datardrRdatas rNpostzBaseRequest.posts : !:  ??e^449z)()HIII ~-7$(J$>$> ("8%%.3-=-=CU-=-V-V'V'V'V'V'V'VVeN7<7H7H7O7ONNNNNNNm&*j&@&@$(#)]'"'"!"!"!"!"!"!"!"!%M(:(: :#$x#6#6#6#6$#6#6#6#6#6*.**D*DT39*U*U$U$U$U$U$U$U$U*CH*M*M$M$7 8P.3-=-=CU-=-V-V'V'V'V'V'V'VVeN#j88sxKKKKKKKKK#+'AH&!J!N !2C88$!M  B////$-;;-2-=-=-?-?'?'?'?'?'?'??e3 CJJ.D 82222d22222&?&I&I I$OOE222 .3-=-=-?-?'?'?'?'?'?'??e3 !* ','8'8'B'B,,,,,,,!!LLOOOO(C$+x/B/B7/K/K+&+&7&7&7&H&HGGGEJ W0E0EFFFFGGEJ6666$Ru#,.."2"222222225?|$$$$$$D ,1'  ,,W55*.!($C(( zs H#Nr@rccZ|j}||S|j}||S|||S)z"Extra info from protocol transport)rhrget_extra_info)rr@rcrrs rNrzBaseRequest.get_extra_infoAs=>  N&  N''g666rMc|jddd}d|jjd|jd|dS)Nasciibackslashreplace< z >)rrrSrrErl)rascii_encodable_paths rN__repr__zBaseRequest.__repr__MsZ#y//9KLLSS   U4>*TTT\TT,> / / (I(+Y77 /!&,,... / /rM)rr)rr9)rr)rN)rr_rT)trErFrGr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETErer!ATTRS frozensetror_PostrIrprLsetrxrHr'r,rasyncioAbstractEventLoopr3dictr"r rr%rr1r/rpropertyrr Transportrrryr$r~rrrrr;rrrrrrrrrrrr{rr(rr|r}rrrrrrrrDr0rdatetimer r  staticmethodr r classmethodrrrr!r$r+r4r9r;r?rArDrGrPrVr-r.rYr*r^r}rrobjectrrr4r BaseExceptionrrrLrMrNr5r5ksS       L     "" E*+/E>% 4 '... $K$$$"suuNCH$$$ '9=!!6+6+6+"6+6+# 6+ - 6+ # 6+'6+6+JsOc)3./$66+d 6+Dj6+d 6+ 6+6+6+6+v#+(0,4"* ("*+39 9 9 i9 I% 9  ) 9 i 9 Io9 i9 y9  9 9 9 9 vXX(7,t3(((X( $,$$$X$%%%%X% * U  U g/ U9z"~9"999X9 /s/s///X/ sZ^3     Fz"~FbFTFFFXF >>>>>>>> ? ?rM)rr:)rr8)rErFrGr5rrrr rIrrHr rr%rr1r/r3rr$rrrrrr4r __classcell__)rs@rNr7r7ls   =/ : : :E37K/0777 + +C +c +d + + + + + +#+(0,4"* ("*+3iI%   )  i Ioiy 0  U &&&X& &]&&&X&?N?t????????rMr7)jrrrJr.stringrirrcollections.abcrrrrrtypingrr r r r r r urllib.parserattr multidictrrrrryarlrrRr_cookie_helpersrabcrhelpersrrrrrrr r!r"r#r$r%r& http_parserr' http_writerr(r^r)r*streamsr+r,typedefsr-r.r/r0r1web_exceptionsr2r3 web_responser4__all__web_appr8 web_protocolr9web_urldispatcherr:r;sr6rHrLrJrdigits ascii_lettersrOrIrQformatrrranger^r_rarccompilerdrer5r7rLrMrNrsi  ==========""""""OOOOOOOOOOOOOOOOOO"""""" 000000%%%%%%+*****$$$$$$6666666644444444HGGGGGGG(((((( 17$$$$$$,,,,,,666666 WT]]T$d333#######43# e i)+]V%99