+
    TŎiw                     
  a R t0 t R t^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	t	^ RI
t
^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIHt ^ RIHt ^ RIHt ^ RIHt ^ RIHt ^ RIHt ^ RI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/H0t0H1t1H2t2H3t3H4t4H5t5 ^ RI6H7t7 ^ RI8H9t9H:t: ^ RI;t;^ RI<H=t=H>t>H?t? ^ RI@HAtB ^ RICHDtD ^RIEHFtF ^RIGHHtH ]P                  R8  d   ^ RItJM^ RIJtJRtK]P                  ! 4       R8H  tM]P                  ! 4       R8H  tN]P                  R8  tO]P                  R8  tP]2! R4      tQ]2! R4      tR]P                  ! RR4      tT]TP                  tU]V! ]P                  P                  R4      4      tY]Z! ^R.][! ^d^4      O54      t\]FP                  t^]P                  P                  ;'       gE    ]P                  P                  '       * ;'       d"    ]V! ]P                  P                  R4      4      tb][! ^ ^4       U u0 uF  p ]c! V 4      kK  	  up td][! ^ ^ 4       U u0 uF  p ]c! V 4      kK  	  up ]c! ^4      0,          teRR R!R"R#R$R%R&R'R(R)R*R+R,R-R.R/R0]c! ^	4      0tf]d]e,          ]f,          tg ! R1 R24      th ! R3 R]! R. RO4      4      tiR4 R5 ltjR6 R7 ltk];P                  ! R8R8R8R97       ! R: R;4      4       tmR< R= ltnR> R? ltoR@ RA ltp];P                  ! R8R8R8R97       ! RB RC4      4       tq]P                  ! ^8RD7      RE RF l4       ts ! RG RH]4      tt]P                  ! ^8RD7      RI RJ l4       tuRRK RL lltv]P                  ! RM4      tx][! ^ ^4       U u0 uF  p ]c! V 4      kK  	  up RN0,          tyRO RP ltzRRQ RR llt{RS RT lt|Rs}] ^ k RUs~RV RW ltRX RY ltRRZ R[ lltRR\ R] lltR^ R_ lt ! R` Ra4      t ! Rb Rc]&Rc,          4      t ! Rd Re]4      t ! Rf Rg]4      tRRh Ri llt ! Rj Rk4      tRl Rm lt]! 4       t ! Rn Ro]/4      t]3Rp Rq llt]EP                   ! Rr Rs])]Q,          4      4       t ! Rt R]-]3]]]$,          3,          ]$3,          4      tRut]P                  ! ]4      tRv] Rw2t]P                  ! ]4      t]P                  ! R] Rx24      tRyt];P                  ! R8R8R8R97       ! Rz R4      4       tR{ R| ltR} R~ lt]P                  R R l4       tR R ltR# u up i u up i u up i )zVarious helper functionsN)
namedtuple)suppress)EmailMessage)HeaderParser)HTTP)	parsedateceil)Path)MappingProxyTypeTracebackType)AnyCallableContextManagerDict	GeneratorGenericIterableIteratorListMappingOptionalProtocolTupleTypeTypeVarUnionget_argsoverload)quote)
getproxiesproxy_bypass)	MultiDictMultiDictProxyMultiMapping)under_cached_property)URL)hdrs)client_logger	BasicAuthChainMapProxyETagDarwinWindows_T_S	_SENTINELsentinelAIOHTTP_NO_EXTENSIONSi0  PYTHONASYNCIODEBUG()<>@,;:\"/[]?={} c                   2   a  ] tR t^wt o V 3R lR ltRtV tR# )noopc                .   < V ^8  d   QhRS[ R,          /# )   return)NNN)r   )format__classdict__s   "^/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/helpers.py__annotate__noop.__annotate__x   s      9%56     c              #     "   R x  R # 5iN selfs   &rM   	__await__noop.__await__x   s     s   	rS   N)__name__
__module____qualname____firstlineno__rV   __static_attributes____classdictcell__rL   s   @rM   rG   rG   w   s      rP   rG   c                      a a ] tR t^|t oRtRV3R lV 3R lllt]RV3R lR ll4       t]RR/V3R lR	 ll4       tV3R
 lR lt	Rt
VtV ;t# )r)   z!Http basic authentication helper.latin1c                0   < V ^8  d   QhRS[ RS[ RS[ RR/# )rI   loginpasswordencodingrJ   r)   str)rK   rL   s   "rM   rN   BasicAuth.__annotate__   s-     ? ??#&?7:?	?rP   c                   < Vf   \        R4      hVf   \        R4      hRV9   d   \        R4      h\        SV `	  WW#4      # )Nz"None is not allowed as login valuez%None is not allowed as password valuer;   z5A ":" is not allowed in login (RFC 1945#section-11.1))
ValueErrorsuper__new__)clsrb   rc   rd   	__class__s   &&&&rM   rk   BasicAuth.__new__   sL     =ABBDEE%<TUUws8>>rP   c                *   < V ^8  d   QhRS[ RS[ RR/# )rI   auth_headerrd   rJ   r)   re   )rK   rL   s   "rM   rN   rg      s"     : : : :; :rP   c                    VP                  R^4      w  r4TP                  4       R8w  d   \        RT,          4      h \        P                  ! TP                  R4      RR7      P                  T4      p TP                  R	^4      w  rgT ! YgTR7      #   \         d    \        R4      hi ; i  \        P                   d    \        R4      hi ; i  \         d    \        R
4      hi ; i)z<Create a BasicAuth object from an Authorization HTTP header.rE   z%Could not parse authorization header.basiczUnknown authorization method %sasciiT)validatezInvalid base64 encoding.r;   zInvalid credentials.rd   )	splitri   lowerbase64	b64decodeencodedecodebinasciiError)rl   rp   rd   	auth_typeencoded_credentialsdecodedusernamerc   s   &&&     rM   r{   BasicAuth.decode   s    	F-8->->sA-F*I ??'>JKK	9&&#**73dfX 	5
 ")sA!6H 899-  	FDEE	F ~~ 	9788	9  	5344	5s"   B 6B- 5C B*-!CC(rd   c                :   < V ^8  d   QhRS[ RS[RS[R,          /# )rI   urlrd   rJ   r)   )r&   rf   r   )rK   rL   s   "rM   rN   rg      s,     J J3 JS J@U JrP   c                   \        V\        4      '       g   \        R4      hVP                  f   VP                  f   R# T ! VP
                  ;'       g    RVP                  ;'       g    RVR7      # )zCreate BasicAuth from url.zurl should be yarl.URL instanceN ru   )
isinstancer&   	TypeErrorraw_userraw_passworduserrc   )rl   r   rd   s   &&$rM   from_urlBasicAuth.from_url   s\     #s##=>> <<C$4$4$<388>>r3<<#5#52IIrP   c                    < V ^8  d   QhRS[ /# rI   rJ   re   )rK   rL   s   "rM   rN   rg      s     J J JrP   c                    V P                    RV P                   2P                  V P                  4      pR\        P
                  ! V4      P                  V P                  4      ,          # )zEncode credentials.r;   zBasic %s)rb   rc   rz   rd   rx   	b64encoder{   )rU   credss   & rM   rz   BasicAuth.encode   sN    JJ<q088GF,,U3::4==IIIrP   rS   )r   r`   )r`   )rX   rY   rZ   r[   __doc__rk   classmethodr{   r   rz   r\   r]   __classcell__rm   rL   s   @@rM   r)   r)   |   sa     +? ? : : :8 J8 J J JJ J JrP   c                h    V ^8  d   QhR\         R\        \         \        \        ,          3,          /# rI   r   rJ   r&   r   r   r)   )rK   s   "rM   rN   rN      s-     N NS NU30C+C%D NrP   c                    V P                   f   V P                  f   V R3# V P                  R4      \        V P                  ;'       g    RV P
                  ;'       g    R4      3# )zIRemove user and password from URL if present and return BasicAuth object.Nr   )r   r   	with_userr)   r   rc   )r   s   &rM   strip_auth_from_urlr      sT     || 0 0 8Dy==	#((..b#,,:L:L" MMMrP   c                N    V ^8  d   QhR\         \        P                  ,          /# r   )r   netrc)rK   s   "rM   rN   rN      s     ( (- (rP   c                    \         P                  P                  R4      p V e   \        V 4      pM- \        P                  ! 4       pT\        '       d   RMR,          p \        P                  ! \        V4      4      #   \
         d#   p\        P                  ! RT4        Rp?R# Rp?ii ; i  \        P                   d#   p\        P                  ! RT4        Rp?R# Rp?i\         d   pRp\        P                  ! \        4      ;_uu_ 4        TP!                  4       pRRR4       M  + '       g   i     M; iT '       g	   T'       d   \        P                  ! RT4        Rp?R# Rp?ii ; i)	zLoad netrc from file.

Attempt to load it from the path specified by the env-var
NETRC or in the default location in the user's home directory.

Returns None if it couldn't be found or fails to parse.
NETRCNzHCould not resolve home directory when trying to look for .netrc file: %s_netrcz.netrczCould not parse .netrc file: %sFzCould not read .netrc file: %s)osenvirongetr
   homeRuntimeErrorr(   debug
IS_WINDOWSr   rf   NetrcParseErrorwarningOSError
contextlibr   is_file)	netrc_env
netrc_pathhome_direnetrc_existss        rM   netrc_from_envr      s    

w'I)_
		yy{H ZZXF
G{{3z?++  	5
 	    D?CC   G  ))%--/L *)))  !!"BAFGse   A= B- =B*B%%B*-E0CE0,E0-$E+D+"	E++D;6E+E+E++E0T)auto_attribsfrozenslotsc                   ,   a  ] tR t^t o V 3R ltRtV tR# )	ProxyInfoc                B   < V ^8  d   Qh/ S[ ;R&   S[S[,          ;R&   # )rI   proxy
