rPj^ 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@mAZAmBZBmCZCmDZDddlEmFZFmGZGddlHmIZIejdk\rddlKmLZLn'ddlKZKGddeKjeMejZLdZOerddlPmQZQddlRmSZSddlTmUZUedZVdZWeeXeYd<ejddd Gd!d"Z[e\eMze]ze[zZ^ejejzd#zZaee\eYd$<d%ead&Zbee\eYd'<d(jd)jd*d+eeefd,d-zDZgee\eYd.<d/Zhee\eYd0<d1ehd2egd3Ziee\eYd4<d5ebd6ebd2eid7Zjee\eYd8<ejd9Zlee e\eYd:<ejejZmee e\eYd;<dZnGd?d@e e\e0ezefe/ZoGdAdBeoZpy)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) )SpooledTemporaryFilec4eZdZdZdefdZdefdZdefdZy)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. returncyNTselfs X/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/aiohttp/web_request.pyreadablezSpooledTemporaryFile.readableFcyr<r=r>s r@writablezSpooledTemporaryFile.writableIrBrCcyr<r=r>s r@seekablezSpooledTemporaryFile.seekableLrBrCN)__name__ __module__ __qualname____doc__boolrArErGr=rCr@r8r8=s+  d  d  d rCr8) BaseRequest FileFieldRequest) Application)RequestHandler)UrlMappingMatchInfo_T_FILE_SPOOL_MAX_SIZET) auto_attribsfrozenslotscLeZdZUeed<eed<eeed<eed<eeed<y)rNnamefilenamefile content_typeheadersN)rHrIrJstr__annotations__rbytesrr=rCr@rNrNcs& IM U)O c ""rCrNz!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]c#2K|]}t|ywN)chr).0cs r@ rkss KSV Ks) !#_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 $9*ZP rCceZdZUejej ej ejejhZ e je gdzZ dZ eedzed<dZedzed<eZeeed<dddddddd ed ed d d edddej4dededeeeezefdzdedzdedzdedzddfdZe e e e e e e e ddee!zde"e!zde#e!zdee!zdee!zdee!zdee!zdee!zddfdZ$e%dfdZ&e%dgdZ'e%dejPdzfd Z)e%defd!Z*e%defd"Z+e%defd#Z,e-defd$Z.e-de/fd%Z0e-dej4fd&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-dhd>ZIe-defd?ZJe-deKefd@ZLe-deMfdAZNe-deOjdzfdBZPe-deOjdzfdCZQeRdDede8eSfdEZTeUdFedzde.s3'Aq'"AHHW$56's/1 raw_headersrrr)rrrr=)r RuntimeErrorr&rr_rrtupleitemsr_replacerr __class__rrrrrrcopy) r?rrr^rrrrrdctnew_urlrkwargss r@clonezBaseRequest.clonesx$   OP P   !"CM ( "ws r@rzBaseRequest.task1s zzrCc|jSrg)rr>s r@rzBaseRequest.protocol5s ~~rCcH|jy|jjSrg)r transportr>s r@rzBaseRequest.transport9s >> !~~'''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&&&rCcRtjdtd|jS)NzRequest.message is deprecatedr6 stacklevel)warningswarnDeprecationWarningrr>s r@rzBaseRequest.messageKs 57IVWX}}rCc|jSrg)rr>s r@rzBaseRequest.rel_urlPs }}rCcRtjdtd|jS)Nz#request.loop property is deprecatedr)rrrrr>s r@rzBaseRequest.loopTs# 13ERS zzrCkeycyrgr=r?rs r@ __getitem__zBaseRequest.__getitem__]s69rCcyrgr=rs r@rzBaseRequest.__getitem__`s,/rCc |j|Srgrrs r@rzBaseRequest.__getitem__cs{{3rCvaluecyrgr=r?rrs r@ __setitem__zBaseRequest.__setitem__fsCFrCcyrgr=rs r@rzBaseRequest.__setitem__is9s r@__len__zBaseRequest.__len__{s4;;rCc,t|jSrg)iterrr>s r@__iter__zBaseRequest.__iter__~sDKK  rCc |jdk(S)z5A bool indicating if the request is handled with SSL.r)rr>s r@securezBaseRequest.secures{{g%%rC.c<g}|jjjtjdD]X}t |}d}d}i}|j tj|d|cxkr|ksEnHtj||}||r|jd|}n|j\}} } | ddk(rtjd| dd} | r| | z } | ||j<|t |j!dz }d }ne||dk(r.d}i}|j tj||dz }n/||d k(rd}|dz }n||d vr|dz }n|jd|}d|cxkr|krX[t#|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=rF,"z\1rT;z )rr^getallr FORWARDEDrappendtypesrrxmatchfindgroupsrwsublowergroupr) r?elems field_valuelengthposneed_separatorelemrrZrports r@ forwardedzBaseRequest.forwardeds(==0077K% 5K%FC"N#%D LL//5 6s#V#*00cB$%)..sC8,1LLN)eT 8s?$;$?$?uQr{$SE!TME-2TZZ\*s5;;q>22)- %,%*NDLL!7!7!=>1HC %,%*N1HC %.1HC&**34C?s#V## % 5LU|rCc|jryy)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  % %rCc|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|jjjtj}||S|j }|yt |tr%t|dk(r 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. rercr]) rr^getrHOSTrrrrr_)r?rrs r@rzBaseRequest.hosts }}$$((3  K++   h &8}!8A;-q))x{# #8}rCc|jyt|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.remotesN  # # + d..u >t//23 34++,,rCctj|j|jj |j S)zThe full URL of the request.)r authority)rbuildrrjoinrr>s r@rzBaseRequest.urls, yy tyyAFFt}}UUrCc.|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}}!!!rCc.|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}}(((rCcft|jjtjS)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||//0F0FGHHrCcft|jjtjS)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||//0H0HIJJrC etag_headerc#K|tk(rtdtytj|D]5}|j ddd\}}}|rytt ||7yw)z'Extract `ETag` objects from raw header.F)is_weakrrr6rN)rr!rfinditerrrL)r$rr&rgarbages r@ _etag_valueszBaseRequest._etag_values[sw ( "  -55kB */++aA*>' M sA,A. header_valuec<|syt|j|Srg)rr))clsr*s r@_if_match_or_none_implz"BaseRequest._if_match_or_none_implps S%%l344rCcr|j|jjtjS)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<<+;+;DMM+JKKrCcr|j|jjtjS)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||// >??rCc0|jj S)zIs keepalive enabled by client?)r should_closer>s r@ keep_alivezBaseRequest.keep_alives==----rCct|jjtjd}t |Dcic]\}}||j c}}Scc}}w)zMReturn request cookies. A read-only dictionary-like object. re)rr^r rCOOKIErr)r?parsedrZmorsels r@cookieszBaseRequest.cookiessI%T\\%5%5dkk2%FG O fv||!3 OPP OsA c|jjtj}d\}}| d}t j ||tj tjzd\}}|r t|nd}|r t|nd}||| }d}|||dz }||k\r td||cxur tdt||dS#t$r tdwxYw) 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_rangesmm + s ? C0ZZbhh6NOPQR s"#c(tC"'CJTE} S_qC<$%@AA# !EFF$UC##+ C !ABB Cs >CC%c|jS)zReturn raw payload stream.)rr>s r@contentzBaseRequest.contentrrCcptjdtd|jj 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_bodys1  24FST =='')))rCc8|jj S)rQ)rrRr>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_existssDMM"*;;;rCcK|jjs>|jjd{|jjs=yy7!w)zKRelease request. Eat unread part of HTTP BODY if present. N)rrRreadanyr>s r@releasezBaseRequest.releasesC --&&(--'') ) )--&&( )s8AAAAcK|j|jr%|jj|jt } |jj d{}|j ||jr/t|}||jkDrt|j|snrt||_|jS7pw)z_Read request body if present. Returns bytes object with full request content. N) rrrset_read_chunk_size bytearrayrZextendrr3ra)r?bodychunk body_sizes r@readzBaseRequest.reads    #$$ 11$2G2GH;D"mm3355 E"(( #D I 4#8#8878M8MNN %T{D 6sA&C(C)A1CcK|jd{}|jxsd}|j|S7%w)z1Return BODY as text using encoding from .charset.Nr)rccharsetdecode)r? bytes_bodyencodings r@r|zBaseRequest.texts899;& <<*7  **'s ><&>)loadsricNK|jd{}||S7 w)zReturn BODY as JSON.Nr{)r?rir`s r@jsonzBaseRequest.jsons#YY[ T{!s %# %cKt|j|j|j|jj |jj tSw)z3Return async iterator to process BODY as multipart.)rmax_field_size max_headersmax_size_error_cls)r+rrrrrmrnr3r>s r@ multipartzBaseRequest.multipartsG MM MM 11>>88228   sAAc K|j |jS|j|jvr$tt |_|jS|j }|dvr$tt |_|jS|dk(rt }|j d{}|j}|j}|j}|jd{x}d|cxkr|jkr t|d|cxkrt|kr t||jj!t"j$}t'|t(r|j* t-d|j.rt1t2} d} |j5t6d{x} rd|cxkr|jkrYnnV| r9|j8j;d| j<d{t|| j=t||j?| 23d{} | xs#| jAt| zt2kD} | r0|j8j;d| jB| d{b| jC| t| r0|j8j;d| jDdd{n| jEd|d}tG|j*|j.| ||j} |jI|j*| ntK}|j5d{x} rMd|cxkr|jkr t||jM| |j5d{x} rMtK}|j?|23d{}|jM|t-d |jd{x}"n|jUd{x}s t }nZ|jVxsd }|jYjS|}|j} t t[||dkDr|nd| }t||_|jS77777w7"6|j5t6d{7x} r$3777?76||jOd r?|jQd }|jI|j*|jS|O|jI|j*|m7Z7@#t,$r t|dwxYww)zReturn POST parameters.N)rez!application/x-www-form-urlencodedmultipart/form-datarrrzMultipart field missing name.F)sizezapplication/octet-streamztext/r)defaultz8To decode nested multipart you need to use custom reader)ryrh).rr POST_METHODSrrr]rprrrnext total_bytesr3rr}r^r r CONTENT_TYPErr*rZrFr[r8rU read_chunkrrrun_in_executorclose decode_itertellwriteseekrNrr^r_ startswith get_charsetrfrcrerstripr)r?r]outrpmax_sizeryrfieldfield_cttmprolledra decoded_chunkffraw_datardredatars r@postzBaseRequest.posts :: !::  <->?e^4zz)()HII ~~23GH"'-2-=-=CU-=-V'VVeV 8Ag.A.AA#)*.***D*DT399*U$U$U'@&I I%(IIK&?&I I7<7H7H7O = =m*0*"$'HHJ]1C$C&:%;!'$**.***D*D(,cii+&%&%&%(IIm$<!"&**"<">  N&&  N''g66rCc|jjddjd}d|jjd|j d|dS)Nasciibackslashreplace< z >)rrrfrrHr)r?ascii_encodable_paths r@__repr__zBaseRequest.__repr__sW#yy//9KLSS  4>>**+1T\\N!s r@__bool__zBaseRequest.__bool__srCresponsec Kywrgr=)r?rs r@ _prepare_hookzBaseRequest._prepare_hooks sexcc0t|j|yrg)r'r)r?rs r@_cancelzBaseRequest._cancelsdmmS)rCc|j|jdk7ry|jjD]0\}}t|ts|j j 2y)Nrr)rr]rrrNr\r{)r? file_namefile_field_objects r@_finishzBaseRequest._finishs^ :: !2!26K!K -1JJ,<,<,> / (I(+Y7!&&,,. /rC)r:r)r:rQ)r:zMultiMapping[str])r:N)r:zMultiDictProxy[_Post]rg)urHrIrJr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETErur"ATTRS frozensetrr_Postr`rrasetrr_r(r-rasyncioAbstractEventLooprGdictr#r rr&rr2r0rpropertyrr Transportrrrrr%rrrrrrSrrrrrrrLrrrrrrr)rrrrrrrrrrr^r1rdatetimer r# staticmethodr!r) classmethodr-r0r3r6r9r>rHrMrOrSrUrXr[rcr|r.r/rkr+rprrrobjectrrr5r BaseExceptionrrr=rCr@rMrMs2      L    " E.+/E>% 4 '. $K$"uNCH$ '!%9=!!=+"=+=+# =+ - =+ # =+''=+=+=+JsOc)3./$6=+d =+Dj=+d =+ =+D#+(0,4"* ("*+3-5= i= I% =  ) = i = Io= i= y= ?=  = ~(7,,t3(( $,$$%%%'3'' *    g// 9z"~9"99 /s/s// sZ^3  Fz"~FbFTFF avF%%&  G c *rCrrrr^rrrrrc xt |||||||||} tt| } |j| _| S)Nr)rrrrOr) r?rrr^rrrrrretnew_retrs r@rz Request.clonesQgm+/  w$"..rCc&|j}|J|S)zResult of route resolving.)rr? match_infos r@rzRequest.match_infos!%% %%%rCc:|j}|J|jS)zApplication instance.)r current_apprs r@appz Request.apps'%% %%%%%%rCc|j}|J|j}|j}|j|}t t |d|dz}t |S)Nr)rappsrindexr reversedr )r?rlstridxsublists r@ config_dictzRequest.config_dicts\%% %%%oohhiinxIcAg/0W%%rCrcK|j}|y|jD]+}|jx}s|j||d{-y7wrg)r_appson_response_preparesend)r?rrrrs r@rzRequest._prepare_hooksZ%%   ## ?C&)&=&=="=)..tX>>> ?>s-AAA A)r:rR)r:rP)rHrIrJrMrrrr r`rr_r rr&rr2r0rGrr%rrrr rr5r __classcell__)rs@r@rOrOs8    =/ : :E37K/07  +C +c +d +#+(0,4"* ("*+3-5iI%   )  i Ioiy? 4   && &]&&?N?t?rCrO)qrriorAstringsysrrcollections.abcrrrrrtypingrr r r r r rrattr multidictrrrrryarlrrrer_cookie_helpersrabcrhelpersrrrrrr r!r"r#r$r%r&r' http_parserr( http_writerr)rpr*r+streamsr,r-typedefsr.r/r0r1r2web_exceptionsr3r4 web_responser5 version_infotempfiler8raIOBase__all__web_apprP web_protocolrQweb_urldispatcherrRrSrUrGr`srNr_r^rdigits ascii_lettersrbrdformatrrrangerqrrrtrvcompilerwrxr}rMrOr=rCr@rsr =="SSS %0%+$64H(w-x<