+
    Di.                    h   ^ RI Ht ^ RIt^ RIt^ RIHtHtHt ^ RIH	t
 ^ RIHtHtHtHtHt ^ RIt^ RIHtHt ^ RIHtHtHtHtHtHt ^ RIHt ^ R	IHtH t H!t! ^ R
I"H#t#H$t$H%t%H&t& ]'       d   ^ RI'H(t( ^ RI)H*t* ^ RI+H,t, M  ^ RI'H(t( ]P^                  R8  d   ^ RIH0t0 M^ RI1H0t0 0 Rmt2R R lt3 ! R R]44      t5]0! R]]6]3,          ],          ]R7      t7 ! R R]]6]3,          ]]7,          4      t8R R lt9R R lt: ! R R]8]7,          4      t;R#   ]- d
    ^ RI.H(t(  Li ; i  ]- d    Rt( Li ; i)    )annotationsN)AsyncGeneratorIteratorMapping)cookies)TYPE_CHECKINGAnyGenericNoReturncast)AwaitableOrContextManager AwaitableOrContextManagerWrapper)URLAddressFormDataHeadersQueryParamsState)HTTPException)
FormParserMultiPartExceptionMultiPartParser)MessageReceiveScopeSend)parse_options_header)	Starlette)Router)TypeVarc                    V ^8  d   QhRRRR/# )   cookie_stringstrreturndict[str, str] )formats   "p/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/starlette/requests.py__annotate__r*   -   s            c                
   / pV P                  R4       Fk  pRV9   d   VP                  R^4      w  r4MRTrCVP                  4       VP                  4       rCV'       g   V'       g   KS  \        P                  ! V4      W&   Km  	  V# )a  
This function parses a ``Cookie`` HTTP header into a dict of key/value pairs.

It attempts to mimic browser cookie parsing behavior: browsers and web servers
frequently disregard the spec (RFC 6265) when setting and reading cookies,
so we attempt to suit the common scenarios here.