proxy_auth)r&   r   r)   )rK   rL   s   "rM   rN   ProxyInfo.__annotate__   s!     J  ## rP   rS   NrX   rY   rZ   r[   __annotate_func__r\   r]   r^   s   @rM   r   r            rP   r   c                f    V ^8  d   QhR\         \        P                  ,          R\        R\        /# )rI   	netrc_objhostrJ   )r   r   rf   r)   )rK   s   "rM   rN   rN      s*     ) )HU[[$9 ) ) )rP   c                    V f   \        R4      hV P                  V4      pVf   \        RV: R24      hVw  r4pV'       g   Vf   TMTpVf   Rp\        We4      # )z
Return :py:class:`~aiohttp.BasicAuth` credentials for ``host`` from ``netrc_obj``.

:raises LookupError: if ``netrc_obj`` is :py:data:`None` or if no
        entry is found for the ``host``.
zNo .netrc file foundzNo entry for z found in the `.netrc` file.r   )LookupErrorauthenticatorsr)   )r   r   auth_from_netrcrb   accountrc   r   s   &&     rM   basicauth_from_netrcr      sr     011..t4OM$1MNOO.EH '/uH X((rP   c                F    V ^8  d   QhR\         \        \        3,          /# r   )r   rf   r   )rK   s   "rM   rN   rN     s      $sI~. rP   c                  l   \        4       P                  4        U Uu/ uF  w  rV R9   g   K  V \        V4      bK  	  pp p\        4       pVP                  4        U Uu/ uF  w  rV \	        V4      bK  	  pp p/ pVP                  4        F  w  rgVw  rVP
                  R9   d3   \        P                  ! RVP
                  P                  4       V4       KL  V'       d)   V	f%   VP                  e    \        W8P                  4      p	\        W4      WV&   K  	  V# u upp i u upp i   \         d    Rp	 L.i ; i)httpz)%s proxies %s are not supported, ignoringN)r   httpswswss)r   r   )r    itemsr&   r   r   schemer(   r   upperr   r   r   r   )
