iYSSKrSSKrSSKrSSKJr SSKJr SSKJrJr SSK J r J r J r J r JrJrJrJrJr SSKJr SSKJr SSKJr S S KJrJr "S S 5r"S S\5r"SS\5rg)N)time)urlsplit)ConnectionType WSConnection) AcceptConnectionRejectConnectionCloseConnectionMessageRequestPingPong TextMessage BytesMessage)PerMessageDeflate) CloseReason)LocalProtocolError)ConnectionErrorConnectionClosedcV\rSrSrS SjrSrSrS SjrSSjrSr S r S r S r g)BaseNc SUlXlX0lX@lXPlSUl/UlSUlSUlSUl U[R:HUl [RUlSUlUcSSKn U R$nUcSSKn U R&nUc[(R*nXlU"5Ul[1U5UlUR55 UR(d [75eU"UR8S9UlUR:R<R?SS5UR:lUR:RA5 g)NTrF)targetz (_thread)z(simple_websocket.Base._thread))! subprotocolsock receive_bytes ping_intervalmax_message_size pong_received input_bufferincoming_messageincoming_message_len connectedrSERVER is_serverrNO_STATUS_RCVD close_reason close_message threadingThreadEvent selectorsDefaultSelectorselector_classeventrws handshaker_threadthreadnamereplacestart) selfrconnection_typerrr thread_class event_classr/r*s P/home/admin/cozy_coffee/venv/lib/python3.13/site-packages/simple_websocket/ws.py__init__ Base.__init__s%  ** 0! $$%!)^-B-BB'66!   $++L   #//K  !&66N, ] / ~~!# #"$,,7 ;;++33 :<  cgN)r8s r<r2Base.handshakeBs r?cbUR(d [URUR5e[ U[ 5(a#UR R[US95nO+UR R[[U5S95nURRU5 g)zSend data over the WebSocket connection. :param data: The data to send. If ``data`` is of type ``bytes``, then a binary message is sent. Else, the message is sent in text format. )dataN) r$rr(r) isinstancebytesr1sendr rstrr)r8rEout_datas r<rH Base.sendFss~~"4#4#4d6H6HI I dE " "ww||G$67Hww||KSY$?@H x r?cUR(anUR(d]URRUS9(dgURR 5 UR(aUR(dM]URR S5$![ a Of=fUR(d [URUR5eg)aMReceive data over the WebSocket connection. :param timeout: Amount of time to wait for the data, in seconds. Set to ``None`` (the default) to wait indefinitely. Set to 0 to read without blocking. The data received is returned, as ``bytes`` or ``str``, depending on the type of the incoming message. )timeoutNr) r$r!r0waitclearpop IndexErrorrr(r))r8rMs r<receive Base.receiveUsnnT%6%6::??7?3 JJ   nnT%6%6%6 $$((+ +   ~~"4#4#4d6H6HI IsB B)(B)cDUR(d [URUR5eURR [ U=(d [RU55nURR U5 SUlg![a Nf=f)aClose the WebSocket connection. :param reason: A numeric status code indicating the reason of the closure, as defined by the WebSocket specification. The default is 1000 (normal closure). :param message: A text message to be sent to the other side. FN) r$rr(r)r1rHr rNORMAL_CLOSURErBrokenPipeError)r8reasonmessagerJs r<close Base.closejs~~"4#4#4d6H6HI I77<<  0k00'!;<  IINN8 $   s/B BBcgrArB)r8requests r<choose_subprotocolBase.choose_subprotocol|sr?cSnUR(aS[5UR-nUR5nURUR[ R S5 UR(GaYU(a[5nWU::dURX#- 5(dUR(d9UR[RSS9 URR5 OSUl URR!UR"R![%555 ['X25UR-nMURR)UR*5n[-U5S:Xa [/5eUR"R1U5 UR35UlUR(aGMYU(aUR5OS URR5 g![a SUlGNf=f![.[4[64a% SUlURR5 Mf=f)NTFzPing/Pong timeoutrWrXr)rrr/registerrr- EVENT_READ ValueErrorr$selectr rYrPOLICY_VIOLATIONr0setrHr1r maxrecvrlenOSError receive_data_handle_eventsConnectionResetErrorr)r8sel next_pingnowin_datas r<r3 Base._threads   !3!33I%%'C ' TYY (<(5(d6[?UR<UR4-RA55UlOU=R<UR4RA5- slOf[UR<[>5(d([?UR<UR4-5UlOU=R<UR4- slURB(dGMY[UR<[D[F45(a&URHRKUR<5 Ow[U[,5(a4URHRKUR<RM55 O.URHRK[GUR<55 SUlSUlUR"R%5 GMFGMI U(aURPR U5 U$![Na# SnUR"R%5 SnGMf=f)NTr?)r extensionsFzMessage is too bigr))r1eventsrFr r]rrHrrr r&responsecoder(rWr)r$r0rfr r r rrr#rirErrMESSAGE_TOO_BIGr" bytearrayencodemessage_finishedrIrGr!appenddecoderr)r8 keep_goingrJr0s r<rlBase._handle_eventssj WW^^%EF #eW--'+'>'>u'ED$ -=$($4$4$5$7#8.:!;;H 77~~ GGLL1A$BB(- D%).D&%*DNJJNN$!&Jt,, U^^-= >>Ht,,)-D& \'BCC--UZZ@-,, 558M8MM GGLL'779M2O%PP (%* ,,4 16 -#E;77)$*?*?KK4=!%!6!6!C K K M5OD1!11UZZ5F5F5HH1)$*?*?KK4= $ 5 5 B5DD1!11UZZ?1 11 !$"7"7#uFF))001F1FG#E;77))00 1188:<))00t7L7L1MN,0D)01D-JJNN$G&P  IINN8 $ & #  "  #s;A#R BR"AR%RCRD.R8C*R(R;:R;)r)r(r$r0r"r#r!r&rrr rr/rrr4r1NNNNNNNrANN) __name__ __module__ __qualname____firstlineno__r=r2rHrRrYr]r3rl__static_attributes__rBr?r<rrs7FJ6:EI&P  !J*$ $LMr?rc\^\rSrSrSrSU4Sjjr\SSj5rSrSr Sr U=r $) ServerzThis class implements a WebSocket server. Instead of creating an instance of this class directly, use the ``accept()`` class method to create individual instances of the server, each bound to a client request. c *>XlU=(d /Ul[UR[5(aUR/UlSUlSn SU;aUR S5n SUlOSU;aUR S5n SUlOSU;a'UR S5R 5n SUlOUR SS 5RS 5(arUS n [U S 5(d[U S 5(a U Rn [U S 5(a.U RRn U R5n S UlU c [S5e[T U]AU ["R$UUUXgUS9 g![a NCf=f)Nunknownzwerkzeug.socketwerkzeugzgunicorn.socketgunicornzeventlet.inputeventletSERVER_SOFTWAREgeventz wsgi.inputrawrfilez+Cannot obtain socket from WSGI environment.)r9rrrr:r;r/)environ subprotocolsrFrImodeget get_socket startswithhasattrrr_sockdupNotImplementedError RuntimeErrorsuperr=rr%) r8rrrrrr:r;r/r wsgi_input __class__s r<r=Server.__init__s (.B d'' - -!%!2!2 3D    ';;01D"DI ' );;01D"DI  (;;/0;;=D"DI [[*B / : :!.J:u--'*g2N2N'-- z5))!~~++88:D% <LM M ~/D/D'4'4*:&2(6  8 +s>F FFc U"XX4UXgUS9$)aCAccept a WebSocket connection from a client. :param environ: A WSGI ``environ`` dictionary with the request details. Among other things, this class expects to find the low-level network socket for the connection somewhere in this dictionary. Since the WSGI specification does not cover where or how to store this socket, each web server does this in its own different way. Werkzeug, Gunicorn, Eventlet and Gevent are the only web servers that are currently supported. :param subprotocols: A list of supported subprotocols, or ``None`` (the default) to disable subprotocol negotiation. :param receive_bytes: The size of the receive buffer, in bytes. The default is 4096. :param ping_interval: Send ping packets to clients at the requested interval in seconds. Set to ``None`` (the default) to disable ping/pong logic. Enable to prevent disconnections when the line is idle for a certain amount of time, or to detect unresponsive clients and disconnect them. A recommended interval is 25 seconds. :param max_message_size: The maximum size allowed for a message, in bytes, or ``None`` for no limit. The default is ``None``. :param thread_class: The ``Thread`` class to use when creating background threads. The default is the ``threading.Thread`` class from the Python standard library. :param event_class: The ``Event`` class to use when creating event objects. The default is the `threading.Event`` class from the Python standard library. :param selector_class: The ``Selector`` class to use when creating selectors. The default is the ``selectors.DefaultSelector`` class from the Python standard library. )rrrrr:r;r/rB) clsrrrrrr:r;r/s r<accept Server.accept*s P7!.$4 ,"0 2 2r?cSnURR5Hvup#URS5(dMSRUSSR S5Vs/sHoDR 5PM sn5nXSUS3R 5- nMx US- nURRU5 UR5Ul gs snf) NsGET / HTTP/1.1 HTTP_-_z: z s ) ritemsrjoinsplit capitalizerzr1rkrlr$)r8rqkeyvaluepheaders r<r2Server.handshakeXs',,,,.JC~~g&&3qr7==;M"N;Ma<<>;M"NOXRwd3::<</ 7 W%,,. #OsC cPURHnX R;dMUs $ g)aChoose a subprotocol to use for the WebSocket connection. The default implementation selects the first protocol requested by the client that is accepted by the server. Subclasses can override this method to implement a different subprotocol negotiation algorithm. :param request: A ``Request`` object. The method should return the subprotocol to use, or ``None`` if no subprotocol is chosen. N)r)r8r\rs r<r]Server.choose_subprotocolbs+#//K///""0r?)r$rrr)NrNNNNN) rrrr__doc__r= classmethodrr2r]r __classcell__rs@r<rrsH BFIM26)8V>BGK04+2+2Z/r?rcf^\rSrSrSrSU4Sjjr\SSj5rSrS U4Sjjr Sr U=r $) ClientitzThis class implements a WebSocket client. Instead of creating an instance of this class directly, use the ``connect()`` class method to create an instance that is connected to a server. c >[U5n U RS;n U RUlU R=(d U (aSOSUlU R UlU R (a"U=R SU R -- slU=(d /Ul[UR[5(aUR/Ul/Ul [U[5(a6UR5H!upURRX45 M# O[U[5(aX0l [R "URUR[R"S9n[%U5S:Xa ['5e[R"USSUSSUSS5nU (aHUc,[(R*"[(R,R.S 9nUR1XRS 9nUR3USS 5 [4TU]mU[8R:UUUXS 9 g) N)httpswssiP?)typerr)purpose)server_hostname)r9rrrr:r;)rschemehostnamehostportpathqueryrrFrIextra_headeersdictrr|listsocket getaddrinfo SOCK_STREAMrirsslcreate_default_contextPurpose SERVER_AUTH wrap_socketconnectrr=rCLIENT)r8urlrheadersrrr ssl_contextr:r; parsed_url is_securerrconnection_argsrrs r<r=Client.__init__{sc] %%)99 '' OOAyb OO    IIz/// /I(.B d'' - -!%!2!2 3D   gt $ $%mmo ##**C<8.  & &")  ,,TYY 282D2DF  1 $!# #}}_Q/2OA4Fq4I,Q/24 "!88KK335 **4*KD _Q'*+ ~/D/D'4'4*:&2  Mr?c U"XUXEXgXS9 $)aGReturns a WebSocket client connection. :param url: The connection URL. Both ``ws://`` and ``wss://`` URLs are accepted. :param subprotocols: The name of the subprotocol to use, or a list of subprotocol names in order of preference. Set to ``None`` (the default) to not use a subprotocol. :param headers: A dictionary or list of tuples with additional HTTP headers to send with the connection request. Note that custom headers are not supported by the WebSocket protocol, so the use of this parameter is not recommended. :param receive_bytes: The size of the receive buffer, in bytes. The default is 4096. :param ping_interval: Send ping packets to the server at the requested interval in seconds. Set to ``None`` (the default) to disable ping/pong logic. Enable to prevent disconnections when the line is idle for a certain amount of time, or to detect an unresponsive server and disconnect. A recommended interval is 25 seconds. In general it is preferred to enable ping/pong on the server, and let the client respond with pong (which it does regardless of this setting). :param max_message_size: The maximum size allowed for a message, in bytes, or ``None`` for no limit. The default is ``None``. :param ssl_context: An ``SSLContext`` instance, if a default SSL context isn't sufficient. :param thread_class: The ``Thread`` class to use when creating background threads. The default is the ``threading.Thread`` class from the Python standard library. :param event_class: The ``Event`` class to use when creating event objects. The default is the `threading.Event`` class from the Python standard library. )rrrrrrr:r;rB) rrrrrrrrr:r;s r<rClient.connects!R37!.$4 ,G Gr?c URR[URURUR UR S95nURRU5 URRUR5nURRU5 [URR55n[U[5(a[!UR"5e[U[$5(d [!S5eUR&UlSUlg![a Of=fM)N)rrr extra_headersTi)r1rHr rrrrrrhrrknextru StopIterationrFrr status_coderrr$)r8rJrqr0s r<r2Client.handshakes77<<TYYtyy595F5F6:6I6I!KL x iinnT%7%78G GG  ) TWW^^-. e- . .!%"3"34 4E#344!#& & ,,!   s+#D22 D?>D?cT>[TU]XS9 URR5 g)Nr`)rrYr)r8rWrXrs r<rY Client.closes  V 5 r?)r$rrrrrrrr) rrrrrr=rrr2rYrrrs@r<rrtsI 8rs^ !0   1.05\\~yTyxtTtr?