aDgdZddlmZddlmZddlmZmZmZm Z m Z m Z ddl m Z mZmZmZddlmZGdd eZGd d eZej*Zej,ZGd d eZy)zU wsproto/connection ~~~~~~~~~~~~~~~~~~ An implementation of a WebSocket connection. )deque)Enum) BytesMessageCloseConnectionMessagePingPong TextMessage) CloseReason FrameProtocolOpcode ParseFailed)LocalProtocolErrorc(eZdZdZdZdZdZdZdZdZ y) ConnectionStatez1 RFC 6455, Section 4 - Opening Handshake rrN) __name__ __module__ __qualname____doc__ CONNECTINGOPENREMOTE_CLOSING LOCAL_CLOSINGCLOSED REJECTINGR/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/wsproto/connection.pyrrs'J DNM FIr"rceZdZdZdZy)ConnectionTyperrN)rrrCLIENTSERVERr!r"r#r%r%s FFr"r%c:eZdZdZddZedZdZdZdZ 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. :param conn_type: Whether this object is on the client- or server-side of a connection. To initialise as a client pass ``CLIENT`` otherwise pass ``SERVER``. :type conn_type: ``ConnectionType`` Nc|tju|_t|_t |j|xsg|_tj|_ |j|yN) r%r&clientr_eventsr _protorr_state receive_data)selfconnection_type extensions trailing_datas r#__init__zConnection.__init__8sO%)>)>> w #DKK1ArB %**  -(r"c|jSr+)r/)r1s r#statezConnection.state@s{{r"cPd}t|tr5||jj|j|j z }|St|t r*||jj|jz }|St|tr*||jj|jz }|St|tr|jtjtjhvrt!d|jz||jj#|j$|j&z }|jtjk(rtj(|_|Stj,|_|St!dj/|)Nr"z'Connection cannot be closed in state %szEvent {} cannot be sent.) isinstancerr. send_datadatamessage_finishedr pingpayloadr pongrr7rrrrclosecodereasonrr/rformat)r1eventr;s r#sendzConnection.sendEsY eW % DKK))%**e6L6LM MD" !t $ DKK$$U]]3 3D t $ DKK$$U]]3 3D  /zz/"6"68V8V!WW(= J DKK%%ejj%,,? ?Dzz_;;;-44  .;;  %%?%F%Fu%MN Nr"cx|I|jjttjt j |_y|jt jt jfvr|jj|y|jt j ur tdy)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)rAzConnection already closed.)r-appendrr ABNORMAL_CLOSURErrr/r7rrr. receive_bytesr)r1r;s r#r0zConnection.receive_data\s < LL  [5Q5Q R S)00DK  ::/..0M0MN N KK % %d + ZZ?11 1$%AB B2r"c#K|jr)|jj|jr) |jjD]}|jt j ur3|jr |jsJt|jS|jt jur3|jr |jsJt|j|jt jurg|j\}}|jtj urtj"|_ntj&|_t)||%|jt j*ur0t-|j|j|jq|jt j.ust1|j|j|jy#t2$r,}t)|j4t7|Yd}~yd}~wwxYww)z Return a generator that provides any events that have been generated by protocol activity. :returns: generator of :class:`Event ` subclasses )r>)rArB)r;frame_finishedr<N)r-popleftr.received_framesopcoderPINGrKr<r r>PONGr CLOSEr7rrrr/rrTEXTr BINARYrrrAstr)r1framerArBexcs r#eventszConnection.eventsvsll,,&&( (ll B446 <<6;;. //E4J4JJJu}}55\\V[[0 //E4J4JJJu}}55\\V\\1#(==LD&zz_%B%BB&5&<&< &5&D&D )tFCC\\V[[0%"]]',';';).)?)? \\V]]2&"]]',';';).)?)?3 < B!sxxCA A Bs55I F'H"1HI  I "I?I I  I )Nr") rrrrr5propertyr7rEr0rWr!r"r#r)r)*s1 ).C4+Br"r)N)r collectionsrenumrrWrrrr r r frame_protocolr r rr utilitiesrrr%r&r'objectr)r!r"r#r^saSSKK) d T      wBwBr"