kv
proxy_urlsr   strippedretprotovalr   auths
             rM   proxies_from_envr     s(    L&&((DA.. 	3q6	(  
  I6@6F6F6HI6Hda&q))6HHI
Cnn&
<<++!!;U\\=O=O=QSX zz% /	::FD u+
 ' J- J #  D s"   DDD/D##D32D3c                h    V ^8  d   QhR\         R\        \         \        \        ,          3,          /# r   r   )rK   s   "rM   rN   rN   ,  s)     7 7s 7uS(92E-E'F 7rP   c                0   V P                   e6   \        V P                   4      '       d   \        RV P                   : R24      h\        4       p WP                  ,          pVP
                  VP                  3#   \         d    \        RT : R24      hi ; i)z5Get a permitted proxy for the given URL from the env.zProxying is disallowed for ``zNo proxies found for `z` in the env)r   r!   r   r   r   r   r   KeyError)r   proxies_in_env
proxy_infos   &  rM   get_env_proxy_for_urlr   ,  s    
xxSXX 6 68AFGG%'N7#JJ/
 !6!666  H23'FGGHs   A9 9Bc                   ,   a  ] tR tRt o V 3R ltRtV tR# )MimeTypei:  c                H   < V ^8  d   Qh/ S[ ;R&   S[ ;R&   S[ ;R&   R;R&   # )rI   typesubtypesuffixzMultiDictProxy[str]
parametersre   )rK   rL   s   "rM   rN   MimeType.__annotate__:  s4     
I  L  K	 
 &% rP   rS   Nr   r^   s   @rM   r   r   :  r   rP   r   )maxsizec                0    V ^8  d   QhR\         R\        /# )rI   mimetyperJ   )rf   r   )rK   s   "rM   rN   rN   C  s     $ $S $X $rP   c           	     8   V '       g!   \        RRR\        \        4       4      R7      # V P                  R4      p\        4       pVR,           F^  pV'       g   K  VP	                  R4      w  rEpVP                  VP                  4       P                  4       VP                  R4      4       K`  	  V^ ,          P                  4       P                  4       pVR8X  d   RpVP	                  R	4      w  rp	V	P	                  R
4      w  rp
\        WV
\        V4      R7      # )zParses a MIME type into its components.

mimetype is a MIME type string.

Returns a MimeType object.

Example:

>>> parse_mimetype('text/html; charset=utf-8')
MimeType(type='text', subtype='html', suffix='',
         parameters={'charset': 'utf-8'})

r   )r   r   r   r   r:      NNrB   z "*z*/*r>   +)r   r#   r"   rv   	partitionaddrw   strip)r   partsparamsitemkey_valuefulltypemtypestyper   s   &          rM   parse_mimetyper   B  s     R~ik7R
 	
 NN3E&[Fb		s+

399;$$&D(9:	  Qx~~%%'H3((-OEes+Ef&^F=S rP   c                   P   a a ] tR tRt oV3R lV 3R lltV3R lR ltRtVtV ;t# )EnsureOctetStreamij  c                   < V ^8  d   QhRR/# rI   rJ   NrS   )rK   rL   s   "rM   rN   EnsureOctetStream.__annotate__k  s     : :$ :rP   c                F   < \         SV `  4        V P                  R 4       R# )application/octet-streamN)rj   __init__set_default_type)rU   rm   s   &rM   r  EnsureOctetStream.__init__k  s    89rP   c                    < V ^8  d   QhRS[ /# r   re   )rK   rL   s   "rM   rN   r  p  s      # rP   c                    V P                  RR4      P                  4       pVP                  R4      w  p pVP                  4       pVP	                  R4      ^8w  d   V P                  4       # V# )zRe-implementation from Message

Returns application/octet-stream in place of plain/text when
value is wrong.

The way this class is used guarantees that content-type will
be present so simplify the checks wrt to the base implementation.
zcontent-typer   r:   r>   )r   rw   r   r   countget_default_type)rU   r   ctyper   s   &   rM   get_content_type"EnsureOctetStream.get_content_typep  sc     ,224 ooc*q!;;sq ((**rP   rS   )	rX   rY   rZ   r[   r  r  r\   r]   r   r   s   @@rM   r  r  j  s     : :
  rP   r  c                t    V ^8  d   QhR\         R\        \         \        \         \         3,          3,          /# )rI   rawrJ   )rf   r   r   )rK   s   "rM   rN   rN     s.     8 8C 8E#/?S/I*I$J 8rP   c                    \        \        \        R7      P                  RV  24      pVP	                  4       pVP                  R4      p\        VR,          4      pV\        V4      3# )zParse Content-Type header.

