+
    Di                        ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIHtHt ^ RI	H
t
 ^ RIt^ RIHtHt ^ RIHtHtHt ]P&                  ! R]^R7       R	 R
 lt ! R R4      t ! R R4      tR# )    )annotationsN)CallableMutableMapping)Any)ObjectReceiveStreamObjectSendStream)ReceiveScopeSendzstarlette.middleware.wsgi is deprecated and will be removed in a future release. Please refer to https://github.com/abersheeran/a2wsgi as a replacement.)
stacklevelc               $    V ^8  d   QhRRRRRR/# )   scoper
   bodybytesreturndict[str, Any] )formats   "w/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/starlette/middleware/wsgi.py__annotate__r      s!     1 1 1e 1 1    c                   V P                  RR4      P                  R4      P                  R4      pV R,          P                  R4      P                  R4      pVP                  V4      '       d   V\	        V4      R pRV R,          R	VR
VRV R,          P                  R4      RRV R,           2RR*RV P                  RR4      R\
        P                  ! V4      R\        P                  RRRRRR/pV P                  R4      ;'       g    R+pV^ ,          VR&   V^,          VR&   V P                  R4      '       d   V R,          ^ ,          VR &   V P                  R!. 4       F~  w  rgVP                  R4      pVR"8X  d   R#pM-VR$8X  d   R%pM#R&V 2P                  4       P                  R'R(4      pVP                  R4      pW9   d   WH,          R),           V,           pWtV&   K  	  V# ),z=
Builds a scope and request body into a WSGI environ object.
	root_path utf8latin1pathNREQUEST_METHODmethodSCRIPT_NAME	PATH_INFOQUERY_STRINGquery_stringasciiSERVER_PROTOCOLzHTTP/http_versionzwsgi.versionzwsgi.url_schemeschemehttpz
wsgi.inputzwsgi.errorszwsgi.multithreadTzwsgi.multiprocesszwsgi.run_onceFserverSERVER_NAMESERVER_PORTclientREMOTE_ADDRheaderszcontent-lengthCONTENT_LENGTHzcontent-typeCONTENT_TYPEHTTP_-_,)   r   )	localhostP   )getencodedecode
startswithlenioBytesIOsysstdoutupperreplace)	r   r   script_name	path_infoenvironr*   namevaluecorrected_names	   &&       r   build_environrJ      s   
 ))K,33F;BB8LKf$$V,33H=IK((c+.01	 	%/{Yn-44W=U5#8"9:599Xv6bjj&szzDTG  YYx 55$5F#AYGM#AYGM yy!&x!3 yyB/{{8$##-N^#+N$TF^113;;CEN X&$+c1E9E"' 0 Nr   c                  .    ] tR t^KtR R ltR R ltRtR# )WSGIMiddlewarec                    V ^8  d   QhRRRR/# )r   appCallable[..., Any]r   Noner   )r   s   "r   r   WSGIMiddleware.__annotate__L   s      . 4 r   c                	    Wn         R # NrN   )selfrN   s   &&r   __init__WSGIMiddleware.__init__L   s    r   c               (    V ^8  d   QhRRRRRRRR/# )	r   r   r
   receiver	   sendr   r   rP   r   )r   s   "r   r   rQ   O   s(     ' 'E 'G '4 'D 'r   c                	~   "   VR ,          R8X  g   Q h\        V P                  V4      pV! W#4      G Rj  xL
  R#  L5i)typer)   N)WSGIResponderrN   )rU   r   rY   rZ   	responders   &&&& r   __call__WSGIMiddleware.__call__O   s5     V}&&&!$((E2	&&&s   2=;=rT   N)__name__
__module____qualname____firstlineno__rV   r_   __static_attributes__r   r   r   rL   rL   K   s    ' 'r   rL   c                  l    ] tR t^Ut$ R]R&   R]R&   R R ltR R ltR	 R
 ltRR R lltR R lt	Rt
