[g6t UddlZddlZddlZddlZddlZddlZddlZddlZddlZddl 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 rddlImJZJddlKmLZLddlMmNZNejdddGddZPejejzdzZSeeTeUd<deSdZVeeTeUd<d jd!jd"d#eYeZd$d%zDZ[eeTeUd&<d'Z\eeTeUd(<d)je[e\*Z]eeTeUd+<d,jeVe]-Z^eeTeUd.<ejd/Z`eeeTeUd0<eje^ZaeeeTeUd1<Gd2d3eeTefe/ZbGd4d5ebZcy)6N) 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) auto_attribsfrozenslotscZeZdZUeed<eed<ej ed<eed<eeed<y)r4namefilenamefile content_typeheadersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderrQ/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/aiohttp/web_request.pyr4r4Ls) IM   c ""rJr4z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]c#2K|]}t|ywN)chr).0cs rK rU[s KSV Ks) !#_QDTEXTz \\[\t !-~] _QUOTED_PAIRz"(?:{quoted_pair}|{qdtext})*")qdtext quoted_pair_QUOTED_STRINGz0({token})=({token}|{quoted_string})(:\d{{1,4}})?)token quoted_string_FORWARDED_PAIRz \\([\t !-~])_QUOTED_PAIR_REPLACE_RE_FORWARDED_PAIR_REceZdZUejej ej ejejhZ e je gdzZ dZ eeeeeefed<dZeeed<dddddddeded d d ed d dej4dedeeeefdeedeedeeddfdZeeeeeeeddeee fdee!e fdee"e fdeee fdeee fdeee fdeee fddfdZ#e$d^dZ%e$d_dZ&e$deejNfdZ(e$defdZ)e$defdZ*e+defd Z,e+de-fd!Z.e+dej4fd"Z/d#edefd$Z0d#ed%eddfd&Z1d#eddfd'Z2defd(Z3de4efd)Z5e+de6fd*Z7e+de8e9eefd+ffd,Z:e+defd-Z;e+defd.Ze+defd0Z?e+deefd1Z@e+de-fd2ZAe+defd3ZBe+defd4ZCe+defd5ZDe+d`d6ZEe+defd7ZFe+deGefd8ZHe+deIfd9ZJe+deeKjfd:ZLe+deeKjfd;ZMeNdeedee8eOd+ffd?ZRe+dee8eOd+ffd@ZSe+dee8eOd+ffdAZTe+deeKjfdBZUe+de6fdCZVe+de9eeffdDZWe+deXfdEZYe+defdFZZe$de6fdGZ[e$de6fdHZ\e+de6fdIZ]dadJZ^defdKZ_defdLZ`eadMdNebdefdOZcdedfdPZedbdQZfdcdRedSedefdTZgdefdUZhdVeide6fdWZjde6fdXZkdYelddfdZZmd[enddfd\Zodad]Zpy)dr3)_message _protocol_payload_writer_payload_headers_method_version_rel_url_post _read_bytes_state_cache_task_client_max_size_loop_transport_sslcontext_transport_peernameNrnroi)client_max_sizestateschemehostremotemessagepayloadprotocolr7payload_writertaskasyncio.Task[None]looprwrxryrzr{returnc||_||_||_||_|j|_|j |_|j|_ i|_ |j} | jr}| | j| } | | j| } | |jd<| j|jd<| j |jd<| j#|_n)| |_| | |jd<| | |jd<|in||_||_||_||_|j.} | J| j1d|_| j1d|_| | |jd<yy)Nurlrzry sslcontextpeernamer{)rfrgrhrirArjmethodrkversionrlrqrabsolute with_scheme with_hostrzryrelativermrprrrsrt transportget_extra_inforurv)selfr|r}r~rrrrwrxryrzr{rrs rK__init__zBaseRequest.__init__sj  !- /6 ~~  &( kk <<!oof-mmD)"%DKK "%((DKK $'JJDKK !LLNDMDM!(. H%&* F#!Mbu  / && $$$%.%=%=l%K"#,#;#;J#G  $*DKK ! rJrrel_urlrAryrzr{rwrrrAc|jr tdi}|tur||d<|turt|} | |d<t | |d<|tur=t t ||d<td|djD|d<|jjd i|} i} |tur|| d<|tur|| d <|tur|| d <|tur |j}|j| |j|j|j|j |j"f||j$j'd | 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 contentrrpathrAc3fK|])\}}|jd|jdf+yw)utf-8N)encode)rSkvs rKrUz$BaseRequest.clone..s3'Aq'"AHHW$56's/1 raw_headersryrzr{)rwrxrI)ro RuntimeErrorr$rrErrtupleitemsrf_replacers __class__rirgrhrrrtrpcopy) rrrrAryrzr{rwdctnew_urlr|kwargss rKclonezBaseRequest.clonesa"   OP P   !"CM ( "w> !~~'''rJc|jSrQ)rhrs rKwriterzBaseRequest.writers###rJc|jSrQ)rsrs rKrwzBaseRequest.client_max_sizes$$$rJcRtjdtd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningrfrs rKr|zBaseRequest.message"s 57IVWX}}rJc|jSrQ)rmrs rKrzBaseRequest.rel_url's }}rJcRtjdtd|jS)Nz#request.loop property is deprecatedr)rrrrtrs rKrzBaseRequest.loop+s# 13ERS zzrJkeyc |j|SrQrprrs rK __getitem__zBaseRequest.__getitem__4s{{3rJvaluec"||j|<yrQr)rrrs rK __setitem__zBaseRequest.__setitem__7s  CrJc|j|=yrQrrs rK __delitem__zBaseRequest.__delitem__:s KK rJc,t|jSrQ)lenrprs rK__len__zBaseRequest.__len__=s4;;rJc,t|jSrQ)iterrprs rK__iter__zBaseRequest.__iter__@sDKK  rJc |jdk(S)z5A bool indicating if the request is handled with SSL.https)ryrs rKsecurezBaseRequest.secureEs{{g%%rJ.c<g}|jjjtjdD]X}t |}d}d}i}|j tj|d|cxkr|ksEnHtj||}||r|jd|}n|j\}} } | ddk(rtjd| dd} | r| | z } | ||j<|t |j!dz }d }ne||dk(r.d}i}|j tj||dz }n/||d k(rd}|dz }n||d vr|dz }n|jd|}d|cxkr|krX[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 rIrF,"z\1rT;z )rfrAgetallr FORWARDEDrappendtypesrrdmatchfindgroupsrcsublowergroupr) relems field_valuelengthposneed_separatorelemrr=rports rK forwardedzBaseRequest.forwardedJs(==0077K% 5K%FC"N#%D LL//5 6s#V#*00cB$%)..sC8,1LLN)eT 8s?$;$?$?uQr{$SE!TME-2TZZ\*s5;;q>22)- %,%*NDLL!7!7!=>1HC %,%*N1HC %.1HC&**34C?s#V## % 5LU|rJc|jryy)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)rurs rKryzBaseRequest.schemes  % %rJc|jS)zyRead only property for getting HTTP method. The value is upper-cased str like 'GET', 'POST', 'PUT' etc. )rkrs rKrzBaseRequest.methods ||rJc|jS)zxRead only property for getting HTTP version of request. Returns aiohttp.protocol.HttpVersion instance. )rlrs rKrzBaseRequest.versions }}rJc|jjjtj}||St j S)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. )rfrAgetrHOSTsocketgetfqdn)rrzs rKrzzBaseRequest.hosts:}}$$((3  K~~rJc|jyt|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)rv isinstancelistrrErs rKr{zBaseRequest.remotesN  # # + d..u >t//23 34++,,rJctj|j|jj |j S)zThe full URL of the request.)ry authority)rbuildryrzjoinrmrs rKrzBaseRequest.urls, yy tyyAFFt}}UUrJc.|jjS)z_The URL including *PATH INFO* without the host or scheme. E.g., ``/app/blog`` )rmrrs rKrzBaseRequest.paths }}!!!rJc,t|jS)zXThe URL including PATH_INFO and the query string. E.g, /app/blog?id=10 )rErmrs rKpath_qszBaseRequest.path_qss 4==!!rJc.|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`` )rfrrs rKraw_pathzBaseRequest.raw_paths}}!!!rJc.|jjS)z7A multidict with all the variables in the query string.)rmqueryrs rKrzBaseRequest.querys}}"""rJc.|jjS)z:The query string in the URL. E.g., id=10 )rm query_stringrs rKrzBaseRequest.query_strings }})))rJc|jS)z4A case-insensitive multidict proxy with all headers.)rjrs rKrAzBaseRequest.headers}}rJc.|jjS)z$A sequence of pairs for all headers.)rfrrs rKrzBaseRequest.raw_headerss}}(((rJcft|jjtjS)zyThe value of If-Modified-Since HTTP header, or None. This header is represented as a `datetime` object. )r"rArrIF_MODIFIED_SINCErs rKif_modified_sincezBaseRequest.if_modified_sinces$ t||//0F0FGHHrJcft|jjtjS)z{The value of If-Unmodified-Since HTTP header, or None. This header is represented as a `datetime` object. )r"rArrIF_UNMODIFIED_SINCErs rKif_unmodified_sincezBaseRequest.if_unmodified_since s$ t||//0H0HIJJrJ etag_headerc#K|tk(rtdtytj|D]5}|j ddd\}}}|rytt ||7yw)z'Extract `ETag` objects from raw header.F)is_weakrrrN)rr rfinditerrbool)rrrrgarbages rK _etag_valueszBaseRequest._etag_valuessw ( "  -55kB */++aA*>' M sA,A. header_valuec<|syt|j|SrQ)rr )clsr s rK_if_match_or_none_implz"BaseRequest._if_match_or_none_impl&s S%%l344rJcr|j|jjtjS)zxThe value of If-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )rrArrIF_MATCHrs rKif_matchzBaseRequest.if_match/s( **4<<+;+;DMM+JKKrJcr|j|jjtjS)z}The value of If-None-Match HTTP header, or None. This header is represented as a `tuple` of `ETag` objects. )rrArr IF_NONE_MATCHrs rK if_none_matchzBaseRequest.if_none_match7s* **4<<+;+;D??rJc0|jj S)zIs keepalive enabled by client?)rf should_closers rK keep_alivezBaseRequest.keep_aliveGs==----rJc|jjtjd}t |}t |j Dcic]\}}||jc}}Scc}}w)zMReturn request cookies. A read-only dictionary-like object. rO)rArrCOOKIErrrr)rrawparsedrvals rKcookieszBaseRequest.cookiesLsS llt{{B/c"  OHCcii OPP OsA- c|jjtj}d\}}|r d}t j ||d\}}|r t|nd}|r t|nd}||| }d}|||dz }||k\r td||cxur tdt||dS#t $r tdwxYw) 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) rjrrRANGErefindall IndexError ValueErrorintslice)rrngstartendpatterns rK http_rangezBaseRequest.http_rangeVsmm + s ? C0ZZ5a8 s"#c(tC"'CJTE} S_qC<$%@AA# !EFF$UC##+ C !ABB Cs B00Cc|jS)zReturn raw payload stream.)rirs rKcontentzBaseRequest.contentzrrJcptjdtd|jj S)@Return True if request's HTTP BODY can be read, False otherwise.z$Deprecated, use .can_read_body #2005rr)rrrriat_eofrs rKhas_bodyzBaseRequest.has_bodys1  24FST =='')))rJc8|jj S)r1)rir2rs rK can_read_bodyzBaseRequest.can_read_bodys=='')))rJc8t|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typerir*rs rK body_existszBaseRequest.body_existssDMM"*;;;rJcK|jjs>|jjd{|jjs=yy7!w)zKRelease request. Eat unread part of HTTP BODY if present. N)rir2readanyrs rKreleasezBaseRequest.releasesC --&&(--'') ) )--&&( )s8AAAAc\K|jt} |jjd{}|j ||j r1t |}||j k\rt|j ||sntt||_|jS7rw)z_Read request body if present. Returns bytes object with full request content. Nmax_size actual_size) ro bytearrayrir:extendrsrr1bytes)rbodychunk body_sizes rKreadzBaseRequest.reads    #;D"mm3355 E"(( #D I D$9$997%)%:%:  %T{D 6s5B,B*A3B,cK|jd{}|jxsd}|j|S7%w)z1Return BODY as text using encoding from .charset.Nr)rFcharsetdecode)r bytes_bodyencodings rKtextzBaseRequest.texts899;& <<*7  **'s ><&>)loadsrMcNK|jd{}||S7 w)zReturn BODY as JSON.N)rL)rrMrCs rKjsonzBaseRequest.jsons#YY[ T{!s %# %cJKt|j|jSw)z3Return async iterator to process BODY as multipart.)r)rjrirs rK multipartzBaseRequest.multipartst}}dmm<nn;|j"j%d|j2d{t5|||j+dd{} | r|j"j%d|j6dd{|d}t9|j|j t;t<j>|||j} |jA|j| n|jCd d{} ||jEd r>|jGd } |jA|j| j-| n|jA|j| |t1| z }d|cxkr|krnnt5||tId|jd{}|nd|jCd{} | rJ|jJxsd } |jMtO| jQj-| d | t||_|jS7r7Q777r7+777[77w)zReturn POST parameters.N)rOz!application/x-www-form-urlencodedmultipart/form-datarSri)sizer=zapplication/octet-streamT)rIztext/r)defaultz8To decode nested multipart you need to use custom reader)keep_blank_valuesrK))rnrk POST_METHODSrrr@rQrsnextrArr CONTENT_TYPErr(r=r>rtrun_in_executortempfile TemporaryFile read_chunkrIwritercloser1seekr4rrGrHaddrF startswith get_charsetr&rHrArrstrip)rr@outrQr>fieldrTfield_cttmprDffrrHdatas rKpostzBaseRequest.posts :: !::  <->?e^4 ::111 ~~$(JJ$>$> ("8"8%',&6&6E&6&B B#$)LL$7E"&**"<" /$sB,P?.P /#P?P#B P?P&P?8P)9AP?:P,;A P?P/&P?+P2,P?3*P?P5A?P?P8B8P?P;P?P?3P=4A-P?#P?&P?)P?,P?/P?2P?5P?8P?;P?=P?r=rUcf|j}||S|j}||S|j||S)z"Extra info from protocol transport)rgrr)rr=rUr~rs rKrzBaseRequest.get_extra_infos?>>  N&&  N''g66rJc|jjddjd}dj|jj |j |S)Nasciibackslashreplacez <{} {} {} >)rrrIformatrrBrk)rascii_encodable_paths rK__repr__zBaseRequest.__repr__+sS#yy//9KLSS  ## NN # #T\\3G  rJotherc0t|t|k(SrQ)id)rrss rK__eq__zBaseRequest.__eq__3s$x2e9$$rJcy)NTrIrs rK__bool__zBaseRequest.__bool__6srJresponsec KywrQrI)rrys rK _prepare_hookzBaseRequest._prepare_hook9s sexcc0t|j|yrQ)r%ri)rr|s rK_cancelzBaseRequest._cancel<sdmmS)rJc|j|jdk7ry|jjD]0\}}t|ts|j j 2y)NrS)rnr@rrr4r?r_)r file_namefile_field_objects rK_finishzBaseRequest._finish?s^ :: !2!26K!K  -1JJ,<,<,> / (I(+Y7!&&,,. /rJ)rr)rr7)rzMultiMapping[str])rN)rz,MultiDictProxy[Union[str, bytes, FileField]]rQ)qrBrCrDr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETErWr!ATTRS frozensetrnr rrrErBr4rFror&r+rasyncioAbstractEventLoopr'rrrr$rr0r.rpropertyrr~ Transportrrrwr#r|rrrrrrrr rrrrr rryrr'rrzr{rrrrrrrrAr/rdatetimerr staticmethodr r  classmethodrrrrrr r(r-r/r3r5r8r;rFrLr,r-rOr)rQrkrrrobjectrvrxr2r{ BaseExceptionr~rrIrJrKr3r3vst      L    " E*EIE8N5eY)>#?@ AH#'K%' '*. $" $7+"7+7+# 7+ - 7+ # 7+''7+7+S#X'7+ 7+sm7+ 7+ 7+x)1.62:(0&.(0199 c9n%9 x*+ 9 |Y./ 9 c9n% 9 CN#9 c9n%9 sI~.9  9 v(8G$5$56(( $,$$%%% *    g//  s s !s!3!4!st  !(3-!  && & :5c!2C!78: :x           c   $  - -  - VSV V  "c" " "" " "#" " # # *c* * )#.  )Z) ) I8H,=,=#>I I KXh.?.?%@K K#(4.(5#C=5 %c " #55 L(5s#34L L QxdCi(89Q Q @(8#4#45@ @ .D. . Qc*Q Q !$E!$ !$F  *$***t** >> ?>s-AAA A)rr8)rr6)rBrCrDr3rrrr rFrrErrr$rrr0r.r'rr#rrrrrr2r{ __classcell__)rs@rKr5r5LsJ    =/ : :E37K/07  +C +c +d +)1.62:(0&.(019c9n%x*+  |Y./  c9n% CN#c9n%sI~. 0   && &]&&?N?t?rJr5)drrrGr#rstringr[rr http.cookiesrrtypingrrrrr r r r r rrr urllib.parserattr multidictrrrrryarlrrOrabcrhelpersrrrrrr r!r"r#r$r% http_parserr& http_writerr'rQr(r)streamsr*r+typedefsr,r-r.r/r0web_exceptionsr1 web_responser2__all__web_appr6 web_protocolr7web_urldispatcherr8sr4digits ascii_lettersrLrErFrNrprrranger[r\r_rbcompilercrdr3r5rIrJrKrs   %"    # %    +$646( 1$,6T$d3##4#]]V%9%99>N?s 0:rzz//Jws|,J+5"**_*EE'#,'ES /.c*LS /lH?kH?rJ