Returns a tuple of the parsed content type and a
MappingProxyType of parameters. The default returned value
is `application/octet-stream`
)policyzContent-Type: r   rS   )r   r  r   parsestrr  
get_paramsdictr   )r  msgcontent_typer   content_dicts   &    rM   parse_content_typer    s`     (
6
?
?.QTPU@V
WC'')L^^BFr
#L),777rP   c                h    V ^8  d   QhR\         R\        \        ,          R\        \        ,          /# )rI   objdefaultrJ   )r   r   rf   )rK   s   "rM   rN   rN     s)       hsm x} rP   c                     \        V R R4      pV'       dH   \        V\        4      '       d2   V^ ,          R8w  d$   VR,          R8w  d   \        V4      P                  # V# )nameNr6   r7   )getattrr   rf   r
   r   )r  r  r   s   && rM   guess_filenamer#    sF    3%D
4%%$q'S.T"X_DzNrP   z[^\041\043-\133\135-\176]	c                0    V ^8  d   QhR\         R\         /# )rI   contentrJ   re   )rK   s   "rM   rN   rN     s     
B 
B3 
B3 
BrP   c                v    \         \        V 4      8  g   \        RV : 24      h\        P	                  R V 4      # )a   Return 7-bit content as quoted-string.

Format content into a quoted-string as defined in RFC5322 for
Internet Message Format. Notice that this is not the 8-bit HTTP
format, but the 7-bit email format. Content must be in usascii or
a ValueError is raised.
zbad content for quoted-string c                 2    R V P                  ^ 4      ,           # )r<   )group)xs   &rM   <lambda>quoted_string.<locals>.<lambda>  s    dQWWQZ&7rP   )QCONTENTsetri   not_qtext_resub)r&  s   &rM   quoted_stringr1    s7     s7|#9'EFF7AArP   c          
      T    V ^8  d   QhR\         R\        R\         R\         R\         /# )rI   disptypequote_fields_charsetr   rJ   rf   bool)rK   s   "rM   rN   rN     s4     0 00!%08;0QT00rP   c                J   V '       d   \         \        V 4      8  g   \        RV : 24      hT pV'       Ed    . pVP                  4        F  w  rgV'       d   \         \        V4      8  g   \        RV: RV: 24      hV'       dh   VP	                  4       R8X  d+   \        VRVR7      pVP                  VRV,          34       K{   \        V4      pVP                  VRV,          34       K  VP                  R
R4      P                  RR4      pVP                  VRV,          34       K  	  RP                  R V 4       4      p	RP                  WI34      pV#   \         d@    RP                  TR\        TRTR7      34      pTP                  TR	,           T34        EKX  i ; i)a?  Sets ``Content-Disposition`` header for MIME.

This is the MIME payload Content-Disposition header from RFC 2183
and RFC 7579 section 4.2, not the HTTP Content-Disposition from
RFC 6266.

disptype is a disposition type: inline, attachment, form-data.
Should be valid extension token (see RFC 2183)

quote_fields performs value quoting to 7-bit MIME headers
according to RFC 7578. Set to quote_fields to False if recipient
can take 8-bit file names and field values.

_charset specifies the charset to use when quote_fields is True.

params is a dict with disposition params.
zbad content disposition type z"bad content disposition parameter rB   filenamer   ru   z"%s"z''r   r<   z\\r=   z\"z; c              3   D   "   T F  pR P                  V4      x  K  	  R# 5i)rB   N)join).0pairs   & rM   	<genexpr>-content_disposition_header.<locals>.<genexpr>  s     ?wtCHHTNNws    )
TOKENr.  ri   r   rw   r   appendr1  r;  replace)
r3  r4  r5  r   r   lparamsr   r   qvalsparamss
   &&&,      rM   content_disposition_headerrF    sq   ( ECM18EFFEvHCus3x/ #EcWAcW!UVV99;*, b8<DNNC$#78=,S1  Vd]';<{{4088eDVd]34' '( ))?w??		5*+L & :!ww%tU3X-NO   c	4'899	:s   EAF"!F"c                F    V ^8  d   QhR\         \        ,          R\        /# )rI   r   rJ   )r   rf   r7  )rK   s   "rM   rN   rN     s     
: 
: 
:$ 
:rP   c                p    V '       g   R# RV 9   ;'       g!    V P                  RR4      P                  4       # )z}Check if host looks like an IP Address.

This check is only meant as a heuristic to ensure that
a host is not a domain name.
Fr;   .r   )rB  isdigit)r   s   &rM   is_ip_addressrK    s2      $;99$,,sB/7799rP   r   c                $    V ^8  d   QhR\         /# r   re   )rK   s   "rM   rN   rN     s     %& %&s %&rP   c                      \        \        P                  ! 4       4      p V \        8w  d=   RpRp\        P                  ! V 4      vr4rVrxrRW,          VW$,          VVVV3,          sV s\        # )Monz#%s, %02d %3s %4d %02d:%02d:%02d GMT)rN  TueWedThuFriSatSun)r   JanFebMarAprMayJunJulAugSepOctNovDec)inttime_cached_current_datetimegmtime_cached_formatted_datetime)now_weekdayname
_monthnameyearmonthdayhhmmsswdtails              rM   rfc822_formatted_timerq    s     diik
C
&& I

  37++c2B/Sbb%JN
 &
" $' %%rP   c                     V ^8  d   QhRRRR/# )rI   infozTuple[weakref.ref[object], str]rJ   NrS   )rK   s   "rM   rN   rN     s        ;    rP   c                     V w  rV! 4       pVe3   \        \        4      ;_uu_ 4        \        W24      ! 4        R R R 4       R # R #   + '       g   i     R # ; irR   )r   	Exceptionr"  )rs  refr   obs   &   rM   _weakref_handlerx    sB    IC	B	~i  B !     s   AA	c                    V ^8  d   QhR\         R\        R\        R\        P                  R\        R\
        \        P                  ,          /# )rI   rw  r   timeoutlooptimeout_ceil_thresholdrJ   )objectrf   floatasyncioAbstractEventLoopr   TimerHandle)rK   s   "rM   rN   rN     sU      
  
#
#	
 " g!!"rP   c                     Ve]   V^ 8  dV   VP                  4       V,           pW$8  d   \        V4      pVP                  V\        \        P
                  ! V 4      V34      # R # rR   )rb  r	   call_atrx  weakrefrv  )rw  r   rz  r{  r|  whens   &&&&& rM   weakref_handler    sR     w{yy{W$,:D||D/GKKOT3JKKrP   c                    V ^8  d   QhR\         . \        3,          R\        R\        P                  R\        R\
        \        P                  ,          /# )rI   cbrz  r{  r|  rJ   )r   r   r~  r  r  r   r  )rK   s   "rM   rN   rN   .  sT     
" 
"S
"
" 
#
#
" "	
"
 g!!"
"rP   c                 v    Ve   V^ 8:  d   R # VP                  4       p\        WAV4      pVP                  WP4      # rR   )rb  calculate_timeout_whenr  )r  rz  r{  r|  rf  r  s   &&&&  rM   
call_laterr  .  s9     'Q,
))+C!#0FGD<<!!rP   c                H    V ^8  d   QhR\         R\         R\         R\         /# )rI   	loop_timerz  timeout_ceiling_thresholdrJ   )r~  )rK   s   "rM   rN   rN   ;  s0     	 			  %	 		rP   c                8    W,           pW8  d   \        V4      # V# )z$Calculate when to execute a timeout.r   )r  rz  r  r  s   &&& rM   r  r  ;  s!     D*DzKrP   c                      a  ] tR tRt o RtRtRV 3R lR lltV 3R lR ltV 3R lR ltV 3R	 lR
 lt	V 3R lR lt
V 3R lR ltRtV tR# )TimeoutHandleiG  zTimeout handlec                T   < V ^8  d   QhRS[ P                  RS[S[,          RS[RR/# )rI   r{  rz  ceil_thresholdrJ   N)r  r  r   r~  )rK   rL   s   "rM   rN   TimeoutHandle.__annotate__L  s=      '' % 	
 
rP   c                8    W n         Wn        W0n        . V n        R # rR   _timeout_loop_ceil_threshold
_callbacks)rU   r{  rz  r  s   &&&&rM   r  TimeoutHandle.__init__L  s       
-  	rP   c                >   < V ^8  d   QhRS[ R,          RS[RS[RR/# )rI   callbackNargskwargsrJ   ).N)r   r   )rK   rL   s   "rM   rN   r  Y  s2     9 9 +9479CF9	9rP   c                @    V P                   P                  WV34       R # rR   )r  rA  )rU   r  r  r  s   &&*,rM   registerTimeoutHandle.registerY  s     	78rP   c                   < V ^8  d   QhRR/# r  rS   )rK   rL   s   "rM   rN   r  ^  s        t  rP   c                :    V P                   P                  4        R # rR   )r  clearrT   s   &rM   closeTimeoutHandle.close^  s    rP   c                D   < V ^8  d   QhRS[ S[P                  ,          /# r   )r   r  r  )rK   rL   s   "rM   rN   r  a  s      x 3 34 rP   c                    V P                   pVei   V^ 8  db   V P                  P                  4       V,           pWP                  8  d   \	        V4      pV P                  P                  W P                  4      # R # rR   )r  r  rb  r  r	   r  __call__)rU   rz  r  s   &  rM   startTimeoutHandle.starta  s]    --7Q;::??$w.D...Dz::%%dMM::rP   c                   < V ^8  d   QhRR/# )rI   rJ   BaseTimerContextrS   )rK   rL   s   "rM   rN   r  k  s      ) rP   c                    V P                   eD   V P                   ^ 8  d3   \        V P                  4      pV P                  VP                  4       V# \        4       # rR   )r  TimerContextr  r  rz  	TimerNoop)rU   timers   & rM   r  TimeoutHandle.timerk  sB    ==$): ,EMM%--(L;rP   c                   < V ^8  d   QhRR/# r  rS   )rK   rL   s   "rM   rN   r  s  s        $  rP   c                    V P                    F.  w  rp\        \        4      ;_uu_ 4        V! V/ VB  R R R 4       K0  	  V P                   P                  4        R #   + '       g   i     K_  ; irR   )r  r   ru  r  )rU   r  r  r  s   &   rM   r  TimeoutHandle.__call__s  sS     $Bf)$$D#F# %$ !0 	 %$$s   	AA,)r  r  r  r  Nr     )rX   rY   rZ   r[   r   	__slots__r  r  r  r  r  r  r\   r]   r^   s   @rM   r  r  G  sI     FI 9 9
        rP   r  c                   6   a  ] tR tRt o RtV 3R lR ltRtV tR# )r  i{  c                   < V ^8  d   QhRR/# r  rS   )rK   rL   s   "rM   rN   BaseTimerContext.__annotate__  s     ? ? ?rP   c                    R# )z0Raise TimeoutError if timeout has been exceeded.NrS   rT   s   &rM   assert_timeoutBaseTimerContext.assert_timeout  s    rP   rS   N)rX   rY   rZ   r[   r  r  r\   r]   r^   s   @rM   r  r  {  s     I? ?rP   r  c                   H   a  ] tR tRt o RtV 3R lR ltV 3R lR ltRtV tR# )r  i  c                    < V ^8  d   QhRS[ /# r   r  )rK   rL   s   "rM   rN   TimerNoop.__annotate__  s      + rP   c                    V # rR   rS   rT   s   &rM   	__enter__TimerNoop.__enter__  s    rP   c                p   < V ^8  d   QhRS[ S[S[,          ,          RS[ S[,          RS[ S[,          RR/# )rI   exc_typeexc_valexc_tbrJ   N)r   r   BaseExceptionr   )rK   rL   s   "rM   rN   r    sG      4./ -( '	
 
rP   c                    R # rR   rS   )rU   r  r  r  s   &&&&rM   __exit__TimerNoop.__exit__  s     	rP   rS   N)	rX   rY   rZ   r[   r  r  r  r\   r]   r^   s   @rM   r  r    s     I  rP   r  c                      a  ] tR tRt o RtRtV 3R lR ltV 3R lR ltV 3R lR ltV 3R	 lR
 lt	V 3R lR lt
RtV tR# )r  i  z&Low resolution timeout context managerc                8   < V ^8  d   QhRS[ P                  RR/# )rI   r{  rJ   N)r  r  )rK   rL   s   "rM   rN   TimerContext.__annotate__  s!      W66 4 rP   c                <    Wn         . V n        R V n        ^ V n        R# )FNr  _tasks
_cancelled_cancelling)rU   r{  s   &&rM   r  TimerContext.__init__  s    
/1rP   c                   < V ^8  d   QhRR/# r  rS   )rK   rL   s   "rM   rN   r    s     1 1 1rP   c                L    V P                   '       d   \        P                  RhR# )z7Raise TimeoutError if timer has already been cancelled.N)r  r  TimeoutErrorrT   s   &rM   r  TimerContext.assert_timeout  s    ???&&D0 rP   c                    < V ^8  d   QhRS[ /# r   r  )rK   rL   s   "rM   rN   r    s      + rP   c                6   \         P                  ! V P                  R 7      pVf   \        R4      h\        P
                  R8  d   VP                  4       V n        V P                  '       d   \         P                  RhV P                  P                  V4       V # ))r{  Nz4Timeout context manager should be used inside a task      )r  current_taskr  r   sysversion_info
cancellingr  r  r  r  rA  rU   tasks   & rM   r  TimerContext.__enter__  st    ##4<UVVw&  $0D???&&D04 rP   c          	         < V ^8  d   QhRS[ S[S[,          ,          RS[ S[,          RS[ S[,          RS[ S[,          /# )rI   r  r  r  rJ   )r   r   r  r   r7  )rK   rL   s   "rM   rN   r    sK      4./ -( '	
 
$rP   c                H   R pV P                   '       d   V P                   P                  4       pV\        P                  J d`   V P                  '       dN   Vf   Q h\
        P                  R8  d"   VP                  4       V P                  8  d   R # \        P                  VhR # )Nr  )
