vKg.SSKJr SSKrSSKrSSKrSSKrSSKJr SSK J r SSK J r SSK Jr SSKJr SS KJr SS KJr SS KJrJr SS KJrJr SS K JrJrJr SSKJr SSK J!r! SSK"J#r# /SQr$"SS\!5r%SSSSSSS\SSSSSSSS.SSjjr&SSSjjr'g)) annotationsN)Sequence)Any)ClientProtocol) HeadersLike)ClientExtensionFactory) enable_client_permessage_deflate)validate_subprotocols) USER_AGENTResponse) CONNECTINGEvent) LoggerLikeOrigin Subprotocol) parse_uri) Connection)Deadline)connect unix_connectClientConnectionc^\rSrSrSrSSS.S U4SjjjrS\S4S SjjrSU4S jjrSU4S jjr S r U=r $)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_queuec^>U [R"5Ul[TU]UUUUS9 g)Nr) threadingr response_rcvdsuper__init__)selfsocketprotocolrr __class__s V/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/websockets/sync/client.pyr%ClientConnection.__init__4s5 &__.   '  NcUR[S9 URR5UlUb%URR R U5 UbX RR S'URRUR5 SSS5 URRU5(d [S5eURRbURReg!,(df  Ng=f)z! Perform the opening handshake. )expected_stateNz User-Agentztimed out during handshake) send_contextrr(rrequestheadersupdate send_requestr#wait TimeoutError handshake_exc)r&additional_headersuser_agent_headertimeouts r* handshakeClientConnection.handshakeEs  j  9==002DL!- $$++,>? ,5F $$\2 MM & &t|| 4 :!!&&w//;< < == & & 2---- - 3: 9s BC== D c>URc8[U[5(deXlURR 5 g[ TU]U5 g)z Process one incoming event. N)response isinstancer r#setr$ process_event)r&eventr)s r*r@ClientConnection.process_eventasH == eX.. ..!M    " " $ G !% (r,c>[TU]5 URR5 g!URR5 f=f)z9 Read incoming data from the socket and process events. N)r$ recv_eventsr#r?)r&r)s r*rDClientConnection.recv_eventsos:  % G  !    " " $D   " " $s ,A)r0r=r#) r'z socket.socketr(rr float | Noner *int | None | tuple[int | None, int | None]returnNone)r7HeadersLike | Noner8 str | Noner9rFrHrI)rArrHrI)rHrI) __name__ __module__ __qualname____firstlineno____doc__r%r r:r@rD__static_attributes__ __classcell__)r)s@r*rrs<')@B   ! $  >     &26(2 $ ...&. .  .8 ) % %r,rdeflaterir)socksslserver_hostnameorigin extensions subprotocolsr7r8 compression open_timeoutrmax_sizer loggercreate_connectionc Uc2SU;a,URS5n[R"S[5 [ U5nUR (dUb [ S5eURSS5nURSS5nU(a"UcUc [ S5eUbUb [ S 5eUb [U5 U S :Xa [U5nOU b[ S U 35e[U 5nUc[nUcU(ai[R"[R[R5nURUR55 UceUR!U5 OMUR#S UR55 [R$"UR&UR(440UD6nURS5 U(d/UR+[R,[R.S 5 UR (afUc[0R2"5nUc UR&nURUR55 UR5XS9nURS5 [7UUUUU US9nU"UUU U S9nUR=UUUR55 U$![8a UbUR;5 ef=f![8a, UR?5 UR@RC5 ef=f)a5 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. 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. 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 incompatiblerSzunsupported compression: r9T)rV)rWrXrYr\r]r)"popwarningswarnDeprecationWarningrsecure ValueErrorr r rrr'AF_UNIX SOCK_STREAM settimeoutr9r setdefaultr^hostport setsockopt IPPROTO_TCP TCP_NODELAY ssl_modulecreate_default_context wrap_socketr Exceptioncloser: close_socketrecv_events_threadjoin)urirTrUrVrWrXrYr7r8rZr[rr\r r]r^kwargswsurirarbdeadliner( connections r*rr{sz {}.jj' ,  cNE <rs" $#(4L+)(44" :^%z^%J"&(,"& :>15-1$.'!#"$ <> $7;/C C  C & C  C C8C/C+C"CCC  !C$%C&:'C* +C.5/C01C23CN< < <<