Ji\VPSSKJr SSKrSSKrSSKrSSKrSSKJr SSK J r J r J r J r Jr SSKJr SSKJr SSKJrJrJr SS KJr SS KJr SS KJr SS KJrJr SS K J!r!J"r" SSK#J$r$J%r%J&r&J'r' SSK(J)r) SSK J*r*J+r+J,r,J-r- SSK.J/r/J0r0 SSK1J2r2 SSK3J4r4 /SQr5"SS\25r6SSSSSSSS\SSSSSSSSSSSS.S0Sjjr7S1S2S jjr8SS!K9J:r: SS"K;J$r< \:Rz\:Rz\:R|\:R|S#.r?SS$SS$S#.r@S3S%jrAS4S'jrCSSSS(.S5S)jjrD\ "S*5rE\ "S+\ S,\E4S-9rF"S.S/5rGg!\Ba S3S&jrANUf=f)6) 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)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 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.r/r0r1 __class__s X/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/websockets/sync/client.pyr6ClientConnection.__init__7s; &__.   '%'  Nc8UR[S9 URR5UlUb%URR R U5 Ub&URR RSU5 URRUR5 SSS5 URRU5(d [S5eURRbURReg!,(df  Ng=f)z! Perform the opening handshake. )expected_stateNz User-Agentz.timed out while waiting for handshake response) send_contextrr9r%requestheadersupdate setdefault send_requestr4wait TimeoutError handshake_exc)r7additional_headersuser_agent_headertimeouts r; handshakeClientConnection.handshakeLs  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 isinstancerr4setr5 process_event)r7eventr:s r;rRClientConnection.process_eventhsH == eX.. ..!M    " " $ G !% (r=c>[TU]5 URR5 g!URR5 f=f)z9 Read incoming data from the socket and process events. N)r5 recv_eventsr4rQ)r7r:s r;rVClientConnection.recv_eventsvs:  % G  !    " " $D   " " $s ,A)rArOr4)r8 socket.socketr9r r. float | Noner/rYr0rYr1*int | None | tuple[int | None, int | None]returnNone)rIHeadersLike | NonerJ str | NonerKrYr[r\)rSrr[r\)r[r\) __name__ __module__ __qualname____firstlineno____doc__r6rrLrRrV__static_attributes__ __classcell__)r:s@r;r'r's<')%'&(@B  ! $  #  $ >    .26(2 $ ...&. .  .8 ) % %r=r'deflateTr+r*ir,)socksslserver_hostnameorigin extensions subprotocols compressionrIrJproxy proxy_sslproxy_server_hostname open_timeoutr.r/r0max_sizer1loggercreate_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. 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 incompatiblerfzunsupported compression: Tsockssource_address) local_addrhttphttpsz8proxy_ssl argument is incompatible with an http:// proxyrJrhrizunsupported proxyrKri)rjrkrlrrrsr-)+popwarningswarnDeprecationWarningr!secure ValueErrorrrrr$r'r8AF_UNIX SOCK_STREAM settimeoutrKr%rschemeconnect_socks_proxyconnect_http_proxyAssertionErrorrDrthostport setsockopt IPPROTO_TCP TCP_NODELAY ssl_modulecreate_default_context wrap_socket SSLSSLSocketr r ExceptioncloserL close_socketrecv_events_threadjoinstart_keepalive)urirgrhrirjrkrlrmrIrJrnrorprqr.r/r0rrr1rsrtkwargsws_urirwrxdeadline proxy_parsedsock_2r9 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/``. rhrvzws://localhost/zwss://localhost/T)rrwrx)getr%)rxrrs 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.rKz failed to connect to SOCKS proxyN) SocksProxySOCKS_PROXY_TYPESrrrusernamepasswordSOCKS_PROXY_RDNSrDrKr%OSErrorrGr8rr)rnrrr 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)Nz6connecting through a SOCKS proxy requires python-socks) ImportError)rnrrrs r;rrs RSSr=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)NT)rnii,z(timed out while connecting to HTTP proxyz0did not receive a valid HTTP response from proxy)rrparse read_line read_exact read_to_eofrrKrecv feed_datafeed_eofnext StopIterationrPvalue status_coderr8rGrr )rgrreaderparserdatarrOs 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)NrKrr)rDrKr8rtrrrrrrrsendallrrrr)rnrrrJrhrirrgs 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)r7rgrvris r;r6SSLSSLSocket.__init__6si #,,. ",,. %.. 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)r7funcargs want_read want_writeresultrs r;rSSLSSLSocket.run_ioFsIJ "t==%%'D''-++D,=,=>MM''-MM++-M-.. ! // "!  "sB>>C.C.-C.cURURRU5$![Ra gf=f)Nr=)rrrr SSLEOFError)r7buflens r;rSSLSSLSocket.recvds: ;;t33V< <%%  s %(??cNURURRU5$N)rrr)r7rs r;sendSSLSSLSocket.sendjs{{4??00$77r=cSn[U5o3RS5n[U5nX%:aX RXBS5- nX%:aMSSS5 SSS5 g!,(df  N=f!,(df  g=f)NrB) memoryviewr lenr)r7rcountview byte_viewamounts r;rSSLSSLSocket.sendallms]  yy~^F.9V#455.(6  ~~  s"A.+A A. A+ 'A.. A<c.[URU5$r)getattrr)r7names r; __getattr__SSLSSLSocket.__getattr__xst--r=)rrrrr)rgrXrvzssl_module.SSLContextrir^r[r\)rzCallable[..., T]rrr[r)rintr[bytes)rrr[r)rrr[r\)rstrr[r) r_r`rarbrcrr6rrrrrrdrr=r;rr,sWL '+ 22+2$ 2  2 < 86.r=r).rrrgzsocket.socket | Nonerhssl_module.SSLContext | Nonerir^rjz Origin | Nonerkz'Sequence[ClientExtensionFactory] | NonerlzSequence[Subprotocol] | Nonermr^rIr]rJr^rnzstr | Literal[True] | Nonerorrpr^rqrYr.rYr/rYr0rYrrrZr1rZrszLoggerLike | Nonertztype[ClientConnection] | Nonerrr[r')NN)rxr^rr^rrr[r') rnrrr rr$rrr[rX)rgrXrr$r[r)rnrrr rr$rJr^rhrrir^rrr[rX)H __future__rr8rhrr3rcollections.abcrtypingrrrrr clientr datastructuresr exceptionsr rrextensions.baserextensions.permessage_deflaterrBrhttp11rrr9rrrnrrrrstreamsrrrrrrr r!rr#utilsr$__all__r'r%r& python_socksrpython_socks.syncrSOCKS5SOCKS4rrrrrrrrrrr=r;rs<" $88#(LL4L+)(JJ"??)" :b%zb%R"&(,"& :>15'-1$.(,.2(,!#"$!#"$;@<> $7;;F F  F & F  F F8F/FF+F"F &F ,!F"&#F&'F( )F*+F, -F091F2:3F6 7F:5;F<=F>?FT< < << <<4J&5##""##""  JJJJ J  J4N%)(,"&# # ## " # & # ###L CL CxQ'(M.M.TTTTT T  TTs> F F%$F%