r  popr  CancelledErrorr  r  r  uncancelr  r  )rU   r  r  r  
enter_tasks   &&&& rM   r  TimerContext.__exit__  s     37
;;;*Jw---$///))) 7* &&(4+;+;;&&G3rP   c                   < V ^8  d   QhRR/# r  rS   )rK   rL   s   "rM   rN   r    s     # # #rP   c                    V P                   '       g6   \        V P                  4       F  pVP                  4        K  	  R V n         R# R# )TN)r  r.  r  cancelr  s   & rM   rz  TimerContext.timeout  s5    DKK( ) #DO	 rP   )r  r  r  r  Nr  )rX   rY   rZ   r[   r   r  r  r  r  r  rz  r\   r]   r^   s   @rM   r  r    s?     0@I 1 1
 " 0# #rP   r  c                f    V ^8  d   QhR\         \        ,          R\        R\        P                  /# )rI   delayr  rJ   )r   r~  async_timeoutTimeout)rK   s   "rM   rN   rN     s.     * *E?*,1**rP   c                     V e   V ^ 8:  d   \         P                  ! R 4      # \        P                  ! 4       pVP	                  4       pW0,           pW8  d   \        V4      p\         P                  ! V4      # rR   )r  rz  r  get_running_looprb  r	   
timeout_at)r  r  r{  rf  r  s   &&   rM   ceil_timeoutr    s`     }
$$T**##%D
))+C;DDz##D))rP   c                      a  ] tR tRt o Rt]! . RO4      tRtRt]	t
V 3R lR lt]V 3R lR l4       t]V 3R lR	 l4       t]V 3R
 lR l4       tV 3R ltRtV tR# )HeadersMixini  zMixin for handling headers.Nc                4   < V ^8  d   QhRS[ S[,          RR/# )rI   r  rJ   Nr   rf   )rK   rL   s   "rM   rN   HeadersMixin.__annotate__  s     
> 
>x} 
> 
>rP   c                    Wn         Vf   RV n        / V n        R # \        V4      w  r#W n        VP	                  4       V n        R # )Nr  )_stored_content_type_content_type_content_dictr  copy)rU   r  r  content_mapping_proxys   &&  rM   _parse_content_type HeadersMixin._parse_content_type  sA    $'!;!;D!#D2DS2I/L!-!6!;!;!=DrP   c                    < V ^8  d   QhRS[ /# r   re   )rK   rL   s   "rM   rN   r    s     " "c "rP   c                    V P                   P                  \        P                  4      pV P                  V8w  d   V P                  V4       V P                  f   Q hV P                  # )z7The value of content part for Content-Type HTTP header.)_headersr   r'   CONTENT_TYPEr  r  r  rU   r  s   & rM   r  HeadersMixin.content_type  sX     mm 1 12$$+$$S)!!---!!!rP   c                0   < V ^8  d   QhRS[ S[,          /# r   r  )rK   rL   s   "rM   rN   r    s     1 1# 1rP   c                    V P                   P                  \        P                  4      pV P                  V8w  d   V P                  V4       V P                  f   Q hV P                  P                  R4      # )z7The value of charset part for Content-Type HTTP header.charset)r
  r   r'   r  r  r  r  r  s   & rM   r  HeadersMixin.charset  sc     mm 1 12$$+$$S)!!---!!%%i00rP   c                0   < V ^8  d   QhRS[ S[,          /# r   )r   ra  )rK   rL   s   "rM   rN   r    s     G G GrP   c                v    V P                   P                  \        P                  4      pVf   R# \	        V4      # )z(The value of Content-Length HTTP header.N)r
  r   r'   CONTENT_LENGTHra  )rU   content_lengths   & rM   r  HeadersMixin.content_length
  s3     **4+>+>?%-tF3~3FFrP   c                   < V ^8  d   Qh/ S[ S[,          ;R&   S[S[,          ;R&   S[S[S[S[3,          ,          ;R&   S[S[RS[3,          ;R&   # )rI   r
  r  r  Nr  )r$   rf   r   r   r   r0   )rK   rL   s   "rM   rN   r    s[     
 3  C='  DcN+2   T9 45@ rP   )r  r  r  )r  r  r  )rX   rY   rZ   r[   r   	frozensetATTRSr  r  r1   r  r  propertyr  r  r  r   r\   r]   r^   s   @rM   r  r    su     %PQE $(M.2M8@
> 
> " " 1 1 G GS  rP   r  c                ,    V ^8  d   QhRRR\         RR/# )rI   futzasyncio.Future[_T]resultrJ   N)r.   )rK   s   "rM   rN   rN     s"      ( "  rP   c                 X    V P                  4       '       g   V P                  V4       R # R # rR   )done
set_result)r  r  s   &&rM   r   r     s    88::v rP   c                   6   a  ] tR tRt o RV 3R lR lltRtV tR# )ErrorableProtocoli  c                *   < V ^8  d   QhRS[ RS[ RR/# )rI   exc	exc_causerJ   Nr  )rK   rL   s   "rM   rN   ErrorableProtocol.__annotate__  s)       ! 
	rP   c                    R # rR   rS   )rU   r$  r%  s   &&&rM   set_exceptionErrorableProtocol.set_exception  s     rP   rS   N.)rX   rY   rZ   r[   r)  r\   r]   r^   s   @rM   r"  r"    s       rP   r"  c                8    V ^8  d   QhRRR\         R\         RR/# )rI   r  z&asyncio.Future[_T] | ErrorableProtocolr$  r%  rJ   Nr&  )rK   s   "rM   rN   rN   !  s0      	1	  
	rP   c                    \         P                  ! V 4      '       d   V P                  4       '       d   R# V\        J pWJ pV'       g   V'       g   W!n        V P                  V4       R# )zSet future exception.

If the future is marked as complete, this function is a no-op.

:param exc_cause: An exception that is a direct cause of ``exc``.
                  Only set if provided.
N)r  isfuturer  _EXC_SENTINEL	__cause__r)  )r  r$  r%  exc_is_sentinelexc_causes_itselfs   &&&  rM   r)  r)  !  sN     =0O(#4!crP   c                   n   a  ] tR tRt o RtRtRV 3R lR lltV 3R lR ltV 3R lR	 ltV 3R
 lt	Rt
V tR# )AppKeyi8  z.Keys for static typing support in Application.Nc                F   < V ^8  d   QhRS[ RS[S[S[,          ,          /# )rI   r   t)rf   r   r   r.   )rK   rL   s   "rM   rN   AppKey.__annotate__C  s$     
 
S 
Xd2h%7 
rP   c                    \         P                  ! 4       pV'       d>   VP                  P                  R 8X  d   VP                  R,          pMVP
                  pKE  XR,           V,           V n        W n        R# )z<module>rX   rI  N)inspectcurrentframef_codeco_name	f_globalsf_back_name_t)rU   r   r6  framemodules   &&&  rM   r  AppKey.__init__C  sT    $$&||##z1#ooj9LLEc\D(
rP   c                &   < V ^8  d   QhRS[ RS[/# )rI   otherrJ   r}  r7  )rK   rL   s   "rM   rN   r7  O  s      F t rP   c                d    \        V\        4      '       d   V P                  VP                  8  # R # )T)r   r4  r?  )rU   rE  s   &&rM   __lt__AppKey.__lt__O  s%    eV$$::++rP   c                    < V ^8  d   QhRS[ /# r   re   )rK   rL   s   "rM   rN   r7  T  s     8 8# 8rP   c                   V P                   pVf=   \        \        4      ;_uu_ 4        \        V P                  4      ^ ,          pR R R 4       Vf   RpM[\        V\        4      '       d;   VP                  R8X  d   VP                  pM'VP                   RVP                   2pM\        V4      pRV P                   RV R2#   + '       g   i     L; i)Nz<<Unknown>>builtinsrI  z<AppKey(z, type=z)>)r@  r   AttributeErrorr   __orig_class__r   r   rY   rZ   reprr?  )rU   r6  t_reprs   &  rM   __repr__AppKey.__repr__T  s    GG9.))T001!4 * 9"F4  ||z)LL>1>>*:;!WF$**WVHB77 *)s   CC	c                6   < V ^8  d   Qh/ S[ S[,          ;R&   # )rI   rN  )r   r}  )rK   rL   s   "rM   rN   r7  8  s      L  rP   )r?  r@  )r?  r@  rN  rR   )rX   rY   rZ   r[   r   r  r  rH  rQ  r   r\   r]   r^   s   @rM   r4  r4  8  s2     81I
 
 
8 89  rP   r4  c                   ^  a  ] tR tRt o Rt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4       tV 3R
 lR lt]V 3R lR l4       t	]R V 3R lR ll4       t	]R V 3R lR ll4       t	R!V 3R lR llt	V 3R lR lt
V 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltRtV tR# )"r*   ig  c                p   < V ^8  d   QhRS[ S[S[S[S[S[,          3,          S[3,          ,          RR/# )rI   mapsrJ   N)r   r   r   rf   r4  r   )rK   rL   s   "rM   rN   ChainMapProxy.__annotate__j  s9     ! !XgeC4D.Es.J&KL !QU !rP   c                &    \        V4      V n        R # rR   )tuple_maps)rU   rV  s   &&rM   r  ChainMapProxy.__init__j  s    4[
rP   c                   < V ^8  d   QhRR/# r  rS   )rK   rL   s   "rM   rN   rW  m  s     
 
$ 
rP   c                J    \        R P                  V P                  4      4      h)z4Inheritance class {} from ChainMapProxy is forbidden)r   rK   rX   )rl   s   &rM   __init_subclass__ChainMapProxy.__init_subclass__m  s"    !6#,,/
 	
rP   c                6   < V ^8  d   QhRS[ S[,          RS[/# rI   r   rJ   )r4  r.   )rK   rL   s   "rM   rN   rW  t  s    55vbz5b5rP   c                    R # rR   rS   rU   r   s   &&rM   __getitem__ChainMapProxy.__getitem__s  s    25rP   c                &   < V ^8  d   QhRS[ RS[/# ra  rf   r   )rK   rL   s   "rM   rN   rW  w  s    //s/s/rP   c                    R # rR   rS   rc  s   &&rM   rd  re  v  s    ,/rP   c                L   < V ^8  d   QhRS[ S[S[S[,          3,          RS[/# ra  r   rf   r4  r.   r   )rK   rL   s   "rM   rN   rW  y  s(      uS&*_5 # rP   c                t    V P                    F  p W!,          u # 	  \        V4      h  \         d     K)  i ; irR   )rZ  r   )rU   r   mappings   && rM   rd  re  y  s=    zzG|# "
 sm  s   (77c                R   < V ^8  d   QhRS[ S[,          RS[RS[S[S[3,          /# rI   r   r  rJ   )r4  r.   r/   r   )rK   rL   s   "rM   rN   rW    s$    EEvbzEBE5R=ErP   c                    R # rR   rS   rU   r   r  s   &&&rM   r   ChainMapProxy.get  s    BErP   c                J   < V ^8  d   QhRS[ S[,          RRRS[S[,          /# )rI   r   r  NrJ   )r4  r.   r   )rK   rL   s   "rM   rN   rW    s     LLvbzLDL8B<LrP   c                    R # rR   rS   rp  s   &&&rM   r   rq    s    ILrP   c                ,   < V ^8  d   QhRS[ RS[RS[/# rn  rg  )rK   rL   s   "rM   rN   rW    s    ;;s;S;3;rP   c                    R # rR   rS   rp  s   &&&rM   r   rq    s    8;rP   Nc                R   < V ^8  d   QhRS[ S[S[S[,          3,          RS[RS[/# rn  rj  )rK   rL   s   "rM   rN   rW    s/      uS&*_-  s rP   c                :     W,          #   \          d    Tu # i ; irR   )r   rp  s   &&&rM   r   rq    s#    	9 	N	s   
 c                    < V ^8  d   QhRS[ /# r   )ra  )rK   rL   s   "rM   rN   rW    s     - - -rP   c                X    \        \        4       P                  ! V P                  !  4      # rR   )lenr.  unionrZ  rT   s   &rM   __len__ChainMapProxy.__len__  s    35;;

+,,rP   c                V   < V ^8  d   QhRS[ S[S[S[S[,          3,          ,          /# r   )r   r   rf   r4  r   )rK   rL   s   "rM   rN   rW    s'      (5fSk)9#:; rP   c                v    / p\        V P                  4       F  pVP                  V4       K  	  \        V4      # rR   )reversedrZ  updateiter)rU   drl  s   &  rM   __iter__ChainMapProxy.__iter__  s1    02

+GHHW , AwrP   c                &   < V ^8  d   QhRS[ RS[/# ra  rF  )rK   rL   s   "rM   rN   rW    s     1 1 14 1rP   c                   a \         ;QJ d)    V3R  lV P                   4       F  '       g   K   R# 	  R# ! V3R  lV P                   4       4      # )c              3   .   <"   T F
  pSV9   x  K  	  R # 5irR   rS   )r<  mr   s   & rM   r>  -ChainMapProxy.__contains__.<locals>.<genexpr>  s     0Z3!8Zs   TFanyrZ  rc  s   &frM   __contains__ChainMapProxy.__contains__  s4    s0TZZ0ss0s0s0TZZ000rP   c                    < V ^8  d   QhRS[ /# r   )r7  )rK   rL   s   "rM   rN   rW    s      $ rP   c                ,    \        V P                  4      # rR   r  rT   s   &rM   __bool__ChainMapProxy.__bool__  s    4::rP   c                    < V ^8  d   QhRS[ /# r   re   )rK   rL   s   "rM   rN   rW    s     + +# +rP   c                `    R P                  \        \        V P                  4      4      pRV R2# )z, zChainMapProxy(r5   )r;  maprO  rZ  )rU   r&  s   & rM   rQ  ChainMapProxy.__repr__  s*    ))Cdjj12y**rP   )rZ  r+  rR   )rX   rY   rZ   r[   r  r  r^  r   rd  r   r|  r  r  r  rQ  r\   r]   r^   s   @rM   r*   r*   g  s     I! !
 
 5 5/ /  E ELL L;; ; - - 1 1 + +rP   z[!\x23-\x7E\x80-\xff]+z(W/)?"(z)"z)(?:\s*,\s*|$)|(.)r   c                   0   a  ] tR tRt o RtV 3R ltRtV tR# )r+   i  Fc                2   < V ^8  d   Qh/ S[ ;R&   S[;R&   # )rI   r   is_weakr6  )rK   rL   s   "rM   rN   ETag.__annotate__  s     J   rP   rS   N)rX   rY   rZ   r[   r  r   r\   r]   r^   s   @rM   r+   r+     s      G  rP   c                (    V ^8  d   QhR\         RR/# )rI   r   rJ   Nre   )rK   s   "rM   rN   rN     s     
 
