+
    Di3                       a  R! t'0 t ^ RIHtHtHtHtHtHtHt ^RI	5 ^RI
HtHt . R#Ot ! R R]]R7      t ! R R]]R7      t ! R R]]R7      t ! R R]]R7      t ! R R]]R7      t ! R R	]]R7      t ! R R
]]R7      t ! R R]]R7      t ! R R]]R7      t ! R R]]R7      t ! R R]]R7      t ! R R]]R7      t ! R R]]R7      t]]],          ]]],          ]]]],          ]]],          ]],          3,          3,          ]],          3,          3,          3,          t]]]]]]/]]]] ]/]]]/]]]/]]]/]/ ]/ ]/ /]]]]]!]]]3]/]]"]]!]]"]3]]!]3]/]]]] ]/]]]/]]]/]]]/]/ ]/ //t#] ^ k ]]]],          ]],          3,          ]]],          ]],          3,          3,          t$]]3]]/]]3]]/]]3]]/]]3]]/]]3]]/]]3]]/]]3]]//t%] ^k  ! R R 4      t&R"# )$    )castDictOptionalSetTupleTypeUnion)*)LocalProtocolErrorSentinelCLIENTSERVERIDLESEND_RESPONSE	SEND_BODYDONE
MUST_CLOSECLOSEDMIGHT_SWITCH_PROTOCOLSWITCHED_PROTOCOLERRORc                       ] tR t^tRtR# )r    N__name__
__module____qualname____firstlineno____static_attributes__r       h/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/h11/_state.pyr   r          r    )	metaclassc                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )r   r   Nr   r   r    r!   r   r      r"   r    c                       ] tR t^tRtR# )_SWITCH_UPGRADEr   Nr   r   r    r!   r/   r/      r"   r    r/   c                       ] tR t^tRtR# )_SWITCH_CONNECTr   Nr   r   r    r!   r1   r1      r"   r    r1   c                      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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RtV tR	# )ConnectionStatec                   < V ^8  d   QhRR/#    returnNr   )format__classdict__s   "r!   __annotate__ConnectionState.__annotate__   s     Y Y$ Yr    c                h    R V n         \        4       V n        \        \        \
        \        /V n        R# TN)
keep_alivesetpending_switch_proposalsr   r   r   statesselfs   &r!   __init__ConnectionState.__init__   s)    
  >AU%=CT6SW<Xr    c                4   < V ^8  d   QhRS[ S[,          RR/# )r6   roler7   Nr   r   )r8   r9   s   "r!   r:   r;     s     1 1$x. 1T 1r    c                L    \         V P                  V&   V P                  4        R # N)r   rA   !_fire_state_triggered_transitions)rC   rG   s   &&r!   process_errorConnectionState.process_error  s    !D..0r    c                   < V ^8  d   QhRR/# r5   r   )r8   r9   s   "r!   r:   r;     s     1 1T 1r    c                4    R V n         V P                  4        R# )FN)r>   rK   rB   s   &r!   process_keep_alive_disabled+ConnectionState.process_keep_alive_disabled  s    ..0r    c                4   < V ^8  d   QhRS[ S[,          RR/# )r6   switch_eventr7   NrH   )r8   r9   s   "r!   r:   r;     s     1 14> 1d 1r    c                \    V P                   P                  V4       V P                  4        R # rJ   )r@   addrK   )rC   rS   s   &&r!   process_client_switch_proposal.ConnectionState.process_client_switch_proposal  s"    %%)),7..0r    Nc                p   < V ^8  d   QhRS[ S[,          RS[ S[,          RS[S[ S[,          ,          RR/# )r6   rG   
event_typeserver_switch_eventr7   N)r   r   Eventr   )r8   r9   s   "r!   r:   r;     sD     1 18n1 K1 &d8n5	1
 