This function has been adapted from Django 3.1.0.
Note: we are explicitly _NOT_ using `SimpleCookie.load` because it is based
on an outdated spec and will fail on lots of input we want to support
;= )splitstriphttp_cookies_unquote)r#   cookie_dictchunkkeyvals   &    r)   cookie_parserr8   -   sw     #%K$$S)%<{{3*HC 599;		S##+44S9K * r+   c                      ] tR t^HtRtR# )ClientDisconnectr'   N)__name__
__module____qualname____firstlineno____static_attributes__r'   r+   r)   r:   r:   H   s    r+   r:   StateT)bounddefaultc                     ] tR t^OtRtR&R R lltR R ltR R ltR	 R
 lt]	P                  t
]	P                  t]R R l4       t]R R l4       t]R R l4       t]R R l4       t]R R l4       t]R R l4       t]R R l4       t]R R l4       t]R R l4       t]R R l4       t]R R  l4       t]R! R" l4       tR# R$ ltR%tR# )'HTTPConnectionz
A base class for incoming HTTP connections, that is used to provide
any functionality that is common to both `Request` and `WebSocket`.
Nc               $    V ^8  d   QhRRRRRR/# )r"   scoper   receivezReceive | Noner%   Noner'   )r(   s   "r)   r*   HTTPConnection.__annotate__U   s!      e n  r+   c                	2    VR ,          R9   g   Q hWn         R# )typeN)http	websocketrF   )selfrF   rG   s   &&&r)   __init__HTTPConnection.__init__U   s    V} 5555
r+   c                    V ^8  d   QhRRRR/# )r"   r6   r$   r%   r	   r'   )r(   s   "r)   r*   rI   Y   s      s s r+   c                	(    V P                   V,          # NrN   )rO   r6   s   &&r)   __getitem__HTTPConnection.__getitem__Y   s    zz#r+   c                   V ^8  d   QhRR/# )r"   r%   zIterator[str]r'   )r(   s   "r)   r*   rI   \   s        -  r+   c                	,    \        V P                  4      # rT   )iterrF   rO   s   &r)   __iter__HTTPConnection.__iter__\   s    DJJr+   c                   V ^8  d   QhRR/# )r"   r%   intr'   )r(   s   "r)   r*   rI   _   s       r+   c                	,    \        V P                  4      # rT   )lenrF   rZ   s   &r)   __len__HTTPConnection.__len___   s    4::r+   c                   V ^8  d   QhRR/# r"   r%   r	   r'   )r(   s   "r)   r*   rI   i   s     ! !S !r+   c                	(    V P                   R ,          # )apprN   rZ   s   &r)   rf   HTTPConnection.apph   s    zz%  r+   c                   V ^8  d   QhRR/# r"   r%   r   r'   )r(   s   "r)   r*   rI   m   s      S r+   c                	t    \        V R 4      '       g   \        V P                  R7      V n        V P                  # )_urlrN   )hasattrr   rF   rk   rZ   s   &r)   urlHTTPConnection.urll   s)    tV$$$**-DIyyr+   c                   V ^8  d   QhRR/# ri   r'   )r(   s   "r)   r*   rI   s   s      # r+   c                	,   \        V R 4      '       gx   \        V P                  4      pVP                  RVP                  RR4      4      pTpVP	                  R4      '       g
   VR,          pW1R&   RVR&   W!R&   \        VR7      V n        V P                  # )		_base_urlapp_root_path	root_pathr/   /pathr+   query_stringrN   )rl   dictrF   getendswithr   rq   )rO   base_url_scoperr   ru   s   &   r)   base_urlHTTPConnection.base_urlr   s    t[))!$**-N +..@R@RS^`b@cdM D==%%%)6"-0N>**7;' ~6DN~~r+   c                   V ^8  d   QhRR/# )r"   r%   r   r'   )r(   s   "r)   r*   rI      s       r+   c                	t    \        V R 4      '       g   \        V P                  R7      V n        V P                  # )_headersrN   )rl   r   rF   r   rZ   s   &r)   headersHTTPConnection.headers   s)    tZ((#$**5DM}}r+   c                   V ^8  d   QhRR/# )r"   r%   r   r'   )r(   s   "r)   r*   rI      s     " "k "r+   c                	    \        V R 4      '       g"   \        V P                  R,          4      V n        V P                  # )_query_paramsrv   )rl   r   rF   r   rZ   s   &r)   query_paramsHTTPConnection.query_params   s1    t_--!,TZZ-G!HD!!!r+   c                   V ^8  d   QhRR/# r"   r%   zdict[str, Any]r'   )r(   s   "r)   r*   rI      s     1 1^ 1r+   c                	:    V P                   P                  R / 4      # )path_params)rF   rx   rZ   s   &r)   r   HTTPConnection.path_params   s    zz~~mR00r+   c                   V ^8  d   QhRR/# )r"   r%   r&   r'   )r(   s   "r)   r*   rI      s     	 	 	r+   c                	    \        V R 4      '       gG   / pV P                  P                  R4      pV F  pVP                  \	        V4      4       K  	  Wn        V P
                  # )_cookiescookie)rl   r   getlistupdater8   r   )rO   r   cookie_headersheaders   &   r)   r   HTTPConnection.cookies   sT    tZ((&(G!\\11(;N(}V45 ) $M}}r+   c                   V ^8  d   QhRR/# )r"   r%   zAddress | Noner'   )r(   s   "r)   r*   rI      s       r+   c                	V    V P                   P                  R 4      pVe
   \        V!  # R# )clientN)rF   rx   r   )rO   	host_ports   & r)   r   HTTPConnection.client   s*     JJNN8,	 I&&r+   c                   V ^8  d   QhRR/# r   r'   )r(   s   "r)   r*   rI      s     % % %r+   c                	X    R V P                   9   g   Q R4       hV P                   R ,          # )sessionz=SessionMiddleware must be installed to access request.sessionrN   rZ   s   &r)   r   HTTPConnection.session   s)    DJJ&g(gg&zz)$$r+   c                   V ^8  d   QhRR/# rd   r'   )r(   s   "r)   r*   rI           " "c "r+   c                	X    R V P                   9   g   Q R4       hV P                   R ,          # )authzAAuthenticationMiddleware must be installed to access request.authrN   rZ   s   &r)   r   HTTPConnection.auth   )    #h%hh#zz&!!r+   c                   V ^8  d   QhRR/# rd   r'   )r(   s   "r)   r*   rI      r   r+   c                	X    R V P                   9   g   Q R4       hV P                   R ,          # )userzAAuthenticationMiddleware must be installed to access request.userrN   rZ   s   &r)   r   HTTPConnection.user   r   r+   c                   V ^8  d   QhRR/# )r"   r%   r@   r'   )r(   s   "r)   r*   rI      s     ) )v )r+   c                	    \        V R 4      '       g>   V P                  P                  R/ 4       \        V P                  R,          4      V n        \        \        V P                  4      # )_statestate)rl   rF   
setdefaultr   r   r   r@   rZ   s   &r)   r   HTTPConnection.state   sK    tX&&JJ!!'2.  

