+ i\V(^RIHt^RIt^RIt^RIt^RIt^RIHt^RI H t H t H t H t Ht^RIHt^RIHt^RIHtHtHt^RIHt^R IHt^R IHt^R IHtHt^R I H!t!H"t"^R I#H$t$H%t%H&t&H't'^RI(H)t)^RI H*t*H+t+H,t,H-t-^RI.H/t/H0t0^RI1H2t2^RI3H4t4.RDOt5!RR]24t6RRRRRRRRRRRRRRRRR]RR R!RR"RR#^ R$^R%^R&^ R'RER(^R)RR*R/R+R,llt7RFR-R.llt8^R/I9H:t:^R0I;H$t<R1]:PzR2]:PzR3]:P|R4]:P|/t?R1R R2R5R3R R4R5/t@R6R7ltAR:R;ltCRRRRRR/R<R=lltD] !R>4tE] !R?] R@]E3,RA7tF!RBRC4tGR# ]Bd R8R9ltALJi;i)G) annotationsN)Sequence)AnyCallableLiteralTypeVarcast)ClientProtocol) HeadersLike)InvalidProxyMessageInvalidProxyStatus ProxyError)ClientExtensionFactory) enable_client_permessage_deflate)validate_subprotocols) USER_AGENTResponse) CONNECTINGEvent)Proxy get_proxy parse_proxyprepare_connect_request) StreamReader) BytesLike LoggerLikeOrigin Subprotocol) WebSocketURI parse_uri) Connection)DeadlineClientConnectionca]tRt^tRtR^R^R^ R^/RV3RllltR]R3R R lltR V3R lltR V3Rllt Rt V;t #)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 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_queuec4V^8dQhRRRRRRRRRRR R R R /#) socket socket.socketprotocolr r% float | Noner&r'r(*int | None | tuple[int | None, int | None]returnNone)formats"]/home/wkmabra/.openclaw/workspace/venv/lib/python3.14/site-packages/websockets/sync/client.py __annotate__ClientConnection.__annotate__7sP   ! $  #  $ >   c  j<V\P!4Vn\SV`VVVVVVR7R#)r%r&r'r(N) threadingr response_rcvdsuper__init__)selfr+r-r%r&r'r( __class__s&&&$$$$r4r=ClientConnection.__init__7s; &__.   '%'  r7Nc(V^8dQhRRRRRRRR/#) r*additional_headersHeadersLike | Noneuser_agent_header str | Nonetimeoutr.r0r1r2)r3s"r4r5r6Ls2....&. .  .r7c \VP\R7;_uu_4VPP4VnVe&VPP P V4Ve'VPP PRV4VPPVP4RRR4VPPV4'g \R4hVPPeVPPhR# +'giLl;i)z! Perform the opening handshake. )expected_stateNz User-Agentz.timed out while waiting for handshake response) send_contextrr-connectrequestheadersupdate setdefault send_requestr;wait TimeoutError handshake_exc)r>rBrDrFs&&&&r4 handshakeClientConnection.handshakeLs  j  9 9==002DL!- $$++,>? , $$// >OP MM & &t|| 4 :!!&&w//OP P == & & 2---- - 3: 9s BD D+ c V^8dQhRRRR/#)r*eventrr0r1r2)r3s"r4r5r6hs ) )5 )T )r7c <VPf;\V\4'gQhWnVPP 4R#\ SV`V4R#)z Process one incoming event. N)response isinstancerr;setr< process_event)r>rVr?s&&r4r[ClientConnection.process_eventhsH == eX.. ..!M    " " $ G !% (r7cV^8dQhRR/#)r*r0r1r2)r3s"r4r5r6vs % %T %r7c <\SV`4VPP4R# TPP4i;i)z9 Read incoming data from the socket and process events. N)r< recv_eventsr;rZ)r>r?s&r4r_ClientConnection.recv_eventsvs:  % G  !    " " $D   " " $s -A )rKrXr;) __name__ __module__ __qualname____firstlineno____doc__r=rrSr[r___static_attributes__ __classcell__)r?s@r4r#r#s`2 ')  &(  ') AC  .26(2 $ .8 ) ) % %r7socksslserver_hostnameorigin extensions subprotocols compressiondeflaterBrDproxyT proxy_sslproxy_server_hostname open_timeoutr%r&r'max_sizer(loggercreate_connectionc.tV^8dQhRRRRRRRRR R R R R RRRRRRRRRRRRRRRRRRRRRRRRRRR R!R"R#R$R%R&/#)'r*uristrrhzsocket.socket | Nonerissl_module.SSLContext | NonerjrErkz Origin | Nonerlz'Sequence[ClientExtensionFactory] | NonermzSequence[Subprotocol] | NonernrBrCrDrpzstr | Literal[True] | Nonerqrrrsr.r%r&r'rtr/r(ruzLoggerLike | Nonervztype[ClientConnection] | Nonekwargsrr0r#r2)r3s"r4r5r5s FF F  F & F  F F8F/FF+F"F &F ,!F"&#F&'F( )F*+F, -F091F2:3F6 7F:5;F<=F>?Fr7c LVf4RV9d-VPR4p\P!R\4\ V4pVP 'gVe \ R4hVPRR4pVPRR4pV'd'VfVf \ R4hVeVe \ R 4hVe \V4VR 8Xd \V4pMVe\ R V 24hV'dRp VeRp V R Jd \V4p \V 4pVf\pVEfpV'dk\P!\P\P4pVPVP!44VfQhVP#V4MV e\%V 4pVP&R ,R8Xd!\)VVVVPRR4R7pMVP&R,R8Xd6VP&R8wdV e \ R4h\+VVV3RV RV RV /VBpMX\-R4hVP/RVP!44\P0!VP2VP433/VBpVPR4V'g0VP7\P8\P:R 4VP 'dVf\<P>!4pVf VP2pVPVP!44V fVPAWR7pM'\CWVR7p\E\PV4pVPR4\GVVVVVVR7pV!VVVVVVR7pTPMTT TP!44TPU4T# \HdTeTPK4hi;i \Hd-TPO4TPPPS4hi;i)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. You may pass a ``(max_message_size, max_fragment_size)`` tuple to set different limits for messages and fragments when you expect long messages sent in short fragments. 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 incompatiblerozunsupported compression: T:NNsockssource_address) local_addr:NNhttphttpsz8proxy_ssl argument is incompatible with an http:// proxyrDrirjzunsupported proxyrFrj)rkrlrmrtrur9)+popwarningswarnDeprecationWarningr secure ValueErrorrrrr"r#r+AF_UNIX SOCK_STREAM settimeoutrFrJrschemeconnect_socks_proxyconnect_http_proxyAssertionErrorrNrvhostport setsockopt IPPROTO_TCP TCP_NODELAY ssl_modulecreate_default_context wrap_socket SSLSSLSocketr r ExceptioncloserS close_socketrecv_events_threadjoinstart_keepalive)rxrhrirjrkrlrmrnrBrDrprqrrrsr%r&r'rtr(rurvr{ws_urir~rdeadline proxy_parsedsock_2r- connections&$$$$$$$$$$$$$$$$$$$$, r4rJrJs` {}.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  !%%**, s-! O.E.OAOB6O!O,!O),7P#c(V^8dQhRRRRRRRR/#)r*rrErxr{rr0r#r2)r3s"r4r5r5s0<< < << >GEFF ! >   sU8B,=/B,, E"7A D$E"E% D$$E";E"E" EE""E%%E8c8V^8dQhRRRRRRRRR R R RR R RR/#)r*rprrrrr"rDrErirzrjr{rr0r,r2)r3s"r4r5r5sX## # ## " # & # ###r7c &VPRVP44\P!VPVP 33/VBpVP R8XdlVf\P!4pVf VPpVPVP44VPWuR7pVPR4VP\WV44\Wr4V# \dTP4hi;i)rFrNr)rNrFr+rvrrrrrrrsendallrrrr)rprrrDrirjr{rhs&&&$$$, r4rrs i!1!1!34  # #UZZ$< G GD ||w ;335C  "#jjO ((*+tE  LL(8IJKd- K   s & C33DTF.)boundcj]tRtRtRtRtRRRlltRRltR R ltR R lt R Rlt RRlt Rt R#)ri,zf Socket-like object providing TLS-in-TLS. Only methods that are used by websockets are implemented. iNc(V^8dQhRRRRRRRR/#) r*rhr,r}zssl_module.SSLContextrjrEr0r1r2)r3s"r4r5SSLSSLSocket.__annotate__6s2222+2$ 2  2r7c \P!4Vn\P!4VnWnVP VPVPVR7VnVPVP P4R#)rN) r MemoryBIOincomingoutgoing ssl_socketwrap_bio ssl_objectrun_io do_handshake)r>rhr}rjs&&&&r4r=SSLSSLSocket.__init__6si #,,. ",,. %.. MM MM+/  DOO001r7c$V^8dQhRRRRRR/#)r*funczCallable[..., T]argsrr0rr2)r3s"r4r5rFs"+CAr7c RpRpV!V!pVPP 4pV'dVP P V4V'dfVP PVP4pV'dVPPV4MVPP4KV'dKX# \PdRpL\PdRpLi;i)TF) rSSLWantReadErrorSSLWantWriteErrorrreadrrr recv_bufsizerwrite write_eof)r>rr want_read want_writeresultrs&&* r4rSSLSSLSocket.run_ioFsIJ "t==%%'D''-++D,=,=>MM''-MM++-M-.. ! // "!  "sCC5C5/C54C5c V^8dQhRRRR/#)r*buflenintr0bytesr2)r3s"r4r5rds35r7c VPVPPV4# \PdR#i;i)r7)rrrr SSLEOFError)r>rs&&r4rSSLSSLSocket.recvds: ;;t33V< <%%  s%(AAc V^8dQhRRRR/#)r*rrr0rr2)r3s"r4r5rjs888s8r7c NVPVPPV4#N)rrr)r>rs&&r4sendSSLSSLSocket.sendjs{{4??00$77r7c V^8dQhRRRR/#)r*rrr0r1r2)r3s"r4r5rms66I6$6r7c  ,^p\V4;_uu_4q3PR4;_uu_4p\V4pW%8dW PWBR4, pK!RRR4RRR4R# +'giL;i +'giR#;i)rBN) memoryviewr lenr)r>rcountview byte_viewamounts&& r4rSSLSSLSocket.sendallmsc   yy~~^F.9V#455!(6  ~~   s"B-A/ B/ A? :B B c V^8dQhRRRR/#)r*nameryr0rr2)r3s"r4r5rxs....r7c .\VPV4#r)getattrr)r>r s&&r4 __getattr__SSLSSLSocket.__getattr__xst--r7)rrrrr) rarbrcrdrerr=rrrrr rfr2r7r4rr,s1L2 < 86..r7r)rJrr#i)NN)H __future__rr+rirr:rcollections.abcrtypingrrrrr clientr datastructuresr exceptionsr r rextensions.baserextensions.permessage_deflaterrLrhttp11rrr-rrrprrrrstreamsrrrrrrxrr rr!utilsr"__all__r#rJr python_socksrpython_socks.syncrSOCKS5SOCKS4rrrrrrrrrr2r7r4rs%" $88#(LL4L+)(JJ"??)" :b%zb%JF"& F )- F #' F!F;?F26F(F.2F%/F)-F /3!F")-#F&"$'F(#%)F*"$+F,#%-F0