+
    Di                        ^ RI Ht ^ RIt^ RIHtHt ^ RIHt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 ^ RIHt  ! R R4      t ! R R4      tR# )    )annotationsN)Callable	Generator)AnyLiteral)status)is_async_callable)run_in_threadpool)HTTPException)Request)PlainTextResponseResponse)MessageReceiveScopeSend)	WebSocketc                  F    ] tR t^tR R ltR R ltR R ltR R ltR	tR
# )HTTPEndpointc               (    V ^8  d   QhRRRRRRRR/# 	   scoper   receiver   sendr   returnNone )formats   "q/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/starlette/endpoints.py__annotate__HTTPEndpoint.__annotate__   s(     	
 	
e 	
g 	
T 	
d 	
    c                	    VR ,          R8X  g   Q hWn         W n        W0n        R Uu. uF#  p\        WP	                  4       R4      f   K!  VNK%  	  upV n        R# u upi )typehttpN)GETHEADPOSTPUTPATCHDELETEOPTIONS)r   r   r   getattrlower_allowed_methods)selfr   r   r   methods   &&&& r    __init__HTTPEndpoint.__init__   s]    V}&&&
	 W!
Vt\\^T2 FV!
 !
s   A
Ac                   V ^8  d   QhRR/# r   r   zGenerator[Any, None, None]r   )r   s   "r    r!   r"           + +5 +r#   c                	>    V P                  4       P                  4       # Ndispatch	__await__r1   s   &r    r<   HTTPEndpoint.__await__       }}((**r#   c                   V ^8  d   QhRR/# r   r   r   r   )r   s   "r    r!   r"       s     
< 
< 
<r#   c                	  "   \        V P                  V P                  R 7      pVP                  R8X  d   \	        V R4      '       g   RMVP                  P                  4       p\        WV P                  4      p\        V4      pV'       d   V! V4      G Rj  xL
 pM\        W14      G Rj  xL
 pV! V P                  V P                  V P                  4      G Rj  xL
  R#  LJ L8 L
5i))r   r(   headgetN)r   r   r   r2   hasattrr/   r.   method_not_allowedr	   r
   r   )r1   requesthandler_namehandleris_asyncresponses   &     r    r;   HTTPEndpoint.dispatch    s     $**dll; '& 8vAVAVu\c\j\j\p\p\r,3DH_H_,`$W-$W--H.w@@Htzz4<<;;; .@;s6   BC(C"C(+C$,/C(C&C($C(&C(c                    V ^8  d   QhRRRR/# )r   rG   r   r   r   r   )r   s   "r    r!   r"   ,   s     Y Y YH Yr#   c                	   "   R RP                  V P                  4      /pRV P                  9   d   \        RVR7      h\	        RRVR7      # 5i)Allowz, appi  )status_codeheaderszMethod Not Allowed)joinr0   r   r   r   )r1   rG   rR   s   && r    rF   HTTPEndpoint.method_not_allowed,   sJ      DIId&;&;<=DJJCAA !53PWXXs   A
A)r0   r   r   r   N)	__name__
__module____qualname____firstlineno__r3   r<   r;   rF   __static_attributes__r   r#   r    r   r      s    	
+
<Y Yr#   r   c                  z    ] tR t^6t$ RtR]R&   R R ltR R ltR R	 ltR
 R lt	R R lt
R R ltR R ltRtR# )WebSocketEndpointNz'Literal['text', 'bytes', 'json'] | Noneencodingc               (    V ^8  d   QhRRRRRRRR/# r   r   )r   s   "r    r!   WebSocketEndpoint.__annotate__9   s(      e g T d r#   c                	J    VR ,          R8X  g   Q hWn         W n        W0n        R# )r%   	websocketN)r   r   r   )r1   r   r   r   s   &&&&r    r3   WebSocketEndpoint.__init__9   s#    V}+++
	r#   c                   V ^8  d   QhRR/# r6   r   )r   s   "r    r!   r^   ?   r7   r#   c                	>    V P                  4       P                  4       # r9   r:   r=   s   &r    r<   WebSocketEndpoint.__await__?   r?   r#   c                   V ^8  d   QhRR/# rA   r   )r   s   "r    r!   r^   B   s     < < <r#   c                	  "   \        V P                  V P                  V P                  R 7      pV P	                  V4      G Rj  xL
  \
        P                  p  VP                  4       G Rj  xL
 pVR,          R8X  d5   V P                  W4      G Rj  xL
 pV P                  W4      G Rj  xL
  K[  VR,          R8X  g   Kk  \        VP                  R4      ;'       g    \
        P                  4      p T P                  Y4      G Rj  xL
  R#  L L L Lj  \         d   p\
        P                  pThRp?ii ; i L3  T P                  Y4      G Rj  xL 
  i ; i5i))r   r   Nr%   zwebsocket.receivezwebsocket.disconnectcode)r   r   r   r   