R# )r]   z*ObjectSendStream[MutableMapping[str, Any]]stream_sendz-ObjectReceiveStream[MutableMapping[str, Any]]stream_receivec               $    V ^8  d   QhRRRRRR/# )r   rN   rO   r   r
   r   rP   r   )r   s   "r   r   WSGIResponder.__annotate__Y   s"     " ". "u " "r   c                	    Wn         W n        R V n        R V n        \        P
                  ! \        P                  4      w  V n        V n	        RV n
        R V n        R # )NF)rN   r   statusresponse_headersanyiocreate_memory_object_streammathinfrg   rh   response_startedexc_info)rU   rN   r   s   &&&r   rV   WSGIResponder.__init__Y   sL    
 $050Q0QRVRZRZ0[-$- %!r   c               $    V ^8  d   QhRRRRRR/# )r   rY   r	   rZ   r   r   rP   r   )r   s   "r   r   rj   b   s&     V Vg VT Vd Vr   c           
     	n  "   R pRpV'       d<   V! 4       G Rj  xL
 pW5P                  RR 4      ,          pVP                  RR4      pKC  \        V P                  V4      p\        P                  ! 4       ;_uu_4       GRj  xL
 pVP                  V P                  V4       V P                  ;_uu_4       GRj  xL
  \        P                  P                  V P                  W`P                  4      G Rj  xL
  RRR4      GRj  xL
  RRR4      GRj  xL
  V P                  eF   V P                  ^ ,          P                  V P                  ^,          V P                  ^,          4      hR#  ELW L L L Lr  + GRj  xL 
 '       g   i     L; i L  + GRj  xL 
 '       g   i     L; i5i)r   TNr   	more_bodyF)r9   rJ   r   rn   create_task_group
start_soonsenderrg   	to_threadrun_syncwsgistart_responsers   with_traceback)rU   rY   rZ   r   rw   messagerF   
task_groups   &&&     r   r_   WSGIResponder.__call__b   s&    	#IoGKK,,DK7I

D1**,,,
!!$++t4''''oo..tyy'CVCVWWW (' -, ==$--"11$--2BDMMRSDTUU % &
 -'W (''' -,,,s   F5
F5E0A'F5E3F55F:E5;F>8E;	6E77E;	;FE9FF5FAF53F55F7E;	9F;FF
FFFF5F2	F" 
F2	+F2	-F5c                    V ^8  d   QhRRRR/# )r   rZ   r   r   rP   r   )r   s   "r   r   rj   r   s     $ $ $$ $r   c                	  "   V P                   ;_uu_4       GR j  xL
  V P                     R j  xL
  pV! V4      G R j  xL
  K   L, L L
DR R R 4      GR j  xL 
  R #   + GR j  xL 
 '       g   i     R # ; i5irS   )rh   )rU   rZ   r   s   && r   rz   WSGIResponder.senderr   s\     &&&&!%!4!4 $ $g7m## '$# "5 '&&&&&s|   A?AA?A"AA

AA"A
A"A?
AA"A"A?AA?"A<	(A+)
A<	4A<	6	A?Nc               (    V ^8  d   QhRRRRRRRR/# )	r   rl   strrm   zlist[tuple[str, str]]rs   r   r   rP   r   )r   s   "r   r   rj   w   s2       0 	
 
r   c           	     	   W0n         V P                  '       g   R V n        VP                  R^4      w  rE\        V4      pV UUu. uFQ  w  rxVP	                  4       P                  R4      P                  4       VP	                  4       P                  R4      3NKS  	  p	pp\        P                  P                  V P                  P                  RRRVRV	/4       R# R# u uppi )T r%   r\   zhttp.response.startrl   r/   N)rs   rr   splitintstripr:   lowerrn   from_threadrunrg   rZ   )
rU   rl   rm   rs   status_code_stringr4   status_coderG   rH   r/   s
   &&&&      r   r~   WSGIResponder.start_responsew   s     !$$$$(D!$*LLa$8!01K $4#3KD $$W-335u{{}7K7KG7TU#3   !!  %%1kw %s   ACc               $    V ^8  d   QhRRRRRR/# )r   rF   r   r~   rO   r   rP   r   )r   s   "r   r   rj      s-     b bb +b 
	br   c           
     	   V P                  W4       F=  p\        P                  P                  V P                  P
                  R RRVRR/4       K?  	  \        P                  P                  V P                  P
                  R RRR/4       R# )r\   zhttp.response.bodyr   rw   Tr   N)rN   rn   r   r   rg   rZ   )rU   rF   r~   chunks   &&& r   r}   WSGIResponder.wsgi   s{    
 XXg6E!!  %%-vuk4P 7 	d..33f>RTZ\_5`ar   )rN   rs   rm   rr   r   rl   rh   rg   rS   )ra   rb   rc   rd   __annotations__rV   r_   rz   r~   r}   re   r   r   r   r]   r]   U   s/    ;;AA"V $
0b br   r]   )
__future__r   r>   rp   r@   warningscollections.abcr   r   typingr   rn   	anyio.abcr   r   starlette.typesr	   r
   r   warnDeprecationWarningrJ   rL   r]   r   r   r   <module>r      s\    " 	  
  4   ; 0 0 N	1h' 'Eb Ebr   