L i3VUddlmZmZmZmZmZmZmZddlddl m Z m Z gdZ Gdde e Z Gd d e e ZGd d e e ZGd de e ZGdde e ZGdde e ZGdde e ZGdde e ZGdde e ZGdde e ZGdde e ZGdde e ZGdd e e Zeee eee eeeeeeeee ffee fffZe eeeeeieeeeeieeeieeeieeeieieieiieeeee eee feiee!ee ee!efee efeieeeeeieeeieeeieeeieieiiiZ"ee#d!<eeee ee feee ee ffZ$eefe eieefeeieefeeieefeeieefe eieefe eieefe eiiZ%e$e#d"<Gd#d$Z&y%)&)castDictOptionalSetTupleTypeUnion)*)LocalProtocolErrorSentinel) CLIENTSERVERIDLE SEND_RESPONSE SEND_BODYDONE MUST_CLOSECLOSEDMIGHT_SWITCH_PROTOCOLSWITCHED_PROTOCOLERRORc eZdZy)rN__name__ __module__ __qualname__P/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/h11/_state.pyrrrr) metaclassc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)rNrrrr rrr!rrc eZdZy)_SWITCH_UPGRADENrrrr r.r.r!rr.c eZdZy)_SWITCH_CONNECTNrrrr r0r0r!rr0EVENT_TRIGGERED_TRANSITIONSSTATE_TRIGGERED_TRANSITIONSc eZdZddZdeeddfdZddZdeeddfdZ ddeed ee d e eeddfd Z deed e ee e ee eeffddfd Zdd ZddZy)ConnectionStatereturnNcfd|_t|_ttt ti|_y)NT) keep_alivesetpending_switch_proposalsrrrstatesselfs r __init__zConnectionState.__init__s) >AU%=CT6SWs r process_errorzConnectionState.process_errors! D ..0rc2d|_|jy)NF)r7rAr;s r process_keep_alive_disabledz+ConnectionState.process_keep_alive_disabled s ..0r switch_eventcZ|jj||jyr@)r9addrA)r<rEs r process_client_switch_proposalz.ConnectionState.process_client_switch_proposals" %%)),7 ..0r event_typeserver_switch_eventc4|}|'|tusJ||jvr td||f}||turt |_|j |||t ur*|tusJ|j tt tf|jy)Nz@Received server _SWITCH_UPGRADE event without a pending proposal) rr9r Responser8!_fire_event_triggered_transitionsRequestrrA)r<r>rIrJ _event_types r process_eventzConnectionState.process_events OY  *6> !>"$*G*GG(V&':;K  &;(+B,/ED ) ..t[A ' !6> !>  2 26GV;L M ..0rc |j|} t|||}||j|<y#t$rLttt |}t dj|j||j|dwxYw)Nz4can't handle event type {} when role={} and state={}) r:r1KeyErrorrrEventr formatr)r<r>rIstate new_states r rMz1ConnectionState._fire_event_triggered_transitions+s  D! 3D9%@LI& D d5k:6J$FMM''t{{4/@   s 0ABc| t|j}|jr0|jtturt |jt<|js0|jtt urt|jt<|j s:ttfD]+}|j|tust|j|<-|jt|jtf}tj|i}|jj||j|k(ry joint_statechangess r rAz1ConnectionState._fire_state_triggered_transitions<s ,L,,;;v&$.*?DKK'00;;v&*??*.DKK'??#V,7D{{4(D0,6 D)7  ;;v. F0CDK155k2FG KK  w '{{l*Irc|jttttik7rt d|j|j sJ|j rJtttti|_y)Nz%not in a reusable state. self.states=)r:rrrr r7r9rr;s r start_next_cyclez ConnectionState.start_next_cycleds_ ;;646 6$7 }E  0000tVT2 r)r5Nr@)rrrr=rr rBrDrHrSrrPr rrMrAr_rrr r4r4s Y1$x.1T1114>1d19= 18n1K1&d8n5 1  10&8n&$u+uT%[$x.-H'IIJ&  &"&P 3rr4N)'typingrrrrrrr _events_utilr r __all__rrrrrrrrrrrr.r0rSEventTransitionTyperNConnectionClosedData EndOfMessagerLInformationalResponser1__annotations__StateTransitionTyper2r4rrr rksbA@@/  X  X  8x  H  H  8x  X  X  H  H  H  h(  h( N X U4;d5k4>&A BB CT(^ ST V  w #3V<D)\48 (%v.!6*r2 r   f i f }   != i "O 46G  '):  D)\48 (%v.!6*2 r% 40B $x.$x. ()4XX0N+OO-.9J0K TNVZ( TNVZ( DMFJ' 6NVZ( 6NVZ( 5MFJ' 40 t3t3r