wg\jr&SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r SSK Jr SSKr"SS\R&5r"S S \R*5r"S S 5rg!\a SSKr\R$"S5 SrNUf=f) al Python WebSocket library Copyright 2011 Joel Martin Copyright 2016 Pierre Ossman Licensed under LGPL version 3 (see docs/LICENSE.LGPL-3) Supports following protocol versions: - http://tools.ietf.org/html/draft-ietf-hybi-thewebsocketprotocol-07 - http://tools.ietf.org/html/draft-ietf-hybi-thewebsocketprotocol-10 - http://tools.ietf.org/html/rfc6455 N) b64encode)sha1)urlparsez/no 'numpy' module, HyBi protocol will be slowerc\rSrSrSrg)WebSocketWantReadError"N__name__ __module__ __qualname____firstlineno____static_attributes__r O/home/edenadmin/noVNC/venv/lib/python3.13/site-packages/websockify/websocket.pyrr"rrc\rSrSrSrg)WebSocketWantWriteError$r Nr r rrrr$rrrc\rSrSrSrSrSrSrS/4SjrSr S r S r S r S r S rSrSrSrSrSrSrSrS&SjrS&SjrS'SjrS'SjrSrSrSrSrSrSrSr S r!S!r"S"r#S(S#jr$S$r%S%r&g)) WebSocket'aWebSocket protocol socket like class. This provides access to the WebSocket protocol by behaving much like a real socket would. It shares many similarities with ssl.SSLSocket. The WebSocket protocols requires extra data to be sent and received compared to the application level data. This means that a socket that is ready to be read may not hold enough data to decode any application data, and a socket that is ready to be written to may not have enough space for an entire WebSocket frame. This is handled by the exceptions WebSocketWantReadError and WebSocketWantWriteError. When these are raised the caller must wait for the socket to become ready again and call the relevant function again. A connection is established by using either connect() or accept(), depending on if a client or server session is desired. See the respective functions for details. The following methods are passed on to the underlying socket: - fileno - getpeername, getsockname - getsockopt, setsockopt - gettimeout, settimeout - setblocking z$258EAFA5-E914-47DA-95CA-C5AB0DC85B11cSUlSUlSUl/UlSUlSUlSUlSUlSUlSUl SUl g)z Creates an unconnected WebSocketnewrNF) _state _partial_msg _recv_buffer _recv_queue _send_buffer_previous_sendmsg _sent_close_received_close close_code close_reasonsocketselfs r__init__WebSocket.__init__GsY !% $  rcUS;a%URce[URU5$[URR<SU<S35e)N)fileno getpeername getsockname getsockopt setsockopt gettimeout settimeout setblockingz instance has no attribute '')r%getattrAttributeError __class__r )r'names r __getattr__WebSocket.__getattr__\sV # # ;;* **4;;- - "&.."9"94"AB BrNc SUl[U5nURnURS;a U(dSnO2URS;a U(dSnO[ SUR-5eUR S:Xa[ R"URU45UlURS;aF[R"5nURUR URS9UlS UlOS UlUR S :Xa!UR R5 S UlUR S :XGatS Ul [S 5H5nU=R[[ R""S 55- sl M7 [%URR'S55R)S5Ul UR*nU(dSnUR-SU5 UR/SUR5 UR/SS5 UR/SS5 UR/SUR5 UR/SS5 UbUR/SU5 [1U5S:a!UR/SSR3U55 UR55 SUlUR S:XaUR75 S UlUR S :XGaPUR95(d [ S!5eUR:R=S"5S#:Xa[>eUR:RAS$S%5uolUR)S5nURA5n [1U 5S&:d U SS':wa [ S(5eU S%S):wa [ S*S+R3U S%S5-5eUR:RAS"S%5uolU R)S5S,-n [BRD"U 5n U RGSS 5RI5S:wa[K[MU 55 [ S-5eU RGS.5n U c [ S/5e[OURURP-R'S55RS5n [%U 5R)S5n U? X:wa [ S05eU RGS5Ul*[1U5S:XaURTb [ S15eOURTU;a [ S25eS3Ulg[ S45e)5a*Establishes a new connection to a WebSocket server. This method connects to the host specified by uri and negotiates a WebSocket connection. origin should be specified in accordance with RFC 6454 if known. A list of valid sub-protocols can be specified in the protocols argument. The data will be sent in the clear if the "ws" scheme is used, and encrypted if the "wss" scheme is used. Both WebSocketWantReadError and WebSocketWantWriteError can be raised whilst negotiating the connection. Repeated calls to connect() must retain the same arguments. T)wshttpP)wsshttpsizUnknown scheme '%s'r)server_hostname ssl_handshakeheaderslatin-1ascii/GETHostUpgrade websocket ConnectionupgradeSec-WebSocket-KeySec-WebSocket-Version NOriginrSec-WebSocket-Protocolz, send_headersresponsezSocket closed unexpectedlys s zHTTP/1.1zInvalid response101zWebSocket request denied: %s  #Missing or incorrect upgrade headerSec-WebSocket-Acceptz#Missing Sec-WebSocket-Accept headerz#Invalid Sec-WebSocket-Accept headerz(Unexpected Sec-WebSocket-Protocol headerz!Invalid protocol chosen by serverdone WebSocket is in an invalid state)+clientrportscheme Exceptionrr%create_connectionhostnamesslcreate_default_context wrap_socket do_handshake_keyrangechrrandom randrangerencodedecodepath send_request send_headerlenjoin end_headers_flush_recvrfindrsplitemailmessage_from_stringgetlowerprinttyperGUIDdigestprotocol) r'uriorigin protocolsracontextirqrequestwordsrBacceptexpecteds rconnectWebSocket.connectis`  smxx :: ' ZZ+ +1CJJ>? ? ;;%  22CLL$3GHDKzz--446%11$++BE,,2P - ' ;;/ ) KK $ $ &#DK ;;) #DI2Y S!1!1#!677 !$))"2"29"=>EEgNDI88D   eT *   VS\\ 2   Y 4   \9 5   0$)) <   4b 9!  629~!  !9499Y;OP    (DK ;;. ( KKM$DK ;;* $::<< <==  %%k2b8,,+/+<+<+B+B7A+N (W'nnY/GMMOEE QE!H $: 233Qx5  >%PQPR)AT TUU+/+<+<+B+B;PQ+R (W'nnY/&8G//8G{{9b)//1[@d7m$ EFF[[!78F~ EFFTYY2::7CDKKMH *11':H ! EFF#KK(@ADM9~"==,#$NOO-== 1#$GHH DK :;;rcBURS:XGaSUlXlURSS5R 5S:wa [ S5eURS5nUc [ S 5eUS ;aS [ U5-UlO[ S U-5eURS 5nUc [ S5e[X@R-RS55R5n[U5RS5nSUlURSS5RS5nU(a1UR!U5UlURU;a [ S5eUR#SS5 UR%SS5 UR%SS5 UR%SU5 UR(aUR%SUR5 UR'5 SUlURS:XaUR)5 SUlg[ S5e)aEstablishes a new WebSocket session with a client. This method negotiates a WebSocket connection with an incoming client. The caller must provide the client socket and the headers from the HTTP request. A server can identify that a client is requesting a WebSocket connection by looking at the "Upgrade" header. It will include the value "websocket" in such cases. WebSocketWantWriteError can be raised if the response cannot be sent right away. accept() must be called again once more space is available using the same arguments. rFrNrCrLr\rPNz$Missing Sec-WebSocket-Version header)7813z hybi-%02dzUnsupported protocol version %srOz Missing Sec-WebSocket-Key headerrGrS,zInvalid protocol selectedezSwitching ProtocolsrKrMr]flushr^r_)rr`r%r}r~rcintversionrrrorrrprrzselect_subprotocol send_responsersrvrw)r'r%rBverkeyrrs rrWebSocket.accepts& ;;% DK K{{9b)//1[@ EFF++56C{ FGG &&*SX5  AC GHH++12C{ BCC3?227;<CCEFv&--g6FDM $s $rcg)zCalled when a WebSocket pong message is received. This will be called whilst processing recv()/recvmsg(). The default implementation does nothing.Nr rs r handle_pongWebSocket.handle_pongEs rc"UR5$)aYRead data from the WebSocket. This will return any available data on the socket (which may be the empty string if the peer sent an empty message or messages). If the socket is closed then None will be returned. The reason for the close is found in the 'close_code' and 'close_reason' properties. Unlike recvmsg() this method may return data from more than one WebSocket message. It is however not guaranteed to return all buffered data. Callers should continue calling recv() whilst pending() returns True. Both WebSocketWantReadError and WebSocketWantWriteError can be raised when calling recv(). )recvmsgr&s rrecvWebSocket.recvLs"||~rcUR(aUR5 gUR5(aUR5$UR 5(dgUR5$)a2Read a single message from the WebSocket. This will return a single WebSocket message from the socket (which will be the empty string if the peer sent an empty message). If the socket is closed then None will be returned. The reason for the close is found in the 'close_code' and 'close_reason' properties. Unlike recv() this method will not return data from more than one WebSocket message. Callers should continue calling recvmsg() whilst pending() returns True. Both WebSocketWantReadError and WebSocketWantWriteError can be raised when calling recvmsg(). N)r"rwpending_recvmsg _recv_framesr&s rrWebSocket.recvmsg_sT"    KKM <<>>==? "  ""}}rc2[UR5S:$)aCheck if any WebSocket data is pending. This method will return True as long as there are WebSocket frames that have yet been processed. A single recv() from the underlying socket may return multiple WebSocket frames and it is therefore important that a caller continues calling recv() or recvmsg() as long as pending() returns True. Note that this function merely tells if there are raw WebSocket frames pending. Those frames may not contain any application data. r)rtrr&s rrWebSocket.pendings4##$q((rcD[U5S:XagURU5$)aWrite data to the WebSocket This will queue the given data and attempt to send it to the peer. Unlike sendmsg() this method might coalesce the data with data from other calls, or split it over multiple messages. WebSocketWantWriteError can be raised if there is insufficient space in the underlying socket. send() must be called again once more space is available using the same arguments. r)rtsendmsg)r'bytess rsendWebSocket.sends! u:?||E""rcL[U[5(d[eUR(agURb8URU:wa[ eUR 5 SUl[U5$URSU5 [U5$![a Xlef=f)auWrite a single message to the WebSocket This will queue the given message and attempt to send it to the peer. Unlike send() this method will preserve the data as a single WebSocket message. WebSocketWantWriteError can be raised if there is insufficient space in the underlying socket. sendmsg() must be called again once more space is available using the same arguments. rNrX) isinstancer TypeErrorr!r ValueErrorrwrt_sendmsgr)r'msgs rrWebSocket.sendmsgs#u%%O     ! ! -%%,  KKM%)D "s8O  MM#s # 3x ' %( "  s 4BB#c.URSX4-5 g)NzHTTP/1.1 %d %s  _queue_str)r'codemessages rrWebSocket.send_responses ,>?rc6URU<SU<S35 g)Nz: r[r)r'keywordvalues rrsWebSocket.send_headers 78rc&URS5 g)Nr[rr&s rrvWebSocket.end_headerss rcRURUR5<SU<S35 g)NrZz HTTP/1.1 )rupper)r'rrqs rrrWebSocket.send_requests  dCDrc[U[5(d[eURb.URU:wa[eUR 5 SUlgUR SU5 g![a Xlef=f)zWrite a ping message to the WebSocket WebSocketWantWriteError can be raised if there is insufficient space in the underlying socket. ping() must be called again once more space is available using the same arguments. N rrrr rrwrrrs rpingWebSocket.pingu$&&O  ! ! -%%-  KKM%)D "   MM#t $& %) "   A++A=c[U[5(d[eURb.URU:wa[eUR 5 SUlgUR SU5 g![a Xlef=f)zWrite a pong message to the WebSocket WebSocketWantWriteError can be raised if there is insufficient space in the underlying socket. pong() must be called again once more space is available using the same arguments. N rrs rrWebSocket.pongrrc"UR(aUR5 gUR(dSUlSUlSUlSnUb0U[ R "SU5- nUbXCRS5- nURSU5 g) aGracefully terminate the WebSocket connection. This will start the process to terminate the WebSocket connection. The caller must continue to calling recv() or recvmsg() after this function in order to wait for the peer to acknowledge the close. Calls to send() and sendmsg() will be ignored. WebSocketWantWriteError can be raised if there is insufficient space in the underlying socket for the close message. shutdown() must be called again once more space is available using the same arguments. The how argument is currently ignored. NzLocally initiated closeTr>HUTF-8) r!rwr"r#r$structpackror)r'howrreasonrs rshutdownWebSocket.shutdowns$    KKM ##"DO 9D    6;;tT* *C!}}W-- c3rcdUR[RX5 UR5 g)aXTerminate the WebSocket connection immediately. This will close the WebSocket connection directly after sending a close message to the peer. WebSocketWantWriteError can be raised if there is insufficient space in the underlying socket for the close message. close() must be called again once more space is available using the same arguments. N)rr% SHUT_RDWR_close)r'rrs rcloseWebSocket.close's! f&&5 rcURceURRS5n[ U5S:XagU=RU- sl[URS5(a"URR5(dgOgM![a*nUR[R:Xa[ eeSnAff=f)NTirFr) r%rOSErrorerrno EWOULDBLOCKrrtrhasattrr)r'rexcs rrxWebSocket._recv5s{{&&& {{''- 4yA~    % t{{I..{{**,, -) 99 1 1100 sB C%CCcJUR5(d:URcSUlSUlS=UlUlUR 5 gUR UR5nUcgURUSSUlURRU5 MT)NizConnection closed abnormallyTFlength) rxr#r$r!r"r _decode_hybirrappend)r'frames rrWebSocket._recv_framesOszz||&"&$B!:>> 4#7 KKM%%d&7&78E}!% 1 1%/2B CD     # #E * rcxUR(GapURRS5nUR(d-US(d#UR[R SS5 MkUR(a-US(a#UR[R SS5 MUSS:XamUR (d#UR[R SS5 MU=R US- slUS (aUR nS UlU$GOOUSS :Xa#UR[R S S 5 GO#USS:XaPUR (a$UR[R SS5 GMUS (aUS$USUlGOUSS:XGaUR(aGMSUlUR(aUR5 gUS (d$UR[R S S5 GMSnSn[US5S:aL[R"SUSSS5Sn[US5S:aUSSSnURS5nUcSUlSUlOX0lUbX@lURSX45 gUSS:XaCUS (d$UR[R S S5 GMUR#US5 OsUSS:XaCUS (d$UR[R S S5 GM2UR%US5 O'UR[R S SUS-5 UR(aGMp[&e![a& UR[R SS5 GMf=f)Nrmaskediz Procotol error: Frame not maskedzProcotol error: Frame maskedopcodez-Procotol error: Unexpected continuation framepayloadfinrrWiz*Unsupported: Text frames are not supportedrXz$Procotol error: Unexpected new framerTzUnsupported: Fragmented closerrz&Procotol error: Invalid UTF-8 in closeiz&No close status code specified by peerrzUnsupported: Fragmented pingrzUnsupported: Fragmented pongz"Unsupported: Unknown opcode 0x%02x)rpopr`rr%rrr"r!rrtrunpackrpUnicodeDecodeErrorr#r$rrr)r'rrrrs rrWebSocket._recvmsgbs5$$((+E;;uX f..6XY{{uX f..6TUX#%((MM&"2"2D:ij!!U9%55!<++C(+D%J xC' f..6bcxC'$$MM&"2"2D:`a< ++(-i(8D%xC''''+$##KKMU|MM&"2"2D:YZuY'(A-!==uY/?/CDQGD5+,q0!&y!1!"!5%%+]]7%;F <&*DO(PD%&*O),2) dD1xC'U|MM&"2"2D:XY  y!12xC'U|MM&"2"2D:XY  y!12 f..6Z]bck]l6lmcf%$; 2% MM&*:*:DBjk$%s+N +N98N9cUR(dgURceURRUR5nURUSUlUR(a[ eUR(a#UR(aUR5 ggg![a*nUR[R :Xa[ eeSnAff=fN) rr%rrrrrr"r!r)r'sentrs rrwWebSocket._flushs  {{&&& ;;##D$5$56D !--de4   ) )   D$4$4 KKM%5  yyE-----  s%B(( C2%CCcNU=RU- slUR5 gr)rrwrs r_sendWebSocket._sends T! rcLU=RURS5- slg)NrF)rro)r'strings rrWebSocket._queue_strs V]]955rcUR(aNSn[S5H*nU[R"S5R 5- nM, UR XU5nOUR X5nUR U5$)NrrE)r`rkrmrnto_bytes _encode_hybir)r'rrmaskrrs rrWebSocket._sendmsgsk ;;D1X((-6688%%f48E%%f2Ezz%  rcFURR5 SUlgr)r%rr&s rrWebSocket._closes  rc$URX5$r)_unmask)r'bufr s r_maskWebSocket._masks||C&&rc[(GaP[U5nSnUnS=pgUS:a[R"S5n[RS:XaUR S5n[R "X(SS9n[R "X[US- 5S9n [R"X5R5nUS-(a[R"S 5n[RS:XaUR S5n[R "X(US-S9n[R "XX3S-- US-S 9n [R"X5R5nXg-$[R"S 5n U RU5 [[U 55Hn X==X*S--ss'M U R5$) Nrrr zrW)countB)offsetr) numpyrtdtypesys byteorder newbyteorder frombufferr bitwise_xortobytesarray frombytesrk) r'rr plenpstartpendbcrrrs rrWebSocket._unmasksn 5s8DFDKAqykk%(==E)!..s3E''1=''#dQh-H%%d199;axkk#&==E)!..s3E''D1HF''#ax0D%%d199;5L;;s#D NN3 3t9%4A;&&<<> !rcbUS-nU(aUS-nSnUbSnURX#5n[U5nUS::a[R"SXWU-5nOKUS:a#US:a[R"SUSU-U5nO"US:a[R"S US U-U5nUbWU-U-$WU-$) zEncode a HyBi style WebSocket frame. Optional opcode: 0x0 - continuation 0x1 - text frame 0x2 - binary frame 0x8 - connection close 0x9 - ping 0xA - pong r}>BBiz>BBH~z>BBQ)rrtrr) r'rrmask_keyrb1mask_bit payload_lenheaders rr WebSocket._encode_hybisd]  $JB  H**S+C#h # [[(,BCF 3 ;#6[[S8^[IF E ![[S8^[IF  H$s* *C< rc(SSSSSS.n[U5nSnX4:ag[R"SUSS5upVUS-US'US -(US 'US -(US 'US (a US - nX4:agUS -nUS:Xa(US- nX4:ag[R"SUSS 5unO-US :Xa'US- nX4:ag[R"SUSS5unXG-US'X2S:agUS (a"XS - UnURXXG-U5US'U$XXG-US'U$)zDecode HyBi style WebSocket packets. Returns: {'fin' : boolean, 'opcode' : number, 'masked' : boolean, 'length' : encoded_length, 'payload' : decoded_buffer} rFN)rrrrrrXr/r,rr-rrr r1r0rrz>Qrrr)rtrrr) r'rfblenhlenr3b2rr2s rrWebSocket._decode_hybi2s\ #"  $ 3x ;uc"1g.4i( I%!Dy/( X; AID{d S= AID{mmD#a(3GF s] AID{mmD#a)4GFm( H+  X;6$'H<<$+(?JAiLT[2AiLr)rjrr r"rrrr!rr`r#r$rr%r)r)rN)NT)'r r r r__doc__rr(r8rrrrrrrrrrrrsrvrrrrrrrxrrrwrrrrrrr rrr rrrr's: 2D* B#'"~<@Irr#r{rrmr%rfrbase64rhashlibr urllib.parserr ImportErrorwarningswarnSSLWantReadErrorrSSLWantWriteErrorrrr rrrGs  !  S11  c33 D D  MMCD EsA//BB