+
    TŎi                        ^ RI t ^ RIt^ RIt^ RIHtHt ^ RIHt ^ RIH	t	H
t
 ^ RIHtHtHtHtHtHtHtHtHtHtHtHtHt ^ RIHt ^ RIHt ^RIHt ^R	IH t  ]'       d   ^R
I!H"t" ^RI#H$t$ ^RI%H&t&H't' ^RI(H)t) M
R;t&;t';t"t)Rt$ ! R R]4      t* ! R R]4      t+ ! R R]4      t, ! R R]4      t- ! R R]4      t.]'       d   ]]
]/,          ,          t0M]t0]R.]13,          t2 ! R R]]04      t3 ! R R]4      t4 ! R R]4      t5R# )    N)ABCabstractmethod)Sized)
BaseCookieMorsel)TYPE_CHECKINGAny	AwaitableCallableDict	GeneratorIterableListOptionalSequenceTuple	TypedDictUnion)CIMultiDictURL)parse_set_cookie_headers)LooseCookiesApplication)HTTPException)BaseRequestRequest)StreamResponsec                      a  ] tR t^'t o V 3R lR ltV 3R lR lt]V 3R lR l4       tV 3R lR lt]	V 3R	 lR
 l4       t
RtV tR# )AbstractRouterc                   < V ^8  d   QhRR/#    returnN )format__classdict__s   "Z/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/abc.py__annotate__AbstractRouter.__annotate__(   s      $     c                    R V n         R# )FN_frozenselfs   &r)   __init__AbstractRouter.__init__(   s	    r,   c                $   < V ^8  d   QhRS[ RR/# r$   appr%   Nr   )r'   r(   s   "r)   r*   r+   +   s      [ T r,   c                    R# )zPost init stage.

Not an abstract method for sake of backward compatibility,
but if the router wants to be aware of the application
it can override this.
Nr&   r1   r6   s   &&r)   	post_initAbstractRouter.post_init+       r,   c                    < V ^8  d   QhRS[ /# r$   r%   bool)r'   r(   s   "r)   r*   r+   4   s       r,   c                    V P                   # Nr.   r0   s   &r)   frozenAbstractRouter.frozen3   s    ||r,   c                   < V ^8  d   QhRR/# r#   r&   )r'   r(   s   "r)   r*   r+   7   s       r,   c                    RV n         R# )zFreeze router.TNr.   r0   s   &r)   freezeAbstractRouter.freeze7   s	    r,   c                $   < V ^8  d   QhRS[ RR/# )r$   requestr%   AbstractMatchInfor   )r'   r(   s   "r)   r*   r+   <   s     2 2W 21D 2r,   c                   "   R# 5i)z#Return MATCH_INFO for given requestNr&   r1   rI   s   &&r)   resolveAbstractRouter.resolve;           r.   N)__name__
__module____qualname____firstlineno__r2   r9   propertyrB   rF   r   rN   __static_attributes____classdictcell__r(   s   @r)   r!   r!   '   sK           2 2r,   r!   c                     a  ] tR t^@t o Rt]]V 3R lR l4       4       t]]V 3R lR l4       4       t]]V 3R lR l4       4       t	]V 3R lR l4       t
]]V 3R	 lR
 l4       4       t]V 3R lR l4       t]V 3R lR l4       tRtV tR# )rJ   c                H   < V ^8  d   QhRS[ S[.S[S[,          3,          /# r=   )r   r   r
   r   )r'   r(   s   "r)   r*   AbstractMatchInfo.__annotate__F   s%     . .7)Y~-F"FG .r,   c                    R# )zExecute matched request handlerNr&   r0   s   &r)   handlerAbstractMatchInfo.handlerD   r;   r,   c                X   < V ^8  d   QhRS[ S[.S[S[S[,          ,          3,          /# r=   )r   r   r
   r   r   )r'   r(   s   "r)   r*   r\   K   s+     9 9	7)Yx'?@@	A9r,   c                    R# )z*Expect handler for 100-continue processingNr&   r0   s   &r)   expect_handler AbstractMatchInfo.expect_handlerI   r;   r,   c                0   < V ^8  d   QhRS[ S[,          /# r=   )r   r   )r'   r(   s   "r)   r*   r\   R   s     K K 7 Kr,   c                    R# )z<HTTPException instance raised on router's resolving, or NoneNr&   r0   s   &r)   http_exception AbstractMatchInfo.http_exceptionP   r;   r,   c                6   < V ^8  d   QhRS[ S[S[3,          /# r=   )r   strr	   )r'   r(   s   "r)   r*   r\   V   s     J J$sCx. Jr,   c                    R# )z;Return a dict with additional info useful for introspectionNr&   r0   s   &r)   get_infoAbstractMatchInfo.get_infoU   r;   r,   c                4   < V ^8  d   QhRS[ S[R3,          /# )r$   r%   .)r   r   )r'   r(   s   "r)   r*   r\   [   s      eK,- r,   c                    R# )zLStack of nested applications.