1r    c                N   TpVe+   V\         J g   Q hW0P                  9  d   \        R4      hW#3pVf   V\        J d   \	        4       V n        V P                  W4       V\        J d-   V\        J g   Q hV P                  \         \        \        34       V P                  4        R # )Nz@Received server _SWITCH_UPGRADE event without a pending proposal)	r   r@   r   Responser?   !_fire_event_triggered_transitionsRequestr   rK   )rC   rG   rY   rZ   _event_types   &&&& r!   process_eventConnectionState.process_event  s     OY*6>!>"*G*GG(V  &;K&;(+B,/ED)..tA '!6>!>226GV;LM..0r    c          	         < V ^8  d   QhRS[ S[,          RS[S[ S[,          S[S[ S[,          S[ S[,          3,          3,          RR/# )r6   rG   rY   r7   N)r   r   r	   r[   r   )r8   r9   s   "r!   r:   r;   +  sM     & &8n& $u+uT%[$x.-H'IIJ& 
	&r    c           	     B   V P                   V,          p \        V,          V,          V,          pY@P                   T&   R#   \         dT    \        \        \
        ,          T4      p\        R P                  TP                  YP                   T,          4      4      Rhi ; i)z4can't handle event type {} when role={} and state={}N)	rA   EVENT_TRIGGERED_TRANSITIONSKeyErrorr   r   r[   r   r8   r   )rC   rG   rY   state	new_states   &&&  r!   r^   1ConnectionState._fire_event_triggered_transitions+  s    
 D!	3D9%@LI &D  	d5k:6J$FMM''{{4/@ 		s   A   ABc                   < V ^8  d   QhRR/# r5   r   )r8   r9   s   "r!   r:   r;   <  s     & &4 &r    c                    \        V P                  4      pV P                  '       d7   V P                  \        ,          \        J d   \
        V P                  \        &   V P                  '       g7   V P                  \        ,          \
        J d   \        V P                  \        &   V P                  '       gD   \        \        3 F3  pV P                  V,          \        J g   K   \        V P                  V&   K5  	  V P                  \        ,          V P                  \        ,          3p\        P                  V/ 4      pV P                  P                  V4       V P                  V8X  g   EKn  R# r=   )dictrA   r@   r   r   r   r>   r   r   STATE_TRIGGERED_TRANSITIONSgetupdate)rC   start_statesrG   joint_statechangess   &    r!   rK   1ConnectionState._fire_state_triggered_transitions<  s    ,L ,,,;;v&$.*?DKK'000;;v&*??*.DKK'???#V,D{{4(D0,6D) -
  ;;v.F0CDK155k2FGKKw'{{l*r    c                   < V ^8  d   QhRR/# r5   r   )r8   r9   s   "r!   r:   r;   d  s     	3 	3$ 	3r    c                   V P                   \        \        \        \        /8w  d   \	        R V P                    24      hV P
                  '       g   Q hV P                  '       d   Q h\        \        \        \        /V n         R# )z%not in a reusable state. self.states=N)rA   r   r   r   r   r>   r@   r   rB   s   &r!   start_next_cycle ConnectionState.start_next_cycled  sd    ;;6466$7}E 
 00000tVT2r    )r>   r@   rA   rJ   )r   r   r   r   rD   rL   rP   rV   ra   r^   rK   rv   r   __classdictcell__)r9   s   @r!   r3   r3      sX     Y Y1 11 11 11 10& &"& &P	3 	3r    r3   c                h    V ^8  d   Qh/ ^ \         9   d
   \        ;R&   ^\         9   d
   \        ;R&   # )r6   re   rm   )__conditional_annotations__EventTransitionTypeStateTransitionType)r8   s   "r!   r:   r:   q   s<     @ @f 0 g At 0 u Ar    N)r   r   r   r   r   r   r   r   r   r   r   )(rz   typingr   r   r   r   r   r   r	   _events_utilr   r   __all__r   r   r   r   r   r   r   r   r   r   r   r/   r1   r[   r{   r_   ConnectionClosedDataEndOfMessager]   InformationalResponsere   r|   rm   r3   r:   )rz   s   @r!   <module>r      s  b A @ @  /	X 		X 	
	8x 		H 		H 		8x 		X 		X 		H 	
	H 		H 		h( 		h( 	 NXU4;d5k4>&A BBCT(^ST	V  w	#3V<D)\48(%v.!6*r2r	 fif}	
 	!=i"O46G'):	
 	D)\48(%v.!6*2r%4  B 	$x.$x.
()4XX0N+OO  -.9J0KTNVZ(TNVZ(
DMFJ'	6NVZ(	6NVZ(	5MFJ'4  t3 t3r    