+ Hjg^RIHt^RIt^RIt^RIt^RIHt^RIHt^RI H t H t H t H t HtHt^RIHt^RIHtHtHtHtHtHtHtHtHtHt^RIHtHt^R I H!t!^R IH"t"H#t#H$t$.ROt%]]]]3,t&!RR ]PN4t(](PRt)](PTt*!RR ]PN4t+]+PXt,]+PZt-]+P\t.]+P^t/Rt0!RR 4t1R#)) annotationsN) Generator)Union)ConnectionClosedConnectionClosedErrorConnectionClosedOK InvalidState PayloadTooBig ProtocolError) Extension) OK_CLOSE_CODES OP_BINARYOP_CLOSEOP_CONTOP_PINGOP_PONGOP_TEXTClose CloseCodeFrame)RequestResponse) StreamReader) LoggerLikeOrigin SubprotocolProtocolSideStatec0]tRt^/tRt]!^4wttRtR#)rz6A WebSocket connection is either a server or a client.N) __name__ __module__ __qualname____firstlineno____doc__rangeSERVERCLIENT__static_attributes__r!ڕ/home/ubuntu/.hermes/installs/5f0a1ff4045d044e/environments/50f6b671e3f94b538e344231dfcb664f/venv/lib/python3.14/site-packages/websockets/protocol.pyrr/s@1XNFFr+c4]tRt^9tRt]!^4wtttt Rt R#)rz6A WebSocket connection is in one of these four states.r!N) r"r#r$r%r&r' CONNECTINGOPENCLOSINGCLOSEDr*r!r+r,rr9s@(-a%Jgvr+r+c]tRt^ItRtR]RR5RR/RRllt]RR l4t]PR R l4t]R R l4t ]RRl4t ]RRl4t RRlt RRltRRltR6RRlltR6RRlltR7RRlltRRltR R!ltR8R"R#lltR$R%ltR&R'ltR(R)ltR*R+ltR,R-ltR.R/ltR0R1ltR2R3ltR4tR#)9ra  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. statemax_sizeloggerNc ,V^8dQhRRRRRRRRR R /#) siderr3rr4 int | Noner5zLoggerLike | NonereturnNoner!)formats"r, __annotate__Protocol.__annotate__YsCB1B1B1 B1  B1 " B1 B1r+c J\P!4VnVf2\P!RVP P 4 24pW@nVP\P4Vn Wn W n W0n RVnRVnRVn.VnRVnRVnRVnRVnRVnRVn\14Vn.Vn.VnVP94Vn\=VP:4RVnR#)Nz websockets.F) uuiduuid4idlogging getLoggernamelowerr5 isEnabledForDEBUGdebugr8r3r4cur_sizeexpect_continuation_frameorigin extensions subprotocol close_rcvd close_sentclose_rcvd_then_sent handshake_exceof_sentrreadereventswritesparseparsernext parser_exc)selfr8r3r4r5s&&$$$r,__init__Protocol.__init__Ys"ZZ\B >&&TYY__5F4G'HIF"( )((7   ! %) */&&* +-/3)-(,15!04  #n #% #% jjl  T[[,0r+cV^8dQhRR/#)r7r:rr!)r<s"r,r=r>s  u r+c VP#)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 )_stater[s&r,r3Protocol.states{{r+c V^8dQhRRRR/#)r7r3rr:r;r!)r<s"r,r=r>s5Tr+c VP'd'VPPRVP4WnR#)z= connection is %sN)rIr5rEr`)r[r3s&&r,r3rbs) ::: KK  2EJJ ? r+cV^8dQhRR/#)r7r:r9r!)r<s"r,r=r>s((J(r+c VP\JdR#VPf\P#VPP #)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)r3r1rOrABNORMAL_CLOSUREcoderas&r, close_codeProtocol.close_codes9 ::V # __ $-- -??'' 'r+cV^8dQhRR/#)r7r:z str | Noner!)r<s"r,r=r>s**j*r+c zVP\JdR#VPfR#VPP#)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)r3r1rOreasonras&r, close_reasonProtocol.close_reasons0 ::V # __ $??)) )r+cV^8dQhRR/#)r7r:rr!)r<s"r,r=r>s!!+!r+c |VP\JgQR4hVPeTVPeFVPP\ 9d'VPP\ 9d\ pM\pV!VPVPVP4pVPVn V#)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) r3r1rOrPrhr rrrQrZ __cause__)r[exc_typeexcs& r, close_excProtocol.close_excs zzV#B%BB# OO '+$$6$$6)H,H ( OO OO  % %!    r+c V^8dQhRRRR/#r7databytesr:r;r!)r<s"r,r=r>s4r+c fVPPV4\VP4R#)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)rT feed_datarYrXr[rzs&&r, receive_dataProtocol.receive_datas" d# T[[r+cV^8dQhRR/#r7r:r;r!)r<s"r,r=r>sTr+c VPP'dR#VPP4\VP4R#)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)rTeoffeed_eofrYrXras&r, receive_eofProtocol.receive_eofs0 ;;???   T[[r+c$V^8dQhRRRRRR/#r7rzr{finboolr:r;r!)r<s"r,r=r>#s!33e3$343r+c VP'g \R4hVP\Jd1\ RVP P P4 24hV'*VnVP\\W44R#)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) rKr r`r/r r3rErF send_framerrr[rzrs&&&r,send_continuationProtocol.send_continuation#si"--- ?@ @ ;;d " 0E0E0G/HIJ J-0& gt12r+c$V^8dQhRRRRRR/#rr!)r<s"r,r=r>;s!33e3$3$3r+c VP'd \R4hVP\Jd1\ RVP P P4 24hV'*VnVP\\W44R#)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) rKr r`r/r r3rErFrrrrs&&&r, send_textProtocol.send_text;si  ) ) ) ?@ @ ;;d " 0E0E0G/HIJ J-0& gt12r+c$V^8dQhRRRRRR/#rr!)r<s"r,r=r>Rs!555D5D5r+c VP'd \R4hVP\Jd1\ RVP P P4 24hV'*VnVP\\W44R#)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) rKr r`r/r r3rErFrrrrs&&&r, send_binaryProtocol.send_binaryRsi  ) ) ) ?@ @ ;;d " 0E0E0G/HIJ J-0& i34r+c$V^8dQhRRRRRR/#)r7rhr9rnstrr:r;r!)r<s"r,r=r>is!""z"#"t"r+c VP\Jd1\RVPPP 4 24hVf0VR8wd \ R4h\\PR4pRpM\W4pVP4pVP\\V44VPeQhW0n\ VnR#)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. rNrmz#cannot send a reason without a coder+)r`r/r r3rErFr rrNO_STATUS_RCVD serializerrrrOrPr0r[rhrncloserzs&&& r, send_closeProtocol.send_closeis$ ;;d " 0E0E0G/HIJ J <|#$IJJ)22B7ED$'E??$D h-.&&& r+c V^8dQhRRRR/#ryr!)r<s"r,r=r>..e..r+c VP\JdEVP\Jd1\RVPP P 4 24hVP\\V44R#)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`r/r0r r3rErFrrrr~s&&r, send_pingProtocol.send_pingR ;;d "t{{''A 0E0E0G/HIJ J gt,-r+c V^8dQhRRRR/#ryr!)r<s"r,r=r>rr+c VP\JdEVP\Jd1\RVPP P 4 24hVP\\V44R#)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`r/r0r r3rErFrrrr~s&&r, send_pongProtocol.send_pongrr+c$V^8dQhRRRRRR/#)r7rhintrnrr:r;r!)r<s"r,r=r>s!---c-4-r+c VP\JdvV\P8wda\ W4pVP 4pVP \\V44W0n VPeRVn \VnVP\Jd#VP'gVP!4VP#4Vn\'VP$4R#)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)r3r/rrgrrrrrrPrOrQr0r8r(rSsend_eofdiscardrXrYrs&&& r,fail Protocol.fails& :: y111d+(h 56"' ??.04D-$ 99 t}}} MMO lln  T[[r+cV^8dQhRR/#)r7r:z list[Event]r!)r<s"r,r=r>s   r+c ,VP.uqnV#)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. )rU)r[rUs& r,events_receivedProtocol.events_receiveds#kk2  r+cV^8dQhRR/#)r7r:z list[bytes]r!)r<s"r,r=r>skr+c ,VP.uqnV#)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. )rV)r[rVs& r, data_to_sendProtocol.data_to_sends"#kk2  r+cV^8dQhRR/#)r7r:rr!)r<s"r,r=r>s)))r+c VP\JdR#VP\JdR#VP\JdR#VP\JgQhVP #)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)r3r/r0r1r.rSras&r,close_expectedProtocol.close_expectedsND ::  ::  :: zzZ'''}}r+cV^8dQhRR/#r7r:zGenerator[None]r!)r<s"r,r=r>/sFCFCFCr+c# "VPP4RjxL 'd9VP'dVPPR4\ R4hVP fRpM8VP fVP pMVP VP , p\P!VPPVP\JVVPR7RjxL pVP'dVPPRV4VPV4EK<ELLI \d;pTP\ P"\%T44Y0nRp?EMORp?i\d;pTP\ P(\%T44Y0nRp?EM Rp?i\*dJpTP\ P,TP. RTP0 24Y0nRp?MRp?i\2dUpTP5TP 4TP\ P6\%T44Y0nRp?M]Rp?i\8dMpTPP;RRR 7TP\ P<4Y0nRp?MRp?ii;iRx\?R 4h5i) 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)maskr4rMz< %sz at position z parser failed)exc_infoz"parse() shouldn't step after error) rTat_eofrIr5EOFErrorr4rJrrW read_exactr8r(rM recv_framer rrPROTOCOL_ERRORrrZrgUnicodeDecodeError INVALID_DATArnstartr set_current_sizeMESSAGE_TOO_BIG ExceptionerrorINTERNAL_ERRORAssertionError)r[r4framerus& r,rWProtocol.parse/s6 "#{{11333zzz ))'2 ##=>>==(#H]]*#}}H#}}t}}wsCCCr+c# "VP\J;'gVP\JVP8XgQhVP P 4RjxL 'gVP P4KDVP'dVPPR4VP\Jd%VP\JdVP4\VnRx\R4hL5i)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)r8r(r3r.rSrTrrrIr5r)rr1rras&r,rProtocol.discardws V#??tzzZ'?T]]SSS"kk00222 KK   ! ::: KK  g & 99 4::Z#? MMO  ABB3sADD D(-DA.Dc V^8dQhRRRR/#r7rrr:r;r!)r<s"r,r=r>sN"N"N"$N"r+c @VP\JgVP\JdHVPe \ R4hVP 'g\ VP4VnEMVP\JdcVPf \ R4hVP 'd RVnEMV;P\ VP4, unEMVP\Jd.\\VP4pVPV4EM\VP\JdEMFVP\JEd\P!VP4VnVP"\$JdVP&fQhRVnVPe \ R4hVP"\*JdMVP\\VP44VP VnRVn\$VnVP,\.JdVP14VP34Vn\7VP44M\9RVPR 24hVP:P=V4R#) z Process an incoming frame. NrrFzincomplete fragmented messageTzunexpected opcode: 02x)opcoderrrJr rlenrzrrrrrrrrWrOr3r0rPrQr/r8r(rrrXrYrrUappend)r[r pong_frames&& r,rProtocol.recv_frames <<7 "elli&?}}(#$CDD999 #EJJ \\W $}}$#$CDDyyy $  UZZ0 \\W $w 3J OOJ ' \\W $  \\X %$kk%**5DOzzW$222,1)}}(#$CDDzzT! h ;<"&//,0)$ yyF" ,,.DK  !#6u||C6H!IJ J 5!r+c V^8dQhRRRR/#rr!)r<s"r,r=r>s   $ r+c VP'dVPPRV4VPPVP VP \ JVPR74R#)z> %s)rrMN)rIr5rVrrr8r)rM)r[rs&&r,rProtocol.send_framesU ::: KK  fe ,  OOYY&(??   r+cV^8dQhRR/#rr!)r<s"r,r=r>s%%$%r+c VP'dQhRVnVP'dVPPR4VPP \ 4R#)Tz> EOFN)rSrIr5rVrSEND_EOFras&r,rProtocol.send_eofsE===   ::: KK  g & 8$r+)r`rOrQrPrJrIrSrUrKrMrRrBr5r4rLrXrZrTr8r3rNrVi)T)Nrm)rm)r"r#r$r%r&r/r\propertyr3setterrirorvrrrrrrrrrrrrrWrrrrr*r!r+r,rrIs B1 B1 % B1 %) B1H   \\ (($**$!!J *303.5."H. . -b  ()ZFCPCrs"  %"   &!33  gx&'?4<<  1DLL1     zz --  Em %m %r+