a hhp @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/m0Z0m1Z1m2Z2dd l3m4Z4dd l5m6Z6ddl7m8Z8m9Z9ddl:m;Z;mZ>m?Z?m@Z@mAZAmBZBddlCmDZDddlEmFZFdZGe rddlHmIZIddlJmKZKddlLmMZMejNddddGdddZOejPejQdZReeSeTd<deRdZUeeSeTd<d Vd!Wd"d#d$eXeYd%d&DZZeeSeTd'<d(Z[eeSeTd)<d*jVeZe[d+Z\eeSeTd,<d-jVeUe\d.Z]eeSeTd/<e^d0Z_eeeSeTd1<e^e]Z`eeeSeTd2<Gd3d4d4eeSefe/ZaGd5d6d6eaZbdS)7N) SimpleCookie)MappingProxyType) TYPE_CHECKINGAnyDictFinalIteratorMappingMutableMappingOptionalPatternTupleUnioncast) parse_qsl) CIMultiDictCIMultiDictProxy MultiDictMultiDictProxy MultiMapping)URL)hdrs)AbstractStreamWriter) _SENTINELDEBUGETAG_ANYLIST_QUOTED_ETAG_RE ChainMapProxyETag HeadersMixinparse_http_datereifysentinel)RawRequestMessage) HttpVersion)BodyPartReaderMultipartReader)EmptyStreamReader StreamReader)DEFAULT_JSON_DECODER JSONDecoder LooseHeaders RawHeadersStrOrURL)HTTPRequestEntityTooLarge)StreamResponse) BaseRequest FileFieldRequest) Application)RequestHandler)UrlMappingMatchInfoT)Z auto_attribsfrozenslotsc@s8eZdZUeed<eed<ejed<eed<ded<dS)r2namefilenamefile content_typezCIMultiDictProxy[str]headersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderrErEX/var/www/html/swiplay.fr/scambot/venv/lib/python3.9/site-packages/aiohttp/web_request.pyr2Ks  r2z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]ccs|]}t|VqdSN)chr).0crErErF ZrO) !#_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 Zeeeeeeed eeefeeefeeefeeefeeefeeefeeefdd d d ZeddddZeddddZ eeej!dddZ"eedddZ#eedddZ$e%e dddZ&e%e'dddZ(e%ejdddZ)eedd d!Z*eedd"d#d$Z+eddd%d&Z,edd'd(Z-e.edd)d*Z/e%e0dd+d,Z1e%e2e3eefd-fdd.d/Z4e%edd0d1Z5e%edd2d3Z6e%e7dd4d5Z8e%edd6d7Z9e%eedd8d9Z:e%e'dd:d;Z;e%eddd?Z=e%edd@dAZ>e%dBddCdDZ?e%eddEdFZ@e%dBddGdHZAe%eBddIdJZCe%eeDjDddKdLZEe%eeDjDddMdNZFeGee.eHdOdPdQZIeJeeee2eHd-fdRdSdTZKe%ee2eHd-fddUdVZLe%ee2eHd-fddWdXZMe%eeDjDddYdZZNe%e0dd[d\ZOe%e3eefdd]d^ZPe%eQdd_d`ZRe%eddadbZSee0ddcddZTee0ddedfZUe%e0ddgdhZVdddidjZWeXddkdlZYeddmdnZZe[doe\edpdqdrZ]e^ddsdtZ_duddvdwZ`deeedxdydzZaedd{d|Zbece0d}d~dZde0dddZeefddddZgehddddZidS)r1)_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_sizestateschemehostremoter5zasyncio.Task[None]) messagepayloadprotocolpayload_writertasklooprnrorprqrrreturncCs|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)NurlrqrpZ sslcontextZpeernamerr)r]r^r_r`r=ramethodrbversionrcrhrz is_absoluterqrprelativerdrerfrgrirjrk transportget_extra_inforlrm)selfrsrtrurvrwrxrnrorprqrrrzrrErErF__init__sB          zBaseRequest.__init__r{rel_urlr=rprqrrrnr{rr=rprqrrrnryc Cs|jrtdi}|tur"||d<|turFt|} | |d<t| |d<|turxtt||d<tdd|D|d<|j j fi|} i} |tur|| d <|tur|| d <|tur|| d <|tur|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)rMkvrErErFrOsz$BaseRequest.clone.. raw_headersrprqrr)rnro)rf RuntimeErrorr#rrArrtupleitemsr]_replacerj __class__r`r^r_rirkrgcopy) rr{rr=rprqrrrndctnew_urlrskwargsrErErFclonesJ   zBaseRequest.clonerycCs|jSrK)rirrErErFrwszBaseRequest.taskcCs|jSrK)r^rrErErFru szBaseRequest.protocolcCs|jdurdS|jjSrK)r^rrrErErFrs zBaseRequest.transportcCs|jSrK)r_rrErErFwriterszBaseRequest.writercCs|jSrK)rjrrErErFrnszBaseRequest.client_max_sizecCstjdtdd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningr]rrErErFrsszBaseRequest.messagecCs|jSrK)rdrrErErFr#szBaseRequest.rel_urlcCstjdtdd|jS)Nz#request.loop property is deprecatedr)rrrrkrrErErFrx'szBaseRequest.loop)keyrycCs |j|SrKrgrrrErErF __getitem__0szBaseRequest.__getitem__)rvaluerycCs||j|<dSrKr)rrrrErErF __setitem__3szBaseRequest.__setitem__cCs |j|=dSrKrrrErErF __delitem__6szBaseRequest.__delitem__cCs t|jSrK)lenrgrrErErF__len__9szBaseRequest.__len__cCs t|jSrK)iterrgrrErErF__iter__<szBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.https)rprrErErFsecureAszBaseRequest.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 rErFN,"z\1rT;z )r]r=ZgetallrZ FORWARDEDrappendtypesrr\matchfindgroupsr[sublowergroupr) relemsZ field_valuelengthposZneed_separatorelemrr9rportrErErF forwardedFs@      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)rlrrErErFrps zBaseRequest.schemecCs|jS)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rbrrErErFr{szBaseRequest.methodcCs|jS)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rcrrErErFr|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)rrqrErErFrqs 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)rm isinstancelistrrArrErErFrrs zBaseRequest.remotecCstj|j|jd}||jS)N)rprq)rbuildrprqjoinrd)rrzrErErFrzszBaseRequest.urlcCs|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rdrrrErErFrszBaseRequest.pathcCs t|jS)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rArdrrErErFpath_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]rrrErErFraw_pathszBaseRequest.raw_pathzMultiMapping[str]cCs t|jjS)z7A multidict with all the variables in the query string.)rrdqueryrrErErFrszBaseRequest.querycCs|jjS)z:The query string in the URL. E.g., id=10 )rd query_stringrrErErFrszBaseRequest.query_stringcCs|jS)z4A case-insensitive multidict proxy with all headers.)rarrErErFr=szBaseRequest.headerscCs|jjS)z$A sequence of pairs for all headers.)r]rrrErErFrszBaseRequest.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_SINCErrErErFif_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_SINCErrErErFif_unmodified_sinceszBaseRequest.if_unmodified_since) etag_headerryccsZ|tkrtdtdVn>t|D]2}|ddd\}}}|rBqVtt||dVq"dS)z'Extract `ETag` objects from raw header.F)is_weakrrrN)rrrfinditerrbool)rrrrgarbagerErErF _etag_valuess zBaseRequest._etag_values) header_valuerycCs|sdSt||SrK)rr)clsrrErErF_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_MATCHrrErErFif_match%szBaseRequest.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_MATCHrrErErF if_none_match-szBaseRequest.if_none_matchcCst|jtjS)zpThe value of If-Range HTTP header, or None. This header is represented as a `datetime` object. )r!r=rrZIF_RANGErrErErFif_range5szBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)r]Z should_closerrErErF keep_alive=szBaseRequest.keep_alivecCs.|jtjd}t|}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. rJcSsi|]\}}||jqSrE)r)rMrvalrErErF JrPz'BaseRequest.cookies..)r=rrZCOOKIErrr)rrawparsedrErErFcookiesBszBaseRequest.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) rarrRANGErefindall IndexError ValueErrorintslice)rrngstartendpatternrErErF http_rangeLs( zBaseRequest.http_rangecCs|jS)zReturn raw payload stream.)r`rrErErFcontentpszBaseRequest.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_bodyuszBaseRequest.has_bodycCs |j S)r)r`rrrErErF can_read_body}szBaseRequest.can_read_bodycCst|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typer`r(rrErErF body_existsszBaseRequest.body_existscs |js|jIdHqdS)zKRelease request. Eat unread part of HTTP BODY if present. N)r`rreadanyrrErErFreleases 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) rf bytearrayr`rextendrjrr/bytes)rbodychunkZ body_sizerErErFreads    zBaseRequest.readcs"|IdH}|jpd}||S)z1Return BODY as text using encoding from .charset.Nr)rcharsetdecode)rZ bytes_bodyencodingrErErFtexts zBaseRequest.text)loads)rrycs|IdH}||S)zReturn BODY as JSON.N)r)rrrrErErFjsonszBaseRequest.jsoncst|j|jS)z3Return async iterator to process BODY as multipart.)r'rar`rrErErF 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)rJz!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=rr CONTENT_TYPErr&r9r:tempfile TemporaryFileZ read_chunkrwritercloser/seekr2rrCrDaddr startswith get_charsetrrrrrstrip)rr<outrrfieldrZfield_cttmprffrrdatarErErFposts                  zBaseRequest.post)r9rrycCs0|j}|dur|S|j}|dur$|S|||S)z"Extra info from protocol transportN)r^rr)rr9rrurrErErFrszBaseRequest.get_extra_infocCs(|jddd}d|jj|j|S)Nasciibackslashreplacez <{} {} {} >)rrrformatrr>rb)rZascii_encodable_pathrErErF__repr__s  zBaseRequest.__repr__)otherrycCst|t|kSrK)id)rrrErErF__eq__'szBaseRequest.__eq__cCsdS)NTrErrErErF__bool__*szBaseRequest.__bool__responserycsdSrKrE)rr#rErErF _prepare_hook-szBaseRequest._prepare_hook)excrycCs|j|dSrK)r`Z set_exception)rr%rErErF_cancel0szBaseRequest._cancel)N)jr>r?r@rZ METH_PATCHZ METH_POSTZMETH_PUTZ METH_TRACEZ METH_DELETErr ATTRS frozensetr$r)rasyncioZAbstractEventLooprr rrArrr#rrr.r,rpropertyrwru Transportrrrnr"rsrrrxrrrrrrrrr r rrpr{r%r|rqrrrzrrrrrr=r-rdatetimerr staticmethodrr classmethodrrrrrrrrrrrrrrrrr*r+rr'rrrrobjectr r!r0r$ BaseExceptionr&rErErErFr1us <        : <  #` r1c 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)r3 _match_infoN)argsrrycstj|i|d|_dSrK)superrr1)rr2rrrErFr8szRequest.__init__)r9rrycs8||jvr&tjd|jj|tddt||dS)Nz-Setting custom {}.{} attribute is discouragedrr) r'rrrrr>rr3 __setattr__)rr9rr4rErFr5Cs zRequest.__setattr__rrc s0tj|||||||d}tt|} |j| _| S)Nr)r3rrr3r1) rr{rr=rprqrrrnretZnew_retr4rErFrMs  z Request.cloner6rcCs|j}|dusJ|S)zResult of route resolving.N)r1r match_inforErErFr8es zRequest.match_infor4cCs|j}|dusJ|jS)zApplication instance.N)r1Z current_appr7rErErFappls z Request.appcCsH|j}|dusJ|j}|j}||}tt|d|d}t|S)Nr)r1Zappsr9indexrreversedr)rr8lstr9idxZsublistrErErF config_dictss  zRequest.config_dictr"cs6|j}|durdS|jD]}|j||IdHqdSrK)r1Z_appsZon_response_preparesend)rr#r8r9rErErFr$}s  zRequest._prepare_hook)r>r?r@r1r'r(rrrrAr5r#rrr.r,rrr"r8r*r9rr>r0r$ __classcell__rErEr4rFr34s8          r3)cr)r,rCrrstringr rr http.cookiesrrtypingrrrrrr r r r r rr urllib.parserattrZ multidictrrrrrZyarlrrJrabcrZhelpersrrrrrrr r!r"r#Z http_parserr$Z http_writerr%rr&r'Zstreamsr(r)Ztypedefsr*r+r,r-r.Zweb_exceptionsr/Z web_responser0__all__Zweb_appr4Z web_protocolr5Zweb_urldispatcherr6sr2digits ascii_lettersrGrArBrIrrrrangerVrWrXrZcompiler[r\r1r3rErErErFsp   8    0        D