o g.@s0ddlmZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZddlmZdd lmZdd lmZdd lmZmZdd lmZmZdd l mZmZmZddlmZddl m!Z!ddl"m#Z#gdZ$Gddde!Z%dddddddeddddddddd?d:d;Z&  d@dAd=d>Z'dS)B) annotationsN)Sequence)Any)ClientProtocol) HeadersLike)ClientExtensionFactory) enable_client_permessage_deflate)validate_subprotocols) USER_AGENTResponse) CONNECTINGEvent) LoggerLikeOrigin Subprotocol) parse_uri) Connection)Deadline)connect unix_connectClientConnectioncsXeZdZdZddddfddZdedfd ddZd!fdd Zd"fdd ZZ S)#ra  :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 ``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.  close_timeout max_queuesocket socket.socketprotocolrr float | Noner*int | None | tuple[int | None, int | None]returnNonecs&|t|_tj||||ddS)Nr) threadingr response_rcvdsuper__init__)selfrr rr __class__M/var/www/visachat/venv/lib/python3.10/site-packages/websockets/sync/client.pyr(4s  zClientConnection.__init__Nadditional_headersHeadersLike | Noneuser_agent_header str | NonetimeoutcCs|jtd*|j|_|dur|jj||dur"||jjd<|j|jWdn1s3wY|j |sBt d|jj durL|jj dS)z1 Perform the opening handshake. )expected_stateNz User-Agentztimed out during handshake) send_contextr r rrequestheadersupdate send_requestr&wait TimeoutError handshake_exc)r)r.r0r2r,r,r- handshakeEs    zClientConnection.handshakeeventrcs<|jdurt|ts J||_|jdSt|dS)z. Process one incoming event. N)response isinstancer r&setr' process_event)r)r=r*r,r-rAas zClientConnection.process_eventcs(z tW|jdS|jw)zI Read incoming data from the socket and process events. N)r' recv_eventsr&r@)r)r*r,r-rBos zClientConnection.recv_events) rrr rrr!rr"r#r$)r.r/r0r1r2r!r#r$)r=rr#r$)r#r$) __name__ __module__ __qualname____doc__r(r r<rArB __classcell__r,r,r*r-rs rdeflaterir)socksslserver_hostnameorigin extensions subprotocolsr.r0 compression open_timeoutrmax_sizerloggercreate_connectionuristrrIsocket.socket | NonerJssl_module.SSLContext | NonerKr1rL Origin | NonerM'Sequence[ClientExtensionFactory] | NonerNSequence[Subprotocol] | Noner.r/r0rOrPr!rrQ int | Nonerr"rRLoggerLike | NonerStype[ClientConnection] | Nonekwargsrr#cKs:|durd|vr|d}tdtt|}|js"|dur"td|dd}|dd}|rH|dur<|dur` 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. 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: r2T)rK)rLrMrNrQrRr)"popwarningswarnDeprecationWarningrsecure ValueErrorr r rrrAF_UNIX SOCK_STREAM settimeoutr2r setdefaultrShostport setsockopt IPPROTO_TCP TCP_NODELAY ssl_modulecreate_default_context wrap_socketr Exceptioncloser< close_socketrecv_events_threadjoin)rTrIrJrKrLrMrNr.r0rOrPrrQrrRrSr^wsurir`radeadliner connectionr,r,r-r{s]            rracKsD|dur|ddur|ddurd}nd}td|d|d|S) 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/``. NrJr_zws://localhost/zwss://localhost/T)rTr`rar,)getr)rarTr^r,r,r-rAs r)$rTrUrIrVrJrWrKr1rLrXrMrYrNrZr.r/r0r1rOr1rPr!rr!rQr[rr"rRr\rSr]r^rr#r)NN)rar1rTr1r^rr#r)( __future__rrrJrqr%rccollections.abcrtypingrclientrdatastructuresrextensions.baserextensions.permessage_deflater r6r http11r r r r rrrrrTrr{rutilsr__all__rrrr,r,r,r-sP           eH