i,@ddlmZddlZddlZddlZddlmZmZmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZdd lmZdd lmZdd lmZmZmZdd lmZmZmZddlm Z ddl!m"Z"ddl#m$Z$gdZ%Gdde"Z&dddddddddedddddddd=d9Z' d>d?d<Z(dS)@) annotationsN)AnyOptionalSequenceType)ClientProtocol) HeadersLike)ClientExtensionFactory) enable_client_permessage_deflate)validate_subprotocols) USER_AGENT)Response) CONNECTINGOPENEvent) LoggerLikeOrigin Subprotocol) parse_uri) Connection)Deadline)connect unix_connectClientConnectioncReZdZdZdddfd Zd ed fddZdfd Zdfd ZxZ S)ra Threaded 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. Args: socket: Socket connected to a WebSocket server. protocol: Sans-I/O connection. close_timeout: Timeout for closing the connection in seconds.  close_timeoutsocket socket.socketprotocolr r Optional[float]returnNonec|tj|_t|||dS)Nr) threadingr response_rcvdsuper__init__)selfr!r#r __class__s \/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/websockets/sync/client.pyr+zClientConnection.__init__1sO %&_..   '      Nadditional_headersOptional[HeadersLike]user_agent_header Optional[str]timeoutcj|t5|j|_||jj||||jjd<|j|jdddn #1swxYwY|j |s<| |j td|j<| |j td|jjt"urL|j |j| |j |jj |jjdS)z1 Perform the opening handshake. )expected_stateNz User-Agentztimed out during handshakez"connection closed during handshake) send_contextrr#rrequestheadersupdate send_requestr)wait close_socketrecv_events_threadjoin TimeoutErrorresponseConnectionErrorstaterr handshake_exc)r,r0r2r4s r. handshakezClientConnection.handshake@s  j  9 9 5 5=0022DL!- $++,>??? ,5F $\2 M & &t| 4 4 4  5 5 5 5 5 5 5 5 5 5 5 5 5 5 5!&&w// =        # ( ( * * *;<< < =        # ( ( * * *!"FGG G = d * *  # ( (); < < <        # ( ( * * * = & 2-- - 3 2sA0BBBeventrc|j9t|tsJ||_|jdSt |dS)z. Process one incoming event. N)rA isinstancerr)setr* process_event)r,rFr-s r.rJzClientConnection.process_eventdse = eX.. . ..!DM   " " $ $ $ $ $ GG ! !% ( ( ( ( (r/c t|jdS#|jwxYw)zI Read incoming data from the socket and process events. N)r* recv_eventsr)rI)r,r-s r.rLzClientConnection.recv_eventsrsV  % GG   ! ! !   " " $ $ $ $ $D  " " $ $ $ $s >A)r!r"r#r r r$r%r&)r0r1r2r3r4r$r%r&)rFrr%r&)r%r&) __name__ __module__ __qualname____doc__r+rrErJrL __classcell__)r-s@r.rrs8*,         "59+5#' ".".".".".H ) ) ) ) ) ) % % % % % % % % % %r/rFdeflateri)sock ssl_contextserver_hostnameunixpathorigin extensions subprotocolsr0r2 compression open_timeoutr max_sizeloggercreate_connectionuristrrSOptional[socket.socket]rTOptional[ssl.SSLContext]rUr3rVboolrWrXOptional[Origin]rY*Optional[Sequence[ClientExtensionFactory]]rZOptional[Sequence[Subprotocol]]r0r1r2r[r\r$r r] Optional[int]r^Optional[LoggerLike]r_ Optional[Type[ClientConnection]]r%c t|}|js|td|r'||td||tdn|J|t|| dkrt |}n| t d| t | }|t} ||rjtjtj tj }| | |J| |n3tj|j|jf| }| d|s+|tjtjd|jrq|t)j}||j}| | |||}| dt/||||t0|| }|||| }|| | | n%#t4$r||wxYw|S) 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:: async with websockets.sync.client.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_context: 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. 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. 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. open_timeout: Timeout for opening the connection in seconds. :obj:`None` disables the timeout. 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. 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. 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. Nz5ssl_context argument is incompatible with a ws:// URIzmissing path argumentz(path and sock arguments are incompatiblerRzunsupported compression: T)rU)rXrYrZrCr]r^r)rsecure TypeErrorr r ValueErrorrrr!AF_UNIX SOCK_STREAM settimeoutr4rr_hostport setsockopt IPPROTO_TCP TCP_NODELAYsslcreate_default_context wrap_socketr rrE Exceptionclose)r`rSrTrUrVrWrXrYrZr0r2r[r\r r]r^r_wsurideadliner# connections r.rr~sf cNNE <QK3OPPP  rs """""" 000000000000######((((((444444LLLLLL++++++..........4444444444"""""" : 9 9b%b%b%b%b%zb%b%b%R%),0%)#=A4804'1!*$&%'##':>1nnnnnnd<<<<<<