Top level application is left-most element.

Nr&   r0   s   &r)   appsAbstractMatchInfo.appsY   r;   r,   c                $   < V ^8  d   QhRS[ RR/# r5   r   )r'   r(   s   "r)   r*   r\   c   s     8 8; 84 8r,   c                    R# )z)Add application to the nested apps stack.Nr&   r8   s   &&r)   add_appAbstractMatchInfo.add_appb   r;   r,   c                   < V ^8  d   QhRR/# r#   r&   )r'   r(   s   "r)   r*   r\   g   s       r,   c                    R# )zoFreeze the match info.

The method is called after route resolution.

After the call .add_app() is forbidden.

Nr&   r0   s   &r)   rF   AbstractMatchInfo.freezef   r;   r,   r&   N)rR   rS   rT   rU   	__slots__rV   r   r^   rb   rf   rk   ro   rs   rF   rW   rX   rY   s   @r)   rJ   rJ   @   s     I.  . 9  9
 K  K J J    8 8  r,   rJ   c                   n   a  ] tR t^qt o RtV 3R lR lt]V 3R lR l4       t]V 3R lR l4       t	Rt
V tR	# )
AbstractViewzAbstract class based view.c                $   < V ^8  d   QhRS[ RR/# )r$   rI   r%   NrK   )r'   r(   s   "r)   r*   AbstractView.__annotate__t   s          D  r,   c                    Wn         R # rA   _requestrM   s   &&r)   r2   AbstractView.__init__t   s    r,   c                    < V ^8  d   QhRS[ /# r=   rK   )r'   r(   s   "r)   r*   r|   x   s       r,   c                    V P                   # )zRequest instance.r~   r0   s   &r)   rI   AbstractView.requestw   s     }}r,   c                6   < V ^8  d   QhRS[ RRS[3,          /# r#   )r   r   )r'   r(   s   "r)   r*   r|   }   s      ( (9T4%?@ (r,   c                    R# )zExecute the view handler.Nr&   r0   s   &r)   	__await__AbstractView.__await__|   r;   r,   r~   N)rR   rS   rT   rU   __doc__r2   rV   rI   r   r   rW   rX   rY   s   @r)   rz   rz   q   s:     $      ( (r,   rz   c                   0   a  ] tR t^t o RtV 3R ltRtV tR# )ResolveResultaq  Resolve result.

This is the result returned from an AbstractResolver's
resolve method.

:param hostname: The hostname that was provided.
:param host: The IP address that was resolved.
:param port: The port that was resolved.
:param family: The address family that was resolved.
:param proto: The protocol that was resolved.
:param flags: The flags that were resolved.
c                b   < V ^8  d   Qh/ S[ ;R&   S[ ;R&   S[;R&   S[;R&   S[;R&   S[;R&   # )r$   hostnamehostportfamilyprotoflags)ri   int)r'   r(   s   "r)   r*   ResolveResult.__annotate__   sM      M  I   I! " K# $ J% & J' r,   r&   N)rR   rS   rT   rU   r   __annotate_func__rW   rX   rY   s   @r)   r   r      s       r,   r   c                   x   a  ] tR t^t o Rt]^ ]P                  3V 3R lR ll4       t]V 3R lR l4       t	Rt
V tR# )AbstractResolverzAbstract DNS resolver.c          	      V   < V ^8  d   QhRS[ RS[RS[P                  RS[S[,          /# )r$   r   r   r   r%   )ri   r   socketAddressFamilyr   r   )r'   r(   s   "r)   r*   AbstractResolver.__annotate__   s8     3 33"3060D0D3	m	3r,   c                   "   R# 5i)z$Return IP address for given hostnameNr&   )r1   r   r   r   s   &&&&r)   rN   AbstractResolver.resolve   rP   rQ   c                   < V ^8  d   QhRR/# r#   r&   )r'   r(   s   "r)   r*   r      s      T r,   c                   "   R# 5i)zRelease resolverNr&   r0   s   &r)   closeAbstractResolver.close   rP   rQ   r&   N)rR   rS   rT   rU   r   r   r   AF_INETrN   r   rW   rX   rY   s   @r)   r   r      s<      %&v~~3 3 3
  r,   r   zMorsel[str]c                      a  ] tR t^t o RtRR/V 3R lR llt]]V 3R lR l4       4       t]RV 3R lR	 ll4       t	]V 3R
 lR l4       t
]]! 4       3V 3R lR ll4       tV 3R lR lt]V 3R lR l4       tRtV tR# )AbstractCookieJarzAbstract Cookie Jar.loopNc                H   < V ^8  d   QhRS[ S[P                  ,          RR/# )r$   r   r%   N)r   asyncioAbstractEventLoop)r'   r(   s   "r)   r*   AbstractCookieJar.__annotate__   s&     8 8)B)B C 8t 8r,   c               N    T;'       g    \         P                  ! 4       V n        R # rA   )r   get_running_loop_loop)r1   r   s   &$r)   r2   AbstractCookieJar.__init__   s    77W557
r,   c                    < V ^8  d   QhRS[ /# r=   r>   )r'   r(   s   "r)   r*   r      s     7 7d 7r,   c                    R# )z(Return True if cookies should be quoted.Nr&   r0   s   &r)   quote_cookieAbstractCookieJar.quote_cookie   r;   r,   c                4   < V ^8  d   QhRS[ S[,          RR/# )r$   	predicater%   N)r   ClearCookiePredicate)r'   r(   s   "r)   r*   r      s!     ; ;x(<= ; ;r,   c                    R# )z,Clear all cookies if no predicate is passed.Nr&   )r1   r   s   &&r)   clearAbstractCookieJar.clear   r;   r,   c                $   < V ^8  d   QhRS[ RR/# )r$   domainr%   Nri   )r'   r(   s   "r)   r*   r      s     ? ?3 ?4 ?r,   c                    R# )z0Clear all cookies for domain and all subdomains.Nr&   )r1   r   s   &&r)   clear_domainAbstractCookieJar.clear_domain   r;   r,   c                *   < V ^8  d   QhRS[ RS[RR/# )r$   cookiesresponse_urlr%   N)r   r   )r'   r(   s   "r)   r*   r      s#      l # RV r,   c                    R# )zUpdate cookies.Nr&   )r1   r   r   s   &&&r)   update_cookies AbstractCookieJar.update_cookies   r;   r,   c                :   < V ^8  d   QhRS[ S[,          RS[RR/# )r$   headersr   r%   N)r   ri   r   )r'   r(   s   "r)   r*   r      s.     A A}A47A	Ar,   c                f    V'       d)   \        V4      ;p'       d   V P                  W24       R# R# R# )z+Update cookies from raw Set-Cookie headers.N)r   r   )r1   r   r   cookies_to_updates   &&& r)   update_cookies_from_headers-AbstractCookieJar.update_cookies_from_headers   s/     -Eg-NN)N 1@ O7r,   c                $   < V ^8  d   QhRS[ RR/# )r$   request_urlr%   zBaseCookie[str]r   )r'   r(   s   "r)   r*   r      s      E E# E2C Er,   c                    R# )z6Return the jar's cookies filtered by their attributes.Nr&   )r1   r   s   &&r)   filter_cookies AbstractCookieJar.filter_cookies   r;   r,   )r   rA   )rR   rS   rT   rU   r   r2   rV   r   r   r   r   r   r   r   r   rW   rX   rY   s   @r)   r   r      s     8d 8 8 7  7 ; ; ; ? ? HK   A A E Er,   r   c                      a  ] tR t^t o Rt^ t^ t^ t]V 3R lR l4       t	]RV 3R lR ll4       t
]V 3R lR l4       t]RV 3R	 lR
 ll4       t]V 3R lR l4       t]V 3R lR l4       tV 3R lR ltV 3R ltRtV tR# )AbstractStreamWriterzAbstract stream writer.c                >   < V ^8  d   QhRS[ S[S[S[3,          RR/# r$   chunkr%   N)r   bytes	bytearray
