+ ioj^RIHt^RIt^RIt^RIt^RIHt^RIHtH t H t H t H t H t ^RIHt^RIHtHtHtHtHtHtHtHtHtHt^RIHtHt^RIHt^R I H!t!H"t"H#t#H$t$.ROt%]],],t&!R R ]PN4t(](PRt)](PTt*!RR ]PN4t+]+PXt,]+PZt-]+P\t.]+P^t/Rt0!RR 4t1R#)) annotationsN) Generator)ConnectionClosedConnectionClosedErrorConnectionClosedOK InvalidState PayloadTooBig ProtocolError) Extension) OK_CLOSE_CODES OP_BINARYOP_CLOSEOP_CONTOP_PINGOP_PONGOP_TEXTClose CloseCodeFrame)RequestResponse) StreamReader) BytesLike 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!Z/home/wkmabra/.openclaw/workspace/venv/lib/python3.14/site-packages/websockets/protocol.pyrr-s@1XNFFr+c4]tRt^7tRt]!^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,rr7s@(-a%Jgvr+r+c]tRt^GtRtR]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. 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. statemax_sizeloggerNc ,V^8dQhRRRRRRRRR R /#) siderr3rr4z*tuple[int | None, int | None] | int | Noner5zLoggerLike | NonereturnNoner!)formats"r, __annotate__Protocol.__annotate__YsCE1E1E1 E1 = E1 " E1 E1r+c \P!4VnVf2\P!RVP P 4 24pW@nVP\P4Vn Wn W n \V\4'gVfVRuVnVnMVwVnVnRVnRVnRVn.VnRVnRVnRVnRVnRVnRVn\74Vn.Vn.VnVP?4Vn \CVP@4RVn"R#)Nz websockets.F)#uuiduuid4idlogging getLoggernamelowerr5 isEnabledForDEBUGdebugr8r3 isinstanceintmax_message_sizemax_fragment_size current_sizeexpect_continuation_frameorigin extensions subprotocol close_rcvd close_sentclose_rcvd_then_sent handshake_exceof_sentrreadereventswritesparseparsernext parser_exc)selfr8r3r4r5s&&$$$r,__init__Protocol.__init__Ys7"ZZ\B >&&TYY__5F4G'HIF"( )((7    h $ $(8
s!33i3d3d3r+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) rNr rcr/rr3rDrErrrrs&&&r, send_textProtocol.send_text>si  ) ) ) ?@ @ ;;d " 0E0E0G/HIJ J-0& gt12r+c$V^8dQhRRRRRR/#rr!)r;s"r,r<r=Us!55 555r+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) rNr rcr/rr3rDrErrr rs&&&r, send_binaryProtocol.send_binaryUsi  ) ) ) ?@ @ ;;d " 0E0E0G/HIJ J-0& i34r+c$V^8dQhRRRRRR/#)r7rkzCloseCode | int | Nonerqstrr9r:r!)r;s"r,r<r=ls#""5"c"SW"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. rNrpz#cannot send a reason without a coder+)rcr/rr3rDrEr rrNO_STATUS_RCVD serializerrrrRrSr0r^rkrqcloser|s&&& r, send_closeProtocol.send_closels$ ;;d " 0E0E0G/HIJ J <|#$IJJ)22B7ED$'E??$D h-.&&& r+c V^8dQhRRRR/#r7r|rr9r:r!)r;s"r,r<r=..i.D.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) rcr/r0rr3rDrErrrrs&&r, send_pingProtocol.send_pingR ;;d "t{{''A 0E0E0G/HIJ J gt,-r+c V^8dQhRRRR/#rr!)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) rcr/r0rr3rDrErrrrs&&r, send_pongProtocol.send_pongrr+c$V^8dQhRRRRRR/#)r7rkzCloseCode | intrqrr9r:r!)r;s"r,r<r=s!---#-t-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/rrjrrrrrrSrRrTr0r8r(rVsend_eofdiscardr[r\rs&&& r,fail Protocol.fails& :: y111d+(h 56"' ??.04D-$ 99 t}}} MMO lln  T[[r+cV^8dQhRR/#)r7r9z 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. )rX)r^rXs& r,events_receivedProtocol.events_receiveds#kk2  r+cV^8dQhRR/#)r7r9z 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. )rY)r^rYs& r, data_to_sendProtocol.data_to_sends"#kk2  r+cV^8dQhRR/#)r7r9rr!)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.rVrds&r,close_expectedProtocol.close_expectedsND ::  ::  :: zzZ'''}}r+cV^8dQhRR/#r7r9zGenerator[None]r!)r;s"r,r<r=2sMCMCMCr+c# 0"VPP4RjxL 'd9VP'dVPPR4\ R4hRpVP e9VP fVP pMVP VP , pVPe'VfVPpM\WP4p\P!VPPVP\JVVPR7RjxL pVP'dVPPRV4VPV4EKoELQLI \ d;pTP#\$P&\)T44Y0nRp?EMORp?i\d;pTP#\$P,\)T44Y0nRp?EM Rp?i\.dJpTP#\$P0TP2 RTP4 24Y0nRp?MRp?i\6dUpTP9TP 4TP#\$P:\)T44Y0nRp?M]Rp?i\<dMpTPP?RRR 7TP#\$P@4Y0nRp?MRp?ii;iRx\CR 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)maskr4rPz< %sz at position z parser failed)exc_infoz"parse() shouldn't step after error)"rWat_eofrHr5EOFErrorrKrMrLminrrZ read_exactr8r(rP recv_framer rrPROTOCOL_ERRORrr]rjUnicodeDecodeError INVALID_DATArqstartr set_current_sizeMESSAGE_TOO_BIG ExceptionerrorINTERNAL_ERRORAssertionError)r^r4framerxs& r,rZProtocol.parse2s;= "#{{11333zzz ))'2 ##=>>((4((0#'#8#8#'#8#84;L;L#L))5'#'#9#9#&x1G1G#H $);;KK**f,%# $:::KK%%fe4&I44 " IIi..C 9!OO " IIi00#c( ;!OO! " IIi,, M#)).U V!OO "  !2!2 3 IIi//S :!OO " KK  o  = IIi.. /!OO  " ABBsLE8E3 E8E8C-E8,E6-E81E86E88 L/F82L8 LL/G;5L; LL ?I L LLA J*%L* L7L8AK?:L?LLcV^8dQhRR/#rr!)r;s"r,r<r=sCCCr+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.rVrWrrrHr5r)rr1rrds&r,rProtocol.discards V#??tzzZ'?T]]SSS"kk00222 KK   ! ::: KK  g & 99 4::Z#? MMO  ABB3sADD D(-DA.Dc V^8dQhRRRR/#r7rrr9r: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)opcoderr rMr rlenr|rrrrrrrrZrRr3r0rSrTr/r8r(rrr[r\rrXappend)r^r pong_frames&& r,rProtocol.recv_frames <<7 "elli&?  ,#$CDD999$' O! \\W $  (#$CDDyyy$(!!!S_4! \\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)rrPN)rHr5rYrrr8r)rP)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)rVrHr5rYrSEND_EOFrds&r,rProtocol.send_eofsE===   ::: KK  g & 8$r+)rcrRrTrSrMrHrVrXrNrPrUrAr5rLrKrOr[r]rWr8r3rQrYi)T)Nrp)rp)r"r#r$r%r&r/r_propertyr3setterrlrrryrrrrrrrrrrrrrZrrrrr*r!r+r,rrGs"E1 E1 @E E1 %) E1N   \\ (($**$!!J *303.5."H. . -b  ()ZMC^Crs"  %"   &!>>  (U"?4<<  1DLL1     zz --  Ey %y %r+