+
    Di                         ^ RI t ^ RIt^ RIHt ^ RIHtHt ^ RIHtH	t	H
t
HtHt Rt ! R R4      t ! R R4      t ! R	 R
]4      tR R ltR# )    N)NoReturn)HeadersMutableHeaders)ASGIAppMessageReceiveScopeSendc                   H   a  ] tR t^t o RV 3R lR lltV 3R lR ltRtV tR# )GZipMiddlewarec                0   < V ^8  d   QhRS[ RS[RS[RR/#    appminimum_sizecompresslevelreturnNr   int)format__classdict__s   "w/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/starlette/middleware/gzip.py__annotate__GZipMiddleware.__annotate__   s*     + +G +3 +S +Y] +    c                *    Wn         W n        W0n        R # N)r   r   r   )selfr   r   r   s   &&&&r   __init__GZipMiddleware.__init__   s    (*r   c                0   < V ^8  d   QhRS[ RS[RS[RR/# r   scopereceivesendr   Nr	   r   r
   )r   r   s   "r   r   r      s)     . .E .G .4 .D .r   c                l  "   VR ,          R8w  d   V P                  WV4      G Rj  xL
  R# \        VR7      pRVP                  RR4      9   d.   \        V P                   V P                  V P
                  R7      pM \        V P                   V P                  4      pV! WV4      G Rj  xL
  R#  L L5i)typehttpN)r#   gzipAccept-Encoding )r   )r   r   getGZipResponderr   r   IdentityResponder)r   r#   r$   r%   headers	responders   &&&&  r   __call__GZipMiddleware.__call__   s     =F"((54000&W[[!2B77%dhh0A0AQUQcQcdI)$((D4E4EFI--- 1 	.s"   $B4B0BB4)B2*B42B4)r   r   r   N)i  	   )__name__
__module____qualname____firstlineno__r   r2   __static_attributes____classdictcell__r   s   @r   r   r      s     + +
. .r   r   c                   t   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tV 3R lR ltV 3R	 ltR
t	V t
R# )r/   c                *   < V ^8  d   QhRS[ RS[RR/# )r   r   r   r   Nr   )r   r   s   "r   r   IdentityResponder.__annotate__#   s"     . .G .3 .4 .r   c                l    Wn         W n        \        V n        / V n        R V n        R V n        R V n        R# )FN)r   r   unattached_sendr%   initial_messagestartedcontent_encoding_setcontent_type_is_excluded)r   r   r   s   &&&r   r   IdentityResponder.__init__#   s3    ()	(*$)!(-%r   c                0   < V ^8  d   QhRS[ RS[RS[RR/# r"   r&   )r   r   s   "r   r   r>   ,   s/     C CE CG C4 CD Cr   c                f   "   W0n         V P                  WV P                  4      G R j  xL
  R #  L5ir   )r%   r   send_with_compression)r   r#   r$   r%   s   &&&&r   r2   IdentityResponder.__call__,   s$     	hhut'A'ABBBs   &1/1c                $   < V ^8  d   QhRS[ RR/# )r   messager   N)r   )r   r   s   "r   r   r>   0   s     ;% ;%7 ;%t ;%r   c                h  "   VR ,          pVR8X  dZ   Wn         \        V P                   R,          R7      pRV9   V n        VP                  RR4      P	                  \
        4      V n        R	# VR8X  d|   V P                  '       g   V P                  '       dX   V P                  '       g+   RV n        V P                  V P                   4      G R	j  xL
  V P                  V4      G R	j  xL
  R	# VR8X  Ed   V P                  '       Eg   RV n        VP                  R
R4      pVP                  RR4      p\        V4      V P                  8  dG   V'       g?   V P                  V P                   4      G R	j  xL
  V P                  V4      G R	j  xL
  R	# V'       g   V P                  VRR7      p\        V P                   R,          R7      pVP                  R4       WAR
,          8w  d+   V P                  VR&   \        \        V4      4      VR&   WAR
&   V P                  V P                   4      G R	j  xL
  V P                  V4      G R	j  xL
  R	# V P                  VRR7      p\        V P                   R,          R7      pVP                  R4       WAR
,          8w  d   V P                  VR&   VR WAR
&   V P                  V P                   4      G R	j  xL
  V P                  V4      G R	j  xL
  R	# VR8X  dU   VP                  R
R4      pVP                  RR4      pV P                  WER7      VR
&   V P                  V4      G R	j  xL
  R	# VR8X  d?   V P                  V P                   4      G R	j  xL
  V P                  V4      G R	j  xL
  R	# R	#  EL EL EL( EL ELp ELZ L L Lc L9 L"5i)r(   zhttp.response.startr0   )rawzcontent-encodingzcontent-typer,   zhttp.response.bodyTNbodyr   	more_bodyF)rO   r+   zContent-EncodingzContent-Lengthzhttp.response.pathsend)rA   r   rC   r-   
