Ej| 0UddlZddlZddlZddlZddlZddlZddlZddlZddlm 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 dlOmPZPedZQejdddGddZSeTeUzeVzeSzZWejejzdzZZeeTe[d<d eZd!Z\eeTe[d"<d#jd$jd%d&e_e`d'd(zDZaeeTe[d)<d*ZbeeTe[d+<d,ebd-ead.ZceeTe[d/<d0e\d1e\d-ecd2ZdeeTe[d3<ejd4Zfee eTe[d5<ejedZgee eTe[d6<Gd7d8e eTe0ezefe/ZhGd9d:ehZiy);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_attribsfrozenslotscZeZdZUeed<eed<ej ed<eed<eeed<y)r6namefilenamefile content_typeheadersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderrQ/root/workspace/ytshorts/venv/lib/python3.12/site-packages/aiohttp/web_request.pyr6r6Es) IM   c ""rMr6z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]c#2K|]}t|ywN)chr).0cs rN rXUs KSV Ks) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:|z)*"_QUOTED_STRING(z)=(z )(:\d{1,4})?_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_REceZdZUejej ej ejejhZ e je gdzZ dZ eedzed<dZedzed<eZeeed<ddddddded ed d d ed ddej4dedeeeezefdzdedzdedzdedzddfdZe e e e e e e ddee!zde"e!zde#e!zdee!zdee!zdee!zdee!zddfdZ$e%dcdZ&e%dddZ'e%dejPdzfdZ)e%defdZ*e%defd Z+e,defd!Z-e,de.fd"Z/e,dej4fd#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,ded;ZHe,defd<ZIe,deJefd=ZKe,deLfd>ZMe,deNjdzfd?ZOe,deNjdzfd@ZPeQdAede7eRfdBZSeTdCedzde;eRd0fdzfdDZUe,de;eRd0fdzfdEZVe,de;eRd0fdzfdFZWe,deNjdzfdGZXe,de9fdHZYe,de.s3'Aq'"AHHW$56's/1 raw_headersr|r}r~)rzr{rL)rp RuntimeErrorr%rrHrrtupleitemsrg_replacert __class__rjrhrirsrurqcopy) rrrrDr|r}r~rzdctnew_urlrkwargss rNclonezBaseRequest.clonesa"   OP P   !"CM ( "w> !~~'''rMc|jSrT)rirs rNwriterzBaseRequest.writers###rMc|jSrT)rtrs rNrzzBaseRequest.client_max_sizes$$$rMcRtjdtd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningrgrs rNrzBaseRequest.messages 57IVWX}}rMc|jSrT)rnrs rNrzBaseRequest.rel_urls }}rMcRtjdtd|jS)Nz#request.loop property is deprecatedr)rrrrurs rNrzBaseRequest.loop s# 13ERS zzrMkeycyrTrLrrs rN __getitem__zBaseRequest.__getitem__)s69rMcyrTrLrs rNrzBaseRequest.__getitem__,s,/rMc |j|SrTrqrs rNrzBaseRequest.__getitem__/s{{3rMvaluecyrTrLrrrs rN __setitem__zBaseRequest.__setitem__2sCFrMcyrTrLrs rNrzBaseRequest.__setitem__5s922)- %,%*NDLL!7!7!=>1HC %,%*N1HC %.1HC&**34C?s#V## % 5LU|rMc|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'. rhttp)rvrs rNr|zBaseRequest.schemes  % %rMc|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|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. rRrPr]) rgrDgetrHOSTrxrrrrH)rr}rs rNr}zBaseRequest.hosts }}$$((3  K++   h &8}!8A;-q))x{# #8}rMc|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)rwrlistrrHrs rNr~zBaseRequest.remotesN  # # + d..u >t//23 34++,,rMctj|j|jj |j S)zThe full URL of the request.)r| authority)rbuildr|r}joinrnrs rNrzBaseRequest.urls, yy tyyAFFt}}UUrMc.|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}}!!!rMc.|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}}(((rMcft|jjtjS)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||//0F0FGHHrMcft|jjtjS)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||//0H0HIJJrM etag_headerc#K|tk(rtdtytj|D]5}|j ddd\}}}|rytt ||7yw)z'Extract `ETag` objects from raw header.F)is_weakrrrrN)rr rfinditerrbool)r rrrgarbages rN _etag_valueszBaseRequest._etag_values'sw ( "  -55kB */++aA*>' M sA,A. header_valuec<|syt|j|SrT)rr)clsrs rN_if_match_or_none_implz"BaseRequest._if_match_or_none_impl<s S%%l344rMcr|j|jjtjS)zxThe value of If-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )rrDrrIF_MATCHrs rNif_matchzBaseRequest.if_matchEs( **4<<+;+;DMM+JKKrMcr|j|jjtjS)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_matchMs* **4<<+;+;D??rMc0|jj S)zIs keepalive enabled by client?)rg should_closers rN keep_alivezBaseRequest.keep_alive]s==----rMct|jjtjd}t |Dcic]\}}||j c}}Scc}}w)zMReturn request cookies. A read-only dictionary-like object. rR)rrDrrCOOKIErr)rparsedr@morsels rNcookieszBaseRequest.cookiesbsI%T\\%5%5dkk2%FG O fv||!3 OPP OsA c|jjtj}d\}}| d}t j ||tj d\}}|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) rkrrRANGErefindallASCII IndexError ValueErrorintslice)rrngstartendpatterns rN http_rangezBaseRequest.http_rangensmm + s ? C0ZZbhh?B s"#c(tC"'CJTE} S_qC<$%@AA# !EFF$UC##+ C !ABB Cs -B??Cc|jS)zReturn raw payload stream.)rjrs rNcontentzBaseRequest.contentrrMcptjdtd|jj 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_bodys1  24FST =='')))rMc8|jj 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_existssDMM"*;;;rMcK|jjs>|jjd{|jjs=yy7!w)zKRelease request. Eat unread part of HTTP BODY if present. N)rjr;readanyrs rNreleasezBaseRequest.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) rprtrjset_read_chunk_size bytearrayrCextendrr2bytes)rbodychunk body_sizes rNreadzBaseRequest.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)rMcharsetdecode)r bytes_bodyencodings rNtextzBaseRequest.texts899;& <<*7  **'s ><&>)loadsrTcNK|jd{}||S7 w)zReturn BODY as JSON.N)rS)rrTrJs rNjsonzBaseRequest.jsons#YY[ T{!s %# %cKt|j|j|j|jj |jj tSw)z3Return async iterator to process BODY as multipart.)rzmax_field_size max_headersmax_size_error_cls)r*rkrjrtrhrXrYr2rs rN multipartzBaseRequest.multipartsG MM MM 11>>88228   sAAc K|j |jS|j|jvr$tt |_|jS|j }|dvr$tt |_|jSt }|dk(r|j d{}|j}d}|jd{x}|jjtj}t|trU|j t!d|j"r|j$j'dt(j*d{}|j-t.d{x} r|j1| 23d{} |j$j'd|j2| d{|t5| z }d|cxkr|ksRnU|j$j'd|j6d{t9||j$j'd|j:dd{|d}t=|j|j"t?t@jB|||j} |jE|j| ntG} |j-d{x} rQ|t5| z }d|cxkr|kr t9|| jI| |j-d{x} rQtG} |j1| 23d{}| jI|t!d |jd{x}nd|jQd{}|rJ|jRxsd }|jItU|jWjO|d | t||_|jS7e7B777~7R7 6|j-t.d{7x} r#77t7'76||jKdr?|jMd }|jE|j| jO|7|jE|j| U7B7(w)zReturn POST parameters.N)rRz!application/x-www-form-urlencodedmultipart/form-datar]rzMultipart field missing name.)sizezapplication/octet-streamztext/r)defaultz8To decode nested multipart you need to use custom readerT)keep_blank_valuesrR),rorl POST_METHODSrrrCr[rtnextrDrr CONTENT_TYPErr)r@r/rArurun_in_executortempfile TemporaryFile read_chunkr decode_iterwritercloser2seekr6r rJrKrrGrH startswith get_charsetrPrMrOrrstrip)rrCoutr[max_sizer^fieldfield_cttmprK decoded_chunkffraw_datardrOdatas rNpostzBaseRequest.posts? :: !::  <->?e^4zz)()HII ~~$(JJ$>$> ("8"8%.3-=-=CU-=-V'VVeV7<7H7H7ONNm&*jj&@&@$(#))]'"!"!"!%M(: :#$x#6$#6*.***D*DT399*U$U$U*CH*M$M"jj88sxxKKK#+'AH&!JJ!NN !2!2C8$!MM  B/$-;-2-=-=-?'??e? CJ.D 82d2&?&I I 3$OOE2 .3-=-=-?'??e? !* ','8'8'B,,!!LLO%Ru#,.."2225?|$D,,1'  ,,W5*.!($C( zz]/3(WN!" %V 8P.3-=-=CU-=-V'V'VVeVL (@'?,'B$+x/B/B7/K&+&7&7&7&HGGGEJJ W0EFGGEJJ6q3|%s+B,S.P/%SPBS'P(SPSP(!P"P(%+SP"S/,SP%9SQBSQAS-Q.S5SQQQ1S S  SS&S'A-SSSSP("S%S(SQSSSSQA2SSr@r_cf|j}||S|j}||S|j||S)z"Extra info from protocol transport)rhrget_extra_info)rr@r_rrs rNr{zBaseRequest.get_extra_infoBs?>>  N&&  N''g66rMc|jjddjd}d|jjd|j d|dS)Nasciibackslashreplace< z >)rrrPrrErl)rascii_encodable_paths rN__repr__zBaseRequest.__repr__NsW#yy//9KLSS  4>>**+1T\\N! / (I(+Y7!&&,,. /rM)rr)rr9)rzMultiMapping[str])rN)rzMultiDictProxy[_Post]rT)trErFrGr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETErar!ATTRS frozensetror_PostrIrprIsetryrHr'r,rasyncioAbstractEventLoopr0dictr"r rr%rr1r/rpropertyrr Transportrrrzr$rrrrrr;rrrrrrrrrrrr|rr(rr}r~rrrrrrrrDr0rdatetimer r  staticmethodr r classmethodrrrr r#r(r1r6r8r<r>rArDrMrSr-r.rVr*r[ryr{robjectrrr4r BaseExceptionrrrLrMrNr5r5ks      L    " E,+/E>% 4 '. $K$"uNCH$ '9=!!6+"6+6+# 6+ - 6+ # 6+''6+6+JsOc)3./$66+d 6+Dj6+d 6+ 6+v#+(0,4"* ("*+39 i9 I% 9  ) 9 i 9 Io9 i9 y9  9 v(7,,t3(( $,$$%%% *    g// 9z"~9"99 /s/s// sZ^3  Fz"~FbFTFF avF%%&  G c *rMrrrrDr|r}r~rzc vt ||||||||}tt|} |j| _| S)Nr)rrr r7r) rrrrDr|r}r~rzretnew_retrs rNrz Request.clonesNgm+ w$"..rMc&|j}|J|S)zResult of route resolving.)rr match_infos rNrzRequest.match_infos!%% %%%rMc:|j}|J|jS)zApplication instance.)r current_apprs rNappz Request.apps'%% %%%%%%rMc|j}|J|j}|j}|j|}t t |d|dz}t |S)Nr)rappsrindexrreversedr)rrlstridxsublists rN config_dictzRequest.config_dicts\%% %%%oohhiinxIcAg/0W%%rMrcK|j}|y|jD]+}|jx}s|j||d{-y7wrT)r_appson_response_preparesend)rrrrrs rNrzRequest._prepare_hooksZ%%   ## ?C&)&=&=="=)..tX>>> ?>s-AAA A)rr:)rr8)rErFrGr5rrrr rIrrHr rr%rr1r/r0rr$rrrrrr4r __classcell__)rs@rNr7r7ms'    =/ : :E37K/07  +C +c +d +#+(0,4"* ("*+3iI%   )  i Ioiy 0   && &]&&?N?t?rMr7)jrrrJr+stringrerrcollections.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;sr6rHrIrGrdigits ascii_lettersrOrIrQformatrrranger^r_rarccompilerdrer5r7rLrMrNrs  =="OOO" 0%+$64H( 1$,6 T]T$d3##4# e i)+]]V%9%99