o m=8j{| @s$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 dlOmPZPedZQejRddddGdddZSeTeUBeVBeSBZWejXejYdZZeeTe[d<d eZd!Z\eeTe[d"<d#]d$^d%d&d'e_e`d(d)DZaeeTe[d*<d+ZbeeTe[d,<d-ebd.ead/ZceeTe[d0<d1e\d2e\d.ecd3ZdeeTe[d4<eed5Zfee eTe[d6<eeedZgee eTe[d7<Gd8d9d9e eTe0eBefe/ZhGd:d;d;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_attribsfrozenslotsc@s<eZdZUeed<eed<ejed<eed<eeed<dS)r5namefilenamefile content_typeheadersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderrrJrJZ/home/nk/hobo-godmode/plappi-mvp/.venv/lib/python3.10/site-packages/aiohttp/web_request.pyr5Es  r5z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]ccs|]}t|VqdSN)chr).0crJrJrK UsrT) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:|z)*"_QUOTED_STRING(z)=(z )(:\d{1,4})?_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_REc@seZdZUejejejejejhZ e j e gdBZ dZ eedBed<dZedBed<eZeeed<ddddddded ed d d ed ddejdedeeeeBefdBdedBdedBdedBddfddZe e e e e e e ddee!Bde"e!Bde#e!Bdee!Bdee!Bdee!Bdee!BddfddZ$e%dddZ&e%dd d!Z'e%dej(dBfd"d#Z)e%defd$d%Z*e%defd&d'Z+e,defd(d)Z-e,de.fd*d+Z/e,dejfd,d-Z0e1d.ee2de2fd/d0Z3e1d.edefd1d0Z3d.eee2Bdefd2d0Z3e1d.ee2d3e2ddfd4d5Z4e1d.ed3eddfd6d5Z4d.eee2Bd3eddfd7d5Z4d.eee2Bddfd8d9Z5defd:d;Z6de7eeeBfdd?Z:e,de;ee,defdEdFZ?e,de@fdGdHZAe,defdIdJZBe,dedBfdKdLZCe,de.fdMdNZDe,defdOdPZEe,defdQdRZFe,defdSdTZGe,ddVdWZHe,defdXdYZIe,deJefdZd[ZKe,deLfd\d]ZMe,deNjNdBfd^d_ZOe,deNjNdBfd`daZPeQdbede7eRfdcddZSeTdeedBde;eRd@fdBfdfdgZUe,de;eRd@fdBfdhdiZVe,de;eRd@fdBfdjdkZWe,deNjNdBfdldmZXe,de9fdndoZYe,dett||d<tdd|dD|d<|j j di|} i} |turQ|| d <|turY|| d <|tura|| d <|turh|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 contentrrpathrBcss(|]\}}|d|dfVqdS)utf-8N)encode)rRkvrJrJrKrTs  z$BaseRequest.clone.. raw_headersrvrwrx)rtruNrJ)rk RuntimeErrorr$rrFrrtupleitemsrb_replacero __class__rercrdrnrprlcopy) rrrrBrvrwrxrtdctnew_urlrykwargsrJrJrKclonesJ    zBaseRequest.clonecC|jSrP)rnrrJrJrKr}zBaseRequest.taskcCrrP)rcrrJrJrKr{rzBaseRequest.protocolcCs|jdurdS|jjSrP)rc transportrrJrJrKrs zBaseRequest.transportcCrrP)rdrrJrJrKwriterrzBaseRequest.writercCrrP)rorrJrJrKrtrzBaseRequest.client_max_sizecCtjdtdd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningrbrrJrJrKryszBaseRequest.messagecCrrP)rirrJrJrKrrzBaseRequest.rel_urlcCr)Nz#request.loop property is deprecatedr)rrrrprrJrJrKrszBaseRequest.loopkeycCdSrPrJrrrJrJrK __getitem__(zBaseRequest.__getitem__cCrrPrJrrJrJrKr+rcCs |j|SrPrlrrJrJrKr. valuecCrrPrJrrrrJrJrK __setitem__1rzBaseRequest.__setitem__cCrrPrJrrJrJrKr4rcCs>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!r4rsaddrrr2rlrrJrJrKr7s cCs |j|=dSrPrrrJrJrK __delitem__Cs zBaseRequest.__delitem__cC t|jSrP)lenrlrrJrJrK__len__FrzBaseRequest.__len__cCrrP)iterrlrrJrJrK__iter__IrzBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.https)rvrrJrJrKsecureN 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 rJrFN,"z\1rT;z )rbrBgetallr FORWARDEDrappendtypesrramatchfindgroupsr`sublowergroupr) relems field_valuelengthposneed_separatorelemrr>rportrJrJrK forwardedSsD           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'. rhttp)rqrrJrJrKrvs zBaseRequest.schemecCr)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rgrrJrJrKrzBaseRequest.methodcCr)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rhrrJrJrKrrzBaseRequest.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. NrOrMr]) rbrBgetrHOSTrrrrrF)rrwrrJrJrKrws   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)rrrlistrrFrrJrJrKrxs  zBaseRequest.remotecCstj|j|jd|jS)zThe full URL of the request.)rv authority)rbuildrvrwjoinrirrJrJrKrszBaseRequest.urlcC|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rirrrJrJrKrzBaseRequest.pathcCr)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rFrirrJrJrKpath_qss 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`` )rbrrrJrJrKraw_pathszBaseRequest.raw_pathMultiMapping[str]cCr)z7A multidict with all the variables in the query string.)riqueryrrJrJrKrzBaseRequest.querycCr)z:The query string in the URL. E.g., id=10 )ri query_stringrrJrJrKrrzBaseRequest.query_stringcCr)z4A case-insensitive multidict proxy with all headers.)rfrrJrJrKrB zBaseRequest.headerscCr)z$A sequence of pairs for all headers.)rbrrrJrJrKrrzBaseRequest.raw_headerscCt|jtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )r"rBrrIF_MODIFIED_SINCErrJrJrKif_modified_sincezBaseRequest.if_modified_sincecCr)z{The value of If-Unmodified-Since HTTP header, or None. This header is represented as a `datetime` object. )r"rBrrIF_UNMODIFIED_SINCErrJrJrKif_unmodified_sincerzBaseRequest.if_unmodified_since etag_headerccs`|tkrtdtdVdSt|D]}|ddd\}}}|r$dStt||dVqdS)z'Extract `ETag` objects from raw header.F)is_weakrrrrN)rrrfinditerrbool)rrrrgarbagerJrJrK _etag_values&s  zBaseRequest._etag_values header_valuecCs|sdSt||SrP)rr)clsrrJrJrK_if_match_or_none_impl;sz"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. )rrBrrIF_MATCHrrJrJrKif_matchDzBaseRequest.if_matchcCr)z}The value of If-None-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )rrBrr IF_NONE_MATCHrrJrJrK if_none_matchLrzBaseRequest.if_none_matchcCr)zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )r"rBrrIF_RANGErrJrJrKif_rangeTrzBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)rb should_closerrJrJrK keep_alive\rzBaseRequest.keep_alivecCs&t|jtjd}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. rOcSsi|]\}}||jqSrJ)r)rRr>morselrJrJrK ksz'BaseRequest.cookies..)rrBrrCOOKIEr)rparsedrJrJrKcookiesaszBaseRequest.cookiescCs|jtj}d\}}|durjzd}t||tjd\}}Wn ty*tdw|r1t |nd}|r9t |nd}|durH|durH| }d}|dur\|dur\|d7}||kr\td||uridurjtdt ||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) rfrrRANGErefindallASCII IndexError ValueErrorintslice)rrngstartendpatternrJrJrK http_rangems,  zBaseRequest.http_rangecCr)zReturn raw payload stream.)rerrJrJrKcontentrzBaseRequest.contentcCstjdtdd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrreat_eofrrJrJrKhas_bodys zBaseRequest.has_bodycCs |j S)r)rerrrJrJrK can_read_bodys zBaseRequest.can_read_bodycCst|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typerer*rrJrJrK body_existsszBaseRequest.body_existscs.|js|jIdH|jrdSdS)zKRelease request. Eat unread part of HTTP BODY if present. N)rerreadanyrrJrJrKreleases 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) rkroreset_read_chunk_size bytearrayrextendrr1bytes)rbodychunk body_sizerJrJrKreads"     zBaseRequest.readcs$|IdH}|jp d}||S)z1Return BODY as text using encoding from .charset.Nr)r'charsetdecode)r bytes_bodyencodingrJrJrKtexts  zBaseRequest.text)loadsr-cs|IdH}||S)zReturn BODY as JSON.N)r,)rr-r$rJrJrKjsonszBaseRequest.jsoncs$t|j|j|j|jj|jjtdS)z3Return async iterator to process BODY as multipart.)rtmax_field_size max_headersmax_size_error_cls)r)rfrerorcr/r0r1rrJrJrK multipartszBaseRequest.multipartMultiDictProxy[_Post]cs|jdur |jS|j|jvrtt|_|jS|j}|dvr(tt|_|jSt}|dkr`|IdH}|j}d}|IdH}dur_|j t j }t |trP|jdur^td|jr|jdtjIdH}|jtdIdH} r|| 2z33dHW} |jd|j| IdH|t| 7}d|kr|krnq||jd|jIdHt|q|6|jtdIdH} sw|jd|jdIdH|durd}t|j|jtt j!|||j } |"|j| not#} |IdH} r|t| 7}d|kr|krt|| $| |IdH} st#} || 2z 3dHW}| $|q6|dus7|%drH|j&d d }|"|j| '|n |"|j| ntd |IdH}dusHn|(IdH}|r|j)pod }|$t*|+'|d |d t||_|jS)zReturn POST parameters.N)rOz!application/x-www-form-urlencodedmultipart/form-datar4rzMultipart field missing name.)sizezapplication/octet-streamztext/r)defaultz8To decode nested multipart you need to use custom readerT)keep_blank_valuesr+),rjrg POST_METHODSrrrAr2ronextrBrr CONTENT_TYPErr(r>rr?rprun_in_executortempfile TemporaryFile read_chunkr decode_iterwritercloser1seekr5r rHrIrr!r" startswith get_charsetr)r'r(rrstrip)rrAoutr2max_sizer5fieldfield_cttmpr% decoded_chunkffraw_datardr(datarJrJrKposts              >   zBaseRequest.postr>r6cCs0|j}|dur |S|j}|dur|S|||S)z"Extra info from protocol transportN)rcrget_extra_info)rr>r6r{rrJrJrKrQAs zBaseRequest.get_extra_infocCs2|jddd}d|jjd|jd|dS)Nasciibackslashreplace< z >)rrr)rrCrg)rascii_encodable_pathrJrJrK__repr__MszBaseRequest.__repr__othercCst|t|kSrP)id)rrXrJrJrK__eq__SzBaseRequest.__eq__cCsdS)NTrJrrJrJrK__bool__VrzBaseRequest.__bool__responsecsdSrPrJ)rr]rJrJrK _prepare_hookYszBaseRequest._prepare_hookexccCst|j|dSrP)r%re)rr_rJrJrK_cancel\r[zBaseRequest._cancelcCsD|jdus |jdkr dS|jD]\}}t|tr|jqdS)Nr4)rjrArrr5r@rA)r file_namefile_field_objectrJrJrK_finish_s  zBaseRequest._finish)rr~)rr8)rr)rN)rr3rP)trCrDrEr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETEr8r ATTRS frozensetrjr_PostrGrkr#setrsrFr&r+rasyncioAbstractEventLooprdictr!rrr$rr0r.rpropertyr}r{ Transportrrrtr#ryrrrr r:rrrrrrrrrrrrvrr'rrwrxrrrrrrrrBr/rdatetimerr staticmethodrr classmethodrrrrrr rrrrrrrr'r,r,r-r.r)r2rPrQrWobjectrZr\r3r^ BaseExceptionr`rcrJrJrJrKr4ksV        ;  ;    <   #  d r4cseZdZUejedgBZdZeded<e r$de de ddffdd Z e e e e e e e d d e eBd eeBd eeBd e eBde eBde eBdeeBddffddZedddZedddZedefddZdeddfddZZS)r6 _match_infoNr9r>valrcs>||jvrtjd|jjd|dtddt||dS)NzSetting custom .z attribute is discouragedrr)rirrrrCrsuper __setattr__)rr>rxrrJrKr{ts zRequest.__setattr__rrrrBrvrwrxrtc s0tj|||||||d}tt|} |j| _| S)Nr)rzrr r6rw) rrrrBrvrwrxrtretnew_retr|rJrKr~s  z Request.clonecCs|j}|dus J|S)zResult of route resolving.N)rwr match_inforJrJrKrs zRequest.match_infor7cCs|j}|dus J|jS)zApplication instance.N)rw current_apprrJrJrKapps z Request.appcCsH|j}|dus J|j}|j}||}tt|d|d}t|S)Nr)rwappsrindexrreversedr)rrlstridxsublistrJrJrK config_dicts  zRequest.config_dictr]cs@|j}|dur dS|jD]}|j}r|||IdHq dSrP)rw_appson_response_preparesend)rr]rrrrJrJrKr^s  zRequest._prepare_hook)rr9)rr7)rCrDrEr4rirjrwr rGrrFrr{r$rr0r.rrr#rrprrrr3r^ __classcell__rJrJr|rKr6lsH       r6)jrmrrrHr stringr<rrcollections.abcrrrrrtypingrrr r r r r urllib.parserattr multidictrrrrryarlrrOr_cookie_helpersrabcrhelpersrrrrrrrr r!r"r#r$r% http_parserr& http_writerr'r2r(r)streamsr*r+typedefsr,r-r.r/r0web_exceptionsr1r2 web_responser3__all__web_appr7 web_protocolr8web_urldispatcherr9r:sr5rFr#r!rkdigits ascii_lettersrLrGrNformatrrrangerZr[r]r_compiler`rar4r6rJrJrJrKsl   $     <       $"