i]ddlmZddlZddlZddlZddlmZmZmZm Z m Z ddl m Z m Z mZmZmZmZddlmZddlmZmZmZmZmZmZmZmZmZmZddlm Z m!Z!dd l"m#Z#dd lm$Z$m%Z%m&Z&gd Z'e e e!efZ( Gd d ej)Z*e*j+Z+e*j,Z,Gddej)Z-e-j.Z.e-j/Z/e-j0Z0e-j1Z1dZ2 GddZ3dS)) annotationsN) GeneratorListOptionalTypeUnion)ConnectionClosedConnectionClosedErrorConnectionClosedOK InvalidState PayloadTooBig ProtocolError) Extension) OK_CLOSE_CODES OP_BINARYOP_CLOSEOP_CONTOP_PINGOP_PONGOP_TEXTClose CloseCodeFrame)RequestResponse) StreamReader) LoggerLikeOrigin Subprotocol)ProtocolSideStateSEND_EOFc.eZdZdZed\ZZdS)r"z6A WebSocket connection is either a server or a client.N)__name__ __module__ __qualname____doc__rangeSERVERCLIENTY/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/websockets/protocol.pyr"r"-s%@@U1XXNFFFFr/r"c2eZdZdZed\ZZZZdS)r#z6A WebSocket connection is in one of these four states.N) r'r(r)r*r+ CONNECTINGOPENCLOSINGCLOSEDr.r/r0r#r#7s*@@(-a%Jgvvvr/r#r/c6eZdZdZedddd7dZed8dZejd9dZed:dZ ed;dZ eddZ d?dZd@d?dZd@d?d ZdAdBd%Zd=d&Zd=d'ZdCdDd)ZdEd+ZdFd-ZdGd.ZdHd0ZdHd1ZdId4ZdId5Zd>d6ZdS)Jr!a6 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_sizeloggersider"r8r#r9 Optional[int]r:Optional[LoggerLike]returnNonecRtj|_ |.tjd|j}||_ |tj |_ ||_ ||_ ||_ d|_d|_d|_g|_d|_d|_d|_d|_d|_ d|_t1|_g|_g|_||_t=|jd|_dS)Nz websockets.F) uuiduuid4idlogging getLoggernamelowerr: isEnabledForDEBUGdebugr;r8r9cur_sizeexpect_continuation_frameorigin extensions subprotocol close_rcvd close_sentclose_rcvd_then_sent handshake_exceof_sentrreadereventswritesparseparsernext parser_exc)selfr;r8r9r:s r0__init__zProtocol.__init__Ws"Z\\B >&'HTY__5F5F'H'HIIF"( )((77   ! (, */&)- +-26,0+/48!37  #nn #% #% jjll  T[/3r/c|jS)zm WebSocket connection state. Defined in 4.1, 4.2, 7.1.3, and 7.1.4 of :rfc:`6455`. )_stater\s r0r8zProtocol.states {r/cb|jr |jd|j||_dS)Nz= connection is %s)rJr:rFr_)r\r8s r0r8zProtocol.states3 : @ K  2EJ ? ? ? r/c`|jturdS|j tjS|jjS)z `WebSocket close code`_. .. _WebSocket close code: https://www.rfc-editor.org/rfc/rfc6455.html#section-7.1.5 :obj:`None` if the connection isn't closed yet. N)r8r6rPrABNORMAL_CLOSUREcoder`s r0 close_codezProtocol.close_codes2 :V # #4 _ $- -?' 'r/ Optional[str]cL|jturdS|jdS|jjS)z `WebSocket close reason`_. .. _WebSocket close reason: https://www.rfc-editor.org/rfc/rfc6455.html#section-7.1.6 :obj:`None` if the connection isn't closed yet. N)r8r6rPreasonr`s r0 close_reasonzProtocol.close_reasons. :V # #4 _ $2?) )r/r c |jtus Jd|j5|j.|jjt vr|jjt vrt }nt}||j|j|j}|j |_ |S)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) r8r6rPrQrdrr r rRr[ __cause__)r\exc_typeexcs r0 close_exczProtocol.close_excs zV###%B### O '+$66$66)HH,H ( O O  %! !    r/databytescb|j|t|jdS)aH 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)rU feed_datarZrYr\rps r0 receive_datazProtocol.receive_datas0 d### T[r/c`|jt|jdS)a 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. Raises: EOFError: if :meth:`receive_eof` was called earlier. N)rUfeed_eofrZrYr`s r0 receive_eofzProtocol.receive_eofs.  T[r/finboolc|jstd| |_|tt||dS)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 frameN)rLr send_framerrr\rprys r0send_continuationzProtocol.send_continuationsM"- A ?@@ @-0& gtS1122222r/Tc|jrtd| |_|tt||dS)a 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 frameN)rLrr}rrr~s r0 send_textzProtocol.send_text/sM  ) A ?@@ @-0& gtS1122222r/c|jrtd| |_|tt||dS)a 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. rN)rLrr}rrr~s r0 send_binaryzProtocol.send_binaryDsM  ) A ?@@ @-0& is3344444r/rhrdristrcX|jrtd|2|dkrtdttjd}d}n$t||}|}|tt|||_ t|_ dS)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 a fragmented message is being sent, if the code isn't valid, or if a reason is provided without a code rNrhz#cannot send a reason without a coder/) rLrrrNO_STATUS_RCVD serializer}rrrQr5r8r\rdricloserps r0 send_closezProtocol.send_closeYs  ) A ?@@ @ <||#$IJJJ)2B77EDD$''E??$$D h--... r/cV|tt|dS)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. N)r}rrrts r0 send_pingzProtocol.send_pingy& gt,,-----r/cV|tt|dS)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. N)r}rrrts r0 send_pongzProtocol.send_pongrr/intc|jturo|tjkr_t ||}|}|tt|||_ t|_|j tur|j s|||_t#|jdS)a? `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. N)r8r4rrcrrr}rrrQr5r;r,rTsend_eofdiscardrYrZrs r0failz Protocol.fails& :  y111dF++((h 5 5666"'$ 9  t}  MMOOO llnn  T[r/ List[Event]c$|jgc}|_|S)a7 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: List[Event]: Events read from the connection. )rV)r\rVs r0events_receivedzProtocol.events_receiveds#k2  r/ List[bytes]c$|jgc}|_|S)a 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: List[bytes]: Data to write to the connection. )rW)r\rWs r0 data_to_sendzProtocol.data_to_sends"#k2  r/c0|jtup|jduS)a 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: bool: Whether the TCP connection is expected to close soon. N)r8r5rSr`s r0close_expectedzProtocol.close_expecteds,zW$F(:$(FFr/Generator[None, None, None]c#K |jEd{Vr0|jr|jdt d|jd}n|j|j}n|j|jz }tj|jj |j tu||j Ed{V}|jr|jd|| |#t$r?}|t jt%|||_Yd}~n0d}~wt$r>}|t jt%|||_Yd}~nd}~wt*$r@}|t j|jd|j||_Yd}~nd}~wt2$r>}|t jt%|||_Yd}~n\d}~wt6$rL}|jdd |t j||_Yd}~nd}~wwxYwdVt=d ) a- 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)maskr9rNz< %sz at position z parser failed)exc_infoz"parse() shouldn't step after error)rUat_eofrJr:EOFErrorr9rKrrX read_exactr;r,rN recv_framerrrPROTOCOL_ERRORrr[rcUnicodeDecodeError INVALID_DATAristartrMESSAGE_TOO_BIG ExceptionerrorINTERNAL_ERRORAssertionError)r\r9framerns r0rXzProtocol.parses5 " '#{1133333333?z3 ))'222 ##=>>>=(#HH]*#}HH#}t}4E77 I6F?? I 4H IAIIc#K|jtu|jksJ|jEd{Vs8|j|jEd{V8|jr|jd|jtur| t|_ dVtd)z Discard incoming data. This coroutine replaces :meth:`parse`: - after receiving a close frame, during a normal closure (1.4); - after sending a close frame, during an abnormal closure (7.1.7). Nrz"discard() shouldn't step after EOF) r;r,rTrUrrrJr:r-rr6r8rr`s r0rzProtocol.discardCs V#7777"k0022222222 " K   ! ! !#k0022222222 " : ' K  g & & & 9   MMOOO  ABBBr/rrc|jtus|jturA|jt d|jr d|_nt |j|_n|jturJ|jt d|jr d|_n|xjt |jz c_nq|jtur1tt|j}| |n2|jturn"|jturtj|j|_|jt$ur|jJd|_|jt d|jt*urL| tt|j|j|_d|_t$|_|jt.ur|||_t7|jnt9d|jd|j|dS) z- Process an incoming frame. Nrr|Fzincomplete fragmented messageTzunexpected opcode: 02x)opcoderrrKrrylenrprrrrr}rrrXrPr8r5rQrRr4r;r,rrrYrZrrVappend)r\r pong_frames r0rzProtocol.recv_frameas  <7 " "eli&?&?}(#$CDDDy 0 $ #EJ \W $ $}$#$CDDDy 1 $  UZ0 \W $ $w 33J OOJ ' ' ' ' \W $ $  \X % %$k%*55DOzW$$222,1)}(#$CDDDzT!! h ; ;<<<"&/,0)$ yF""  ,,..DK     !!Iu|!I!I!IJJ J 5!!!!!r/c |jturtd|jjd|jr|jd||j||j tu|j dS)Nz#cannot write to a WebSocket in the z statez> %s)rrN) r8r4r rFrJr:rWrrr;r-rN)r\rs r0r}zProtocol.send_frames :T ! !MdjoMMM  : - K  fe , , ,  OOf!4O Q Q     r/c|jrJd|_|jr|jd|jt dS)NTz> EOF)rTrJr:rWrr$r`s r0rzProtocol.send_eofsS=    : ' K  g & & & 8$$$$$r/) r;r"r8r#r9r<r:r=r>r?)r>r#)r8r#r>r?)r>r<)r>rf)r>r )rprqr>r?)r>r?)rprqryrzr>r?)T)Nrh)rdr<rirr>r?)rh)rdrrirr>r?)r>r)r>r)r>rz)r>r)rrr>r?)r'r(r)r*r4r]propertyr8setterrerjrorurxrrrrrrrrrrrXrrr}rr.r/r0r!r!Gsq  &"''+ B4B4B4B4B4B4HX \\ (((X("***X*"!!!X!J (3333,33333*55555*@ . . . . . . . .'''''V     (GGGG4ECECECECNCCCCrsv""""""  99999999999999"!!!!!                        &%%%%%%%!!!!!!3333333333    gx&'?4<  11111DL111    z -  E} %} %} %} %} %} %} %} %} %} %r/