iojSSKJr SSKrSSKrSSKrSSKJr SSKJrJ r J r J r J r J r SSKJr SSKJrJrJrJrJrJrJrJrJrJr SSKJrJr SS KJr SS K J!r!J"r"J#r#J$r$ /S Qr%\\-\-r&"S S \RN5r(\(RRr)\(RTr*"SS\RN5r+\+RXr,\+RZr-\+R\r.\+R^r/Sr0"SS5r1g)) annotationsN) Generator)ConnectionClosedConnectionClosedErrorConnectionClosedOK InvalidState PayloadTooBig ProtocolError) Extension) OK_CLOSE_CODES OP_BINARYOP_CLOSEOP_CONTOP_PINGOP_PONGOP_TEXTClose CloseCodeFrame)RequestResponse) StreamReader) BytesLike LoggerLikeOrigin Subprotocol)ProtocolSideStateSEND_EOFc.\rSrSrSr\"S5urrSrg)r-z6A WebSocket connection is either a server or a client.N) __name__ __module__ __qualname____firstlineno____doc__rangeSERVERCLIENT__static_attributes__r%P/home/mande/repo/quber/.venv/lib/python3.13/site-packages/websockets/protocol.pyrr-s@1XNFFr/rc2\rSrSrSr\"S5urrrr Sr g)r 7z6A WebSocket connection is in one of these four states.r%N) r&r'r(r)r*r+ CONNECTINGOPENCLOSINGCLOSEDr.r%r/r0r r 7s@(-a%Jgvr/r r/cr\rSrSrSr\SSS.SSjjr\SSj5r\RS Sj5r\S!S j5r \S"S j5r \S#S j5r S$S jr S%S jrS&SjrS'S&SjjrS'S&SjjrS(S)SjjrS*SjrS*SjrS+S,SjjrS-SjrS.SjrS/SjrS0SjrS0SjrS1SjrS1SjrS%SjrSrg)2rGa Sans-I/O implementation of a WebSocket connection. Args: side: :attr:`~Side.CLIENT` or :attr:`~Side.SERVER`. state: Initial state of the WebSocket connection. max_size: Maximum size of incoming messages in bytes. :obj:`None` disables the limit. You may pass a ``(max_message_size, max_fragment_size)`` tuple to set different limits for messages and fragments when you expect long messages sent in short fragments. logger: Logger for this connection; depending on ``side``, defaults to ``logging.getLogger("websockets.client")`` or ``logging.getLogger("websockets.server")``; see the :doc:`logging guide <../../topics/logging>` for details. iN)statemax_sizeloggerc[R"5UlUc1[R"SUR R 535nX@lUR[R5Ul Xl X l [U[5(dUcUSsUlUlOUuUlUlSUlSUlSUl/UlSUlSUlSUlSUlSUlSUl[75Ul/Ul/UlUR?5Ul [CUR@5 SUl"g)Nz websockets.F)#uuiduuid4idlogging getLoggernamelowerr< isEnabledForDEBUGdebugsider: isinstanceintmax_message_sizemax_fragment_size current_sizeexpect_continuation_frameorigin extensions subprotocol close_rcvd close_sentclose_rcvd_then_sent handshake_exceof_sentrreadereventswritesparseparsernext parser_exc)selfrHr:r;r<s r0__init__Protocol.__init__Ys7"ZZ\B >&&TYY__5F4G'HIF"( )((7    h $ $(8
sf  ) ) ?@ @ ;;d " 0E0E0G/HIJ J-0& gt12r/cUR(a [S5eUR[La0[ SUR R R535eU(+UlUR[[X55 g)aU Send a `Binary frame`_. .. _Binary frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 Parameters: data: payload containing arbitrary binary data. fin: FIN bit; set it to :obj:`False` if this is the first frame of a fragmented message. Raises: ProtocolError: If a fragmented message is in progress. rrN) rNr rbr5r r:rCrDrrrrs r0 send_binaryProtocol.send_binaryUsf  ) ) ?@ @ ;;d " 0E0E0G/HIJ J-0& i34r/cUR[La0[SURRR 535eUc.US:wa [ S5e[[RS5nSnO[X5nUR5nUR[[U55 URbeX0l[ Ulg)a Send a `Close frame`_. .. _Close frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.5.1 Parameters: code: close code. reason: close reason. Raises: ProtocolError: If the code isn't valid or if a reason is provided without a code. rNrlz#cannot send a reason without a coder/)rbr5r r:rCrDr rrNO_STATUS_RCVD serializerrrrRrSr6r^rhrmcloserys r0 send_closeProtocol.send_closels$ ;;d " 0E0E0G/HIJ J <|#$IJJ)22B7ED$'E??$D h-.&&& r/cUR[LaCUR[La0[SURR R 535eUR[[U55 g)z Send a `Ping frame`_. .. _Ping frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.5.2 Parameters: data: payload containing arbitrary binary data. rN) rbr5r6r r:rCrDrrrrxs r0 send_pingProtocol.send_pingR ;;d "t{{''A 0E0E0G/HIJ J gt,-r/cUR[LaCUR[La0[SURR R 535eUR[[U55 g)z Send a `Pong frame`_. .. _Pong frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.5.3 Parameters: data: payload containing arbitrary binary data. rN) rbr5r6r r:rCrDrrrrxs r0 send_pongProtocol.send_pongrr/cUR[LasU[R:wa_[ X5nUR 5nUR [[U55 X0l URbSUl [UlUR[La!UR(dUR!5 UR#5Ul['UR$5 g)z `Fail the WebSocket connection`_. .. _Fail the WebSocket connection: https://datatracker.ietf.org/doc/html/rfc6455#section-7.1.7 Parameters: code: close code reason: close reason Raises: ProtocolError: If the code isn't valid. NT)r:r5rrgrrrrrrSrRrTr6rHr,rVsend_eofdiscardr[r\rs r0fail Protocol.fails& :: y111d+(h 56"' ??.04D-$ 99 t}} MMO lln  T[[r/c,UR/solU$)z Fetch events generated from data received from the network. Call this method immediately after any of the ``receive_*()`` methods. Process resulting events, likely by passing them to the application. Returns: Events read from the connection. )rX)r^rXs r0events_receivedProtocol.events_receiveds#kk2  r/c,UR/solU$)ay Obtain data to send to the network. Call this method immediately after any of the ``receive_*()``, ``send_*()``, or :meth:`fail` methods. Write resulting data to the connection. The empty bytestring :data:`~websockets.protocol.SEND_EOF` signals the end of the data stream. When you receive it, half-close the TCP connection. Returns: Data to write to the connection. )rY)r^rYs r0 data_to_sendProtocol.data_to_sends"#kk2  r/cUR[LagUR[LagUR[LagUR[LdeUR $)ai Tell if the TCP connection is expected to close soon. Call this method immediately after any of the ``receive_*()``, ``send_close()``, or :meth:`fail` methods. If it returns :obj:`True`, schedule closing the TCP connection after a short timeout if the other side hasn't already closed it. Returns: Whether the TCP connection is expected to close soon. FT)r:r5r6r7r4rVrcs r0close_expectedProtocol.close_expectedsND ::  ::  :: zzZ'''}}r/c## URR5ShvN (a7UR(aURRS5 [ S5eSnUR b3UR c UR nOUR UR - nURb%Uc URnO[XR5n[R"URRUR[LUURS9ShvN nUR(aURRSU5 URU5 GM`GNCNH![ a:nUR#[$R&[)U55 X0lSnAGOHSnAf[a:nUR#[$R,[)U55 X0lSnAGOSnAf[.aInUR#[$R0UR2SUR435 X0lSnAOSnAf[6aTnUR9UR 5 UR#[$R:[)U55 X0lSnAOYSnAf[<aInURR?SSS 9 UR#[$R@5 X0lSnAOSnAff=fSv [CS 5e7f) z Parse incoming data into frames. :meth:`receive_data` and :meth:`receive_eof` run this generator coroutine until it needs more data or reaches EOF. :meth:`parse` never raises an exception. Instead, it sets the :attr:`parser_exc` and yields control. TN< EOFzunexpected end of stream)maskr;rPz< %sz at position z parser failed)exc_infoz"parse() shouldn't step after error)"rWat_eofrGr<EOFErrorrKrMrLminrrZ read_exactrHr,rP recv_framer rrPROTOCOL_ERRORstrr]rgUnicodeDecodeError INVALID_DATArmstartr set_current_sizeMESSAGE_TOO_BIG ExceptionerrorINTERNAL_ERRORAssertionError)r^r;framerss r0rZProtocol.parse2s:= "#{{11333zz ))'2 ##=>>((4((0#'#8#8#'#8#84;L;L#L))5'#'#9#9#&x1G1G#H $);;KK**f,%# $::KK%%fe4&K34 " IIi..C 9!OO " IIi00#c( ;!OO! " IIi,, M#)).U V!OO "  !2!2 3 IIi//S :!OO " KK  o  = IIi.. /!OO  " ABBsLE*E%C %s)rrP)rGr<rYrrrHr-rP)r^rs r0rProtocol.send_framesS :: KK  fe ,  OOYY&(??   r/cUR(aeSUlUR(aURRS5 URR [ 5 g)NTz> EOF)rVrGr<rYrr!rcs r0rProtocol.send_eofsA==   :: KK  g & 8$r/)rbrRrTrSrMrGrVrXrNrPrUr@r<rLrKrOr[r]rWrHr:rQrY) rHrr:r r;z*tuple[int | None, int | None] | int | Noner<zLoggerLike | NonereturnNone)rr )r:r rr)rz int | None)rz str | None)rr)ryzbytes | bytearrayrr)rr)ryrrboolrr)T)Nrl)rhzCloseCode | int | Nonermrrr)ryrrr)rl)rhzCloseCode | intrmrrr)rz list[Event])rz list[bytes])rr)rzGenerator[None])rrrr)r&r'r(r)r*r5r_propertyr:setterrirnrtrzrrrrrrrrrrrrZrrrrr.r%r/r0rrGs*?D$( E1E1 E1 = E1 " E1 E1N   \\ (($**$!!J *303.5."H. . -b  ()ZMC^Ccollections.abcr exceptionsrrrr r r rPr framesr rrrrrrrrrhttp11rrstreamsrtypingrrrr__all__EventIntEnumrr,r-r r4r5r6r7r!rr%r/r0rs"  %"   &!>>  (U"?4<<  1DLL1     zz --  Ey %y %r/