+ O|jLY(^RIHt^RIt^RIt^RIt^RIt^RIt^RIH t ^RI H t H t H t HtHt^RIHt^RIHt^RIHtHtHt^RIHt^R IHt^R IHt^R IHtH t ^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/H0t0H1t1^RI2H3t3^RI4H5t5.RDOt6!RR]34t7RRRRRRRRRRRRRRRRR]RR R!RR"RR#^ R$^R%^R&^ R'RER(^R)RR*R/R+R,llt8RFR-R.llt9^R/I:H;t;^R0I4tF]!R?] R@]F3,RA7tG!RBRC4tHR# ]Cd R8R9ltBLJi;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 /#) sock socket.socketprotocolr r% float | Noner&r'r(*int | None | tuple[int | None, int | None]returnNone)formats"OC:\Users\alokc\chatbot\backend\venv\Lib\site-packages\websockets/sync/client.py __annotate__ClientConnection.__annotate__8sP   ! $  #  $ >   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__8s; &__.   '%'  r7Nc(V^8dQhRRRRRRRR/#) r*additional_headersHeadersLike | Noneuser_agent_header str | Nonetimeoutr.r0r1r2)r3s"r4r5r6Ms2....&. .  .r7c \VPP4VnVe&VPPP V4Ve'VPPP RV4VP \R7;_uu_4VPPVP4RRR4VPPV4'g \R4hVPPeVPPhR# +'giLl;i)z! Perform the opening handshake. Nz User-Agent)expected_statez.timed out while waiting for handshake response) r-connectrequestheadersupdate setdefault send_contextr send_requestr;wait TimeoutError handshake_exc)r>rBrDrFs&&&&r4 handshakeClientConnection.handshakeMs}},,.  ) LL ' '(: ;  ( LL + +L:K L   j  9 9 MM & &t|| 4:!!&&w//OP P == & & 2---- - 3: 9s &D D+ c V^8dQhRRRR/#)r*eventrr0r1r2)r3s"r4r5r6is ) )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_eventisH == eX.. ..!M    " " $ G !% (r7cV^8dQhRR/#)r*r0r1r2)r3s"r4r5r6ws % %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_eventsws:  % G  !    " " $D   " " $s -A )rJrXr;) __name__ __module__ __qualname____firstlineno____doc__r=rrSr[r___static_attributes__ __classcell__)r?s@r4r#r#s`2 ')  &(  ') AC  .26(2 $ .8 ) ) % %r7r+sslserver_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*uristrr+zsocket.socket | Nonerhssl_module.SSLContext | NonerirErjz Origin | Nonerkz'Sequence[ClientExtensionFactory] | NonerlzSequence[Subprotocol] | NonermrBrCrDrozstr | Literal[True] | Nonerprqrrr.r%r&r'rsr/r(rtzLoggerLike | Noneruztype[ClientConnection] | Nonekwargsrr0r#r2)r3s"r4r5r5s OO O  O & O  O O8O/OO+O"O &O ,!O"&#O&'O( )O*+O, -O091O2:3O6 7O:5;O>?O@AOr7c Vf4RV9d-VPR4p\P!R\4\ V4pVP 'gVe \ R4hVe \V4VR8Xd \V4pMVe\ RV 24hVf\P!R4pVf\pVPRR 4pVPR R4pV'd'VfVf \ R 4hVeVe \ R 4hV'dRp VeRp V R Jd \V4p \V 4pVEfpV'dk\P!\P\P 4pVP#VP%44VfQhVP'V4MV e\)V 4pVP*R,R8Xd!\-VVVVPRR4R7pMVP*R,R8Xd6VP*R8wdV e \ R4h\/VVV3RV RV RV /VBpMX\1R4hVP3RVP%44\P4!VP6VP833/VBpVP#R4V'g0VP;\P<\P>R 4VP 'dVf\@PB!4pVf VP6pVP#VP%44V fVPEWR7pM'\GWVR7p\I\PV4pVP#R4\KVVVVVVR7pV!VVVVVVR7pTPQTT TP%44TPY4T# \LdTeTPO4hi;i \Ld-TPS4TPTPW4hi;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: 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. InvalidProxy: If ``proxy`` isn't a valid proxy. 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:// URIrnzunsupported compression: zwebsockets.clientunixFpathzmissing path argumentzpath is incompatible with sockT:NNsockssource_address) local_addr:NNhttphttpsz8proxy_ssl argument is incompatible with an http:// proxyrDrhriz&parse_proxy returned unsupported proxyrFri)rjrkrlrsrtr9)-popwarningswarnDeprecationWarningr secure ValueErrorrrlogging getLoggerr#rr"socketAF_UNIX SOCK_STREAM settimeoutrFrIrschemeconnect_socks_proxyconnect_http_proxyAssertionErrorrMruhostport setsockopt IPPROTO_TCP TCP_NODELAY ssl_modulecreate_default_context wrap_socket SSLSSLSocketr r ExceptioncloserS close_socketrecv_events_threadjoinstart_keepalive)rwr+rhrirjrkrlrmrBrDrorprqrrr%r&r'rsr(rtrurzws_urir}r~deadline proxy_parsedsock_2r- connections&$$$$$$$$$$$$$$$$$$$$, r4rIrIs d {}.jj' ,  s^F ===S_HIIl+i5jA  4[MBCC ~""#67 ,FE*Dzz&$/D  >   }&!  %H` <}}V^^V5G5GH 0 0 23''' T""*51 &&r*g5.$ $*::.>#E D"((,6#**g5):O(V.$ +<  &  )> !D))QRR!!)X-=-=-?@//[[&++. OOD ! OOF..0B0BD I ==={ 779&"(++ OOH,,. / tM%dQFMM62 OOD !" !%  '  '%'           #    JJL  !%%**, s-; O"E.O"7AO"8B6O"/!P"!P7P=c(V^8dQhRRRRRRRR/#)r*r~rErwrzrr0r#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*rorrrrr"rDrErhryrirzrr0r,r2)r3s"r4r5r5 sX$$ $ $$ " $ & $ $$$r7c *VPRVP44\P!VPVP 33/VBpVP R8XdlVf\P!4pVf VPpVPVP44VPWuR7pVPR4\WV4pVPV4\Wr4V# \dTP4hi;i)rFrNr)rMrFrrurrrrrrrrsendallrrr) rorrrDrhrirzr+rJs &&&$$$, r4rr s i!1!1!34  # #UZZ$< G GD ||w ;335C  "#jjO ((*+tE &e5FGGLLd- K   s ( C55DTF.)boundcj]tRtRtRtRtRRRlltRRltR R ltR R lt R Rlt RRlt Rt R#)ri7zf Socket-like object providing TLS-in-TLS. Only methods that are used by websockets are implemented. iNc(V^8dQhRRRRRRRR/#) r*r+r,r|zssl_module.SSLContextrirEr0r1r2)r3s"r4r5SSLSSLSocket.__annotate__As2222+2$ 2  2r7c \P!4Vn\P!4VnWnVP VPVPVR7VnVPVP P4R#)rN) r MemoryBIOincomingoutgoing ssl_socketwrap_bio ssl_objectrun_io do_handshake)r>r+r|ris&&&&r4r=SSLSSLSocket.__init__Asi #,,. ",,. %.. MM MM+/  DOO001r7c$V^8dQhRRRRRR/#)r*funczCallable[..., T]argsrr0rr2)r3s"r4r5rQs"+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_ioQsIJ "t==%%'D''-++D,=,=>MM''-MM++-M-.. ! // "!  "sCC5C5/C54C5c V^8dQhRRRR/#)r*buflenintr0bytesr2)r3s"r4r5ros35r7c VPVPPV4# \PdR#i;i)r7)rrrr SSLEOFError)r>rs&&r4rSSLSSLSocket.recvos: ;;t33V< <%%  s%(AAc V^8dQhRRRR/#)r*rrr0rr2)r3s"r4r5rus888s8r7c NVPVPPV4#N)rrr)r>rs&&r4sendSSLSSLSocket.sendus{{4??00$77r7c V^8dQhRRRR/#)r*rrr0r1r2)r3s"r4r5rxs66I6$6r7c  ,^p\V4;_uu_4q3PR4;_uu_4p\V4pW%8dW PWBR4, pK!RRR4RRR4R# +'giL;i +'giR#;i)rBN) memoryviewr lenr)r>rcountview byte_viewamounts&& r4rSSLSSLSocket.sendallxsc   yy~~^F.9V#455!(6  ~~   s"B-A/ B/ A? :B B c V^8dQhRRRR/#)r*namerxr0rr2)r3s"r4r5rs....r7c .\VPV4#r)getattrr)r>r s&&r4 __getattr__SSLSSLSocket.__getattr__st--r7)rrrrr) rarbrcrdrerr=rrrrrrfr2r7r4rr7s1L2 < 86..r7r)rIrr#i)NN)I __future__rrrrhrr:rcollections.abcrtypingrrrrr clientr datastructuresr exceptionsr r rextensions.baserextensions.permessage_deflaterrKrhttp11rrr-rrrorrrrstreamsrrrrrrwrr rr!utilsr"__all__r#rIr python_socksrpython_socks.syncrSOCKS5SOCKS4rrrrrrrrrr2r7r4r s(" $88#(LL4L+)(JJ"??)" :b%zb%JO"& O )- O #' O!O;?O26O(O.2O%/O)-O /3!O")-#O&"$'O(#%)O*"$+O,#%-O0