7 34DKFDKK((r+   c               $    V ^8  d   QhRRRRRR/# )r"   namer$   r   r	   r%   r   r'   )r(   s   "r)   r*   rI      s&     B BC B3 B3 Br+   c               	    V P                   P                  R 4      ;'       g    V P                   P                  R4      pVf   \        R4      hVP                  ! V3/ VB pVP	                  V P
                  R7      # )routerrf   zVThe `url_for` method can only be used inside a Starlette application or with a router.)r{   )rF   rx   RuntimeErrorurl_path_formake_absolute_urlr{   )rO   r   r   url_path_providerurl_paths   "",  r)   url_forHTTPConnection.url_for   so    7;zz~~h7O7h7hSWS]S]SaSabgSh$wxx$11$F+F))4==)AAr+   )rq   r   r   r   r   rk   rF   rT   )r;   r<   r=   r>   __doc__rP   rU   r[   ra   object__eq____hash__propertyrf   rm   r{   r   r   r   r   r   r   r   r   r   r   r?   r'   r+   r)   rD   rD   O   s)   
  ]]FH! !  
     
 " "
 1 1 	 	   % % " " " " ) )B Br+   rD   c                   V ^8  d   QhRR/# )r"   r%   r   r'   )r(   s   "r)   r*   r*      s     F FX Fr+   c                     "   \        R 4      h5i)z+Receive channel has not been made availabler   r'   r+   r)   empty_receiver      s     
D
EE   c                    V ^8  d   QhRRRR/# )r"   messager   r%   r   r'   )r(   s   "r)   r*   r*      s     C Cg C( Cr+   c                    "   \        R 4      h5i)z(Send channel has not been made availabler   )r   s   &r)   
empty_sendr      s     
A
BBr   c                     a  ] tR t^t$ R]R&   ]]3R V 3R lllt]R R l4       t	]R R l4       t
R	 R
 ltR R ltR R ltRRRRRR/R R lltRRRRRR/R R lltR R ltR R ltR R ltRtV ;t# )RequestzFormData | None_formc               $    V ^8  d   QhRRRRRR/# )r"   rF   r   rG   r   sendr   r'   )r(   s   "r)   r*   Request.__annotate__   s!      e g T r+   c                	   < \         SV `  V4       VR ,          R8X  g   Q hW n        W0n        RV n        RV n        RV n        R# )rK   rL   FN)superrP   _receive_send_stream_consumed_is_disconnectedr   )rO   rF   rG   r   	__class__s   &&&&r)   rP   Request.__init__   sC    V}&&&
 % %
r+   c                   V ^8  d   QhRR/# )r"   r%   r$   r'   )r(   s   "r)   r*   r      s     / / /r+   c                	D    \        \        V P                  R ,          4      # )method)r   r$   rF   rZ   s   &r)   r   Request.method   s    CH-..r+   c                   V ^8  d   QhRR/# )r"   r%   r   r'   )r(   s   "r)   r*   r      s       r+   c                	    V P                   # rT   )r   rZ   s   &r)   rG   Request.receive   s    }}r+   c                   V ^8  d   QhRR/# )r"   r%   zAsyncGenerator[bytes, None]r'   )r(   s   "r)   r*   r      s      9 r+   c               	  "   \        V R 4      '       d   V P                  5x  R5x  R# V P                  '       d   \        R4      hV P                  '       g   V P	                  4       G Rj  xL
 pVR,          R8X  dC   VP                  RR4      pVP                  RR4      '       g   R	V n        V'       d   V5x  Kx  Kz  VR,          R
8X  g   K  R	V n        \        4       hR5x  R#  L|5i)_bodyr+   NzStream consumedrK   zhttp.requestbody	more_bodyFThttp.disconnect)rl   r   r   r   r   rx   r   r:   )rO   r   r   s   &  r)   streamRequest.stream   s     4!!**I   011''' MMO+Gv.0{{63/{{;66,0D)J $55(,%&((	 ,s.   :C,C,C,-C*.;C,*C,9C,C,c                   V ^8  d   QhRR/# )r"   r%   bytesr'   )r(   s   "r)   r*   r      s      E r+   c                	   "   \        V R 4      '       g0   . pV P                  4         Rj  xL
  pVP                  V4       K  V P                  #  L$D%RP                  T4      T n        L&5i)r   Nr+   )rl   r   appendjoinr   )rO   chunksr5   s   &  r)   r   Request.body   sY     tW%%"$F#{{} % %ee$zz%}&)DJs%   %A*AAA!A*AA*c                   V ^8  d   QhRR/# rd   r'   )r(   s   "r)   r*   r      s      C r+   c                	   "   \        V R 4      '       g4   V P                  4       G Rj  xL
 p\        P                  ! V4      V n        V P                  #  L+5i)_jsonN)rl   r   jsonloadsr   )rO   r   s   & r)   r   Request.json   s?     tW%%$DD)DJzz %s   &AA,A	max_filesi  
