vKggSSKJr SSKrSSKrSSKrSSKJr SSKJr SSK J r J r J r J r JrJr SSKJr SSKJrJrJrJrJrJrJrJrJrJr SS KJrJr SS K J!r! SS KJ"r"J#r#J$r$ /S Qr%\\\\4r&"S S\RN5r(\(RRr)\(RTr*"SS\RN5r+\+RXr,\+RZr-\+R\r.\+R^r/Sr0"SS5r1g)) annotationsN) Generator)Union)ConnectionClosedConnectionClosedErrorConnectionClosedOK InvalidState PayloadTooBig ProtocolError) Extension) OK_CLOSE_CODES OP_BINARYOP_CLOSEOP_CONTOP_PINGOP_PONGOP_TEXTClose CloseCodeFrame)RequestResponse) StreamReader) 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%S/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/websockets/protocol.pyrr/s@1XNFFr/rc2\rSrSrSr\"S5urrrr Sr g)r 9z6A WebSocket connection is in one of these four states.r%N) r&r'r(r)r*r+ CONNECTINGOPENCLOSINGCLOSEDr.r%r/r0r r 9s@(-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.SjrS/SjrS/SjrS0SjrS0SjrS%SjrSrg)1rIa  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. 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_sizeloggercF[R"5UlUc1[R"SUR R 535nX@lUR[R5Ul Xl X l X0l SUlSUlSUl/UlSUlSUlSUlSUlSUlSUl[15Ul/Ul/UlUR95Ul[=UR:5 SUlg)Nz websockets.F) uuiduuid4idlogging getLoggernamelowerr< isEnabledForDEBUGdebugsider:r;cur_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__Ys"ZZ\B >&&TYY__5F4G'HIF"( )((7   ! %) */&&* +-/3)-(,15!04  #n #% #% jjl  T[[,0r/cUR$)au State of the WebSocket connection. Defined in 4.1_, 4.2_, 7.1.3_, and 7.1.4_ of :rfc:`6455`. .. _4.1: https://datatracker.ietf.org/doc/html/rfc6455#section-4.1 .. _4.2: https://datatracker.ietf.org/doc/html/rfc6455#section-4.2 .. _7.1.3: https://datatracker.ietf.org/doc/html/rfc6455#section-7.1.3 .. _7.1.4: https://datatracker.ietf.org/doc/html/rfc6455#section-7.1.4 )_staterZs r0r:Protocol.states{{r/c~UR(a&URRSUR5 Xlg)Nz= connection is %s)rGr<rCr^)rZr:s r0r:r`s' :: KK  2EJJ ? r/cUR[LagURc[R$URR $)z WebSocket close code received from the remote endpoint. Defined in 7.1.5_ of :rfc:`6455`. .. _7.1.5: https://datatracker.ietf.org/doc/html/rfc6455#section-7.1.5 :obj:`None` if the connection isn't closed yet. N)r:r7rNrABNORMAL_CLOSUREcoder_s r0 close_codeProtocol.close_codes9 ::V # __ $-- -??'' 'r/crUR[LagURcgURR$)z WebSocket close reason received from the remote endpoint. Defined in 7.1.6_ of :rfc:`6455`. .. _7.1.6: https://datatracker.ietf.org/doc/html/rfc6455#section-7.1.6 :obj:`None` if the connection isn't closed yet. N)r:r7rNreasonr_s r0 close_reasonProtocol.close_reasons0 ::V # __ $??)) )r/crUR[LdS5eURbPURbCURR[ ;a%URR[ ;a[ nO[nU"URURUR5nURUl U$)a Exception to raise when trying to interact with a closed connection. Don't raise this exception while the connection :attr:`state` is :attr:`~websockets.protocol.State.CLOSING`; wait until it's :attr:`~websockets.protocol.State.CLOSED`. Indeed, the exception includes the close code and reason, which are known only once the connection is closed. Raises: AssertionError: If the connection isn't closed yet. zconnection isn't closed yet) r:r7rNrOrdrr rrPrY __cause__)rZexc_typeexcs r0 close_excProtocol.close_excs zzV#B%BB# OO '+$$6$$6)H,H ( OO OO  % %!    r/cdURRU5 [UR5 g)a Receive data from the network. After calling this method: - You must call :meth:`data_to_send` and send this data to the network. - You should call :meth:`events_received` and process resulting events. Raises: EOFError: If :meth:`receive_eof` was called earlier. N)rS feed_datarXrWrZdatas r0 receive_dataProtocol.receive_datas" d# T[[r/cURR(agURR5 [UR5 g)aa Receive the end of the data stream from the network. After calling this method: - You must call :meth:`data_to_send` and send this data to the network; it will return ``[b""]``, signaling the end of the stream, or ``[]``. - You aren't expected to call :meth:`events_received`; it won't return any new events. :meth:`receive_eof` is idempotent. N)rSeoffeed_eofrXrWr_s r0 receive_eofProtocol.receive_eofs. ;;??   T[[r/cUR(d [S5eUR[La0[ SUR R R535eU(+UlUR[[X55 g)a Send a `Continuation frame`_. .. _Continuation frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 Parameters: data: payload containing the same kind of data as the initial frame. fin: FIN bit; set it to :obj:`True` if this is the last frame of a fragmented message and to :obj:`False` otherwise. Raises: ProtocolError: If a fragmented message isn't in progress. unexpected continuation frameconnection is N) rJr r^r5r r:rCrD send_framerrrZrufins r0send_continuationProtocol.send_continuation#sf"-- ?@ @ ;;d " 0E0E0G/HIJ J-0& gt12r/cUR(a [S5eUR[La0[ SUR R R535eU(+UlUR[[X55 g)aS Send a `Text frame`_. .. _Text frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 Parameters: data: payload containing text encoded with UTF-8. 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. expected a continuation framerN) rJr r^r5r r:rCrDrrrrs r0 send_textProtocol.send_text;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) rJr r^r5r r:rCrDrrrrs r0 send_binaryProtocol.send_binaryRsf  ) ) ?@ @ ;;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. rNrhz#cannot send a reason without a coder/)r^r5r r:rCrDr rrNO_STATUS_RCVD serializerrrrNrOr6rZrdricloserus r0 send_closeProtocol.send_closeis$ ;;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) r^r5r6r r:rCrDrrrrts 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) r^r5r6r r:rCrDrrrrts 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:r5rrcrrrrrrOrNrPr6rHr,rRsend_eofdiscardrWrXrs 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. )rT)rZrTs 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. )rU)rZrUs 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:r5r6r7r4rRr_s r0close_expectedProtocol.close_expectedsND ::  ::  :: zzZ'''}}r/c## URR5ShvN (a7UR(aURRS5 [ S5eUR cSnO3UR c UR nOUR UR - n[R"URRUR[LUURS9ShvN nUR(aURRSU5 URU5 GM/GNNH![a:nUR[ R"[%U55 X0lSnAGOHSnAf[a:nUR[ R([%U55 X0lSnAGOSnAf[*aInUR[ R,UR.SUR035 X0lSnAOSnAf[2aTnUR5UR 5 UR[ R6[%U55 X0lSnAOYSnAf[8aInURR;SSS 9 UR[ R<5 X0lSnAOSnAff=fSv [?S 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;rLz< %sz at position z parser failed)exc_infoz"parse() shouldn't step after error) rSat_eofrGr<EOFErrorr;rIrrV read_exactrHr,rL recv_framer rrPROTOCOL_ERRORstrrYrcUnicodeDecodeError INVALID_DATAristartr set_current_sizeMESSAGE_TOO_BIG ExceptionerrorINTERNAL_ERRORAssertionError)rZr;frameros r0rVProtocol.parse/s6 "#{{11333zz ))'2 ##=>>==(#H]]*#}}H#}}t}} %s)rrL)rGr<rUrrrHr-rL)rZrs r0rProtocol.send_framesS :: KK  fe ,  OOYY&(??   r/cUR(aeSUlUR(aURRS5 URR [ 5 g)NTz> EOF)rRrGr<rUrr!r_s r0rProtocol.send_eofsA==   :: KK  g & 8$r/)r^rNrPrOrIrGrRrTrJrLrQr@r<r;rKrWrYrSrHr:rMrU) rHrr:r r; int | Noner<zLoggerLike | NonereturnNone)rr )r:r rr)rr)rz str | None)rr)rubytesrr)rr)rurrboolrr)T)Nrh)rdrrirrr)rh)rdintrirrr)rz list[Event])rz list[bytes])rr)rzGenerator[None])rrrr)r&r'r(r)r*r5r[propertyr:setterrerjrprvr{rrrrrrrrrrrVrrrrr.r%r/r0rrIs &$$( B1B1 B1  B1 " B1 B1H   \\ (($**$!!J *303.5."H. . -b  ()ZFCPCcollections.abcrtypingr exceptionsrrr r r r rLr framesrrrrrrrrrrhttp11rrstreamsrrrr__all__EventIntEnumrr,r-r r4r5r6r7r!rr%r/r0rs"  %"   &!33  gx&'?4<<  1DLL1     zz --  Em %m %r/