qj\VBddlmZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z mZddlmZddlmZddlmZmZmZdd lmZdd lmZdd lmZdd lmZmZdd l m!Z!m"Z"ddl#m$Z$m%Z%m&Z&m'Z'ddl(m)Z)ddl m*Z*m+Z+m,Z,m-Z-ddl.m/Z/m0Z0ddl1m2Z2ddl3m4Z4gdZ5Gdde2Z6ddddddddedddddddddddd d0dZ7 d1 d2d Z8 dd!l9m:Z:dd"l;m$Z<e:jze:jze:j|e:j|d#Z?dd$dd$d#Z@ d3d%ZAd4d'ZCdddd( d5d)ZDe d*ZEe d+e d,eEf-ZFGd.d/ZGy#eB$r d3d&ZAYSwxYw)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_connectClientConnectionceZdZdZddddd d fdZdedf d dZd fd Zdfd ZxZ S)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_queuecf|tj|_t|||||||y)Nr,) threadingr response_rcvdsuper__init__)selfsocketprotocolr-r.r/r0 __class__s W/var/www/html/kelly-backend/venv/lib/python3.12/site-packages/websockets/sync/client.pyr5zClientConnection.__init__7s; &__.   '%'  Nc$|jt5|jj|_|%|jj j ||&|jj jd||jj|jddd|jj|s td|jj|jjy#1swY\xYw)z1 Perform the opening handshake. )expected_stateNz User-Agentz.timed out while waiting for handshake response) send_contextrr8r%requestheadersupdate setdefault send_requestr3wait TimeoutError handshake_exc)r6additional_headersuser_agent_headertimeouts r: handshakezClientConnection.handshakeLs  j  9==002DL!- $$++,>? , $$// >OP MM & &t|| 4 :!!&&w/OP P == & & 2---- - 3: 9s BDDc|j4t|tsJ||_|jj yt ||y)z. Process one incoming event. N)response isinstancerr3setr4 process_event)r6eventr9s r:rOzClientConnection.process_eventhsG == eX. ..!DM    " " $ G !% (r;c t||jjy#|jjwxYw)zI Read incoming data from the socket and process events. N)r4 recv_eventsr3rN)r6r9s r:rRzClientConnection.recv_eventsvs:  % G  !    " " $D   " " $s ,A)r7 socket.socketr8r r- float | Noner.rTr/rTr0*int | None | tuple[int | None, int | None]returnNone)rGHeadersLike | NonerH str | NonerIrTrVrW)rPrrVrW)rVrW) __name__ __module__ __qualname____doc__r5rrJrOrR __classcell__)r9s@r:r'r's<')%'&(@B  ! $  #  $ >   .26(2 $ ...&. .  .8 ) % %r;r'deflateTr*r)ir+)socksslserver_hostnameorigin extensions subprotocols compressionrGrHproxy proxy_sslproxy_server_hostname open_timeoutr-r.r/max_sizer0loggercreate_connectionc |/d|vr+|jd}tjdtt |}|j s | t d|jdd}|jdd}|r| | t d| | t d | t||d k(r t|}n|t d ||rd} |d} | d ur t|} t| }|t} |Q|rgtjtjtj}|j|j!|J|j#|n| t%| }|j&dd dk(r t)||||jdd}n|j&dddk(r/|j&dk7r | t dt+|||f| | | d|}nWt-d|j/d|j!tj0|j2|j4ffi|}|jd|s/|j7tj8tj:d |j r|t=j>}| |j2}|j|j!| |jA||}n(tC|||}tEtj|}|jdtG||||||}|||||||} |jM|| |j!|jU|S#tH$r||jKwxYw#tH$r,|jO|jPjSwxYw)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 incompatibler_zunsupported compression: Tsockssource_address) local_addrhttphttpsz8proxy_ssl argument is incompatible with an http:// proxyrHrarbzunsupported proxyrIrb)rcrdrerkrlr,)+popwarningswarnDeprecationWarningr!secure ValueErrorrrrr$r'r7AF_UNIX SOCK_STREAM settimeoutrIr%rschemeconnect_socks_proxyconnect_http_proxyAssertionErrorrBrmhostport setsockopt IPPROTO_TCP TCP_NODELAY ssl_modulecreate_default_context wrap_socket SSLSSLSocketr r ExceptioncloserJ close_socketrecv_events_threadjoinstart_keepalive)urir`rarbrcrdrerfrGrHrgrhrirjr-r.r/rkr0rlrmkwargsws_urirprqdeadline proxy_parsedsock_2r8 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,,. / t_M%dCQFMM62 OOD !" !%  '  '%'           #    JJL  !%%**, s3IM)6!N )N 5N>c r|'|jd|jdd}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/``. rarozws://localhost/zwss://localhost/T)rrprq)getr%)rqrrs r:r&r&sG* { ::e  $M)B)J#C$C  ;sD ;F ;;r;) ProxyType)r)socks5hsocks5socks4asocks4Fc tt|j|j|j|j |j t|j}|jd|j |j|j|jfi|S#tttjf$rt$r}td|d}~wwxYw)z0Connect via a SOCKS proxy and return the socket.rIz failed to connect to SOCKS proxyN) SocksProxySOCKS_PROXY_TYPESrrrusernamepasswordSOCKS_PROXY_RDNSrBrIr%OSErrorrEr7rr)rgrrr 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 td)Nz6connecting through a SOCKS proxy requires python-socks) ImportError)rgrrrs r:rrs RSSr;ct}tj|j|j|j d} |j |j|jd}|r|j|n|jt|`#t$rr}t|jtsJ|j}d|jcxkrdkr%n t!||cYd}~|j dSt!|d}~wt"j$r t%dt&$r}t)d|d}~wwxYw#|j dwxYw)NT)rgii,z(timed out while connecting to HTTP proxyz0did not receive a valid HTTP response from proxy)rrparse read_line read_exact read_to_eofrrIrecv feed_datafeed_eofnext StopIterationrMvalue status_coderr7rErr )r`rreaderparserdatarrLs r:read_connect_responsers; ^F ^^ F  OOH,,. /99T?D  &! L /#))X...99 (&& , ,%X. .O %X. . >>GEFF ! >   sDA!B$$ E-A D8E9E D)E EEEE*ryc |jd|jtj|j|j ffi|}|j dk(rg|tj}| |j}|j|j|j||}|jd|jt||| t|||S#t$r|jwxYw)NrIrxrz)rBrIr7rmrrrrrrrsendallrrrr)rgrrrHrarbrr`s r:rrs i!1!1!34  # #UZZ$< G GD ||w ;335C  "#jjO ((*+t_E  LL(8IJKdH- K   s C..D TF.)boundcVeZdZdZdZ d d dZd dZd dZddZddZ dd Z y)rzr Socket-like object providing TLS-in-TLS. Only methods that are used by websockets are implemented. iNctj|_tj|_||_|j |j|j||_|j|j jy)Nrz) r MemoryBIOincomingoutgoing ssl_socketwrap_bio ssl_objectrun_io do_handshake)r6r`rorbs r:r5zSSLSSLSocket.__init__6sk #,,. ",,. %.. MM MM+/  DOO001r;c d}d} ||}|jj }|r|j j ||r^|j j|j}|r|jj|n|jj|rS#tj$rd}Ytj$rd}YwxYw)NTF) rSSLWantReadErrorSSLWantWriteErrorrreadrrr recv_bufsizerwrite write_eof)r6funcargs want_read want_writeresultrs r:rzSSLSSLSocket.run_ioFsIJ "t==%%'D''-++D,=,=>MM''-MM++-M-.. ! // "!  "sB((C?CCc |j|jj|S#tj$rYywxYw)Nr;)rrrr SSLEOFError)r6buflens r:rzSSLSSLSocket.recvds: ;;t33V< <%%  s %(>>cN|j|jj|SN)rrr)r6rs r:sendzSSLSSLSocket.sendjs{{4??00$77r;cd}t|5}|jd5}t|}||kr||j||dz }||krddddddy#1swYxYw#1swYyxYw)NrB) memoryviewr lenr)r6rcountview byte_viewamounts r:rzSSLSSLSocket.sendallmsg  tyy~^F&.9UV#455&.(6  ~~  s"A+-AA+A( $A++A4c.t|j|Sr)getattrr)r6names r: __getattr__zSSLSSLSocket.__getattr__xst--r;r)r`rSrozssl_module.SSLContextrbrYrVrW)rzCallable[..., T]rrrVr)rintrVbytes)rrrVr)rrrVrW)rstrrVr) rZr[r\r]rr5rrrrrrr;r:rr,sWL '+ 22+2$ 2  2 < 86.r;r).rrr`zsocket.socket | Nonerassl_module.SSLContext | NonerbrYrcz Origin | Nonerdz'Sequence[ClientExtensionFactory] | NonerezSequence[Subprotocol] | NonerfrYrGrXrHrYrgzstr | Literal[True] | NonerhrrirYrjrTr-rTr.rTr/rTrkrUr0rUrlzLoggerLike | Nonermztype[ClientConnection] | NonerrrVr')NN)rqrYrrYrrrVr') rgrrr rr$rrrVrS)r`rSrr$rVr)rgrrr rr$rHrYrarrbrYrrrVrS)H __future__rr7rarr2r|collections.abcrtypingrrrrr clientr datastructuresr exceptionsr rrextensions.baserextensions.permessage_deflaterr@rhttp11rrr8rrrgrrrrstreamsrrrrrrr 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: FFF