memoryview)r'   r(   s   "r)   r*   !AbstractStreamWriter.__annotate__   s'     ' 'ui'C!D ' 'r,   c                   "   R# 5i)zWrite chunk into stream.Nr&   r1   r   s   &&r)   writeAbstractStreamWriter.write   rP   rQ   c                $   < V ^8  d   QhRS[ RR/# r   )r   )r'   r(   s   "r)   r*   r      s        U  T  r,   c                   "   R# 5i)zWrite last chunk.Nr&   r   s   &&r)   	write_eofAbstractStreamWriter.write_eof   rP   rQ   c                   < V ^8  d   QhRR/# r#   r&   )r'   r(   s   "r)   r*   r      s     & &T &r,   c                   "   R# 5i)zFlush the write buffer.Nr&   r0   s   &r)   drainAbstractStreamWriter.drain   rP   rQ   Nc                :   < V ^8  d   QhRS[ RS[S[,          RR/# )r$   encodingstrategyr%   N)ri   r   r   )r'   r(   s   "r)   r*   r      s)     + ++3;C=+	+r,   c                    R# )zEnable HTTP body compressionNr&   )r1   r   r   s   &&&r)   enable_compression'AbstractStreamWriter.enable_compression   r;   r,   c                   < V ^8  d   QhRR/# r#   r&   )r'   r(   s   "r)   r*   r      s     ' ' 'r,   c                    R# )zEnable HTTP chunked modeNr&   r0   s   &r)   enable_chunking$AbstractStreamWriter.enable_chunking   r;   r,   c                (   < V ^8  d   QhRS[ RRRR/# )r$   status_liner   zCIMultiDict[str]r%   Nr   )r'   r(   s   "r)   r*   r      s%     ! !!);!	!r,   c                   "   R# 5i)zWrite HTTP headersNr&   )r1   r   r   s   &&&r)   write_headers"AbstractStreamWriter.write_headers   rP   rQ   c                   < V ^8  d   QhRR/# r#   r&   )r'   r(   s   "r)   r*   r      s      d r,   c                    R# )zForce sending buffered headers if not already sent.

Required only if write_headers() buffers headers instead of sending immediately.
For backwards compatibility, this method does nothing by default.
Nr&   r0   s   &r)   send_headers!AbstractStreamWriter.send_headers   r;   r,   c                N   < V ^8  d   Qh/ S[ ;R&   S[ ;R&   S[S[ ,          ;R&   # )r$   buffer_sizeoutput_sizelength)r   r   )r'   r(   s   "r)   r*   r      s0        	 
 SM r,   r&   )r,   )deflateN)rR   rS   rT   rU   r   r   r   r   r   r   r   r   r   r   r   r   r   rW   rX   rY   s   @r)   r   r      s     !KKF' '       & & + + +
 ' ' ! !
 G  r,   r   c                   r   a  ] tR t^t o RtR