s 
t 
rP   c                 v    V \         8w  d.   \        P                  V 4      '       g   \        R V : R24      hR# R# )zValue z, is not a valid etag. Maybe it contains '"'?N)ETAG_ANY	_ETAGC_RE	fullmatchri   )r   s   &rM   validate_etag_valuer    s<    !4!4U!;!;UIJK
 	
 "<rP   c                p    V ^8  d   QhR\         \        ,          R\         \        P                  ,          /# )rI   date_strrJ   )r   rf   datetime)rK   s   "rM   rN   rN     s)      hsm 9J9J0K rP   c                   V eg   \        V 4      pVeX   \        \        4      ;_uu_ 4        \        P                  ! VR,          R\        P                  P
                  / uuRRR4       # R#   + '       g   i     R# ; i)z/Process a date string, return a datetime objectN:N   Ntzinfo)r   r   ri   r  timezoneutc)r  	timetuples   & rM   parse_http_dater    s]    h'	 *%%(()B-V@Q@Q@U@UV &% &%s   5A--A>	c                <    V ^8  d   QhR\         R\        R\        /# rI   methodcoderJ   rf   ra  r7  )rK   s   "rM   rN   rN     s!      s # $ rP   c                    V\         9   ;'       gC    V \        9   ;'       g2    ^Tu;8*  ;'       d    R8  Mu ;'       d    V \        P                  9   # )z-Check if a request must return an empty body.,  )EMPTY_BODY_STATUS_CODESEMPTY_BODY_METHODSr'   METH_CONNECT_ALLr  r  s   &&rM   must_be_empty_bodyr    sV     	'' 	C 	C''	C 	C4#AA&D,A,A"ArP   c                <    V ^8  d   QhR\         R\        R\        /# r  r  )rK   s   "rM   rN   rN     s!     	 	 	C 	D 	rP   c                    V\         9   ;'       g2    ^Tu;8*  ;'       d    R8  Mu ;'       d    V \        P                  9   # )zjCheck if a Content-Length header should be removed.

