a Ocn @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 rddlFmGZGddlHmIZIddlJmKZKejLddddGdddZMejNejOdZPeSrN) !#_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@seZdZejejejejejhZ e j e gdBZ dddddde ededejeeeeefeeeeeedd dd Zeeeeeed eeeeeedd d d ZeddddZeddddZeeejdddZ eedddZ!e"e dddZ#e"e$dddZ%e"ejdddZ&eedddZ'eedd d!d"Z(eddd#d$Z)edd%d&Z*e+edd'd(Z,e"e-dd)d*Z.e"e/e0eefd+fdd,d-Z1e"edd.d/Z2e"edd0d1Z3e"e4dd2d3Z5e"edd4d5Z6e"eedd6d7Z7e"e$dd8d9Z8e"edd:d;Z9e"eddd?Z;e"d@ddAdBZe"e?ddHdIZ@e"eeAjAddJdKZBe"eeAjAddLdMZCeDee+eEdNdOdPZFeGeeee/eEd+fdQdRdSZHe"ee/eEd+fddTdUZIe"ee/eEd+fddVdWZJe"eeAjAddXdYZKe"e-ddZd[ZLe"e0eefdd\d]ZMe"eNdd^d_ZOe"edd`daZPee-ddbdcZQee-ddddeZRe"e-ddfdgZSdddhdiZTeUddjdkZVeddldmZWeXdneYedodpdqZZe[ddrdsZ\dtddudvZ]deeedwdxdyZ^eddzd{Z_e`e-d|d}d~Zae-dddZbecddddZdeeddddZfdS)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_sizestateschemehostremoter3zasyncio.Task[None]) messagepayloadprotocolpayload_writertasklooprmrnrorprqreturncCs|dur i}||_||_||_||_|j|_|j|_|j|_ i|_ |j } | r~| |j d<| j |j d<| j|j d<| |_n|j |_d|_d|_||_||_||_||_|jj} | dusJ| d|_| d|_| dur| |j d<| dur| |j d<| dur| |j d<dS)NurlrproZ sslcontextZpeernamerq)r\r]r^r_r<r`methodraversionrbrgry is_absoluterprorelativercrdrerfrhrirj transportget_extra_inforkrl)selfrrrsrtrurvrwrmrnrorprqryr~rDrDrE__init__sB          zBaseRequest.__init__rzrel_urlr<rorprqrzrr<rorprqrxc Cs|jrtdi}|tur"||d<|turFt|}||d<t||d<|turxtt||d<tdd|D|d<|j j fi|} i} |tur|| d <|tur|| d <|tur|| d <|j | |j |j |j|j|jf|j|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 contentrzrypathr<css&|]\}}|d|dfVqdS)utf-8N)encode)rLkvrDrDrErNsz$BaseRequest.clone.. raw_headersrorprq)rmrn)re RuntimeErrorr rr@rrtupleitemsr\_replace __class__r_r]r^rhrjrirfcopy) rrzrr<rorprqdctnew_urlrrkwargsrDrDrEclonesF   zBaseRequest.clonerxcCs|jSrJ)rhrrDrDrErvszBaseRequest.taskcCs|jSrJ)r]rrDrDrErtszBaseRequest.protocolcCs|jdurdS|jjSrJ)r]r~rrDrDrEr~s zBaseRequest.transportcCs|jSrJ)r^rrDrDrEwriter szBaseRequest.writercCstjdtdd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningr\rrDrDrErrszBaseRequest.messagecCs|jSrJ)rcrrDrDrErszBaseRequest.rel_urlcCstjdtdd|jS)Nz#request.loop property is deprecatedr)rrrrjrrDrDrErwszBaseRequest.loop)keyrxcCs |j|SrJrfrrrDrDrE __getitem__"szBaseRequest.__getitem__)rvaluerxcCs||j|<dSrJr)rrrrDrDrE __setitem__%szBaseRequest.__setitem__cCs |j|=dSrJrrrDrDrE __delitem__(szBaseRequest.__delitem__cCs t|jSrJ)lenrfrrDrDrE__len__+szBaseRequest.__len__cCs t|jSrJ)iterrfrrDrDrE__iter__.szBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.https)rorrDrDrEsecure3szBaseRequest.secure.c CsXg}|jjtjdD]6}t|}d}d}i}|t|d|krT|krnqt ||}|dur|r~| d|}n\| \}} } | ddkrt d| dd } | r| | 7} | ||<|t|d7}d }q@||dkr d}i}|t||d7}q@||d kr(d}|d7}q@||d vr@|d7}q@| d|}q@qt|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 rDrFN,"z\1rT;z )r\r<ZgetallrZ FORWARDEDrappendtypesrr[matchfindgroupsrZsublowergroupr) relemsZ field_valuelengthposZneed_separatorelemrr7rportrDrDrE forwarded8s@      zBaseRequest.forwardedcCs|jr dSdSdS)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'. rhttpN)rkrrDrDrErous zBaseRequest.schemecCs|jS)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rarrDrDrErzszBaseRequest.methodcCs|jS)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rbrrDrDrEr{szBaseRequest.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)rrprDrDrErps zBaseRequest.hostcCs6|jdurdSt|jttfr,t|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)rl isinstancelistrr@rrDrDrErqs zBaseRequest.remotecCstj|j|jd}||jS)N)rorp)rbuildrorpjoinrc)rryrDrDrEryszBaseRequest.urlcCs|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rcrrrDrDrErszBaseRequest.pathcCs t|jS)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )r@rcrrDrDrEpath_qsszBaseRequest.path_qscCs|jjS)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\rrrDrDrEraw_pathszBaseRequest.raw_pathzMultiDictProxy[str]cCs t|jjS)z7A multidict with all the variables in the query string.)rrcqueryrrDrDrErszBaseRequest.querycCs|jjS)z:The query string in the URL. E.g., id=10 )rc query_stringrrDrDrErszBaseRequest.query_stringr;cCs|jS)z4A case-insensitive multidict proxy with all headers.)r`rrDrDrEr<szBaseRequest.headerscCs|jjS)z$A sequence of pairs for all headers.)r\rrrDrDrErszBaseRequest.raw_headerscCst|jtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )rr<rrZIF_MODIFIED_SINCErrDrDrEif_modified_sinceszBaseRequest.if_modified_sincecCst|jtjS)z{The value of If-Unmodified-Since HTTP header, or None. This header is represented as a `datetime` object. )rr<rrZIF_UNMODIFIED_SINCErrDrDrEif_unmodified_sinceszBaseRequest.if_unmodified_since) etag_headerrxccsZ|tkrtdtdVn>t|D]2}|ddd\}}}|rBqVtt||dVq"dS)z'Extract `ETag` objects from raw header.F)is_weakrrrN)rrrfinditerrbool)rrrrgarbagerDrDrE _etag_valuess zBaseRequest._etag_values) header_valuerxcCs|sdSt||SrJ)rr)clsrrDrDrE_if_match_or_none_implsz"BaseRequest._if_match_or_none_implcCs||jtjS)zxThe value of If-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )rr<rrZIF_MATCHrrDrDrEif_matchszBaseRequest.if_matchcCs||jtjS)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_MATCHrrDrDrE if_none_matchszBaseRequest.if_none_matchcCst|jtjS)zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )rr<rrZIF_RANGErrDrDrEif_range'szBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)r\Z should_closerrDrDrE keep_alive/szBaseRequest.keep_alivecCs.|jtjd}t|}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. rIcSsi|]\}}||jqSrD)r)rLrvalrDrDrE <rOz'BaseRequest.cookies..)r<rrZCOOKIErrr)rrawparsedrDrDrEcookies4szBaseRequest.cookiescCs|jtj}d\}}|durzd}t||d\}}WntyTtdYn0|rbt|nd}|rrt|nd}|dur|dur| }d}|dur|dur|d7}||krtd||urdurnntdt ||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) r`rrRANGErefindall IndexError ValueErrorintslice)rrngstartendpatternrDrDrE http_range>s( zBaseRequest.http_rangecCs|jS)zReturn raw payload stream.)r_rrDrDrEcontentbszBaseRequest.contentcCstjdtdd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrr_at_eofrrDrDrEhas_bodygszBaseRequest.has_bodycCs |j S)r)r_rrrDrDrE can_read_bodyoszBaseRequest.can_read_bodycCst|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typer_r%rrDrDrE body_existstszBaseRequest.body_existscs |js|jIdHqdS)zKRelease request. Eat unread part of HTTP BODY if present. N)r_rreadanyrrDrDrEreleaseys zBaseRequest.releasecsh|jdurbt}|jIdH}|||jrPt|}||jkrPt|j|d|sqXqt||_|jS)z_Read request body if present. Returns bytes object with full request content. Nmax_sizeZ actual_size) re bytearrayr_rextendrirr-bytes)rbodychunkZ body_sizerDrDrEreads    zBaseRequest.readcs"|IdH}|jpd}||S)z1Return BODY as text using encoding from .charset.Nr)rcharsetdecode)rZ bytes_bodyencodingrDrDrEtexts zBaseRequest.text)loads)rrxcs|IdH}||S)zReturn BODY as JSON.N)r)rrrrDrDrEjsonszBaseRequest.jsoncst|j|jS)z3Return async iterator to process BODY as multipart.)r$r`r_rrDrDrE multipartszBaseRequest.multipartz,MultiDictProxy[Union[str, bytes, FileField]]cs~|jdur|jS|j|jvr.tt|_|jS|j}|dvrNtt|_|jSt}|dkr0|IdH}|j}|IdH}|durnd}|j t j }t |tr|jdusJ|jrt}|jddIdH} | rB|| } || |t| 7}d|kr|kr.nn|t||d|jddIdH} q|d|durZd}t|j|jttj|||j } ||j| n|jd d IdH} |dus| d r|j!d d } ||j| | n||j| |t| 7}d|kr|krnn t||dnt"d|IdH}qn>|IdH} | rn|j#pNd } |$t%| &| d | dt||_|jS)zReturn POST parameters.N)rIz!application/x-www-form-urlencodedmultipart/form-datarri)sizerzapplication/octet-streamT)rztext/r)defaultz8To decode nested multipart you need to use custom reader)keep_blank_valuesr)'rdra POST_METHODSrrr:rrinextr<rr CONTENT_TYPErr#r7r8tempfile TemporaryFileZ read_chunkrwritercloser-seekr0rrBrCaddr startswith get_charsetrrrrrstrip)rr:outrrfieldrZfield_cttmprffrrdatarDrDrEposts                  zBaseRequest.post)r7rrxcCs0|j}|dur|S|j}|dur$|S|||S)z"Extra info from protocol transportN)r]r~r)rr7rrtr~rDrDrErszBaseRequest.get_extra_infocCs(|jddd}d|jj|j|S)Nasciibackslashreplacez <{} {} {} >)rrrformatrr=ra)rZascii_encodable_pathrDrDrE__repr__s  zBaseRequest.__repr__)otherrxcCst|t|kSrJ)id)rrrDrDrE__eq__szBaseRequest.__eq__cCsdS)NTrDrrDrDrE__bool__szBaseRequest.__bool__responserxcsdSrJrD)rr"rDrDrE _prepare_hookszBaseRequest._prepare_hook)excrxcCs|j|dSrJ)r_Z set_exception)rr$rDrDrE_cancel"szBaseRequest._cancel)N)gr=r>r?rZ METH_PATCHZ METH_POSTZMETH_PUTZ METH_TRACEZ METH_DELETErrATTRS frozensetr!r&rasyncioZAbstractEventLooprr rr@rrr r,r*rpropertyrvrt Transportr~rrrrrrrwrrrrrrrrr rrrorzr"r{rprqryrrrrrr<r+rdatetimerr staticmethodrr classmethodrrrrrrrrrrrrrrrrr'r)rr$rrrrobjectrr r.r# BaseExceptionr%rDrDrDrEr/ns  < 7 <  #` r/c seZdZejedgBZeeddfdd ZerHe eddfdd Z e e e e e e d e e e e e e dd fd d Zed dddZeddddZeedddZeddddZZS)r1 _match_infoN)argsrrxcstj|i|d|_dSrJ)superrr0)rr1rrrDrEr*szRequest.__init__)r7rrxcs8||jvr&tjd|jj|tddt||dS)Nz-Setting custom {}.{} attribute is discouragedrr) r&rrrrr=rr2 __setattr__)rr7rr3rDrEr45s zRequest.__setattr__rrc s.tj||||||d}tt|}|j|_|S)Nr)r2rrr1r0) rrzrr<rorprqretZnew_retr3rDrEr?s  z Request.cloner4rcCs|j}|dusJ|S)zResult of route resolving.N)r0r match_inforDrDrEr7Us zRequest.match_infor2cCs|j}|dusJ|jS)zApplication instance.N)r0Z current_appr6rDrDrEapp\s z Request.appcCsH|j}|dusJ|j}|j}||}tt|d|d}t|S)Nr)r0Zappsr8indexrreversedr)rr7lstr8idxZsublistrDrDrE config_dictcs  zRequest.config_dictr!cs6|j}|durdS|jD]}|j||IdHqdSrJ)r0Z_appsZon_response_preparesend)rr"r7r8rDrDrEr#ms  zRequest._prepare_hook)r=r>r?r/r&r'rrrr@r4r r,r*rrr7r)r8rr=r.r# __classcell__rDrDr3rEr1&s4   r1)ar(r+rBrrstringr rr http.cookiesrrtypingrrrrrr r r r r r urllib.parserattrZ multidictrrrrZyarlrrIrabcrZhelpersrrrrrrrrr Z http_parserr!Z http_writerr"rr#r$Zstreamsr%r&Ztypedefsr'r(r)r*r+r,Zweb_exceptionsr-Z web_responser.__all__Zweb_appr2Z web_protocolr3Zweb_urldispatcherr4sr0digits ascii_lettersrFr@rArHrrrrangerUrVrWrYcompilerZr[r/r1rDrDrDrEsp   4    ,         =