o it @sUddlZddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z mZmZmZmZmZmZmZmZmZddlmZddlZddlmZmZmZmZmZddl 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<Gd3d4d4eeTe fe/ZbGd5d6d6ebZcdS)7N)MappingProxyType) TYPE_CHECKINGAnyDictFinalIteratorMappingMutableMappingOptionalPatternTupleUnioncast) parse_qsl) CIMultiDictCIMultiDictProxy MultiDictMultiDictProxy MultiMapping)URL)hdrs)parse_cookie_header)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)Z auto_attribsfrozenslotsc@s<eZdZUeed<eed<ejed<eed<eeed<dS)r3namefilenamefile content_typeheadersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderrrFrFM/home/kim/smarthome/.venv/lib/python3.10/site-packages/aiohttp/web_request.pyr3Ls  r3z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]ccs|]}t|VqdSN)chr).0crFrFrG [srP) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:{quoted_pair}|{qdtext})*")ZqdtextZ quoted_pair_QUOTED_STRINGz0({token})=({token}|{quoted_string})(:\d{{1,4}})?)tokenZ quoted_string_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_REc@s\eZdZUejejejejejhZ e j e gdBZ dZ eeeeeefed<dZeeed<dddddddeded d d ed d dejdedeeeefdeedeedeeddfddZeeeeeeeddeee fdee!e fdee"e fdeee fdeee fdeee fdeee fddfddZ#e$dddZ%e$ddd Z&e$deej'fd!d"Z(e$defd#d$Z)e$defd%d&Z*e+defd'd(Z,e+de-fd)d*Z.e+dejfd+d,Z/d-edefd.d/Z0d-ed0eddfd1d2Z1d-eddfd3d4Z2defd5d6Z3de4efd7d8Z5e+de6fd9d:Z7e+de8e9eefd;ffdd?Z;e+defd@dAZe+defdDdEZ?e+deefdFdGZ@e+de-fdHdIZAe+defdJdKZBe+defdLdMZCe+defdNdOZDe+ddQdRZEe+defdSdTZFe+deGefdUdVZHe+deIfdWdXZJe+deeKjKfdYdZZLe+deeKjKfd[d\ZMeNd]ede4eOfd^d_ZPeQd`eedee8eOd;ffdadbZRe+dee8eOd;ffdcddZSe+dee8eOd;ffdedfZTe+deeKjKfdgdhZUe+de6fdidjZVe+de9eeffdkdlZWe+deXfdmdnZYe+defdodpZZe$de6fdqdrZ[e$de6fdsdtZ\e+de6fdudvZ]ddwdxZ^defdydzZ_defd{d|Z`ead}d~ebdefddZcdedfddZedddZfddededefddZgdefddZhdeide6fddZjde6fddZkdelddfddZmdenddfddZodddZpdS)r2)_message _protocol_payload_writer_payload_headers_method_version_rel_url_post _read_bytes_state_cache_task_client_max_size_loop_transport_sslcontext_transport_peernameNrerfi)client_max_sizestateschemehostremotemessagepayloadprotocolr6payload_writertaskasyncio.Task[None]looprnrorprqrrreturnc Cs ||_||_||_||_|j|_|j|_|j|_ i|_ |j } | j rJ| dur*| | } | dur3| | } | |j d<| j|j d<| j|j d<| |_n| |_| durV| |j d<| dur_| |j d<|durein||_||_||_||_|j|_|j|_| dur| |j d<dSdS)Nurlrqrprr)r]r^r_r`r>ramethodrbversionrcrhr{absoluteZ with_schemeZ with_hostrqrprelativerdrgrirjrk ssl_contextrlZpeernamerm) selfrsrtrurvrwryrnrorprqrrr{rFrFrG__init__s@        zBaseRequest.__init__r|rel_urlr>rprqrrrnr|rr>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 contentr|r{pathr>css(|]\}}|d|dfVqdS)utf-8N)encode)rNkvrFrFrGrPs  z$BaseRequest.clone.. raw_headersrprqrr)rnroNrF)rf RuntimeErrorr#rrBrrtupleitemsr]_replacerj __class__r`r^r_rirkrgcopy) rr|rr>rprqrrrndctnew_urlrskwargsrFrFrGclonesJ    zBaseRequest.clonecC|jSrL)rirrFrFrGrw zBaseRequest.taskcCrrL)r^rrFrFrGrurzBaseRequest.protocolcCs|jdurdS|jjSrL)r^ transportrrFrFrGrs zBaseRequest.transportcCrrL)r_rrFrFrGwriterrzBaseRequest.writercCrrL)rjrrFrFrGrnrzBaseRequest.client_max_sizecCtjdtdd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningr]rrFrFrGrs szBaseRequest.messagecCrrL)rdrrFrFrGr%rzBaseRequest.rel_urlcCr)Nz#request.loop property is deprecatedr)rrrrkrrFrFrGry)szBaseRequest.loopkeycCs |j|SrLrgrrrFrFrG __getitem__2 zBaseRequest.__getitem__valuecCs||j|<dSrLr)rrrrFrFrG __setitem__5szBaseRequest.__setitem__cCs |j|=dSrLrrrFrFrG __delitem__8s zBaseRequest.__delitem__cC t|jSrL)lenrgrrFrFrG__len__;rzBaseRequest.__len__cCrrL)iterrgrrFrFrG__iter__>rzBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.https)rprrFrFrGsecureC 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 rFrFN,"z\1rT;z )r]r>ZgetallrZ FORWARDEDrappendtypesrr\matchfindgroupsr[sublowergroupr) rZelemsZ field_valuelengthposZneed_separatorelemrr:rportrFrFrG 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)rlrrFrFrGrps zBaseRequest.schemecCr)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rbrrFrFrGr|zBaseRequest.methodcCr)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rcrrFrFrGr}rzBaseRequest.versioncCs$|jjtj}|dur|StS)a@Hostname of the request. Hostname is resolved in this order: - overridden value by .clone(host=new_host) call. - HOST HTTP header - socket.getfqdn() value For example, 'example.com' or 'localhost:8080'. For historical reasons, the port number may be included. N)r]r>getrZHOSTsocketgetfqdn)rrqrFrFrGrqszBaseRequest.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)rm isinstancelistrrBrrFrFrGrrs  zBaseRequest.remotecCstj|j|jd|jS)zThe full URL of the request.)rp authority)rbuildrprqjoinrdrrFrFrGr{szBaseRequest.urlcC|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rdrrrFrFrGrzBaseRequest.pathcCr)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rBrdrrFrFrGpath_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`` )r]rrrFrFrGraw_pathszBaseRequest.raw_pathMultiMapping[str]cCr)z7A multidict with all the variables in the query string.)rdqueryrrFrFrGrzBaseRequest.querycCr)z:The query string in the URL. E.g., id=10 )rd query_stringrrFrFrGrrzBaseRequest.query_stringcCr)z4A case-insensitive multidict proxy with all headers.)rarrFrFrGr>zBaseRequest.headerscCr)z$A sequence of pairs for all headers.)r]rrrFrFrGrrzBaseRequest.raw_headerscCt|jtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )r!r>rrZIF_MODIFIED_SINCErrFrFrGif_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>rrZIF_UNMODIFIED_SINCErrFrFrGif_unmodified_sincerzBaseRequest.if_unmodified_since etag_headerccs`|tkrtdtdVdSt|D]}|ddd\}}}|r$dStt||dVqdS)z'Extract `ETag` objects from raw header.F)is_weakrrrN)rrrfinditerrbool)rrrrgarbagerFrFrG _etag_valuess  zBaseRequest._etag_values header_valuecCs|sdSt||SrL)rr)clsrrFrFrG_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. )rr>rrZIF_MATCHrrFrFrGif_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>rrZ IF_NONE_MATCHrrFrFrG if_none_match5rzBaseRequest.if_none_matchcCr)zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )r!r>rrZIF_RANGErrFrFrGif_range=rzBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)r]Z should_closerrFrFrG keep_aliveErzBaseRequest.keep_alivecCs&t|jtjd}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. rKcSsi|]\}}||jqSrF)r)rNr:morselrFrFrG Tsz'BaseRequest.cookies..)rr>rrZCOOKIEr)rparsedrFrFrGcookiesJszBaseRequest.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) rarrRANGErefindallASCII IndexError ValueErrorintslice)rrngstartendpatternrFrFrG http_rangeVs,  zBaseRequest.http_rangecCr)zReturn raw payload stream.)r`rrFrFrGcontentzrzBaseRequest.contentcCstjdtdd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrr`at_eofrrFrFrGhas_bodys zBaseRequest.has_bodycCs |j S)r)r`rrrFrFrG can_read_bodys zBaseRequest.can_read_bodycCst|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typer`r)rrFrFrG body_existsszBaseRequest.body_existscs.|js|jIdH|jrdSdS)zKRelease request. Eat unread part of HTTP BODY if present. N)r`rreadanyrrFrFrGreleases 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_sizeZ actual_size) rf bytearrayr`rextendrjrr0bytes)rbodychunkZ body_sizerFrFrGreads"    zBaseRequest.readcs$|IdH}|jp d}||S)z1Return BODY as text using encoding from .charset.Nr)r charsetdecode)rZ bytes_bodyencodingrFrFrGtexts  zBaseRequest.text)loadsrcs|IdH}||S)zReturn BODY as JSON.N)r)rrr rFrFrGjsonszBaseRequest.jsoncst|j|jS)z3Return async iterator to process BODY as multipart.)r(rar`rrFrFrG multipartszBaseRequest.multipart,MultiDictProxy[Union[str, bytes, FileField]]cs|jdur |jS|j|jvrtt|_|jS|j}|dvr(tt|_|jSt}|dkr8|IdH}|j}d}|IdH}dur7|j t j }t |tr(|jdur^td|jr|jdtjIdH}|jddIdH} | r|| IdH} |jd|j| IdH|t| 7}d|kr|krnn|jd|jIdHt||d|jddIdH} | sw|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||dntd|IdH}dusHn|"IdH} | rW|j%pGd } |&t'| (| d | dt||_|jS)zReturn POST parameters.N)rKz!application/x-www-form-urlencodedmultipart/form-datarrzMultipart field missing name.i)sizerzapplication/octet-streamT)r ztext/r)defaultz8To decode nested multipart you need to use custom reader)keep_blank_valuesr))rerb POST_METHODSrrr=rrjnextr>rrZ CONTENT_TYPErr'r:rr;rkZrun_in_executortempfile TemporaryFileZ read_chunkr writercloser0seekr3rrDrEaddr  startswith get_charsetr rrrstrip)rr=outrrrfieldZfield_cttmpr ffrr datarFrFrGposts             :   zBaseRequest.postr:rcCs0|j}|dur |S|j}|dur|S|||S)z"Extra info from protocol transportN)r^rget_extra_info)rr:rrurrFrFrGr)s zBaseRequest.get_extra_infocCs(|jddd}d|jj|j|S)Nasciibackslashreplacez <{} {} {} >)rrr formatrr?rb)rZascii_encodable_pathrFrFrG__repr__)s  zBaseRequest.__repr__othercCst|t|kSrL)id)rr.rFrFrG__eq__1zBaseRequest.__eq__cCsdS)NTrFrrFrFrG__bool__4szBaseRequest.__bool__responsecsdSrLrF)rr3rFrFrG _prepare_hook7szBaseRequest._prepare_hookexccCst|j|dSrL)r$r`)rr5rFrFrG_cancel:r1zBaseRequest._cancelcCsD|jdus |jdkr dS|jD]\}}t|tr|jqdS)Nr)rer=rrr3r<r)r file_nameZfile_field_objectrFrFrG_finish=s  zBaseRequest._finish)rzrx)rzr6)rzr)rzN)rzrrL)qr?r@rArZ METH_PATCHZ METH_POSTZMETH_PUTZ METH_TRACEZ METH_DELETErr ATTRS frozensetrer rr rBrr3rCrfr%r*rasyncioZAbstractEventLooprrrrr#rr/r-rpropertyrwru Transportrrrnr"rsrrryrrrrrrrrr rrrpr|r&r}rqrrr{rrrrrrr>r.rdatetimerr staticmethodrr classmethodrrrrrrrrrrrrrr rr+r,rr(rr(r)r-objectr0r2r1r4 BaseExceptionr6r8rFrFrFrGr2vsD        :        ;   <   #  ` r2cseZdZUejedgBZdZeded<e r$de de ddffdd Z e e e e e e e d d ee efd eeefd eeefd ee efdee efdee efdeeefddffddZedddZedddZedefddZdeddfddZZS)r4 _match_infoNr7r:valrzcs8||jvrtjd|jj|tddt||dS)Nz-Setting custom {}.{} attribute is discouragedrr) r9rrr,rr?rsuper __setattr__)rr:rDrrFrGrFRs  zRequest.__setattr__rr|rr>rprqrrrnc s0tj|||||||d}tt|} |j| _| S)Nr)rErrr4rC) rr|rr>rprqrrrnretZnew_retrGrFrGr\s  z Request.clonecCs|j}|dus J|S)zResult of route resolving.N)rCr match_inforFrFrGrJts zRequest.match_infor5cCs|j}|dus J|jS)zApplication instance.N)rCZ current_apprIrFrFrGapp{s z Request.appcCsH|j}|dus J|j}|j}||}tt|d|d}t|S)Nr)rCZappsrKindexrreversedr)rrJlstrKidxZsublistrFrFrG config_dicts  zRequest.config_dictr3cs@|j}|dur dS|jD]}|j}r|||IdHq dSrL)rCZ_appson_response_preparesend)rr3rJrKrQrFrFrGr4s  zRequest._prepare_hook)rzr7)rzr5)r?r@rAr2r9r:rCr rCrrBrrFr#r rr/r-rrr"rJr<rKrrPr1r4 __classcell__rFrFrGrGr4JsH             r4)dr;r>rDrrstringrrrrtypingrrrrrrr r r r r r urllib.parserattrZ multidictrrrrrZyarlrrKrZ_cookie_helpersrabcrZhelpersrrrrrrr r!r"r#r$Z http_parserr%Z http_writerr&rr'r(streamsr)r*Ztypedefsr+r,r-r.r/Zweb_exceptionsr0Z web_responser1__all__Zweb_appr5Z web_protocolr6Zweb_urldispatcherr7sr3digits ascii_lettersrHrBrCrJr,rrrangerVrWrXrZcompiler[r\r2r4rFrFrFrGsn  8     4       Y