a `g6t @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__ioBufferedReaderrrFrFa/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/aiohttp/web_request.pyr3Ls  r3z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]ccs|]}t|VqdSN)chr).0crFrFrG [rP) !#_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@s8eZdZUejejejejejhZ e j e gdBZ dZ eeeeeefed<dZeeed<ddddddeededejeeeeefeeeeeedd d d Zeeeeeeed eee fee!e fee"e feee feee feee feee fdd ddZ#e$ddddZ%e$ddddZ&e$eej'dddZ(e$edddZ)e$edddZ*e+edddZ,e+e-dddZ.e+ejddd Z/eed!d"d#Z0eedd$d%d&Z1edd!d'd(Z2edd)d*Z3e4edd+d,Z5e+e6dd-d.Z7e+e8e9eefd/fdd0d1Z:e+edd2d3Z;e+edd4d5Ze+edd8d9Z?e+eedd:d;Z@e+e-ddd?ZBe+edd@dAZCe+eddBdCZDe+dDddEdFZEe+eddGdHZFe+eGeddIdJZHe+eIddKdLZJe+eeKjKddMdNZLe+eeKjKddOdPZMeNee4eOdQdRdSZPeQeeee8eOd/fdTdUdVZRe+ee8eOd/fddWdXZSe+ee8eOd/fddYdZZTe+eeKjKdd[d\ZUe+e6dd]d^ZVe+e9eefdd_d`ZWe+eXddadbZYe+eddcddZZe$e6ddedfZ[e$e6ddgdhZ\e+e6ddidjZ]dddkdlZ^eddmdnZ_eddodpZ`eadqebedrdsdtZcedddudvZedwddxdyZfdeeedzd{d|Zgedd}d~Zheie6dddZje6dddZkelddddZmenddddZoddddZpdS)r2)_message _protocol_payload_writer_payload_headers_method_version_rel_url_post _read_bytes_state_cache_task_client_max_size_loop_transport_sslcontext_transport_peernameNrgrhi)client_max_sizestateschemehostremoter6zasyncio.Task[None]) messagepayloadprotocolpayload_writertasklooprprqrrrsrtreturncCs$||_||_||_||_|j|_|j|_|j|_ i|_ |j } | j r| durT| | } | durf| | } | |j d<| j|j d<| j|j d<| |_n*| |_| dur| |j d<| dur| |j d<|durin||_||_||_||_|j} | dusJ| d|_| d|_| dur | |j d<dS)Nurlrsrr sslcontextpeernamert)r_r`rarbr>rcmethodrdversionrerjr|absoluteZ with_schemeZ with_hostrsrrrelativerfrirkrlrm transportget_extra_infornro)selfrurvrwrxryrzrprqrrrsrtr|rrFrFrG__init__sB            zBaseRequest.__init__rrel_urlr>rrrsrtrprrr>rrrsrtrpr{c Cs|jrtdi}|tur"||d<|turFt|} | |d<t| |d<|tur|tt||d<tdd|dD|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 contentrr|pathr>css&|]\}}|d|dfVqdS)utf-8N)encode)rNkvrFrFrGrPsz$BaseRequest.clone.. raw_headersrrrsrt)rprq)rh RuntimeErrorr#rrBrrtupleitemsr__replacerl __class__rbr`rarkrmricopy) rrrr>rrrsrtrpdctnew_urlrukwargsrFrFrGclonesJ   zBaseRequest.cloner{cCs|jSrL)rkrrFrFrGry szBaseRequest.taskcCs|jSrL)r`rrFrFrGrwszBaseRequest.protocolcCs|jdurdS|jjSrL)r`rrrFrFrGrs zBaseRequest.transportcCs|jSrL)rarrFrFrGwriterszBaseRequest.writercCs|jSrL)rlrrFrFrGrpszBaseRequest.client_max_sizecCstjdtdd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningr_rrFrFrGru"szBaseRequest.messagecCs|jSrL)rfrrFrFrGr'szBaseRequest.rel_urlcCstjdtdd|jS)Nz#request.loop property is deprecatedr)rrrrmrrFrFrGrz+szBaseRequest.loop)keyr{cCs |j|SrLrirrrFrFrG __getitem__4szBaseRequest.__getitem__)rvaluer{cCs||j|<dSrLr)rrrrFrFrG __setitem__7szBaseRequest.__setitem__cCs |j|=dSrLrrrFrFrG __delitem__:szBaseRequest.__delitem__cCs t|jSrL)lenrirrFrFrG__len__=szBaseRequest.__len__cCs t|jSrL)iterrirrFrFrG__iter__@szBaseRequest.__iter__cCs |jdkS)z5A bool indicating if the request is handled with SSL.https)rrrrFrFrGsecureEszBaseRequest.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 rFrFN,"z\1rT;z )r_r>ZgetallrZ FORWARDEDrappendtypesrr^matchfindgroupsr]sublowergroupr) rZelemsZ field_valuelengthposZneed_separatorelemrr:rportrFrFrG forwardedJs@      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)rnrrFrFrGrrs zBaseRequest.schemecCs|jS)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rdrrFrFrGrszBaseRequest.methodcCs|jS)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rerrFrFrGrszBaseRequest.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)rrsrFrFrGrsszBaseRequest.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)ro isinstancelistrrBrrFrFrGrts zBaseRequest.remotecCstj|j|jd|jS)zThe full URL of the request.)rr authority)rbuildrrrsjoinrfrrFrFrGr|szBaseRequest.urlcCs|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rfrrrFrFrGrszBaseRequest.pathcCs t|jS)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rBrfrrFrFrGpath_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.)rfqueryrrFrFrGrszBaseRequest.querycCs|jjS)z:The query string in the URL. E.g., id=10 )rf query_stringrrFrFrGrszBaseRequest.query_stringcCs|jS)z4A case-insensitive multidict proxy with all headers.)rcrrFrFrGr>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_headerr{ccsZ|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_valuer{cCs|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_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_MATCHrrFrFrG if_none_match7szBaseRequest.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_range?szBaseRequest.if_rangecCs |jj S)zIs keepalive enabled by client?)r_Z should_closerrFrFrG keep_aliveGszBaseRequest.keep_alivecCs.|jtjd}t|}tdd|DS)zMReturn request cookies. A read-only dictionary-like object. rKcSsi|]\}}||jqSrF)r)rNrvalrFrFrG TrQz'BaseRequest.cookies..)r>rrZCOOKIErrr)rrawparsedrFrFrGcookiesLszBaseRequest.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) rcrrRANGErefindall IndexError ValueErrorintslice)rrngstartendpatternrFrFrG http_rangeVs( zBaseRequest.http_rangecCs|jS)zReturn raw payload stream.)rbrrFrFrGcontentzszBaseRequest.contentcCstjdtdd|j S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrrbat_eofrrFrFrGhas_bodyszBaseRequest.has_bodycCs |j S)r)rbrrrFrFrG can_read_bodyszBaseRequest.can_read_bodycCst|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typerbr)rrFrFrG body_existsszBaseRequest.body_existscs |js|jIdHqdS)zKRelease request. Eat unread part of HTTP BODY if present. N)rbrreadanyrrFrFrGreleases 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) rh bytearrayrbrextendrlrr0bytes)rbodychunkZ body_sizerFrFrGreads    zBaseRequest.readcs"|IdH}|jpd}||S)z1Return BODY as text using encoding from .charset.Nr)rcharsetdecode)rZ bytes_bodyencodingrFrFrGtexts zBaseRequest.text)loads)rr{cs|IdH}||S)zReturn BODY as JSON.N)r)rrrrFrFrGjsonszBaseRequest.jsoncst|j|jS)z3Return async iterator to process BODY as multipart.)r(rcrbrrFrFrG multipartszBaseRequest.multipartz,MultiDictProxy[Union[str, bytes, FileField]]cs|jdur|jS|j|jvr.tt|_|jS|j}|dvrNtt|_|jSt}|dkrh|IdH}|j}|IdH}|durd}|j t j }t |trN|jdusJ|jr|jdtjIdH}|jddIdH} | rl|| } |jd|j| IdH|t| 7}d|kr2|krXnn"|jd|jIdHt||d|jddIdH} q|jd|jdIdH|durd}t|j|jttj|||j } | |j| n|j!d d IdH} |dus|"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))rgrd POST_METHODSrrr=rrlnextr>rrZ CONTENT_TYPErr'r:r;rmrun_in_executortempfile TemporaryFileZ read_chunkrwritercloser0seekr3rrDrEaddr startswith get_charsetrrrrrstrip)rr=outrrfieldr Zfield_cttmprffrrdatarFrFrGposts                 zBaseRequest.post)r:r r{cCs0|j}|dur|S|j}|dur$|S|||S)z"Extra info from protocol transportN)r`rr)rr:r rwrrFrFrGrszBaseRequest.get_extra_infocCs(|jddd}d|jj|j|S)Nasciibackslashreplacez <{} {} {} >)rrrformatrr?rd)rZascii_encodable_pathrFrFrG__repr__+s  zBaseRequest.__repr__)otherr{cCst|t|kSrL)id)rr"rFrFrG__eq__3szBaseRequest.__eq__cCsdS)NTrFrrFrFrG__bool__6szBaseRequest.__bool__responser{csdSrLrF)rr'rFrFrG _prepare_hook9szBaseRequest._prepare_hook)excr{cCst|j|dSrL)r$rb)rr)rFrFrG_cancel<szBaseRequest._cancelcCsD|jdus|jdkrdS|jD]\}}t|tr"|jq"dS)Nr)rgr=rrr3r<r)r file_nameZfile_field_objectrFrFrG_finish?s  zBaseRequest._finish)N)qr?r@rArZ METH_PATCHZ METH_POSTZMETH_PUTZ METH_TRACEZ METH_DELETEr r ATTRS frozensetrgr rrrBrr3rCrhr%r*rasyncioAbstractEventLooprrrrr#rr/r-rpropertyryrw Transportrrrpr"rurrrzrrrrrrrrr r rrrrr&rrsrtr|rrrrrrr>r.rdatetimerr staticmethodrr classmethodrrrrrrrrrrrrrrrr+r,rr(rrrr!objectr$r%r1r( BaseExceptionr*r,rFrFrFrGr2vs   <        ; <  #b r2c seZdZUejedgBZdZeded<e rDe e ddfdd Z e e e e e e e dee efeeefeeefee efee efee efeeefddfd d Zedd d d Zedd ddZeed ddZeddddZZS)r4 _match_infoNr7)r:rr{cs8||jvr&tjd|jj|tddt||dS)Nz-Setting custom {}.{} attribute is discouragedrr) r-rrr rr?rsuper __setattr__)rr:rrrFrGr:Ts zRequest.__setattr__rrc s0tj|||||||d}tt|} |j| _| S)Nr)r9rrr4r8) rrrr>rrrsrtrpretZnew_retr;rFrGr^s  z Request.clonercCs|j}|dusJ|S)zResult of route resolving.N)r8r match_inforFrFrGr>vs zRequest.match_infor5cCs|j}|dusJ|jS)zApplication instance.N)r8Z current_appr=rFrFrGapp}s z Request.appcCsH|j}|dusJ|j}|j}||}tt|d|d}t|S)Nr)r8Zappsr?indexrreversedr)rr>lstr?idxZsublistrFrFrG config_dicts  zRequest.config_dictr&cs>|j}|durdS|jD] }|j}r|||IdHqdSrL)r8Z_appson_response_preparesend)rr'r>r?rErFrFrGr(s   zRequest._prepare_hook)r?r@rAr2r-r.r8r rCrrBrr:r#rrr/r-rrr"r>r1r?rrDr1r( __classcell__rFrFr;rGr4Ls8          r4)dr/r3rDrrstringrrr http.cookiesrrtypingrrrrrr r r r r rr urllib.parserattrZ multidictrrrrrZyarlrrKrabcrhelpersrrrrrrr 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 rrrangerWrXrYr\compiler]r^r2r4rFrFrFrGsl   8    4        [