startswithDEFAULT_EXCLUDED_CONTENT_TYPESrD   rB   r%   lenr   apply_compressionr   add_vary_headercontent_encodingstr)r   rK   message_typer0   rN   rO   s   &&    r   rH   'IdentityResponder.send_with_compression0   s    v00 $+ $"6"6y"ABG(:g(ED%,3KK,K,V,VWu,vD)11t7P7P7PTXTqTqTq<<<#ii 4 4555))G$$$11$,,,DL;;vs+DK7I4y4,,,Yii 4 4555ii(((--de-D(T-A-A)-LM''(9:6?*262G2GG./03CIG,-&*FOii 4 4555ii((( --dd-C(T-A-A)-LM''(9:6?*262G2GG./ 01&*FOii 4 4555ii(((11;;vs+DK7I"44T4OGFO))G$$$55))D00111))G$$$ 6Y 6$ 6( 6( 6( % 2$s   BN2N2N2)%N2NN2'N( N2	AN2N24N5N2NN2BN22N"3N2N%BN2N(N2-N*.AN2N,	+N24N.5N2N0	N2N2N2N2"N2%N2(N2*N2,N2.N20N2c                ,   < V ^8  d   QhRS[ RS[RS[ /# r   rN   rO   r   bytesbool)r   r   s   "r   r   r>   m   s"      e 4 E r   c                   V# )zApply compression on the response body.

If more_body is False, any compression file should be closed. If it
isn't, it won't be closed automatically until all background tasks
complete.
 r   rN   rO   s   &&$r   rS   #IdentityResponder.apply_compressionm   s	     r   c                &   < V ^8  d   Qh/ S[ ;R&   # )r   rU   )rV   )r   r   s   "r   r   r>       s      r   )r   rC   rD   rA   r   r%   rB   N)r5   r6   r7   r8   r   r2   rH   rS   __annotate_func__r9   r:   r;   s   @r   r/   r/       s8     . .C C;% ;%z [  r   r/   c                   p   a a ] tR t^wt oRtR	V3R lV 3R llltV3R lV 3R lltV3R lR ltRtVt	V ;t
# )
r.   r*   c                0   < V ^8  d   QhRS[ RS[RS[RR/# r   r   )r   r   s   "r   r   GZipResponder.__annotate__z   s0     i iG i3 is iSW ir   c                   < \         SV `  W4       \        P                  ! 4       V n        \
        P                  ! R V P                  VR7      V n        R# )wb)modefileobjr   N)superr   ioBytesIOgzip_bufferr*   GzipFile	gzip_file)r   r   r   r   	__class__s   &&&&r   r   GZipResponder.__init__z   s9    +::<D$:J:JZghr   c                0   < V ^8  d   QhRS[ RS[RS[RR/# r"   r&   )r   r   s   "r   r   rf      s)     9 9E 9G 94 9D 9r   c           	       <"   V P                   ;_uu_ 4        V P                  ;_uu_ 4        \        SV `  WV4      G R j  xL
  R R R 4       R R R 4       R #  L  + '       g   i     L; i  + '       g   i     R # ; i5ir   )rn   rp   rk   r2   )r   r#   r$   r%   rq   s   &&&&r   r2   GZipResponder.__call__   sN     t~~~'"54888  .8  .~sE   BA-A	AA	A-
BA	A*%A--A>	8	Bc                ,   < V ^8  d   QhRS[ RS[RS[ /# rZ   r[   )r   r   s   "r   r   rf      s"     	 	e 	4 	E 	r   c                  V P                   P                  V4       V'       g   V P                   P                  4        V P                  P	                  4       pV P                  P                  ^ 4       V P                  P                  4        V# )r   )rp   writeclosern   getvalueseektruncater`   s   &&$r   rS   GZipResponder.apply_compression   sf    T"NN  "((*a !!#r   )rn   rp   )r4   )r5   r6   r7   r8   rU   r   r2   rS   r9   r:   __classcell__)rq   r   s   @@r   r.   r.   w   s0     i i9 9	 	 	r   r.   c                0    V ^8  d   QhR\         R\        /# )r   rK   r   )r   r   )r   s   "r   r   r      s     1 17 1x 1r   c                     "   \        R 4      h5i)zsend awaitable not set)RuntimeError)rK   s   &r   r@   r@      s     
/
00s   )ztext/event-stream)r*   rl   typingr   starlette.datastructuresr   r   starlette.typesr   r   r   r	   r
   rQ   r   r/   r.   r@   r_   r   r   <module>r      sF     	  < B B!7 . .*T Tn% 21r   