mhb) dZddlmZddlZddlZddlmZgdZGddeZ 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*dS)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 InvalidStateConcurrencyErrorceZdZdZdS)rz? Base class for all exceptions defined by websockets. N__name__ __module__ __qualname____doc__@/usr/local/lib/python3.11/site-packages/websockets/exceptions.pyrrFr'rcVeZdZdZ ddd Zdd ZeddZeddZdS)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. Nrcvdframes.Close | Nonesentrcvd_then_sent bool | NonereturnNonecn||_||_||_|jdu|jdup|jduksJdSNr+r-r.)selfr+r-r.s r(__init__zConnectionClosed.__init__\sM   ,#t+d1B1WdiSWFWXXXXXXr'strc|j|jdSd|jdS|j d|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 r4r5s r(__str__zConnectionClosed.__str__gs 9 y 88CtyCCCCy C49CCCC&JItyIIdiIIII49IIdiIIIr'intc~tjdt|jtjjS|jjS)NzZConnectionClosed.code is deprecated; use Protocol.close_code or ConnectionClosed.rcvd.code)warningswarnDeprecationWarningr+frames CloseCodeABNORMAL_CLOSUREcoder9s r(rCzConnectionClosed.codexs?  D    9 #4 4y~r'c`tjdt|jdS|jjS)Nz`ConnectionClosed.reason is deprecated; use Protocol.close_reason or ConnectionClosed.rcvd.reason)r=r>r?r+reasonr9s r(rFzConnectionClosed.reasons9  H    9 2yr'r3)r+r,r-r,r.r/r0r1r0r7)r0r;) r"r#r$r%r6r:propertyrCrFr&r'r(rrMs  $'+ Y Y Y Y Y J J J J"X   X   r'rceZdZdZdS)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'rceZdZdZdS)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 rJr'r c"eZdZdZd dZd dZd S) r zL Raised when connecting to a URI that isn't a valid WebSocket URI. urir7msgr0r1c"||_||_dSr3rMrN)r5rMrNs r(r6zInvalidURI.__init__sr'c$|jd|jS)Nz isn't a valid URI: rPr9s r(r:zInvalidURI.__str__s(:::::r'N)rMr7rNr7r0r1rGr"r#r$r%r6r:r&r'r(r r sF ;;;;;;r'r ceZdZdZdS)r zM Base class for exceptions raised when the opening handshake fails. Nr!r&r'r(r r r)r'r ceZdZdZdS)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 rJr'r c"eZdZdZd dZd dZd S) rzJ Raised when a handshake response rejects the WebSocket upgrade. responsehttp11.Responser0r1c||_dSr3)rV)r5rVs r(r6zInvalidStatus.__init__s   r'r7c"d|jjdS)Nz+server rejected WebSocket connection: HTTP d)rV status_coder9s r(r:zInvalidStatus.__str__s! 2M- 1 2 2 r'N)rVrWr0r1rGrRr&r'r(rrsF !!!!      r'rc$eZdZdZd d d Zd d ZdS)rzK Raised when an HTTP header doesn't have a valid format or value. Nnamer7value str | Noner0r1c"||_||_dSr3r]r^r5r]r^s r(r6zInvalidHeader.__init__  r'cv|j d|jdS|jdkr d|jdSd|jd|jS)Nzmissing z headerrEzempty zinvalid z header: r^r]r9s r(r:zInvalidHeader.__str__sW : 0di000 0 Z2  .DI... .>di>>$*>> >r'r3r]r7r^r_r0r1rGrRr&r'r(rrsK ??????r'rc$eZdZdZd fd ZxZS) rz Raised when an HTTP header cannot be parsed. The format of the header doesn't match the grammar for that header. r]r7errorheaderposr;r0r1c\t||d|d|dS)Nz at z in superr6)r5r]rhrirj __class__s r(r6zInvalidHeaderFormat.__init__s9 %>>S>>f>>?????r') r]r7rhr7rir7rjr;r0r1r"r#r$r%r6 __classcell__rns@r(rrsQ@@@@@@@@@@r'rceZdZdZdS)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. originr_r0r1cLtd|dS)NOriginrl)r5rtrns r(r6zInvalidOrigin.__init__s# 6*****r')rtr_r0r1rorqs@r(rrsG ++++++++++r'rceZdZdZdS)rzF Raised when the Upgrade or Connection header isn't correct. Nr!r&r'r(rrr)r'rceZdZdZdS)rzG Raised when negotiating an extension or a subprotocol fails. Nr!r&r'r(rr r)r'rc"eZdZdZd dZd dZdS) rzK Raised when a parameter name is repeated in an extension header. r]r7r0r1c||_dSr3r]r5r]s r(r6zDuplicateParameter.__init__  r'cd|jS)Nzduplicate parameter: r{r9s r(r:zDuplicateParameter.__str__s2ty222r'Nr]r7r0r1rGrRr&r'r(rrsF 333333r'rc"eZdZdZd dZd dZdS) rzJ Raised when a parameter name in an extension header is invalid. r]r7r0r1c||_dSr3r{r|s r(r6zInvalidParameterName.__init__%r}r'cd|jS)Nzinvalid parameter name: r{r9s r(r:zInvalidParameterName.__str__(s5$)555r'NrrGrRr&r'r(rrsF 666666r'rc"eZdZdZd dZd d Zd S) rzK Raised when a parameter value in an extension header is invalid. r]r7r^r_r0r1c"||_||_dSr3rarbs r(r6zInvalidParameterValue.__init__2rcr'cr|j d|jS|jdkr d|jSd|jd|jS)Nzmissing value for parameter rEzempty value for parameter zinvalid value for parameter z: rer9s r(r:zInvalidParameterValue.__str__6sQ : =$)== = Z2  ; ;; ;K$)KKtzKK Kr'NrfrGrRr&r'r(rr,sL LLLLLLr'rceZdZdZdS)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'rceZdZdZdS)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'rceZdZdZdS)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'rceZdZdZdS)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(rrgrJr'r)rr rrz.legacy.exceptions)rr rrr)aliases)r@http11)+r% __future__rtypingr=importsr__all__ Exceptionrrrr r r r rrrrrrrrrrrrAssertionErrorr RuntimeErrorr TYPE_CHECKINGlegacy.exceptionsrr rrrglobalsrEr@rr&r'r(rs>#"""""     <? ? ? ? ? )? ? ? D), ; ; ; ; ;# ; ; ;)$      $    ?????$???& @ @ @ @ @- @ @ @+++++M+++]' 3 3 3 3 3) 3 3 3 6 6 6 6 6+ 6 6 6LLLLL,LLL&     &        &        %~   )< +K 22!5!5&:       r'