o j^ @s~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@mAZAmBZBmCZCmDZDddlEmFZFmGZGddlHmIZIejJdkrddlKmLZLnddlKZKGdddeKjLeMejNZLdZOerddlPmQZQddlRmSZSddlTmUZUedZVdZWeeXeYd<ejZdddd Gd!d"d"Z[e\eMBe]Be[BZ^ej_ej`d#Zaee\eYd$<d%ead&Zbee\eYd'<d(cd)dd*d+d,eeefd-d.DZgee\eYd/<d0Zhee\eYd1<d2ehd3egd4Ziee\eYd5<d6ebd7ebd3eid8Zjee\eYd9<ekd:Zlee e\eYd;<ekejZmee e\eYd<<d=eXd>eFfd?d@ZnGdAdBdBe e\e0eBefe/ZoGdCdDdDeoZpdS)EN)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) )SpooledTemporaryFilec@s:eZdZdZdefddZdefddZdefddZd S) r7aMake 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. returncCdSNTselfr;r;F/opt/steambot/venv/lib/python3.10/site-packages/aiohttp/web_request.pyreadableFzSpooledTemporaryFile.readablecCr9r:r;r<r;r;r>writableIr@zSpooledTemporaryFile.writablecCr9r:r;r<r;r;r>seekableLr@zSpooledTemporaryFile.seekableN)__name__ __module__ __qualname____doc__boolr?rArBr;r;r;r>r7=s r7) BaseRequest FileFieldRequest) Application)RequestHandler)UrlMappingMatchInfo_T_FILE_SPOOL_MAX_SIZET) auto_attribsfrozenslotsc@s>eZdZUeed<eed<eeed<eed<eeed<dS)rInamefilenamefile content_typeheadersN)rCrDrEstr__annotations__rbytesrr;r;r;r>rIcs  rIz!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]ccs|]}t|VqdSN)chr).0cr;r;r> ssrd) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:|z)*"_QUOTED_STRING(z)=(z )(:\d{1,4})?_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_RE max_fieldsr8cCst|d|ddS)NzMaximum number of form fields z exceeded.text)r2)rrr;r;r>_too_many_fieldss ruc@seZdZUejejejejejhZ e j e gdBZ dZ eedBed<dZedBed<eZeeed<dddddddd ed ed d d edddejdededeeeeBefdBdedBdedBdedBddfddZe e e e e e e e ddee!Bde"e!Bde#e!Bdee!Bdee!Bdee!Bdee!Bdee!BddfddZ$e%dd d!Z&e%dd"d#Z'e%dej(dBfd$d%Z)e%defd&d'Z*e%defd(d)Z+e%defd*d+Z,e-defd,d-Z.e-de/fd.d/Z0e-dejfd0d1Z1e2d2ee3de3fd3d4Z4e2d2edefd5d4Z4d2eee3Bdefd6d4Z4e2d2ee3d7e3ddfd8d9Z5e2d2ed7eddfd:d9Z5d2eee3Bd7eddfd;d9Z5d2eee3Bddfdd?Z7de8eeeBfd@dAZ9e-de:fdBdCZ;e-dee-defdGdHZ?e-defdIdJZ@e-deAfdKdLZBe-defdMdNZCe-dedBfdOdPZDe-de/fdQdRZEe-defdSdTZFe-defdUdVZGe-defdWdXZHe-ddZd[ZIe-defd\d]ZJe-deKefd^d_ZLe-deMfd`daZNe-deOjOdBfdbdcZPe-deOjOdBfdddeZQeRdfede8eSfdgdhZTeUdiedBde__init__sH        zBaseRequest.__init__rrel_urlrXrrrrrrrrXc Cs|jrtdi} |tur|| d<|tur#t|} | | d<t| | d<|tur>tt|| d<tdd| dD| d<|j j di| } i} |turQ|| d <|turY|| d <|tura|| d <|turh|j }|turo|j }|j | |j|j|j|j|jf|||jd | S)aClone itself with replacement some attributes. Creates and returns a new instance of Request object. If no parameters are given, an exact copy is returned. If a parameter is not passed, it will reuse the one from the current request object. z.Cannot clone request after reading its contentrrpathrXcss(|]\}}|d|dfVqdS)utf-8N)encode)rbkvr;r;r>rds  z$BaseRequest.clone.. raw_headersrrr)rrrNr;)r RuntimeErrorr%rrYrrtupleitemsrv_replacerr __class__ryrwrxrrrcopy) r=rrrXrrrrrdctnew_urlrkwargsr;r;r>clonesP    zBaseRequest.clonecC|jSr`)rr<r;r;r>r1zBaseRequest.taskcCrr`)rwr<r;r;r>r5rzBaseRequest.protocolcCs|jdurdS|jjSr`)rw transportr<r;r;r>r9s zBaseRequest.transportcCrr`)rxr<r;r;r>writer?rzBaseRequest.writercCrr`)rr<r;r;r>rCrzBaseRequest.client_max_sizecCrr`)rr<r;r;r>rGrzBaseRequest.client_max_fieldscCtjdtdd|jS)NzRequest.message is deprecatedr5 stacklevel)warningswarnDeprecationWarningrvr<r;r;r>rKszBaseRequest.messagecCrr`)r}r<r;r;r>rPrzBaseRequest.rel_urlcCr)Nz#request.loop property is deprecatedr)rrrrr<r;r;r>rTszBaseRequest.loopkeycCdSr`r;r=rr;r;r> __getitem__]r@zBaseRequest.__getitem__cCrr`r;rr;r;r>r`r@cCs |j|Sr`rrr;r;r>rc valuecCrr`r;r=rrr;r;r> __setitem__fr@zBaseRequest.__setitem__cCrr`r;rr;r;r>rir@cCs>t|ts|tjvrtj|tjdtdd||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"rHraddrrr3rrr;r;r>rls cCs |j|=dSr`rrr;r;r> __delitem__xs zBaseRequest.__delitem__cC t|jSr`)lenrr<r;r;r>__len__{rzBaseRequest.__len__cCrr`)iterrr<r;r;r>__iter__~rzBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.r)rr<r;r;r>secure zBaseRequest.secure.c Csdg}|jjtjdD]}t|}d}d}i}|t|d|kr)|krnq t ||}|durm|r>| d|}nd| \}} } | ddkrUt d| dd } | r[| | 7} | ||<|t|d7}d }n5||dkrd}i}|t||d7}n||d krd}|d7}n||d vr|d7}n| d|}d|kr|ks+q q 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;rFN,"z\1rT;z )rvrXgetallr FORWARDEDrappendtypesrrqmatchfindgroupsrpsublowergroupr) r=elems field_valuelengthposneed_separatorelemrrTrportr;r;r> forwardedsD           zBaseRequest.forwardedcCs|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<r;r;r>rs zBaseRequest.schemecCr)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )r{r<r;r;r>rzBaseRequest.methodcCr)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )r|r<r;r;r>rrzBaseRequest.versioncCsh|jjtj}|dur|S|j}|durdSt|tr0t|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. Nr_r]r]) rvrXgetrHOSTrrrrrY)r=rrr;r;r>rs   zBaseRequest.hostcCs6|jdurdSt|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)rrlistrrYr<r;r;r>rs  zBaseRequest.remotecCstj|j|jd|jS)zThe full URL of the request.)r authority)rbuildrrjoinr}r<r;r;r>rszBaseRequest.urlcC|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )r}rr<r;r;r>rzBaseRequest.pathcCr)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rYr}r<r;r;r>path_qs"s zBaseRequest.path_qscCr)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`` )rvrr<r;r;r>raw_path*szBaseRequest.raw_pathMultiMapping[str]cCr)z7A multidict with all the variables in the query string.)r}queryr<r;r;r>r4zBaseRequest.querycCr)z:The query string in the URL. E.g., id=10 )r} query_stringr<r;r;r>r9rzBaseRequest.query_stringcCr)z4A case-insensitive multidict proxy with all headers.)rzr<r;r;r>rXAzBaseRequest.headerscCr)z$A sequence of pairs for all headers.)rvrr<r;r;r>rFrzBaseRequest.raw_headerscCt|jtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )r#rXrrIF_MODIFIED_SINCEr<r;r;r>if_modified_sinceKzBaseRequest.if_modified_sincecCr)z{The value of If-Unmodified-Since HTTP header, or None. This header is represented as a `datetime` object. )r#rXrrIF_UNMODIFIED_SINCEr<r;r;r>if_unmodified_sinceSrzBaseRequest.if_unmodified_since etag_headerccs`|tkrtdtdVdSt|D]}|ddd\}}}|r$dStt||dVqdS)z'Extract `ETag` objects from raw header.F)is_weakrrr5rN)rr rfinditerrrG)rrrrgarbager;r;r> _etag_values[s  zBaseRequest._etag_values header_valuecCs|sdSt||Sr`)rr)clsrr;r;r>_if_match_or_none_implpsz"BaseRequest._if_match_or_none_implcC||jtjS)zxThe value of If-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )r rXrrIF_MATCHr<r;r;r>if_matchyzBaseRequest.if_matchcCr )z}The value of If-None-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )r rXrr IF_NONE_MATCHr<r;r;r> if_none_matchrzBaseRequest.if_none_matchcCr)zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )r#rXrrIF_RANGEr<r;r;r>if_rangerzBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)rv should_closer<r;r;r> keep_aliverzBaseRequest.keep_alivecCs&t|jtjd}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. r_cSsi|]\}}||jqSr;)r)rbrTmorselr;r;r> sz'BaseRequest.cookies..)rrXrrCOOKIEr)r=parsedr;r;r>cookiesszBaseRequest.cookiescCs|jtj}d\}}|durmzd}t||tjtjBd\}}Wn ty-t dw|r4t |nd}|r http_ranges,"  zBaseRequest.http_rangecCr)zReturn raw payload stream.)ryr<r;r;r>contentrzBaseRequest.contentcCstjdtdd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrryat_eofr<r;r;r>has_bodys zBaseRequest.has_bodycCs |j S)r))ryr*r<r;r;r> can_read_bodys zBaseRequest.can_read_bodycCst|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typeryr+r<r;r;r> body_existsszBaseRequest.body_existscs.|js|jIdH|jrdSdS)zKRelease request. Eat unread part of HTTP BODY if present. N)ryr*readanyr<r;r;r>releases zBaseRequest.releasecs||jdur;|jr|j|jt} |jIdH}|||jr2t|}||jkr2t|j|s5nqt ||_|jS)z_Read request body if present. Returns bytes object with full request content. N) rrryset_read_chunk_size bytearrayr/extendrr2r[)r=bodychunk body_sizer;r;r>reads"     zBaseRequest.readcs$|IdH}|jp d}||S)z1Return BODY as text using encoding from .charset.Nr)r7charsetdecode)r= bytes_bodyencodingr;r;r>rts  zBaseRequest.text)loadsr<cs|IdH}||S)zReturn BODY as JSON.Nrs)r=r<r4r;r;r>jsonszBaseRequest.jsoncs$t|j|j|j|jj|jjtdS)z3Return async iterator to process BODY as multipart.)rmax_field_size max_headersmax_size_error_cls)r*rzryrrwr>r?r2r<r;r;r> multipartszBaseRequest.multipartMultiDictProxy[_Post]cs|jdur |jS|j|jvrtt|_|jS|j}|dvr(tt|_|jS|dkrt}|IdH}|j}|j}|j }| IdH}durd|krZ|j kr[t |d|krjt |krkt||jtj}t|tr|jdurtd|jr#tt} d} |jtdIdH} rd|kr|j krnn| r|jd| jIdHt || t ||| 2z&3dHW} | p| t | tk} | r|jd| j!| IdHq| !| q6|jtdIdH} s| r|jd| j"dIdHn| "d|durd}t#|j|j| ||j} |$|j| nkt%}|IdH} rPd|kr@|j krAt ||&| |IdH} s0t%}||2z 3dHW}|&|qX6|dusq|'d r|j(d d }|$|j|)|n |$|j|ntd | IdH}dusLn>|*IdH}st}n0|j+pd }|,)|}|j}ztt-||dkr|nd|d }Wn tyt|dwt||_|jS)zReturn POST parameters.N)r_z!application/x-www-form-urlencodedmultipart/form-datarCrzMultipart field missing name.F)sizezapplication/octet-streamztext/r)defaultz8To decode nested multipart you need to use custom reader)rrr;).r~r{ POST_METHODSrrrWrArrrynext total_bytesr2rrurXrr CONTENT_TYPErr)rTr rUr7rP read_chunkrrrun_in_executorclose decode_itertellwriteseekrIrr2r3 startswith get_charsetr9r7r8rstripr)r=rWoutrAmax_sizerrrfieldfield_cttmprolledr5 decoded_chunkffraw_datardr8datarr;r;r>posts            R   zBaseRequest.postrTrEcCs0|j}|dur |S|j}|dur|S|||S)z"Extra info from protocol transportN)rwrget_extra_info)r=rTrErrr;r;r>r`s zBaseRequest.get_extra_infocCs2|jddd}d|jjd|jd|dS)Nasciibackslashreplace< z >)rrr9rrCr{)r=ascii_encodable_pathr;r;r>__repr__szBaseRequest.__repr__othercCst|t|kSr`)id)r=rgr;r;r>__eq__zBaseRequest.__eq__cCr9r:r;r<r;r;r>__bool__r@zBaseRequest.__bool__responsecsdSr`r;)r=rlr;r;r> _prepare_hookszBaseRequest._prepare_hookexccCst|j|dSr`)r&ry)r=rnr;r;r>_cancelrjzBaseRequest._cancelcCsD|jdus |jdkr dS|jD]\}}t|tr|jqdS)NrC)r~rWrrrIrVrL)r= file_namefile_field_objectr;r;r>_finishs  zBaseRequest._finish)r8r)r8rL)r8r)r8N)r8rBr`)urCrDrEr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETErFr!ATTRS frozensetr~r_PostrZrr[setrrYr'r,rasyncioAbstractEventLoopr!dictr"r rr%rr1r/rpropertyrr Transportrrrrr$rrrrrrNrrrrrrrGrrrrrrr(rrrrrrrrrrrXr0rdatetimerr staticmethodr r classmethodr r rrrrr"r'r(r+r,r.r0r7rtr-r.r=r*rAr_r`rfobjectrirkr4rm BaseExceptionrorrr;r;r;r>rHsh        B   ?    <   $   rHcseZdZUejedgBZdZeded<e r$de de ddffdd Z e e e e e e e e d d e eBd eeBd eeBd e eBde eBde eBdeeBdeeBddffddZedddZedddZedefddZdeddfddZZS) rJ _match_infoNrMrTvalr8cs>||jvrtjd|jjd|dtddt||dS)NzSetting custom .z attribute is discouragedrr)rxrrrrCrsuper __setattr__)r=rTrrr;r>rs zRequest.__setattr__rrrrXrrrrrc s2tj||||||||d} tt| } |j| _| S)Nr)rrr rJr) r=rrrXrrrrrretnew_retrr;r>rs  z Request.clonecCs|j}|dus J|S)zResult of route resolving.N)rr= match_infor;r;r>rs zRequest.match_inforKcCs|j}|dus J|jS)zApplication instance.N)r current_apprr;r;r>apps z Request.appcCsH|j}|dus J|j}|j}||}tt|d|d}t|S)Nr)rappsrindexrreversedr)r=rlstridxsublistr;r;r> config_dicts  zRequest.config_dictrlcs@|j}|dur dS|jD]}|j}r|||IdHq dSr`)r_appson_response_preparesend)r=rlrrrr;r;r>rms  zRequest._prepare_hook)r8rM)r8rK)rCrDrErHrxryrr rZrrYr rr%rr1r/r!rr$rrrrrr4rm __classcell__r;r;rr>rJsN        rJ)qr|riorstringsysrrcollections.abcrrrrrtypingrrr r r r r rattr multidictrrrrryarlrrr_r_cookie_helpersrabcrhelpersrrrrrrr r!r"r#r$r%r& http_parserr' http_writerr(rAr)r*streamsr+r,typedefsr-r.r/r0r1web_exceptionsr2r3 web_responser4 version_infotempfiler7r[IOBase__all__web_apprK web_protocolrLweb_urldispatcherrMrNrPr!rZsrIrYr2rzdigits ascii_lettersr\r^formatrrrangerjrkrmrocompilerprqrurHrJr;r;r;r>sv   (   <        $"2