U ;ggu @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)Z auto_attribsfrozenslotsc@s<eZdZUeed<eed<ejed<eed<eeed<dS)r3namefilenamefile content_typeheadersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderrrFrFS/opt/bot/vods_filmes/script/venv/lib/python3.8/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&eZdZejejejejejhZ e j e ddddddddd d d d d ddddgBZ dddddde ededejeeeeefeeeeeedd ddZeeeeeeedeeefeeefeeefeeefeeefeeefeeefddddZedddd Zeddd!d"Z eeej!dd#d$Z"eedd%d&Z#eedd'd(Z$e%e dd)d*Z&e%e'dd+d,Z(e%ejdd-d.Z)eed/d0d1Z*eedd2d3d4Z+edd/d5d6Z,edd7d8Z-e.edd9d:Z/e%e0dd;d<Z1e%e2e3eefd=fdd>d?Z4e%edd@dAZ5e%eddBdCZ6e%e7ddDdEZ8e%eddFdGZ9e%eeddHdIZ:e%e'ddJdKZ;e%eddLdMZe%dRddSdTZ?e%eddUdVZ@e%eAeddWdXZBe%eCddYdZZDe%eeEjEdd[d\ZFe%eeEjEdd]d^ZGeHee.eId_d`daZJeKeeee2eId=fdbdcddZLe%ee2eId=fddedfZMe%ee2eId=fddgdhZNe%eeEjEddidjZOe%e0ddkdlZPe%e3eefddmdnZQe%eRddodpZSe%eddqdrZTee0ddsdtZUee0ddudvZVe%e0ddwdxZWdddydzZXeYdd{d|ZZedd}d~Z[e\de]edddZ^e_dddZ`ddddZadeeedddZbedddZcede0dddZee0dddZfegddddZheiddddZjddddZkdS)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_sizestateschemehostremoter6zasyncio.Task[None]) messagepayloadprotocolpayload_writertasklooprnrorprqrrreturncCs6|dkr i}||_||_||_||_|j|_|j|_|j|_ i|_ |j } | j r| dk r`| | } | dk rr| | } | |j d<| j|j d<| j|j d<| |_n,|j |_| dk r| |j d<| dk r| |j d<d|_d|_||_||_||_||_|jj} | dk st| d|_| d|_| dk r2| |j d<dS)NurlrqrpZ sslcontextZpeernamerr)r]r^r_r`r>ramethodrbversionrcrhrzabsoluteZ with_schemeZ with_hostrqrprelativerdrerfrgrirjrk transportAssertionErrorget_extra_inforlrm)selfrsrtrurvrwrxrnrorprqrrrzrrFrFrG__init__sJ           zBaseRequest.__init__r{rel_urlr>rprqrrrnr{rr>rprqrrrnryc Cs|jrtdi}|tk r"||d<|tk rFt|} | |d<t| |d<|tk r|tt||d<tdd|dD|d<|j j f|} i} |tk r|| d <|tk r|| d <|tk r|| d <|tkr|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{rzpathr>css&|]\}}|d|dfVqdS)utf-8N)encode)rNkvrFrFrGrPsz$BaseRequest.clone.. raw_headersrprqrr)rnro)rf RuntimeErrorr#rrBrrtupleitemsr]_replacerj __class__r`r^r_rirkrgcopy) rr{rr>rprqrrrndctnew_urlrskwargsrFrFrGclonesJ   zBaseRequest.clonerycCs|jSrL)rirrFrFrGrwszBaseRequest.taskcCs|jSrL)r^rrFrFrGruszBaseRequest.protocolcCs|jdkrdS|jjSrL)r^rrrFrFrGrs zBaseRequest.transportcCs|jSrL)r_rrFrFrGwriterszBaseRequest.writercCs|jSrL)rjrrFrFrGrn szBaseRequest.client_max_sizecCstjdtdd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningr]rrFrFrGrs$szBaseRequest.messagecCs|jSrL)rdrrFrFrGr)szBaseRequest.rel_urlcCstjdtdd|jS)Nz#request.loop property is deprecatedr)rrrrkrrFrFrGrx-s zBaseRequest.loop)keyrycCs |j|SrLrgrrrFrFrG __getitem__6szBaseRequest.__getitem__)rvaluerycCs||j|<dSrLr)rrrrFrFrG __setitem__9szBaseRequest.__setitem__cCs |j|=dSrLrrrFrFrG __delitem__<szBaseRequest.__delitem__cCs t|jSrL)lenrgrrFrFrG__len__?szBaseRequest.__len__cCs t|jSrL)iterrgrrFrFrG__iter__BszBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.https)rprrFrFrGsecureGszBaseRequest.secure.c CsXg}|jjtjdD]6}t|}d}d}i}|t|d|krT|krnqt ||}|dk r|r~| d|}n\| \}} } | ddkrt d| dd } | r| | 7} | ||<|t|d7}d }q@||dkr d}i}|t||d7}q@||d kr(d}|d7}q@||d kr@|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 rFrFN,"z\1rT;z )r]r>ZgetallrZ FORWARDEDrappendtypesrr\matchfindgroupsr[sublowergroupr) rZelemsZ field_valuelengthposZneed_separatorelemrr:rportrFrFrG forwardedLs@      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)rlrrFrFrGrps zBaseRequest.schemecCs|jS)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rbrrFrFrGr{szBaseRequest.methodcCs|jS)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rcrrFrFrGr|szBaseRequest.versioncCs$|jjtj}|dk r|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|jdkrdSt|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)rm isinstancelistrrBrrFrFrGrrs zBaseRequest.remotecCstj|j|jd|jS)zThe full URL of the request.)rp authority)rbuildrprqjoinrdrrFrFrGrzszBaseRequest.urlcCs|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rdrrrFrFrGrszBaseRequest.pathcCs t|jS)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rBrdrrFrFrGpath_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]rrrFrFrGraw_pathszBaseRequest.raw_pathzMultiMapping[str]cCs|jjS)z7A multidict with all the variables in the query string.)rdqueryrrFrFrGrszBaseRequest.querycCs|jjS)z:The query string in the URL. E.g., id=10 )rd query_stringrrFrFrGrszBaseRequest.query_stringcCs|jS)z4A case-insensitive multidict proxy with all headers.)rarrFrFrGr>szBaseRequest.headerscCs|jjS)z$A sequence of pairs for all headers.)r]rrrFrFrGrszBaseRequest.raw_headerscCst|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_sinceszBaseRequest.if_modified_sincecCst|jtjS)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_since szBaseRequest.if_unmodified_since) etag_headerryccsZ|tkrtdtdVn>t|D]2}|ddd\}}}|rBqVtt||dVq"dS)z'Extract `ETag` objects from raw header.F)is_weakrrrN)rrrfinditerrbool)rrrrgarbagerFrFrG _etag_valuess zBaseRequest._etag_values) header_valuerycCs|sdSt||SrL)rr)clsrrFrFrG_if_match_or_none_impl(sz"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_MATCHrrFrFrGif_match1szBaseRequest.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_MATCHrrFrFrG if_none_match9szBaseRequest.if_none_matchcCst|jtjS)zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )r!r>rrZIF_RANGErrFrFrGif_rangeAszBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)r]Z should_closerrFrFrG keep_aliveIszBaseRequest.keep_alivecCs.|jtjd}t|}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. rKcSsi|]\}}||jqSrF)r)rNrvalrFrFrG Vsz'BaseRequest.cookies..)r>rrZCOOKIErrr)rrawparsedrFrFrGcookiesNszBaseRequest.cookiescCs|jtj}d\}}|dk rzd}t||d\}}Wntk rVtdYnX|rdt|nd}|rtt|nd}|dkr|dk r| }d}|dk r|dk r|d7}||krtd||krdkrnntdt ||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)rrngstartendpatternrFrFrG http_rangeXs(zBaseRequest.http_rangecCs|jS)zReturn raw payload stream.)r`rrFrFrGcontent|szBaseRequest.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_bodyszBaseRequest.can_read_bodycCst|jtk S)z6Return True if request has HTTP BODY, False otherwise.)typer`r)rrFrFrG body_existsszBaseRequest.body_existscs |js|jIdHqdS)zKRelease request. Eat unread part of HTTP BODY if present. N)r`rreadanyrrFrFrGreleases zBaseRequest.releasecsh|jdkrbt}|jIdH}|||jrPt|}||jkrPt|j|d|sqXqt||_|jS)z_Read request body if present. Returns bytes object with full request content. Nmax_sizeZ actual_size) rf bytearrayr`rextendrjrr0bytes)rbodychunkZ body_sizerFrFrGreads    zBaseRequest.readcs"|IdH}|jpd}||S)z1Return BODY as text using encoding from .charset.Nr)rcharsetdecode)rZ bytes_bodyencodingrFrFrGtexts zBaseRequest.text)loads)rrycs|IdH}||S)zReturn BODY as JSON.N)r)rrrrFrFrGjsonszBaseRequest.jsoncst|j|jS)z3Return async iterator to process BODY as multipart.)r(rar`rrFrFrG multipartszBaseRequest.multipartz,MultiDictProxy[Union[str, bytes, FileField]]cs|jdk r|jS|j|jkr.tt|_|jS|j}|dkrNtt|_|jSt}|dkrh|IdH}|j}|IdH}|dk rd}|j t j }t |trN|jdk st|jr|jdtjIdH}|jddIdH} | rl|| } |jd|j| IdH|t| 7}d|kr2|krXnn"|jd|jIdHt||d|jddIdH} q|jd|jdIdH|dkrd}t|j|jttj |||j } |!|j| n|j"d d IdH} |dks|#d r |j$d d } |!|j| | n|!|j| |t| 7}d|kr<|krVnn t||dnt%d|IdH}qn>|"IdH} | r|j&pd } |'t(| )| d | dt||_|jS)zReturn POST parameters.N)rKz!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)*rerb POST_METHODSrrr=rrjnextr>rrZ CONTENT_TYPErr'r:rr;rkZrun_in_executortempfile TemporaryFileZ read_chunkrwritercloser0seekr3rrDrEaddr startswith get_charsetrrrrrstrip)rr=outrrfieldrZfield_cttmprffrrdatarFrFrGposts                 zBaseRequest.post)r:rrycCs0|j}|dkr|S|j}|dkr$|S|||S)z"Extra info from protocol transportN)r^rr)rr:rrurrFrFrGr!szBaseRequest.get_extra_infocCs(|jddd}d|jj|j|S)Nasciibackslashreplacez <{} {} {} >)rrrformatrr?rb)rZascii_encodable_pathrFrFrG__repr__-szBaseRequest.__repr__)otherrycCst|t|kSrL)id)rrrFrFrG__eq__5szBaseRequest.__eq__cCsdS)NTrFrrFrFrG__bool__8szBaseRequest.__bool__responserycsdSrLrF)rr#rFrFrG _prepare_hook;szBaseRequest._prepare_hook)excrycCst|j|dSrL)r$r`)rr%rFrFrG_cancel>szBaseRequest._cancelcCsD|jdks|jdkrdS|jD]\}}t|tr"|jq"dS)Nr)rer=rrr3r<r)r file_nameZfile_field_objectrFrFrG_finishAs  zBaseRequest._finish)N)lr?r@rArZ METH_PATCHZ METH_POSTZMETH_PUTZ METH_TRACEZ METH_DELETEr r ATTRS frozensetr%r*rasyncioZAbstractEventLooprr rrBrrr#rrr/r-rpropertyrwru Transportrrrnr"rsrrrxrrrrrrrrr r rrpr{r&r|rqrrrzrrrrrrr>r.rdatetimerr staticmethodrr classmethodrrrrrrrrrrrrrrrrr+r,rr(rrrrobjectr r!r1r$ BaseExceptionr&r(rFrFrFrGr2vs8 @        ; <  #b r2c seZdZejedgBZeeddfdd ZerHe eddfdd Z e e e e e e e d e e e fe ee fe ee fe e e fe e e fe e e fe ee fdd fd d Zed dddZeddddZeedddZeddddZZS)r4 _match_infoN)argsrrycstj||d|_dSrL)superrr3)rr4rrrFrGrRszRequest.__init__)r:rrycs8||jkr&tjd|jj|tddt||dS)Nz-Setting custom {}.{} attribute is discouragedrr) r)rrrrr?rr5 __setattr__)rr:rr6rFrGr7]s zRequest.__setattr__rrc s0tj|||||||d}tt|} |j| _| S)Nr)r5rrr4r3) rr{rr>rprqrrrnretZnew_retr6rFrGrgs  z Request.cloner7rcCs|j}|dk st|S)zResult of route resolving.N)r3rr match_inforFrFrGr:s zRequest.match_infor5cCs|j}|dk st|jS)zApplication instance.N)r3rZ current_appr9rFrFrGapps z Request.appcCsH|j}|dk st|j}|j}||}tt|d|d}t|S)Nr)r3rZappsr;indexrreversedr)rr:lstr;idxZsublistrFrFrG config_dicts  zRequest.config_dictr"cs>|j}|dkrdS|jD] }|j}r|||IdHqdSrL)r3Z_appson_response_preparesend)rr#r:r;rArFrFrGr$s   zRequest._prepare_hook)r?r@rAr2r)r*rrrrBr7r#rrr/r-rrr"r:r,r;rr@r1r$ __classcell__rFrFr6rGr4Ns8          r4)dr+r.rDrrstringr rr http.cookiesrrtypingrrrrrr r r r r rr urllib.parserattrZ multidictrrrrrZyarlrrKrabcrZhelpersrrrrrrr 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_lettersrHrBrCrJrrrrangerVrWrXrZcompiler[r\r2r4rFrFrFrGsr  8    4        ]