max_fieldsmax_part_sizec               (    V ^8  d   QhRRRRRRRR/# )r"   r   int | floatr   r   r^   r%   r   r'   )r(   s   "r)   r*   r     s4     ! ! !  	!
 ! 
!r+   c               	  "   V P                   f   \        f   Q R4       hV P                  P                  R4      p\        V4      w  rVVR8X  dS    \	        V P                  V P                  4       VVVR7      pVP                  4       G R j  xL
 V n         V P                   # VR8X  dN   \        V P                  V P                  4       4      p	V	P                  4       G R j  xL
 V n         V P                   # \        4       V n         V P                   #  L  \         d0   pRT P                  9   d   \        RTP                  R7      hThR p?ii ; i Lo5i)	NzEThe `python-multipart` library must be installed to use form parsing.zContent-Types   multipart/form-datar   r   r   rf   i  )status_codedetails!   application/x-www-form-urlencoded)r   r   r   rx   r   r   parser   rF   r   r   r   r   )
rO   r   r   r   content_type_headercontent_type_multipart_parserexcform_parsers
   &$$$      r)   	_get_formRequest._get_form  s0     ::'3 W3 #',,"2"2>"B23FGOL55'6"+#-&3($ (8'='='?!?DJ zz !EE(t{{}E#.#4#4#66
 zz &Z
zz "@) 

*+CKKPPI 7sI   AE;D D	D A
EE 0ED E*EEEc               (    V ^8  d   QhRRRRRRRR/# )r"   r   r   r   r   r^   r%   z#AwaitableOrContextManager[FormData]r'   )r(   s   "r)   r*   r   )  s4     	
 	
 	
  		

 	
 
-	
r+   c               	:    \        V P                  WVR 7      4      # )r   )r   r  )rO   r   r   r   s   &$$$r)   formRequest.form)  s"     0NNYUbNc
 	
r+   c                   V ^8  d   QhRR/# )r"   r%   rH   r'   )r(   s   "r)   r*   r   4  s     % %T %r+   c                	v   "   V P                   e%   V P                   P                  4       G R j  xL
  R # R #  L5irT   )r   closerZ   s   &r)   r	  Request.close4  s-     ::!**""$$$ "$s   ,97	9c                   V ^8  d   QhRR/# )r"   r%   boolr'   )r(   s   "r)   r*   r   8  s     % %t %r+   c                	J  "   V P                   '       gn   / p\        P                  ! 4       ;_uu_ 4       pVP                  4        V P	                  4       G R j  xL
 pR R R 4       VP                  R4      R8X  d   RV n         V P                   #  L5  + '       g   i     L;; i5i)NrK   r   T)r   anyioCancelScopecancelr   rx   )rO   r   css   &  r)   is_disconnectedRequest.is_disconnected8  sz     $$$!G ""$$		 $/ % {{6"&77(,%$$$ 0 %$s.   2B#$BBB1B#BB 	B#c                    V ^8  d   QhRRRR/# )r"   ru   r$   r%   rH   r'   )r(   s   "r)   r*   r   F  s     c cC cD cr+   c                	Z  "   R V P                   P                  R/ 4      9   d   . p\         FV  pV P                  P	                  V4       F4  pVP                  VP                  R4      VP                  R4      34       K6  	  KX  	  V P                  RR RVRV/4      G Rj  xL
  R# R#  L5i)zhttp.response.push
extensionszlatin-1rK   ru   r   N)rF   rx   SERVER_PUSH_HEADERS_TO_COPYr   r   r   encoder   )rO   ru   raw_headersr   values   &&   r)   send_push_promiseRequest.send_push_promiseF  s     4::>>,#CC57K3!\\11$7E&&I(>Y@W'XY 8 4 **f&:FD)U`abbb D
 cs   BB+ B)!	B+)r   r   r   r   r   r   r   i   )r;   r<   r=   r>   __annotations__r   r   rP   r   r   rG   r   r   r   r  r  r	  r  r  r?   __classcell__)r   s   @r)   r   r      s    8ET^   / /  (! "&! #'	!
 )!F	
 "&	
 #'		

 )	
%%c cr+   r   )      >   accept
user-agentcache-controlaccept-encodingaccept-language)<
__future__r   r   syscollections.abcr   r   r   rL   r   r2   typingr   r	   r
   r   r   r  starlette._utilsr   r   starlette.datastructuresr   r   r   r   r   r   starlette.exceptionsr   starlette.formparsersr   r   r   starlette.typesr   r   r   r   python_multipart.multipartr   starlette.applicationsr   starlette.routingr   ModuleNotFoundErrormultipart.multipartversion_infor    typing_extensionsr  r8   	Exceptionr:   r$   r@   rD   r   r   r   r'   r+   r)   <module>r7     s   "  
 = = ( > >  X X X . Q Q 9 9?0($	AG w) 6	y 	 
c!2U!:E	JvBWS#X& vBrFC|cnV$ |cm # 	A@	A $#$s*   D D"D% !D""D% %	D10D1