This should always be a subset of must_be_empty_body
r  )r  r'   r  r  s   &&rM   should_remove_content_lengthr    s?     **  tc==f(=(==rP   c                V    V ^8  d   Qh/ ^ \         9   d   \        \        ,          ;R&   # )rI   rc  )__conditional_annotations__r   ra  )rK   s   "rM   rN   rN      s       R / .(3- .S rP   r  )r)   r*   r+   reify)r  
   )rb   rc   rd   rR   )Tzutf-8r  )r  r   r  rx   r|   r   r  enum	functoolsr9  r   r   platformrer  rb  r  collectionsr   r   email.messager   email.parserr   email.policyr   email.utilsr   mathr	   pathlibr
   typesr   r   typingr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   urllib.parser   urllib.requestr    r!   attr	multidictr"   r#   r$   propcache.apir%   r  yarlr&   r   r'   logr(   r  r  __all__systemIS_MACOSr   PY_310PY_311r.   r/   Enumr0   r1   r7  r   r   NO_EXTENSIONSr  ranger  METH_HEAD_ALLr  flagsdev_modeignore_environmentDEBUGchrCHARCTL
SEPARATORSr@  rG   r)   r   r   sr   r   r   r   r   	lru_cacher   r  r  r#  compiler/  r-  r1  rF  rK  rc  re  rq  rx  r  r  r  r  r  r  r  r  r  r   r  r/  r"  r)  total_orderingr4  rf   r*   _ETAGCr  _QUOTED_ETAGQUOTED_ETAG_RELIST_QUOTED_ETAG_REr  r+   r  r  r  r  rN   )ir  s   0@rM   <module>r     s             	  	 
   "  & %  !   1    (  3  = = 8   w#
9??(__)+
			W	$			W	$ T]T]IIk:.	RZZ^^$;<= $S#$@c3$@A  '' 		 	 			$$$SSbjjnn=Q.R)S 
 a&1A&Q|$|!s1v|$H(  F'
* 	s
Z 
<J
;(IJ <J~N(V T$d3$ $ 4$
):47 T$d3& & 4& R $ !$N 2 R 8 !8 zz67!$-.-qCF-.$7
B0f
: +/  . %&P  
"	1  1 h?~&89 ?   >## >#B*,G ,G^
    -. +8WR[ +8 +8\<+GE#vc{"23S89 <+@ 
#JJv	&$L)jjAl^3E!FG  T$d3  4

  	m '$|	 /s   T 7T,T
