vjb) zdZddlmZddlZddlZddlmZgdZGddeZ Gd d e Z Gd d e Z Gd de Z Gdde Z Gdde ZGddeZGddeZGddeZGddeZGddeZGddeZGdd eZGd!d"eZGd#d$eZGd%d&eZGd'd(eZGd)d*e ZGd+d,e ZGd-d.e eZGd/d0e eZej@rdd1l!m"Z"m#Z#m$Z$m%Z%eZ&nee'd2d2d2d2d2d34dd5l(m)Z)m*Z*y)6a :mod:`websockets.exceptions` defines the following hierarchy of exceptions. * :exc:`WebSocketException` * :exc:`ConnectionClosed` * :exc:`ConnectionClosedOK` * :exc:`ConnectionClosedError` * :exc:`InvalidURI` * :exc:`InvalidHandshake` * :exc:`SecurityError` * :exc:`InvalidMessage` (legacy) * :exc:`InvalidStatus` * :exc:`InvalidStatusCode` (legacy) * :exc:`InvalidHeader` * :exc:`InvalidHeaderFormat` * :exc:`InvalidHeaderValue` * :exc:`InvalidOrigin` * :exc:`InvalidUpgrade` * :exc:`NegotiationError` * :exc:`DuplicateParameter` * :exc:`InvalidParameterName` * :exc:`InvalidParameterValue` * :exc:`AbortHandshake` (legacy) * :exc:`RedirectHandshake` (legacy) * :exc:`ProtocolError` (Sans-I/O) * :exc:`PayloadTooBig` (Sans-I/O) * :exc:`InvalidState` (Sans-I/O) * :exc:`ConcurrencyError` ) annotationsN) lazy_import)WebSocketExceptionConnectionClosedConnectionClosedOKConnectionClosedError InvalidURIInvalidHandshake SecurityErrorInvalidMessage InvalidStatusInvalidStatusCode InvalidHeaderInvalidHeaderFormatInvalidHeaderValue InvalidOriginInvalidUpgradeNegotiationErrorDuplicateParameterInvalidParameterNameInvalidParameterValueAbortHandshakeRedirectHandshake ProtocolErrorWebSocketProtocolError PayloadTooBig InvalidStateConcurrencyErrorceZdZdZy)rz? Base class for all exceptions defined by websockets. N__name__ __module__ __qualname____doc__f/workspace/moltex-experiments/.pixi/envs/default/lib/python3.12/site-packages/websockets/exceptions.pyrrFr'rcVeZdZdZ d ddZd dZed dZed dZy) ra Raised when trying to interact with a closed connection. Attributes: rcvd: If a close frame was received, its code and reason are available in ``rcvd.code`` and ``rcvd.reason``. sent: If a close frame was sent, its code and reason are available in ``sent.code`` and ``sent.reason``. rcvd_then_sent: If close frames were received and sent, this attribute tells in which order this happened, from the perspective of this side of the connection. Nc||_||_||_|jdu|jduxs|jduk(sJyNrcvdsentrcvd_then_sent)selfr.r/r0s r(__init__zConnectionClosed.__init__\sK   ,##t+d1B1WdiiSWFWXXXr'c|j|jyd|jdS|jd|jdS|jrd|jd|jSd|jd|jS)Nzno close frame received or sentzsent z; no close frame receivedz received z; no close frame sentz ; then sent z; then received r-r1s r(__str__zConnectionClosed.__str__gs 99 yy 8tyyk)BCCyy "499+-BCC&&&tyykdii[II"499+-=dii[IIr'ctjdt|jtj j S|jjS)NzZConnectionClosed.code is deprecated; use Protocol.close_code or ConnectionClosed.rcvd.code)warningswarnDeprecationWarningr.frames CloseCodeABNORMAL_CLOSUREcoder4s r(r=zConnectionClosed.codexsC  D  99 ##44 4yy~~r'c|tjdt|jy|jjS)Nz`ConnectionClosed.reason is deprecated; use Protocol.close_reason or ConnectionClosed.rcvd.reason)r7r8r9r.reasonr4s r(r@zConnectionClosed.reasons6  H  99 yyr'r,)r.frames.Close | Noner/rAr0z bool | NonereturnNonerBstr)rBint) r"r#r$r%r2r5propertyr=r@r&r'r(rrMsj $'+ Y! Y" Y$ Y  Y J"  r'rceZdZdZy)rz Like :exc:`ConnectionClosed`, when the connection terminated properly. A close code with code 1000 (OK) or 1001 (going away) or without a code was received and sent. Nr!r&r'r(rrr'rceZdZdZy)r z Like :exc:`ConnectionClosed`, when the connection terminated with an error. A close frame with a code other than 1000 (OK) or 1001 (going away) was received or sent, or the closing handshake didn't complete properly. Nr!r&r'r(r r rIr'r c eZdZdZddZddZy)r zL Raised when connecting to a URI that isn't a valid WebSocket URI. c ||_||_yr,urimsg)r1rNrOs r(r2zInvalidURI.__init__sr'c8|jd|jS)Nz isn't a valid URI: rMr4s r(r5zInvalidURI.__str__s((/z::r'N)rNrErOrErBrCrDr"r#r$r%r2r5r&r'r(r r s ;r'r ceZdZdZy)r zM Base class for exceptions raised when the opening handshake fails. Nr!r&r'r(r r r)r'r ceZdZdZy)r z Raised when a handshake request or response breaks a security rule. Security limits can be configured with :doc:`environment variables <../reference/variables>`. Nr!r&r'r(r r rIr'r c eZdZdZddZddZy)rzJ Raised when a handshake response rejects the WebSocket upgrade. c||_yr,)response)r1rVs r(r2zInvalidStatus.__init__s   r'c6d|jjdS)Nz+server rejected WebSocket connection: HTTP d)rV status_coder4s r(r5zInvalidStatus.__str__s# MM--a0 2 r'N)rVzhttp11.ResponserBrCrDrQr&r'r(rrs ! r'rc"eZdZdZdddZddZy)rzK Raised when an HTTP header doesn't have a valid format or value. Nc ||_||_yr,namevaluer1r]r^s r(r2zInvalidHeader.__init__  r'c|jd|jdS|jdk(rd|jdSd|jd|jS)Nzmissing z headerr?zempty zinvalid z header: r^r]r4s r(r5zInvalidHeader.__str__sY :: dii[0 0 ZZ2 DII;g. .dii[ $**> >r'r,r]rEr^ str | NonerBrCrDrQr&r'r(rrs ?r'rc$eZdZdZdfd ZxZS)rz Raised when an HTTP header cannot be parsed. The format of the header doesn't match the grammar for that header. c6t|||d|d|y)Nz at z in superr2)r1r]errorheaderpos __class__s r(r2zInvalidHeaderFormat.__init__s# %SEfX>?r') r]rErirErjrErkrFrBrCr"r#r$r%r2 __classcell__rls@r(rrs@@r'rceZdZdZy)rz Raised when an HTTP header has a wrong value. The format of the header is correct but the value isn't acceptable. Nr!r&r'r(rrsr'rc$eZdZdZdfd ZxZS)rzD Raised when the Origin header in a request isn't allowed. c&t|d|y)NOriginrg)r1originrls r(r2zInvalidOrigin.__init__s 6*r')rtrdrBrCrmros@r(rrs ++r'rceZdZdZy)rzF Raised when the Upgrade or Connection header isn't correct. Nr!r&r'r(rrr)r'rceZdZdZy)rzG Raised when negotiating an extension or a subprotocol fails. Nr!r&r'r(rr r)r'rc eZdZdZddZddZy)rzK Raised when a parameter name is repeated in an extension header. c||_yr,r]r1r]s r(r2zDuplicateParameter.__init__  r'c d|jS)Nzduplicate parameter: ryr4s r(r5zDuplicateParameter.__str__s&tyyk22r'Nr]rErBrCrDrQr&r'r(rrs 3r'rc eZdZdZddZddZy)rzJ Raised when a parameter name in an extension header is invalid. c||_yr,ryrzs r(r2zInvalidParameterName.__init__%r{r'c d|jS)Nzinvalid parameter name: ryr4s r(r5zInvalidParameterName.__str__(s)$))55r'Nr}rDrQr&r'r(rrs 6r'rc eZdZdZddZddZy)rzK Raised when a parameter value in an extension header is invalid. c ||_||_yr,r\r_s r(r2zInvalidParameterValue.__init__2r`r'c|jd|jS|jdk(rd|jSd|jd|jS)Nzmissing value for parameter r?zempty value for parameter zinvalid value for parameter z: rbr4s r(r5zInvalidParameterValue.__str__6sU :: 1$))= = ZZ2 / {; ;1$))BtzzlK Kr'NrcrDrQr&r'r(rr,s Lr'rceZdZdZy)ra Raised when receiving or sending a frame that breaks the protocol. The Sans-I/O implementation raises this exception when: * receiving or sending a frame that contains invalid data; * receiving or sending an invalid sequence of frames. Nr!r&r'r(rr?sr'rceZdZdZy)raU Raised when parsing a frame with a payload that exceeds the maximum size. The Sans-I/O layer uses this exception internally. It doesn't bubble up to the I/O layer. The :meth:`~websockets.extensions.Extension.decode` method of extensions must raise :exc:`PayloadTooBig` if decoding a frame would exceed the limit. Nr!r&r'r(rrKs r'rceZdZdZy)ra Raised when sending a frame is forbidden in the current state. Specifically, the Sans-I/O layer raises this exception when: * sending a data frame to a connection in a state other :attr:`~websockets.protocol.State.OPEN`; * sending a control frame to a connection in a state other than :attr:`~websockets.protocol.State.OPEN` or :attr:`~websockets.protocol.State.CLOSING`. Nr!r&r'r(rrXs r'rceZdZdZy)rz Raised when receiving or sending messages concurrently. WebSocket is a connection-oriented protocol. Reads must be serialized; so must be writes. However, reading and writing concurrently is possible. Nr!r&r'r(rrgrIr'r)rr rrz.legacy.exceptions)rr rrr)aliases)r:http11)+r% __future__rtypingr7importsr__all__ Exceptionrrrr r r r rrrrrrrrrrrrAssertionErrorr RuntimeErrorr TYPE_CHECKINGlegacy.exceptionsrr rrrglobalsr?r:rr&r'r(rsz>#   <? )? D), ;# ;)$  $  ?$?& @- @+M+]' 3) 3 6+ 6L,L& &  &  %~ )< + 22!5!5&:   r'