o n~bl @sUddlZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddlm Z ddl m Z mZmZmZmZmZmZmZmZmZmZddlmZddlZddlmZmZmZmZddl 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.m/Z/dd l0m1Z1dd l2m3Z3ddl4m5Z5m6Z6ddl7m8Z8m9Z9ddl:m;Z;mZ>m?Z?m@Z@ddlAmBZBddlCmDZDdZEe rddlFmGZGddlHmIZIddlJmKZKejLddddGdddZMejNejOdZPe/usr/local/lib/python3.10/dist-packages/aiohttp/web_request.pyr0Ds   r0z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]ccs|]}t|VqdSN)chr).0crErErF SsrO) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:{quoted_pair}|{qdtext})*")ZqdtextZ quoted_pair_QUOTED_STRINGz0({token})=({token}|{quoted_string})(:\d{{1,4}})?)token quoted_string_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_REc@seZdZejejejejejhZ e j e gdBZ ddddddde deddd ed d d ejd edeeeefdeedeedeeddfddZeeeeeeddededededededdfddZedddZedddZedeejfdd 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-d.Z(d)eddfd/d0Z)defd1d2Z*de+efd3d4Z,e"de-fd5d6Z.e"de/e0eefd7ffd8d9Z1e"defd:d;Z2e"defdd?Z5e"defd@dAZ6e"deefdBdCZ7e"de$fdDdEZ8e"defdFdGZ9e"defdHdIZ:e"defdJdKZ;e"ddMdNZe"de?fdTdUZ@e"deeAjAfdVdWZBe"deeAjAfdXdYZCeDdZede+eEfd[d\ZFeGd]eedee/eEd7ffd^d_ZHe"dee/eEd7ffd`daZIe"dee/eEd7ffdbdcZJe"deeAjAfdddeZKe"de-fdfdgZLe"de0eeffdhdiZMe"deNfdjdkZOe"defdldmZPede-fdndoZQede-fdpdqZRe"de-fdrdsZSddtduZTdeUfdvdwZVdefdxdyZWeXdzd{eYdefd|d}ZZde[fd~dZ\dddZ]ddededefddZ^defddZ_de`de-fddZade-fddZbdecddfddZddeeddfddZfdS)r/)_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_sizestateschemehostremotemessagepayloadprotocolr3payload_writertaskasyncio.Task[None]looprnrorprqrrreturnc Cs|duri}||_||_||_||_|j|_|j|_|j|_ |j |_ d|_ d|_ ||_i|_||_||_||_|jj} | dusAJ| d|_| d|_| durV| |jd<| dur_| |jd<| durj| |jd<dSdS)N sslcontextpeernamerprqrr)r]r^r_r`r=ramethodrbversionrcurlrdrerfrgrhrirjrk transportget_extra_inforlrm) selfrsrtrurvrwryrnrorprqrrrrErErF__init__s:     zBaseRequest.__init__r}rel_urlr=rprqrrr}rr=c Cs|jrtdi}|tur||d<|tur#t|}||d<t||d<|tur. raw_headersrprqrr)rnroNrE)rf RuntimeErrorr rrArrtupleitemsr]_replace __class__r`r^r_rirkrjrgcopy) rr}rr=rprqrrdctnew_urlrskwargsrErErFclonesF   zBaseRequest.clonecC|jSrK)rirrErErFrwzBaseRequest.taskcCrrK)r^rrErErFrurzBaseRequest.protocolcCs|jdurdS|jjSrK)r^rrrErErFrs zBaseRequest.transportcCrrK)r_rrErErFwriterrzBaseRequest.writercCtjdtdd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningr]rrErErFrsszBaseRequest.messagecCrrK)rdrrErErFr rzBaseRequest.rel_urlcCr)Nz#request.loop property is deprecatedr)rrrrkrrErErFryszBaseRequest.loopkeycCs |j|SrKrgrrrErErF __getitem__ zBaseRequest.__getitem__valuecCs||j|<dSrKr)rrrrErErF __setitem__szBaseRequest.__setitem__cCs |j|=dSrKrrrErErF __delitem__ s zBaseRequest.__delitem__cC t|jSrK)lenrgrrErErF__len__#rzBaseRequest.__len__cCrrK)iterrgrrErErF__iter__&rzBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.https)rprrErErFsecure+ 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 rErFN,"z\1rT;z )r]r=ZgetallrZ FORWARDEDrappendtypesrr\matchfindgroupsr[sublowergroupr) relemsZ field_valuelengthposZneed_separatorelemrr8rportrErErF forwarded0sD           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)rlrrErErFrpms zBaseRequest.schemecCr)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rbrrErErFr}}zBaseRequest.methodcCr)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rcrrErErFr~rzBaseRequest.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)r]r=getrZHOSTsocketgetfqdn)rrqrErErFrqs 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)rm isinstancelistrrArrErErFrrs  zBaseRequest.remotecCstj|j|jd}||jS)N)rprq)rbuildrprqjoinrd)rrrErErFrs zBaseRequest.urlcC|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rdrrrErErFrzBaseRequest.pathcCr)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rArdrrErErFpath_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]rrrErErFraw_pathszBaseRequest.raw_pathMultiDictProxy[str]cCs t|jjS)z7A multidict with all the variables in the query string.)rrdqueryrrErErFr zBaseRequest.querycCr)z:The query string in the URL. E.g., id=10 )rd query_stringrrErErFrrzBaseRequest.query_stringr<cCr)z4A case-insensitive multidict proxy with all headers.)rarrErErFr=zBaseRequest.headerscCr)z$A sequence of pairs for all headers.)r]rrrErErFrszBaseRequest.raw_headerscCt|jtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )rr=rrZIF_MODIFIED_SINCErrErErFif_modified_sincezBaseRequest.if_modified_sincecCr)z{The value of If-Unmodified-Since HTTP header, or None. This header is represented as a `datetime` object. )rr=rrZIF_UNMODIFIED_SINCErrErErFif_unmodified_sincerzBaseRequest.if_unmodified_since etag_headerccs`|tkrtdtdVdSt|D]}|ddd\}}}|r$dStt||dVqdS)z'Extract `ETag` objects from raw header.F)is_weakrrrN)rrrfinditerrbool)rrrrgarbagerErErF _etag_valuess  zBaseRequest._etag_values header_valuecCs|sdSt||SrK)rr)clsrrErErF_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=rrZIF_MATCHrrErErFif_matchzBaseRequest.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_MATCHrrErErF if_none_matchrzBaseRequest.if_none_matchcCr)zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )rr=rrZIF_RANGErrErErFif_rangerzBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)r]Z should_closerrErErF keep_alive'rzBaseRequest.keep_alivecCs.|jtjd}t|}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. rJcSsi|]\}}||jqSrE)r)rMrvalrErErF 4sz'BaseRequest.cookies..)r=rrZCOOKIErrr)rrawparsedrErErFcookies,szBaseRequest.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) rarrRANGErefindall IndexError ValueErrorintslice)rrngstartendpatternrErErF http_range6s,  zBaseRequest.http_rangecCr)zReturn raw payload stream.)r`rrErErFcontentZrzBaseRequest.contentcCstjdtdd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrr`at_eofrrErErFhas_body_s zBaseRequest.has_bodycCs |j S)r)r`rrrErErF can_read_bodygrzBaseRequest.can_read_bodycCst|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typer`r%rrErErF body_existslszBaseRequest.body_existscs.|js|jIdH|jrdSdS)zKRelease request. Eat unread part of HTTP BODY if present. N)r`rreadanyrrErErFreleaseqs 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`rextendrjrr-bytes)rbodychunkZ body_sizerErErFreadys"    zBaseRequest.readcs$|IdH}|jp d}||S)z1Return BODY as text using encoding from .charset.Nr)r charsetdecode)rZ bytes_bodyencodingrErErFtexts  zBaseRequest.text)loadsrcs|IdH}||S)zReturn BODY as JSON.N)r)rrr rErErFjsonszBaseRequest.jsoncst|j|jS)z3Return async iterator to process BODY as multipart.)r$rar`rrErErF multipartszBaseRequest.multipart,MultiDictProxy[Union[str, bytes, FileField]]csx|jdur |jS|j|jvrtt|_|jS|j}|dvr(tt|_|jSt}|dkr|IdH}|j}|IdH}|durd}|j t j }t |tr|jdus\J|jrt}|jddIdH} | r|| } || |t| 7}d|kr|krnn |t||d|jddIdH} | sn|d|durd}t|j|jttj|||j } ||j| nH|jd d IdH} |dus| d r|j!d d } ||j| | n||j| |t| 7}d|kr|krnn t||dnt"d|IdH}|dusFn|IdH} | r4|j#p$d } |$t%| &| d | dt||_|jS)zReturn POST parameters.N)rJz!application/x-www-form-urlencodedmultipart/form-datarri)sizerzapplication/octet-streamT)r ztext/r)defaultz8To decode nested multipart you need to use custom reader)keep_blank_valuesr)'rerb POST_METHODSrrr;rrjnextr=rr CONTENT_TYPErr#r8r9tempfile TemporaryFileZ read_chunkr writercloser-seekr0rrCrDaddr  startswith get_charsetrr rrrstrip)rr;outrrfieldrZfield_cttmpr ffrr datarErErFposts              :   zBaseRequest.postr8rcCs0|j}|dur |S|j}|dur|S|||S)z"Extra info from protocol transportN)r^rr)rr8rrurrErErFrs zBaseRequest.get_extra_infocCs(|jddd}d|jj|j|S)Nasciibackslashreplacez <{} {} {} >)rrr formatrr>rb)rZascii_encodable_pathrErErF__repr__ s  zBaseRequest.__repr__othercCst|t|kSrK)id)rr.rErErF__eq__zBaseRequest.__eq__cCsdS)NTrErrErErF__bool__szBaseRequest.__bool__responsecsdSrKrE)rr3rErErF _prepare_hookszBaseRequest._prepare_hookexccCs|j|dSrK)r` set_exception)rr5rErErF_cancelr1zBaseRequest._cancel)rzrx)rzr3)rzr)rzr<)rzN)rzrrK)gr>r?r@rZ METH_PATCHZ METH_POSTZMETH_PUTZ METH_TRACEZ METH_DELETErrATTRS frozensetr!r&rasyncioAbstractEventLooprr rrArrr r,r*rpropertyrwru Transportrrrrsrrryrrrrrrrrr rrrpr}r"r~rqrrrrrrrrr=r+rdatetimerr staticmethodrr classmethodrrrrrrrrrrrrrrr rr'r)rr$rr)rr-objectr0r2r.r4 BaseExceptionr7rErErErFr/ns4      4 7   <    #  ` r/cseZdZejedgBZdededdffdd Zer(de d eddffd d Z e e e e e e d d e de de de de de ddffddZed ddZed!ddZedefddZdeddfddZZS)"r1 _match_infoargsrrzNcstj|i|d|_dSrK)superrrC)rrDrrrErFr"s zRequest.__init__r8rcs8||jvrtjd|jj|tddt||dS)Nz-Setting custom {}.{} attribute is discouragedrr) r8rrr,rr>rrE __setattr__)rr8rrFrErFrG-s  zRequest.__setattr__rr}rr=rprqrrc s.tj||||||d}tt|}|j|_|S)Nr)rErrr1rC) rr}rr=rprqrrretZnew_retrFrErFr7s  z Request.cloner4cCs|j}|dus J|S)zResult of route resolving.N)rCr match_inforErErFrJMs zRequest.match_infor2cCs|j}|dus J|jS)zApplication instance.N)rCZ current_apprIrErErFappTs z Request.appcCsH|j}|dus J|j}|j}||}tt|d|d}t|S)Nr)rCZappsrKindexrreversedr)rrJlstrKidxZsublistrErErF config_dict[s  zRequest.config_dictr3cs8|j}|dur dS|jD] }|j||IdHq dSrK)rCZ_appsZon_response_preparesend)rr3rJrKrErErFr4es zRequest._prepare_hook)rzr4)rzr2)r>r?r@r/r8r9rrrrArGr r,r*rrrJr<rKrrPr.r4 __classcell__rErErFrFr1sB      r1)ar:r>rCrrstringrrr http.cookiesrrtypingrrrrrr r r r r r urllib.parserattrZ multidictrrrrZyarlrrJrabcrhelpersrrrrrrrrr Z http_parserr!Z http_writerr"rr#r$streamsr%r&Ztypedefsr'r(r)r*r+r,Zweb_exceptionsr-Z web_responser.__all__Zweb_appr2Z web_protocolr3Zweb_urldispatcherr4sr0digits ascii_lettersrGrArBrIr,rrrangerUrVrWrZcompiler[r\r/r1rErErErFsr   4    ,        5