on_connectr   WS_1000_NORMAL_CLOSUREdecode
on_receiveintrD   	ExceptionWS_1011_INTERNAL_ERRORon_disconnect)r1   r`   
close_codemessagedataexcs   &     r    r;   WebSocketEndpoint.dispatchB   s    djj$,,TYYO	ooi(((22
	< ) 1 1 336?&99!%Y!@@D//):::V_(>>!$W[[%8%Y%YF<Y<Y!ZJ
 $$Y;;;# 	) 4@:  	66JI	 <$$$Y;;;s   AE DE D -D.&D DD -D.D D !D 6E 7E D?E D D D D<%D77D<<E ?E EEEE c               $    V ^8  d   QhRRRRRR/# )r   r`   r   rq   r   r   r   r   )r   s   "r    r!   r^   W   s&     L Li L' Lc Lr#   c                	b  "   V P                   R 8X  dD   R V9  d4   VP                  \        P                  R7      G Rj  xL
  \	        R4      hVR ,          # V P                   R8X  dD   RV9  d4   VP                  \        P                  R7      G Rj  xL
  \	        R4      hVR,          # V P                   R8X  dM   VP                  R 4      e   VR ,          pMVR,          P                  R4      p \        P                  ! V4      # V P                   e   Q R	V P                    24       hVP                  R 4      '       d
   VR ,          # VR,          #  EL L  \        P                  P                   d6    TP                  \        P                  R7      G Rj  xL 
  \	        R4      hi ; i5i)
text)rg   Nz/Expected text websocket messages, but got bytesbytesz/Expected bytes websocket messages, but got textjsonzutf-8zMalformed JSON data received.z!Unsupported 'encoding' attribute )r\   closer   WS_1003_UNSUPPORTED_DATARuntimeErrorrD   rj   ry   loadsdecoderJSONDecodeError)r1   r`   rq   rw   s   &&& r    rj   WebSocketEndpoint.decodeW   so    ==F"W$oo6+J+JoKKK"#TUU6?"]]g%g%oo6+J+JoKKK"#TUU7##]]f${{6".vw'..w7Dzz$''
 }}$Y(I$--&YY$")++f"5"5wvK77;KK/ L L <<// Doo6+J+JoKKK"#BCCDsN   <F/EAF/EAF/2E 9F/F/F/AF,FF,,F/c                    V ^8  d   QhRRRR/# )r   r`   r   r   r   r   )r   s   "r    r!   r^   s   s     ! !) ! !r#   c                B   "   VP                  4       G Rj  xL
  R#  L5i)z3Override to handle an incoming websocket connectionN)accept)r1   r`   s   &&r    rh   WebSocketEndpoint.on_connects   s        s   c               $    V ^8  d   QhRRRRRR/# )r   r`   r   rr   r   r   r   r   )r   s   "r    r!   r^   w   s!     ? ?) ?3 ?4 ?r#   c                   "   R# 5i)z0Override to handle an incoming websocket messageNr   )r1   r`   rr   s   &&&r    rk   WebSocketEndpoint.on_receivew           c               $    V ^8  d   QhRRRRRR/# )r   r`   r   rp   rl   r   r   r   )r   s   "r    r!   r^   z   s!     ; ;Y ;C ;D ;r#   c                   "   R# 5i)z,Override to handle a disconnecting websocketNr   )r1   r`   rp   s   &&&r    ro   WebSocketEndpoint.on_disconnectz   r   r   )r   r   r   )rU   rV   rW   rX   r\   __annotations__r3   r<   r;   rj   rh   rk   ro   rY   r   r#   r    r[   r[   6   s6    8<H5<+<*L8!?; ;r#   r[   )
__future__r   ry   collections.abcr   r   typingr   r   	starletter   starlette._utilsr	   starlette.concurrencyr
   starlette.exceptionsr   starlette.requestsr   starlette.responsesr   r   starlette.typesr   r   r   r   starlette.websocketsr   r   r[   r   r#   r    <module>r      sE    "  /   . 3 . & ; 9 9 *"Y "YJE; E;r#   