5hxXjSSKJr SSKrSSKrSSKrSSKrSSKJr SSK J r J r J r J r Jr SSKJr SSKJrJr SSKJrJrJr SS KJr SS KJr SS KJrJrJr SS K J!r!J"r" SS K#J$r$J%r% SSK&J'r' SSK J(r(J)r)J*r* SSK+J,r,J-r-J.r.J/r/J0r0 SSK1J2r2 SSK3J4r4 /SQr5"SS\25r6SSSSSSSS\!SSSSSSSSSSSS.S0Sjjr7S1S2Sjjr8SS K9J:r: SS!K;J,r< \:Rz\:Rz\:R|\:R|S".r?SS#SS#S".r@S3S$jrAS4S5S&jjrCS6S'jrDSSSS(.S7S)jjrE\ "S*5rF\ "S+\ S,\F4S-9rG"S.S/5rHg!\Ba S3S%jrANdf=f)8) annotationsN)Sequence)AnyCallableLiteralTypeVarcast)ClientProtocol)Headers HeadersLike)InvalidProxyMessageInvalidProxyStatus ProxyError)ClientExtensionFactory) enable_client_permessage_deflate)build_authorization_basic build_hostvalidate_subprotocols) USER_AGENTResponse) CONNECTINGEvent) StreamReader) LoggerLikeOrigin Subprotocol)Proxy WebSocketURI get_proxy parse_proxy parse_uri) Connection)Deadline)connect unix_connectClientConnectionc^\rSrSrSrSSSSS.S U4SjjjrS\S4SS jjrSU4S jjrSU4S jjr S r U=r $)r(a :mod:`threading` implementation of a WebSocket client connection. :class:`ClientConnection` provides :meth:`recv` and :meth:`send` methods for receiving and sending messages. It supports iteration to receive messages:: for message in websocket: process(message) The iterator exits normally when the connection is closed with close code 1000 (OK) or 1001 (going away) or without a close code. It raises a :exc:`~websockets.exceptions.ConnectionClosedError` when the connection is closed with any other code. The ``ping_interval``, ``ping_timeout``, ``close_timeout``, and ``max_queue`` arguments have the same meaning as in :func:`connect`. Args: socket: Socket connected to a WebSocket server. protocol: Sans-I/O connection.   ping_interval ping_timeout close_timeout max_queuec b>U [R"5Ul[TU]UUUUUUS9 g)Nr.) threadingr response_rcvdsuper__init__)selfsocketprotocolr/r0r1r2 __class__s a/var/www/html/cementerio_25MayoBackend/env/lib/python3.13/site-packages/websockets/sync/client.pyr7ClientConnection.__init__6s; &__.   '%'  Nc8UR[S9 URR5UlUb%URR R U5 Ub&URR RSU5 URRUR5 SSS5 URRU5(d [S5eURRbURReg!,(df  Ng=f)z! Perform the opening handshake. )expected_stateN User-Agentz.timed out while waiting for handshake response) send_contextrr:r&requestheadersupdate setdefault send_requestr5wait TimeoutError handshake_exc)r8additional_headersuser_agent_headertimeouts r< handshakeClientConnection.handshakeKs  j  9==002DL!- $$++,>? , $$// >OP MM & &t|| 4 :!!&&w//OP P == & & 2---- - 3: 9s BD  Dc>URc8[U[5(deXlURR 5 g[ TU]U5 g)z Process one incoming event. N)response isinstancerr5setr6 process_event)r8eventr;s r<rTClientConnection.process_eventgsH == eX.. ..!M    " " $ G !% (r>c>[TU]5 URR5 g!URR5 f=f)z9 Read incoming data from the socket and process events. N)r6 recv_eventsr5rS)r8r;s r<rXClientConnection.recv_eventsus:  % G  !    " " $D   " " $s ,A)rCrQr5)r9 socket.socketr:r r/ float | Noner0r[r1r[r2*int | None | tuple[int | None, int | None]returnNone)rKHeadersLike | NonerL str | NonerMr[r]r^)rUrr]r^)r]r^) __name__ __module__ __qualname____firstlineno____doc__r7rrNrTrX__static_attributes__ __classcell__)r;s@r<r(r(s<')%'&(@B  ! $  #  $ >    .26(2 $ ...&. .  .8 ) % %r>r(deflateTr,r+ir-)socksslserver_hostnameorigin extensions subprotocols compressionrKrLproxy proxy_sslproxy_server_hostname open_timeoutr/r0r1max_sizer2loggercreate_connectionc Uc2SU;a,URS5n[R"S[5 [ U5nUR (dUb [ S5eURSS5nURSS5nU(a"UcUc [ S5eUbUb [ S 5eUb [U5 US :Xa [U5nOUb[ S U35eU(aSn UbSn U S La [U5n [U 5nUc[nUGc[U(ai[R"[R[R5nURUR!55 UceUR#U5 OU b[%U 5nUR&SS S:Xa[)UUUURSS5S9nOUR&SSS:Xa1UR&S:waU b [ S5e[+UUU4U U U S.UD6nOX[-S5eUR/SUR!55 [R0"UR2UR4440UD6nURS5 U(d/UR7[R8[R:S 5 UR (aUc[<R>"5nUc UR2nURUR!55 U cURAXS9nO$[CXUS9n[RU5nURS5 [GUUUUUUS9nU"UUUUUUS9nURMUU UR!55 URU5 U$![Ha UbURK5 ef=f![Ha, URO5 URPRS5 ef=f)a Connect to the WebSocket server at ``uri``. This function returns a :class:`ClientConnection` instance, which you can use to send and receive messages. :func:`connect` may be used as a context manager:: from websockets.sync.client import connect with connect(...) as websocket: ... The connection is closed automatically when exiting the context. Args: uri: URI of the WebSocket server. sock: Preexisting TCP socket. ``sock`` overrides the host and port from ``uri``. You may call :func:`socket.create_connection` to create a suitable TCP socket. ssl: Configuration for enabling TLS on the connection. server_hostname: Host name for the TLS handshake. ``server_hostname`` overrides the host name from ``uri``. origin: Value of the ``Origin`` header, for servers that require it. extensions: List of supported extensions, in order in which they should be negotiated and run. subprotocols: List of supported subprotocols, in order of decreasing preference. compression: The "permessage-deflate" extension is enabled by default. Set ``compression`` to :obj:`None` to disable it. See the :doc:`compression guide <../../topics/compression>` for details. additional_headers (HeadersLike | None): Arbitrary HTTP headers to add to the handshake request. user_agent_header: Value of the ``User-Agent`` request header. It defaults to ``"Python/x.y.z websockets/X.Y"``. Setting it to :obj:`None` removes the header. proxy: If a proxy is configured, it is used by default. Set ``proxy`` to :obj:`None` to disable the proxy or to the address of a proxy to override the system configuration. See the :doc:`proxy docs <../../topics/proxies>` for details. proxy_ssl: Configuration for enabling TLS on the proxy connection. proxy_server_hostname: Host name for the TLS handshake with the proxy. ``proxy_server_hostname`` overrides the host name from ``proxy``. open_timeout: Timeout for opening the connection in seconds. :obj:`None` disables the timeout. ping_interval: Interval between keepalive pings in seconds. :obj:`None` disables keepalive. ping_timeout: Timeout for keepalive pings in seconds. :obj:`None` disables timeouts. close_timeout: Timeout for closing the connection in seconds. :obj:`None` disables the timeout. max_size: Maximum size of incoming messages in bytes. :obj:`None` disables the limit. max_queue: High-water mark of the buffer where frames are received. It defaults to 16 frames. The low-water mark defaults to ``max_queue // 4``. You may pass a ``(high, low)`` tuple to set the high-water and low-water marks. If you want to disable flow control entirely, you may set it to ``None``, although that's a bad idea. logger: Logger for this client. It defaults to ``logging.getLogger("websockets.client")``. See the :doc:`logging guide <../../topics/logging>` for details. create_connection: Factory for the :class:`ClientConnection` managing the connection. Set it to a wrapper or a subclass to customize connection handling. Any other keyword arguments are passed to :func:`~socket.create_connection`. Raises: InvalidURI: If ``uri`` isn't a valid WebSocket URI. OSError: If the TCP connection fails. InvalidHandshake: If the opening handshake fails. TimeoutError: If the opening handshake times out. N ssl_contextzssl_context was renamed to sslz-ssl argument is incompatible with a ws:// URIunixFpathzmissing path argumentz(path and sock arguments are incompatiblerhzunsupported compression: Tsockssource_address) local_addrhttphttpsz8proxy_ssl argument is incompatible with an http:// proxyrLrjrkzunsupported proxyrMrk)rlrmrnrtrur.)+popwarningswarnDeprecationWarningr"secure ValueErrorrrr r%r(r9AF_UNIX SOCK_STREAM settimeoutrMr&r!schemeconnect_socks_proxyconnect_http_proxyAssertionErrorrFrvhostport setsockopt IPPROTO_TCP TCP_NODELAY ssl_modulecreate_default_context wrap_socket SSLSSLSocketr r ExceptioncloserN close_socketrecv_events_threadjoinstart_keepalive)uririrjrkrlrmrnrorKrLrprqrrrsr/r0r1rtr2rurvkwargsws_uriryrzdeadline proxy_parsedsock_2r: connections r<r&r&s\ {}.jj' ,  s^F ==S_HIIFE*Dzz&$/D #E D"((!,6#**g5):O(V.$ +<%(= !D))<==!!)X-=-=-?@//[[&++. OOD ! OOF..0B0BD I =={ 779&"(++ OOH,,. / tM%dQFMM62 OOD !" !%  '  '%'           #    JJL  !%%**, sI N!N4N146O*c xUc)URS5cURS5cSnOSn[SUSUS.UD6$)a Connect to a WebSocket server listening on a Unix socket. This function accepts the same keyword arguments as :func:`connect`. It's only available on Unix. It's mainly useful for debugging servers listening on Unix sockets. Args: path: File system path to the Unix socket. uri: URI of the WebSocket server. ``uri`` defaults to ``ws://localhost/`` or, when a ``ssl`` is provided, to ``wss://localhost/``. rjrxzws://localhost/zwss://localhost/T)rryrz)getr&)rzrrs r<r'r'sG* { ::e  $M)B)J#C$C  ;sD ;F ;;r>) ProxyType)r)socks5hsocks5socks4asocks4Fc [[URURURUR UR [UR5nURSUR55 UR"URUR40UD6$![[[R4a e[an[S5UeSnAff=f)z0Connect via a SOCKS proxy and return the socket.rMz failed to connect to SOCKS proxyN) SocksProxySOCKS_PROXY_TYPESrrrusernamepasswordSOCKS_PROXY_RDNSrFrMr&OSErrorrIr9rr)rprrr socks_proxyexcs r<rrs! ell + JJ JJ NN NN U\\ *   )X%5%5%78 J&&v{{FKKJ6J Jv~~6   J?@c I Js<'B$$)C CCc [S5e)Nz-python-socks is required to use a SOCKS proxy) ImportError)rprrrs r<rrs IJJr>c[URURURSS9n[ 5n[URURUR5US'UbX$S'UR b2UR ce[UR UR 5US'SUS3R5UR5-$)NT)always_include_portHostrAzProxy-AuthorizationzCONNECT z HTTP/1.1 ) rrrrr rrrencode serialize)rprrLrrDs r<prepare_connect_requestrs fkk6;; SW XDiG fkk6==IGFO$ 1  ~~!~~))))B NNENN* %&dV= ) 0 0 2W5F5F5H HHr>c[5n[R"URURUR SS9nUR UR55 URS5nU(aURU5 OUR5 [U5 Mf![aon[UR[5(deURnSURs=::aS:aO OUsSnAUR S5 $[!U5eSnAf["Ra [%S5e[&an[)S5UeSnAff=f!UR S5 f=f)NF) include_bodyii,z(timed out while connecting to HTTP proxyz0did not receive a valid HTTP response from proxy)rrparse read_line read_exact read_to_eofrrMrecv feed_datafeed_eofnext StopIterationrRvalue status_coderr9rIrr)rirreaderparserdatarrQs r<read_connect_responsers/ ^F ^^ F  OOH,,. /99T?D  &! L /#))X....99 (&& , ,O %X. . >>GEFF ! >   sDA'B(( E2AD:E;E D+E EEEE.rc URSUR55 [R"URUR 440UD6nUR S:XafUc[R"5nUc URnURUR55 URXuS9nURS5 UR[XU55 [Xr5 U$![a UR5 ef=f)NrMrr)rFrMr9rvrrrrrrrsendallrrrr)rprrrLrjrkrris r<rrs i!1!1!34  # #UZZ$< G GD ||w ;335C  "#jjO ((*+tE  LL(8IJKd- K   s C--D TF.)boundcl\rSrSrSrSrS S SjjrSSjrSSjrSSjr SS jr SS jr S r g)ri;zf Socket-like object providing TLS-in-TLS. Only methods that are used by websockets are implemented. iNc[R"5Ul[R"5UlXlUR URURUS9UlURUR R5 g)Nr) r MemoryBIOincomingoutgoing ssl_socketwrap_bio ssl_objectrun_io do_handshake)r8rirxrks r<r7SSLSSLSocket.__init__Esi #,,. ",,. %.. MM MM+/  DOO001r>cSnSnU"U6nURR 5nU(aUR R U5 U(adUR RUR5nU(aURRU5 OURR5 MU(aMW$![Ra SnN[Ra SnNf=f)NTF) rSSLWantReadErrorSSLWantWriteErrorrreadrrr recv_bufsizerwrite write_eof)r8funcargs want_read want_writeresultrs r<rSSLSSLSocket.run_ioUsIJ "t==%%'D''-++D,=,=>MM''-MM++-M-.. ! // "!  "sB>>C.C.-C.cURURRU5$![Ra gf=f)Nr>)rrrr SSLEOFError)r8buflens r<rSSLSSLSocket.recvss: ;;t33V< <%%  s %(??cNURURRU5$N)rrr)r8rs r<sendSSLSSLSocket.sendys{{4??00$77r>cSn[U5o3RS5n[U5nX%:aX RXBS5- nX%:aMSSS5 SSS5 g!,(df  N=f!,(df  g=f)NrB) memoryviewr lenr)r8rcountview byte_viewamounts r<rSSLSSLSocket.sendall|s]  yy~^F.9V#455.(6  ~~  s"A.+A A. A+ 'A.. A<c.[URU5$r)getattrr)r8names r< __getattr__SSLSSLSocket.__getattr__st--r>)rrrrr)rirZrxzssl_module.SSLContextrkr`r]r^)rzCallable[..., T]rrr]r)rintr]bytes)rrr]r)rrr]r^)rstrr]r) rarbrcrdrerr7rrrrrrfrr>r<rr;sWL '+ 22+2$ 2  2 < 86.r>r).rrrizsocket.socket | Nonerjssl_module.SSLContext | Nonerkr`rlz Origin | Nonermz'Sequence[ClientExtensionFactory] | NonernzSequence[Subprotocol] | Noneror`rKr_rLr`rpzstr | Literal[True] | Nonerqrrrr`rsr[r/r[r0r[r1r[rtz int | Noner2r\ruzLoggerLike | Nonervztype[ClientConnection] | Nonerrr]r()NN)rzr`rr`rrr]r() rprrrrr%rrr]rZr)rprrrrLr`r]r)rirZrr%r]r)rprrrrr%rLr`rjrrkr`rrr]rZ)I __future__rr9rjrr4rcollections.abcrtypingrrrrr clientr datastructuresr r exceptionsrrrextensions.baserextensions.permessage_deflaterrDrrrhttp11rrr:rrstreamsrrrrrrrr r!r"rr$utilsr%__all__r(r&r' python_socksrpython_socks.syncrSOCKS5SOCKS4rrrrrrrrrrrr>r<rsp" $88#1LL4LRR)("44HH" :b%zb%R"&(,"& :>15'-1$.(,.2(,!#"$!#"$ <> $7;;D D  D & D  D D8D/DD+D"D &D ,!D"&#D&'D( )D*+D, -D01D2:3D6 7D:5;D<=D>?DP< < << <<3K&5##""##""  JJJJ J  JN%)I I I"I I&N%)(,"&# # ## " # & # ###L CL CxQ'(M.M.UKKKKK K  KKs