aQbj dZddlmZddlmZddlmZddlmZddl m Z m Z m Z m Z mZmZmZddlmZmZmZmZdd lmZer dd lmZdd lmZGd d eZGddeZej<Zej>ZGddZ y)zU wsproto/connection ~~~~~~~~~~~~~~~~~~ An implementation of a WebSocket connection. ) annotations)deque)Enum) TYPE_CHECKING) BytesMessageCloseConnectionEventMessagePingPong TextMessage) CloseReason FrameProtocolOpcode ParseFailed)LocalProtocolError) Generator) Extensionc(eZdZdZdZdZdZdZdZdZ y) ConnectionStatez1 RFC 6455, Section 4 - Opening Handshake rrN) __name__ __module__ __qualname____doc__ CONNECTINGOPENREMOTE_CLOSING LOCAL_CLOSINGCLOSED REJECTINGE/var/www/html/venv/lib/python3.12/site-packages/wsproto/connection.pyrrs' J DNM FIr'rceZdZdZdZdZy)ConnectionTypez#An enumeration of connection types.rrN)rrrrCLIENTSERVERr&r'r(r*r*2s-FFr'r*cVeZdZdZ d d dZed dZd dZd dZd dZ y) Connectiona  A low-level WebSocket connection object. This wraps two other protocol objects, an HTTP/1.1 protocol object used to do the initial HTTP upgrade handshake and a WebSocket frame protocol object used to exchange messages and other control frames. Nc|tju|_t|_t |j|xsg|_tj|_ |j|y)a Constructor :param wsproto.connection.ConnectionType connection_type: Whether this object is on the client- or server-side of a connection. To initialise as a client pass ``CLIENT`` otherwise pass ``SERVER``. :param list extensions: The proposed extensions. :param bytes trailing_data: Data that has been received, but not yet processed. N) r*r+clientr_eventsr_protorr!_state receive_data)selfconnection_type extensions trailing_datas r(__init__zConnection.__init__IsQ &)>)>> %*W #DKK1ArB %**  -(r'c|jS)N)r3)r5s r(statezConnection.state_s {{r'cd}t|trR|jtjk(r5||j j |j|jz }|St|trG|jtjk(r*||j j|jz }|St|trG|jtjk(r*||j j|jz }|St|tr|jtjtjhvr~||j j!|j"|j$z }|jtjk(rtj&|_|Stj*|_|Sd|d|jd}t-|)Nr'zEvent z cannot be sent in state .) isinstancer r;rr!r2 send_datadatamessage_finishedr pingpayloadr pongr r"closecodereasonr$r3r#r)r5eventr@msgs r(sendzConnection.sendcs eW %$**8L8L*L DKK))%**e6L6LM MD& %t $7K7K)K DKK$$U]]3 3D" !t $7K7K)K DKK$$U]]3 3D  /DJJ   * *C 5  DKK%%ejj%,,? ?Dzz_;;;-44  .;;  5'!:4::,aHC$ r'c||I|jjttjt j |_y|jt jt jfvr|jj|y|jt j ur d}t|y)aO Pass some received data to the connection for handling. A list of events that the remote peer triggered by sending this data can be retrieved with :meth:`~wsproto.connection.Connection.events`. :param data: The data received from the remote peer on the network. :type data: ``bytes`` N)rFzConnection already closed.)r1appendr rABNORMAL_CLOSURErr$r3r;r!r#r2 receive_bytesr)r5r@rIs r(r4zConnection.receive_data{s < LL  [5Q5Q R S)00DK  ::/..0M0MN N KK % %d + ZZ?11 1.C$S) ) r'c#K|jr)|jj|jr) |jjD]^}|jt j urW|jsJ|jsJt|jttfsJt|jw|jt jurW|jsJ|jsJt|jttfsJt|j|jt j urt|jt"sJ|j\}}|j$t&j(urt&j*|_nt&j.|_t1|||jt j2urLt|jt4sJt7|j|j|j|jt j8urRt|jttfsJt;|j|j|j_ay#t<$r,}t1|j>t5|Yd}~yd}~wwxYww)z Return a generator that provides any events that have been generated by protocol activity. :returns: generator of :class:`Event ` subclasses )rC)rFrG)r@frame_finishedrAN) r1popleftr2received_framesopcoderPINGrPrAr>rCbytes bytearrayr PONGr CLOSEtupler;rr#r$r3r"r TEXTstrrBINARYrrrF)r5framerFrGexcs r(eventszConnection.eventss-ll,,&&( (ll* B446' <<6;;. //// 1111%emmeY5GHHHu}}55\\V[[0 //// 1111%emmeY5GHHHu}}55\\V\\1%emmU;;;#(==LD&zz_%B%BB&5&<&< &5&D&D )tFCC\\V[[0%emmS999%"]]',';';).)?)? \\V]]2%emmeY5GHHH&"]]',';';).)?)?O' P B!sxxCA A Bs/5K.Irjsz # LK))%d&T      JBJBr'