tV 3R lR lt]V 3R lR l4       t]	V 3R lR l4       t
RtV tR	# )AbstractAccessLoggerzAbstract writer to access log.c                >   < V ^8  d   QhRS[ P                  RS[RR/# )r$   logger
log_formatr%   N)loggingLoggerri   )r'   r(   s   "r)   r*   !AbstractAccessLogger.__annotate__  s&     % %w~~ %3 %4 %r,   c                    Wn         W n        R # rA   r   r   )r1   r   r   s   &&&r)   r2   AbstractAccessLogger.__init__  s    $r,   c                0   < V ^8  d   QhRS[ RS[RS[RR/# )r$   rI   responsetimer%   N)r   r   float)r'   r(   s   "r)   r*   r    s*     " "; ". " "RV "r,   c                    R# )zEmit log to logger.Nr&   )r1   rI   r  r  s   &&&&r)   logAbstractAccessLogger.log  r;   r,   c                    < V ^8  d   QhRS[ /# r=   r>   )r'   r(   s   "r)   r*   r  
  s       r,   c                    R# )zCheck if logger is enabled.Tr&   r0   s   &r)   enabledAbstractAccessLogger.enabled	  s     r,   )r   r   Nr  )rR   rS   rT   rU   r   rx   r2   r   r  rV   r  rW   rX   rY   s   @r)   r   r      s?     ((I% % " "  r,   r   )6r   r   r   abcr   r   collections.abcr   http.cookiesr   r   typingr   r	   r
   r   r   r   r   r   r   r   r   r   r   	multidictr   yarlr   _cookie_helpersr   typedefsr   web_appr   web_exceptionsr   web_requestr   r   web_responser   r!   rJ   rz   r   r   ri   IterableBaser?   r   r   r   r   r&   r,   r)   <module>r     s       # ! +     "  5 "$-1,;??K?'?K.M2S 22. .b(3 ( I ,s  F3K(LL   56  E|  EF(3 (V3 r,   