o Rhhs @sUddlZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddlm Z ddl m Z mZmZmZmZmZmZmZmZmZmZmZddlmZddlZddlmZmZmZm Z m!Z!ddl"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/m0Z0m1Z1m2Z2m3Z3dd l4m5Z5dd l6m7Z7ddl8m9Z9m:Z:ddl;mm?Z?m@Z@mAZAmBZBmCZCddlDmEZEddlFmGZGdZHe rddlImJZJddlKmLZLddlMmNZNejOddddGdddZPejQejRdZSeeTeUd<deSdZVeeTeUd<d Wd!Xd"d#d$eYeZd%d&DZ[eeTeUd'<d(Z\eeTeUd)<d*jWe[e\d+Z]eeTeUd,<d-jWeVe]d.Z^eeTeUd/<e_d0Z`eeeTeUd1<e_e^ZaeeeTeUd2<Gd3d4d4eeTefe/ZbGd5d6d6ebZcdS)7N) SimpleCookie)MappingProxyType) TYPE_CHECKINGAnyDictFinalIteratorMappingMutableMappingOptionalPatternTupleUnioncast) parse_qsl) CIMultiDictCIMultiDictProxy MultiDictMultiDictProxy MultiMapping)URL)hdrs)AbstractStreamWriter) _SENTINELDEBUGETAG_ANYLIST_QUOTED_ETAG_RE ChainMapProxyETag HeadersMixinparse_http_datereifysentinel set_exception)RawRequestMessage) HttpVersion)BodyPartReaderMultipartReader)EmptyStreamReader StreamReader)DEFAULT_JSON_DECODER JSONDecoder LooseHeaders RawHeadersStrOrURL)HTTPRequestEntityTooLarge)StreamResponse) BaseRequest FileFieldRequest) Application)RequestHandler)UrlMappingMatchInfoT) auto_attribsfrozenslotsc@s8eZdZUeed<eed<ejed<eed<ded<dS)r3namefilenamefile content_typezCIMultiDictProxy[str]headersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderrGrGU/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/aiohttp/web_request.pyr3Ls   r3z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]ccs|]}t|VqdSN)chr).0crGrGrH [srQ) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:{quoted_pair}|{qdtext})*")qdtext quoted_pair_QUOTED_STRINGz0({token})=({token}|{quoted_string})(:\d{{1,4}})?)token quoted_string_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_REc@s$eZdZejejejejejhZ e j e gdBZ ddddddde deddd ed d d ejd edeeeefdeedeedeeddfddZeeeeeeeddeeefdeeefdeeefdeeefdeeefdeeefd eeefddfddZedddZedddZ edeej!fdd Z"edefd!d"Z#edefd#d$Z$e%de fd%d&Z&e%de'fd'd(Z(e%dejfd)d*Z)d+edefd,d-Z*d+ed.eddfd/d0Z+d+eddfd1d2Z,defd3d4Z-de.efd5d6Z/e%de0fd7d8Z1e%de2e3eefd9ffd:d;Z4e%defdd?Z6e%de7fd@dAZ8e%defdBdCZ9e%deefdDdEZ:e%de'fdFdGZ;e%defdHdIZe%ddOdPZ?e%defdQdRZ@e%ddSdTZAe%deBfdUdVZCe%deeDjDfdWdXZEe%deeDjDfdYdZZFeGd[ede.eHfd\d]ZIeJd^eedee2eHd9ffd_d`ZKe%dee2eHd9ffdadbZLe%dee2eHd9ffdcddZMe%deeDjDfdedfZNe%de0fdgdhZOe%de3eeffdidjZPe%deQfdkdlZRe%defdmdnZSede0fdodpZTede0fdqdrZUe%de0fdsdtZVddudvZWdeXfdwdxZYdefdydzZZe[d{d|e\defd}d~Z]de^fddZ_dddZ`ddededefddZadefddZbdecde0fddZdde0fddZedefddfddZgdehddfddZidddZjdS)r2)_message _protocol_payload_writer_payload_headers_method_version_rel_url_post _read_bytes_state_cache_task_client_max_size_loop_transport_sslcontext_transport_peernameiN)client_max_sizestateschemehostremotemessagepayloadprotocolr6payload_writertaskasyncio.Task[None]looprrrsrtrurvreturncCs|duri}||_||_||_||_|j|_|j|_|j|_ i|_ |j } | r?| |j d<| j |j d<| j|j d<| |_n|j |_d|_d|_||_||_||_||_|jj} | dus_J| d|_| d|_| durt| |j d<| dur}| |j d<| dur| |j d<dSdS)Nurlrurt sslcontextpeernamerv)rarbrcrdr?remethodrfversionrgrlr is_absoluterurtrelativerhrirjrkrmrnro transportget_extra_inforprq)selfrwrxryrzr{r}rrrsrtrurvrrrGrGrH__init__sD         zBaseRequest.__init__rrel_urlr?rtrurvrrrrr?c 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 }|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 contentrrpathr?css(|]\}}|d|dfVqdS)utf-8N)encode)rOkvrGrGrHrQs  z$BaseRequest.clone.. raw_headersrtrurv)rrrsNrG)rj RuntimeErrorr#rrCrrtupleitemsra_replacern __class__rdrbrcrmrorkcopy) rrrr?rtrurvrrdctnew_urlrwkwargsrGrGrHclonesJ    zBaseRequest.clonecC|jSrM)rmrrGrGrHr{ zBaseRequest.taskcCrrM)rbrrGrGrHryrzBaseRequest.protocolcCs|jdurdS|jjSrM)rbrrrGrGrHrs zBaseRequest.transportcCrrM)rcrrGrGrHwriterrzBaseRequest.writercCrrM)rnrrGrGrHrrrzBaseRequest.client_max_sizecCtjdtdd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningrarrGrGrHrw szBaseRequest.messagecCrrM)rhrrGrGrHr%rzBaseRequest.rel_urlcCr)Nz#request.loop property is deprecatedr)rrrrorrGrGrHr})szBaseRequest.loopkeycCs |j|SrMrkrrrGrGrH __getitem__2 zBaseRequest.__getitem__valuecCs||j|<dSrMr)rrrrGrGrH __setitem__5szBaseRequest.__setitem__cCs |j|=dSrMrrrGrGrH __delitem__8s zBaseRequest.__delitem__cC t|jSrM)lenrkrrGrGrH__len__;rzBaseRequest.__len__cCrrM)iterrkrrGrGrH__iter__>rzBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.https)rtrrGrGrHsecureC 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 rGrFN,"z\1rT;z )rar?getallr FORWARDEDrappendtypesrr`matchfindgroupsr_sublowergroupr) relems field_valuelengthposneed_separatorelemrr;rportrGrGrH forwardedHsD           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)rprrGrGrHrts zBaseRequest.schemecCr)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rfrrGrGrHrzBaseRequest.methodcCr)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rgrrGrGrHrrzBaseRequest.versioncCs$|jjtj}|dur|StS)zHostname of the request. Hostname is resolved in this order: - overridden value by .clone(host=new_host) call. - HOST HTTP header - socket.getfqdn() value N)rar?getrHOSTsocketgetfqdn)rrurGrGrHrus 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)rq isinstancelistrrCrrGrGrHrvs  zBaseRequest.remotecCstj|j|jd}||jS)N)rtru)rbuildrtrujoinrh)rrrGrGrHrs zBaseRequest.urlcC|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rhrrrGrGrHrzBaseRequest.pathcCr)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rCrhrrGrGrHpath_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`` )rarrrGrGrHraw_pathszBaseRequest.raw_pathMultiMapping[str]cCs t|jjS)z7A multidict with all the variables in the query string.)rrhqueryrrGrGrHr zBaseRequest.querycCr)z:The query string in the URL. E.g., id=10 )rh query_stringrrGrGrHrrzBaseRequest.query_stringcCr)z4A case-insensitive multidict proxy with all headers.)rerrGrGrHr?zBaseRequest.headerscCr)z$A sequence of pairs for all headers.)rarrrGrGrHrszBaseRequest.raw_headerscCt|jtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )r!r?rrIF_MODIFIED_SINCErrGrGrHif_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!r?rrIF_UNMODIFIED_SINCErrGrGrHif_unmodified_sincerzBaseRequest.if_unmodified_since etag_headerccs`|tkrtdtdVdSt|D]}|ddd\}}}|r$dStt||dVqdS)z'Extract `ETag` objects from raw header.F)is_weakrrrN)rrrfinditerrbool)rrrrgarbagerGrGrH _etag_values s  zBaseRequest._etag_values header_valuecCs|sdSt||SrM)rr)clsrrGrGrH_if_match_or_none_implsz"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. )rr?rrIF_MATCHrrGrGrHif_match'zBaseRequest.if_matchcCr)z}The value of If-None-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )rr?rr IF_NONE_MATCHrrGrGrH if_none_match/rzBaseRequest.if_none_matchcCr)zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )r!r?rrIF_RANGErrGrGrHif_range7rzBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)ra should_closerrGrGrH keep_alive?rzBaseRequest.keep_alivecCs.|jtjd}t|}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. rLcSsi|]\}}||jqSrG)r)rOrvalrGrGrH Lsz'BaseRequest.cookies..)r?rrCOOKIErrr)rrawparsedrGrGrHcookiesDszBaseRequest.cookiescCs|jtj}d\}}|durhzd}t||d\}}Wn ty(tdw|r/t|nd}|r7t|nd}|durF|durF| }d}|durZ|durZ|d7}||krZtd||urgdurhtdt ||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) rerrRANGErefindall IndexError ValueErrorintslice)rrngstartendpatternrGrGrH http_rangeNs,  zBaseRequest.http_rangecCr)zReturn raw payload stream.)rdrrGrGrHcontentrrzBaseRequest.contentcCstjdtdd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrrdat_eofrrGrGrHhas_bodyws zBaseRequest.has_bodycCs |j S)r)rdrrrGrGrH can_read_bodyrzBaseRequest.can_read_bodycCst|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typerdr)rrGrGrH body_existsszBaseRequest.body_existscs.|js|jIdH|jrdSdS)zKRelease request. Eat unread part of HTTP BODY if present. N)rdrreadanyrrGrGrHreleases zBaseRequest.releasecsl|jdur3t} |jIdH}|||jr*t|}||jkr*t|j|d|s-nq t||_|jS)z_Read request body if present. Returns bytes object with full request content. NTmax_size actual_size) rj bytearrayrdrextendrnrr0bytes)rbodychunk body_sizerGrGrHreads"    zBaseRequest.readcs$|IdH}|jp d}||S)z1Return BODY as text using encoding from .charset.Nr)rcharsetdecode)r bytes_bodyencodingrGrGrHtexts  zBaseRequest.text)loadsr%cs|IdH}||S)zReturn BODY as JSON.N)r$)rr%rrGrGrHjsonszBaseRequest.jsoncst|j|jS)z3Return async iterator to process BODY as multipart.)r(rerdrrGrGrH multipartszBaseRequest.multipart,MultiDictProxy[Union[str, bytes, FileField]]cs|jdur |jS|j|jvrtt|_|jS|j}|dvr(tt|_|jSt}|dkr3|IdH}|j}|IdH}|dur2d}|j t j }t |tr#|jdus\J|jr|jdtjIdH}|jddIdH} | r|| } |jd|j| IdH|t| 7}d|kr|krnn|jd|jIdHt||d|jddIdH} | su|jd|jdIdH|durd}t|j|jttj|||j } | |j| nJ|j!d d IdH} |dus|"d r|j#d d } | |j| | n| |j| |t| 7}d|kr|kr"nn t||dnt$d|IdH}|dusFn|!IdH} | rR|j%pBd } |&t'| (| d | dt||_|jS)zReturn POST parameters.N)rLz!application/x-www-form-urlencodedmultipart/form-datar)ri)sizerzapplication/octet-streamT)r!ztext/r)defaultz8To decode nested multipart you need to use custom reader)keep_blank_valuesr#))rirf POST_METHODSrrr>r'rnnextr?rr CONTENT_TYPErr'r;r<rorun_in_executortempfile TemporaryFile read_chunkr!writercloser0seekr3rrErFaddr startswith get_charsetrr rrrstrip)rr>outr'rfieldr*field_cttmprffrr datarGrGrHposts              <   zBaseRequest.postr;r+cCs0|j}|dur |S|j}|dur|S|||S)z"Extra info from protocol transportN)rbrr)rr;r+ryrrGrGrHrs zBaseRequest.get_extra_infocCs(|jddd}d|jj|j|S)Nasciibackslashreplacez <{} {} {} >)rrr!formatrr@rf)rascii_encodable_pathrGrGrH__repr__#s  zBaseRequest.__repr__othercCst|t|kSrM)id)rrGrGrGrH__eq__+zBaseRequest.__eq__cCsdS)NTrGrrGrGrH__bool__.szBaseRequest.__bool__responsecsdSrMrG)rrLrGrGrH _prepare_hook1szBaseRequest._prepare_hookexccCst|j|dSrM)r$rd)rrNrGrGrH_cancel4rJzBaseRequest._cancelcCsD|jdus |jdkr dS|jD]\}}t|tr|jqdS)Nr))rir>rrr3r=r5)r file_namefile_field_objectrGrGrH_finish7s  zBaseRequest._finish)r~r|)r~r6)r~r)r~N)r~r(rM)kr@rArBr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETEr-r ATTRS frozensetr%r*rasyncioAbstractEventLooprr rrCrrr#rrr/r-rpropertyr{ry Transportrrrrr"rwrrr}rrrrrrrrr r rrtrr&rrurvrrrrrrr?r.rdatetimerr staticmethodrr classmethodrrrrrrrr r rrrrrrr$r+r,r&r(r'rArrFobjectrIrKr1rM BaseExceptionrOrRrGrGrGrHr2vs@      <        ;   <    #  b r2cseZdZejedgBZdededdffdd Zer(de d eddffd d Z e e e e e e e d d e e e fde ee fde ee fde e e fde e e fde e e fde ee fddffddZed!ddZed"ddZedefddZdeddfdd ZZS)#r4 _match_infoargsrr~Ncstj|i|d|_dSrM)superrrc)rrdrrrGrHrHs zRequest.__init__r;rcs8||jvrtjd|jj|tddt||dS)Nz-Setting custom {}.{} attribute is discouragedrr) rXrrrDrr@rre __setattr__)rr;rrfrGrHrgSs  zRequest.__setattr__rrrr?rtrurvrrc s0tj|||||||d}tt|} |j| _| S)Nr)rerrr4rc) rrrr?rtrurvrrretnew_retrfrGrHr]s  z Request.cloner7cCs|j}|dus J|S)zResult of route resolving.N)rcr match_inforGrGrHrkus zRequest.match_infor5cCs|j}|dus J|jS)zApplication instance.N)rc current_apprjrGrGrHapp|s z Request.appcCsH|j}|dus J|j}|j}||}tt|d|d}t|S)Nr)rcappsrmindexrreversedr)rrklstrmidxsublistrGrGrH config_dicts  zRequest.config_dictrLcs8|j}|dur dS|jD] }|j||IdHq dSrM)rc_appson_response_preparesend)rrLrkrmrGrGrHrMs zRequest._prepare_hook)r~r7)r~r5)r@rArBr2rXrYrrrrCrgr#rrr/r-rrr"rkr\rmrrtr1rM __classcell__rGrGrfrHr4DsH             r4)drZr^rErrstringr1rr http.cookiesrrtypingrrrrrr r r r r rr urllib.parserattr multidictrrrrryarlrrLrabcrhelpersrrrrrrr r!r"r#r$ http_parserr% http_writerr&r'r'r(streamsr)r*typedefsr+r,r-r.r/web_exceptionsr0 web_responser1__all__web_appr5 web_protocolr6web_urldispatcherr7sr3digits ascii_lettersrIrCrDrKrDrrrangerWrXr[r^compiler_r`r2r4rGrGrGrHsn   8    4       S