ht ~UddlZddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z mZmZmZmZmZmZmZmZmZddlmZddlZddlmZmZmZmZmZddl 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 rddlImJZJddlKmLZLddlMmNZNejOdddGddZPejQejRzdzZSeeTeUd<deSdZVeeTeUd<d Wd!Xd"d#eYeZd$d%zDZ[eeTeUd&<d'Z\eeTeUd(<d)We[e\*Z]eeTeUd+<d,WeVe]-Z^eeTeUd.<ej_d/Z`eeeTeUd0<ej_e^ZaeeeTeUd1<Gd2d3eeTe fe/ZbGd4d5ebZcdS)6N)MappingProxyType) TYPE_CHECKINGAnyDictFinalIteratorMappingMutableMappingOptionalPatternTupleUnioncast) parse_qsl) CIMultiDictCIMultiDictProxy MultiDictMultiDictProxy MultiMapping)URL)hdrs)parse_cookie_header)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_attribsfrozenslotscXeZdZUeed<eed<ejed<eed<eeed<dS)r4namefilenamefile content_typeheadersN)__name__ __module__ __qualname__str__annotations__ioBufferedReaderr[/var/www/html/services/rag-service/venv/lib/python3.11/site-packages/aiohttp/web_request.pyr4r4LsP IIIMMM  c """"""rJr4z!#$%&'*+.^_`|~-_TCHAR[z]+_TOKENz[{}]c#4K|]}t|VdSN)chr).0cs rK rU[s( K KSVV K K K K K KrJ) !#_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_REc,eZdZUejejejejejhZ e j e gdzZ dZ eeeeeefed<dZeeed<dddddddeded d d ed d dejdedeeeefdeedeedeeddfdZeeeeeeeddeee fdee!e fdee"e fdeee fdeee fdeee fdeee fddfdZ#e$d`dZ%e$dadZ&e$deej'fdZ(e$defdZ)e$defdZ*e+defd Z,e+de-fd!Z.e+dejfd"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+dbd7ZEe+defd8ZFe+deGefd9ZHe+deIfd:ZJe+deeKjKfd;ZLe+deeKjKfd<ZMeNd=ede4eOfd>ZPeQd?eedee8eOd+ffd@ZRe+dee8eOd+ffdAZSe+dee8eOd+ffdBZTe+deeKjKfdCZUe+de6fdDZVe+de9eeffdEZWe+deXfdFZYe+defdGZZe$de6fdHZ[e$de6fdIZ\e+de6fdJZ]dcdKZ^defdLZ_defdMZ`eadNdOebdefdPZcdedfdQZedddSZfdedTedUedefdVZgdefdWZhdXeide6fdYZjde6fdZZkd[elddfd\Zmd]enddfd^Zodcd_ZpdS)fr3)_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{returncZ||_||_||_||_|j|_|j|_|j|_ i|_ |j } | j rp| | | } | | | } | |j d<| j|j d<| j|j d<| |_n| |_| | |j d<| | |j d<|in||_||_||_||_|j|_|j|_| | |j d<dSdS)Nurlrzryr{)rfrgrhrirArjmethodrkversionrlrqrabsolute with_scheme with_hostrzryrelativermrprrrsrt ssl_contextrupeernamerv) selfr|r}r~rrrrwrxryrzr{rs rK__init__zBaseRequest.__init__sC  !- /6 ~  &( k < +!oof--mmD))"%DK "%(DK $'JDK !LLNNDMMDM!(. H%&* F#!Mbbu  / %-%9"#+#4  $*DK ! ! !  rJrrel_urlrAryrzr{rwrrrAc|jrtdi}|tur||d<|tur&t|} | |d<t | |d<|turSt t ||d<td|dD|d<|j j d i|} 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 contentrrpathrAc3pK|]1\}}|d|dfV2dS)utf-8N)encode)rSkvs rKrUz$BaseRequest.clone..sW''Aq'""AHHW$5$56''''''rJ raw_headersryrzr{)rwrxrI)ro RuntimeErrorr$rrErrtupleitemsrf_replacers __class__rirgrhrrrtrpcopy) rrrrAryrzr{rwdctnew_urlr|kwargss rKclonezBaseRequest.clones"   QOPP P   ! !"CM ( " "w< !4~''rJc|jSrQ)rhrs rKwriterzBaseRequest.writers ##rJc|jSrQ)rsrs rKrwzBaseRequest.client_max_sizes $$rJcHtjdtd|jS)NzRequest.message is deprecated stacklevel)warningswarnDeprecationWarningrfrs rKr|zBaseRequest.message s$ 57IVWXXXX}rJc|jSrQ)rmrs rKrzBaseRequest.rel_url%s }rJcHtjdtd|jS)Nz#request.loop property is deprecatedr)rrrrtrs rKrzBaseRequest.loop)s. 13ERS    zrJkeyc|j|SrQrprrs rK __getitem__zBaseRequest.__getitem__2s{3rJvaluec||j|<dSrQr)rrrs rK __setitem__zBaseRequest.__setitem__5s  CrJc|j|=dSrQrrs rK __delitem__zBaseRequest.__delitem__8s K   rJc*t|jSrQ)lenrprs rK__len__zBaseRequest.__len__;s4;rJc*t|jSrQ)iterrprs rK__iter__zBaseRequest.__iter__>sDK   rJc|jdkS)z5A bool indicating if the request is handled with SSL.https)ryrs rKsecurezBaseRequest.secureCs{g%%rJ.cg}|jjtjdD]}t |}d}d}i}|tj|d|cxkr|krOnPt ||}||r| d|}n| \}} } | ddkr#td| dd } | r| | z } | ||<|t |dz }d }nw||dkr1d}i}|tj||dz }n:||d krd}|dz }n&||d vr|dz }n| d|}d|cxkr|kIt#|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 rIrFN,"z\1rT;z )rfrAgetallr FORWARDEDrappendtypesrrdmatchfindgroupsrcsublowergroupr) relems field_valuelengthposneed_separatorelemrr=rports rK forwardedzBaseRequest.forwardedHs(=077KK% 5% 5K%%FC"N#%D LL/55 6 6 6s####V#####*00cBB$% .)..sC88,1LLNN)eT 8s??$;$?$?uQrT{$S$SE*!TME-2TZZ\\*s5;;q>>222)- %,,%*NDLL!7!=!=>>>1HCC %,,%*N1HCC %..1HCC&**344C?s####V####@U||rJc|jrdSdS)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  % 76rJc|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|jjtj}||St jS)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.hosts7}$((33  K~rJc|jdSt|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.remotesR  # +4 d.u > > 4t/233 34+,,,rJcrtj|j|j|jS)zThe full URL of the request.)ry authority)rbuildryrzjoinrmrs rKrzBaseRequest.urls- y tyAAAFFt}UUUrJc|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}!!rJMultiMapping[str]c|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}((rJcdt|jtjS)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|//0FGGHHHrJcdt|jtjS)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_sinces% t|//0HIIJJJrJ etag_headerc#K|tkrtdtVdStj|D]B}|ddd\}}}|rdStt ||VCdS)z'Extract `ETag` objects from raw header.F)is_weakrrrN)rr rfinditerrbool)rrrrgarbages rK _etag_valueszBaseRequest._etag_valuess ( " "      -5kBB  */++aA*>*>'EE MM  rJ header_valuecN|sdSt||SrQ)rr )clsr s rK_if_match_or_none_implz"BaseRequest._if_match_or_none_impl$s- 4S%%l33444rJcp||jtjS)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<+;+;DM+J+JKKKrJcp||jtjS)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_match5s+ **4<+;+;D>???rJc|jj S)zIs keepalive enabled by client?)rf should_closers rK keep_alivezBaseRequest.keep_aliveEs=---rJct|jtjd}t d|DS)zMReturn request cookies. A read-only dictionary-like object. rOc$i|] \}}||jSrI)r)rSr=morsels rK z'BaseRequest.cookies..Ts O O O fv| O O OrJ)rrArrCOOKIEr)rparseds rKcookieszBaseRequest.cookiesJsB%T\%5%5dk2%F%FGG O O O O OPPPrJc|jtj}d\}}| d}t j||d\}}n#t $rtdwxYw|rt|nd}|rt|nd}||| }d}|||dz }||krtd||cxurnntdt||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) rjrrRANGErefindall IndexError ValueErrorintslice)rrngstartendpatterns rK http_rangezBaseRequest.http_rangeVs&m ++ s ? C0Z55a8 ss C C C !ABBB C"+#c(((tC"'1CJJJTE} S_qC<<$%@AAA######## !EFFFUC###s AA(c|jS)zReturn raw payload stream.)rirs rKcontentzBaseRequest.contentzrrJcntjdtd|j 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_bodys?  24FST    =''))))rJc6|j S)r2)rir3rs rK can_read_bodyzBaseRequest.can_read_bodys=''))))rJc8t|jtuS)z6Return True if request has HTTP BODY, False otherwise.)typerir*rs rK body_existszBaseRequest.body_existssDM""*;;;rJcK|js:|jd{V|j8dSdS)zKRelease request. Eat unread part of HTTP BODY if present. N)rir3readanyrs rKreleasezBaseRequest.releasesp -&&(( *-'')) ) ) ) ) ) ) )-&&(( * * * * *rJcFK|jt} |jd{V}|||jr0t |}||jkrt|j||snot||_|jS)z_Read request body if present. Returns bytes object with full request content. NTmax_size actual_size) ro bytearrayrir;extendrsrr1bytes)rbodychunk body_sizes rKreadzBaseRequest.reads   #;;D "m3355555555 E"""( #D I D$9997%)%:   %T{{D rJcvK|d{V}|jpd}||S)z1Return BODY as text using encoding from .charset.Nr)rGcharsetdecode)r bytes_bodyencodings rKtextzBaseRequest.textsE99;;&&&&&& <*7  ***rJ)loadsrNcPK|d{V}||S)zReturn BODY as JSON.N)rM)rrNrDs rKjsonzBaseRequest.jsons3YY[[      uT{{rJc:Kt|j|jS)z3Return async iterator to process BODY as multipart.)r)rjrirs rK multipartzBaseRequest.multipartst}dm<<zapplication/octet-streamT)rJztext/r)defaultz8To decode nested multipart you need to use custom reader)keep_blank_valuesrL))rnrk POST_METHODSrrr@rRrsnextrArr CONTENT_TYPErr(r=r>rtrun_in_executortempfile TemporaryFile read_chunkrJwritercloser1seekr4rrGrHaddrG startswith get_charsetr'rIrBrrstrip)rr@outrRr?fieldrVfield_cttmprEffrrIdatas rKpostzBaseRequest.posts : !:  ??e^444 :111 ~)$(J$>$> ("8%%',&6&6E&6&B&B B B B B B B# G$)LL$7$7E"&*"<"  N&  N''g666rJc|jddd}d|jj|j|S)Nasciibackslashreplacez <{} {} {} >)rrrJformatrrBrk)rascii_encodable_paths rK__repr__zBaseRequest.__repr__+sW#y//9KLLSS   ## N #T\3G   rJothercBt|t|kSrQ)id)rrvs rK__eq__zBaseRequest.__eq__3s$xx2e99$$rJcdS)NTrIrs rK__bool__zBaseRequest.__bool__6strJresponsec KdSrQrI)rr|s rK _prepare_hookzBaseRequest._prepare_hook9s rJexcc0t|j|dSrQ)r%ri)rrs rK_cancelzBaseRequest._cancel<sdmS)))))rJc|j |jdkrdS|jD]3\}}t|tr|j4dS)NrU)rnr@rrr4r?ra)r file_namefile_field_objects rK_finishzBaseRequest._finish?su : !26K!K!K F -1J,<,<,>,> / / (I(+Y77 /!&,,... / /rJ)rr)rr7)rr)rN)rrSrQ)qrBrCrDr METH_PATCH METH_POSTMETH_PUT METH_TRACE METH_DELETErYr!ATTRS frozensetrnr rrrErCr4rFror&r+rasyncioAbstractEventLoopr(rrrr$rr0r.rpropertyrr~ Transportrrrwr#r|rrrrrrrrrrrr r rryrr'rrzr{rrrrrrrrAr/rdatetimerr staticmethodr r  classmethodrrrrrr!r)r.r0r4r6r9r<rGrMr,r-rPr)rRrmroruobjectryr{r2r~ BaseExceptionrrrIrJrKr3r3vs       L     "" E*EIE8N5eY)>#?@ AHHH#'K%''' '*. $" $5+5+5+"5+5+# 5+ - 5+ # 5+'5+5+S#X'5+ 5+sm5+ 5+ 5+5+5+5+t)1.62:(0&.(0199 9 9 c9n%9 x*+ 9 |Y./ 9 c9n% 9 CN#9 c9n%9 sI~.9  9 9 9 9 vXX(8G$56(((X( $,$$$X$%%%%X% * U  U g/ U s s    !s!3!4!!!!st     !(3-!!!!  &&&& U& :5c!2C!78::: U:x      U   U  U  c    U $  - - - - U - VSVVV UV  "c""" U" """" U" "#""" U" ### U# *c*** U* )#. U )Z))) U) I8H,=#>III UI KXh.?%@KKK UK#(4.\(5#C=5 %c " #555[5 L(5s#34LLL UL QxdCi(89QQQ UQ @(8#45@@@ U@ .D... U.  Qc* Q Q Q U Q !$E!$!$!$ U!$F  U*$***X**t***X* >>>>>>>> ? ?rJ)rr8)rr6)rBrCrDr3rrrr rFrrErrr$rrr0r.r(rr#rrrrrr2r~ __classcell__)rs@rKr5r5Ls   =/ : : :E37K/0777 + +C +c +d + + + + + +)1.62:(0&.(019c9n%x*+  |Y./  c9n% CN#c9n%sI~. 0  U &&&X& &]&&&X&?N?t????????rJr5)drrrGr$rstringr]rrrtypingrrrrrr r r r r rr urllib.parserattr multidictrrrrryarlrrOr_cookie_helpersrabcrhelpersrrrrrr r!r"r#r$r% http_parserr& http_writerr'rRr(r)streamsr*r+typedefsr,r-r.r/r0web_exceptionsr1 web_responser2__all__web_appr6 web_protocolr7web_urldispatcherr8sr4digits ascii_lettersrLrErFrNrsrrranger[r\r_rbcompilercrdr3r5rIrJrKrsj  """"""                            #""""" 000000%%%%%%                          +*****$$$$$$6666666644444444655555(((((( 17$$$$$$,,,,,,666666T$d333#######43#]V%99>N?s 0:rz//J/Jws|,JJJ+5"*_*E*EE'#,'EEES /S /S /S /S /.c*LS /S /S /lH?H?H?H?H?kH?H?H?H?H?rJ