Jtj\ddlZddlZddlZddlZddlmZmZmZmZddl m Z ddl m Z ddl mZmZddlmZmZmZddlmZdd lmZdd lmZmZmZmZ d gZdad ed dfdZ Gdd Z!dS)N)AnyCallableOptionalUnion)_logging)ABNF) WebSocketgetdefaulttimeout)"WebSocketConnectionClosedExceptionWebSocketExceptionWebSocketTimeoutException) SSLEOFError) parse_url) DispatcherDispatcherBase SSLDispatcherWrappedDispatcher WebSocketAppreconnectIntervalreturnc |adSN) RECONNECT)rs L/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/websocket/_app.py set_reconnectr+s !IIIc#eZdZdZ dd$ed%ed&eeefd'eeeefd(ed)ed*eeefd+ed,ed-eed.e d/ed0ed1e d2ed3ede f"d4Z d?d'eeeefd5eed6e d7e deee e!ff d8Z"d9edefd:Z#d=d;Z$dS)@rz_ Higher level of APIs are provided. The interface is like JavaScript WebSocket object. NTurlheaderon_open on_reconnect on_messageon_erroron_closeon_pingon_pongon_cont_message keep_running get_mask_keycookie subprotocolson_datasocketrc||_||ng|_| |_||_||_||_||_||_||_||_ | |_ | |_ d|_ | |_ d|_td|_td|_d|_d|_td|_d|_d|_||_||_d|_d|_t7j|_dS)a WebSocketApp initialization Parameters ---------- url: str Websocket url. header: list or dict or Callable Custom header for websocket handshake. If the parameter is a callable object, it is called just before the connection attempt. The returned dict or list is used as custom header value. This could be useful in order to properly setup timestamp dependent headers. on_open: function Callback object which is called at opening websocket. on_open has one argument. The 1st argument is this class object. on_reconnect: function Callback object which is called at reconnecting websocket. on_reconnect has one argument. The 1st argument is this class object. on_message: function Callback object which is called when received data. on_message has 2 arguments. The 1st argument is this class object. The 2nd argument is utf-8 data received from the server. on_error: function Callback object which is called when we get error. on_error has 2 arguments. The 1st argument is this class object. The 2nd argument is exception object. on_close: function Callback object which is called when connection is closed. on_close has 3 arguments. The 1st argument is this class object. The 2nd argument is close_status_code. The 3rd argument is close_msg. on_cont_message: function Callback object which is called when a continuation frame is received. on_cont_message has 3 arguments. The 1st argument is this class object. The 2nd argument is utf-8 string which we get from the server. The 3rd argument is continue flag. if 0, the data continue to next frame data on_data: function Callback object which is called when a message received. This is called before on_message or on_cont_message, and then on_message or on_cont_message is called. on_data has 4 argument. The 1st argument is this class object. The 2nd argument is utf-8 string which we get from the server. The 3rd argument is data type. ABNF.OPCODE_TEXT or ABNF.OPCODE_BINARY will be came. The 4th argument is continue flag. If 0, the data continue keep_running: bool This parameter is obsolete and ignored. get_mask_key: function A callable function to get new mask keys, see the WebSocket.set_mask_key's docstring for more information. cookie: str Cookie value. subprotocols: list List of available sub protocols. Default is None. socket: socket Pre-initialized stream socket. NFr)rr r+r!r"r#r-r$r%r&r'r(r)r*sockfloat last_ping_tm last_pong_tm ping_thread stop_ping ping_interval ping_timeout ping_payloadr,prepared_socket has_erroredhas_done_teardown threadingLockhas_done_teardown_lock)selfrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.s r__init__zWebSocketApp.__init__5st & 2ff   ($       .!()- !!HH!!HH7;48"1XX9=(% !&&/n&6&6###rdataopcodecp|jr|j||dkrtddS)a send message Parameters ---------- data: str Message to send. If you set opcode to OPCODE_TEXT, data must be utf-8 string or unicode. opcode: int Operation code of data. Default is OPCODE_TEXT. rConnection is already closed.N)r1sendr )r@rBrCs rrFzWebSocketApp.sends@y VDINN488A==45TUU U>=r text_datac|jr)|j|tjdkrt ddS)z+ Sends UTF-8 encoded text. rrEN)r1rFr OPCODE_TEXTr )r@rGs r send_textzWebSocketApp.send_textsDy VDINN9d6FGG1LL45TUU UMLrc|jr)|j|tjdkrt ddS)z, Sends a sequence of bytes. rrEN)r1rFr OPCODE_BINARYr )r@rBs r send_byteszWebSocketApp.send_bytessDy VDINN41CDDII45TUU UJIrc Xd|_|jr|jjdi|d|_dSdS)z- Close websocket connection. FN)r)r1close)r@kwargss rrPzWebSocketApp.closesE" 9  DIO % %f % % %DIII  rctdx|_|_tj|_tj|j|_d|j_ |j dS)Nr)targetT) r2r3r4r=Eventr6Thread _send_pingr5daemonstartr@s r_start_ping_threadzWebSocketApp._start_ping_threadse05a8D-"**$+4?CCC"&      rcf|jr|j|jr`|jrG|jd|jrt jdd|_d|_tdx|_|_ dS)NzYPing thread failed to terminate within 3 seconds, forcing cleanup. Thread may be blocked.r) r6setr5is_alivejoinrwarningr2r3r4rYs r_stop_ping_threadzWebSocketApp._stop_ping_threads > ! N      0 9 9 ; ;    ! !! $ $ $((**  > 05a8D---rc|jdS|j|js |jdurdS|j|js|jdur|jr{t j|_ tjd|j |j n.#t$r!}tjd|Yd}~nd}~wwxYw|j|js|jdudSdSdSdS)NFTz Sending pingzFailed to send ping: ) r6waitr7r)r1timer3rdebugpingr9 Exception)r@es rrVzWebSocketApp._send_pingsJ > ! F >  t1 2 2 d6G56P6P F.%%d&899 @d>OSW>W>Wy @$(IKK!@N>222INN4#45555 @@@N#>1#>#>????????@ .%%d&899 @d>OSW>W>W>W>W @ @>W>W @ @s<3B00 C:CCc(|jo |jjSr)r1 connectedrYs rreadyzWebSocketApp.readysy0TY00rrr0Fsockoptssloptr7r8r9http_proxy_hosthttp_proxy_port http_no_proxyhttp_proxy_authhttp_proxy_timeoutskip_utf8_validationhostoriginsuppress_origin proxy_type reconnectc t||dkrtd||dkrtd|r|r||krtdsdsijrtd|_|_|_d_d _dd tffd dd td df    fd d tf fd d tffd  ddttttttt fd tffd  ddttttttfd td tffd t|t%jd s\rZjrSt)jdt-t/jdjSn?#ttf$r+}t)jd|Yd}~nd}~wwxYws n#s wwxYwjS)a Run event loop for WebSocket framework. This loop is an infinite loop and is alive while websocket is available. Parameters ---------- sockopt: tuple Values for socket.setsockopt. sockopt must be tuple and each element is argument of sock.setsockopt. sslopt: dict Optional dict object for ssl socket option. ping_interval: int or float Automatically send "ping" command every specified period (in seconds). If set to 0, no ping is sent periodically. ping_timeout: int or float Timeout (in seconds) if the pong message is not received. ping_payload: str Payload message to send with each ping. http_proxy_host: str HTTP proxy host name. http_proxy_port: int or str HTTP proxy port. If not set, set to 80. http_no_proxy: list Whitelisted host names that don't use the proxy. http_proxy_timeout: int or float HTTP proxy timeout, default is 60 sec as per python-socks. http_proxy_auth: tuple HTTP proxy auth information. tuple of username and password. Default is None. skip_utf8_validation: bool skip utf8 validation. host: str update host header. origin: str update origin header. dispatcher: Dispatcher object customize reading data from socket. suppress_origin: bool suppress outputting origin header. proxy_type: str type of proxy from: http, socks4, socks4a, socks5, socks5h reconnect: int delay interval when reconnecting Returns ------- teardown: bool False if the `WebSocketApp` is closed or caught KeyboardInterrupt, True if any other exception was raised during a loop. NrzEnsure ping_timeout > 0zEnsure ping_interval >= 0z#Ensure ping_interval > ping_timeoutrOzsocket is already openedFT close_framecvj5jr ddddSd_dddn #1swxYwYd_jr"j}d_||r|nd\}}j||dS)a Tears down the connection. Parameters ---------- close_frame: ABNF frame If close_frame is set, the on_close handler is invoked with the statusCode and reason from the provided frame. NTF) r?r<rar)r1rP_get_close_args _callbackr%)rz current_sockclose_status_code close_reasonr@s rteardownz*WebSocketApp.run_forever..teardown_s3, . .) . . . . . . . .*.& . . . . . . . . . . . . . . .  " " $ $ $ %D y % $y   ""$$$.2.B.B*4 // + | NN4=*;\ J J J J Js 2266 reconnectingrcT|r jrjtjjdud_jt  tjrnj}j j |j  j   j tjdjr|r"jrjnjjjdS#t,t.t0t2t4f$r}||Yd}~dSd}~wwxYw)NT)rlrmfire_cont_framersenable_multithread dispatcher) r r+rnrorprqrrr,rtrurvrwr.zWebsocket connected)r1shutdownr r*r( settimeoutr callabler connectrr+r,r:rinfor7rZr"r}r!readr ConnectionRefusedErrorKeyboardInterrupt SystemExitrg)rr rhcheckrhandleDisconnectrtrprqrnrorrrurwrr@rsrlrmrvs rinitialize_socketz3WebSocketApp.run_forever..initialize_sockets %  % ""$$$!! $ 4D @%9#'%DI I !2!4!4 5 5 5& 2*24;*?*?PT[ !!H!;$3$3"/$3'9!%!2!$3)/"" 3444%.++---1D$51NN4#45555NN4<000 e<<<<<2&!  2 2 2! L111111111 2s2C9E--#F' F""F'cjs dSjdS jd\}}n3#ttt f$r}r|cYd}~S|d}~wwxYw|t jkr |S|t jkr" j |j n|t j kr9tj _ j|j n|t jkrZjrS j|j |j|j j|j |jnk|j }|t jkrs|d} j||jd j|dS)NFTutf-8)r)r1recv_data_framer rrr OPCODE_CLOSE OPCODE_PINGr}r&rB OPCODE_PONGrdr4r' OPCODE_CONTr(r-rCfinrIdecoder#) op_codeframerhrBclosedcustom_dispatcherr@rsrs rrz&WebSocketApp.run_forever..reads$  uy u !%!:!:4!@!@2!    %!6!99$$$$$$G $+++ve}}$D,,,t|UZ8888D,,,$(IKK!t|UZ8888D,,,1E,t|UZuyQQQt3UZKKKKzd...7K.;;w//Dt|T5<FFFt5554s!=A- A( A-&A((A-cjrktjjz jk}jjz dk}jjz jk}jr|r|s|rt ddS)Nrzping/pong timed outT)r8rdr3r4r)has_timeout_expired$has_pong_not_arrived_after_last_pinghas_pong_arrived_too_later@s rrz'WebSocketApp.run_forever..checks  KIKK$"33d6GG$%(99A=5%(99D.closeds:Aww#~~6q99##AtI77 7rcd_|sj|t |t t fr rftj|drLtj dttj d n!tj|djS)NTz - reconnectz%Calling custom dispatcher reconnect [ frames in stack]z - goodbye)r;rar}r$ isinstancerrrrreleninspectstackrxerror)rhrrrrrxr@rs rrz2WebSocketApp.run_forever..handleDisconnects $D   " " $ $ $ 1t}a000!/<==    000111$GNgGMOO@T@Tggg((4EFFF!///000 # #rr\zCalling dispatcher reconnect [rztearing down on exception r)F)r)rr r1r7r8r9r<r)r rrr rrrrgrcreate_dispatcherrrrrerrrrxrr;)r@rlrmr7r8r9rnrorprqrrrsrtrurrvrwrxrhrrrrrrrs``` ```````````` @@@@@@@r run_foreverzWebSocketApp.run_forevers+R  !I  # (9(9$%>?? ?  $):):$%@AA A  LM Lm|.K.K$%JKK K G F 9 A$%?@@ @*((!& " K" K$" K" K" K" K" K" KH5 25 2D5 2T5 25 25 25 25 25 25 25 25 25 25 25 25 25 25 25 25 25 25 25 25 25 2n% d% % % % % % % % % % N t      >& 8 82&!  8 8 8 8 8 8 8 8,"' $ $2&!  $ $ $ $ $ $ $ $ $ $ $ $ $@!,,++ *i&9&9!&&> > #BB! !%abb)F&%(( 0w//%v. .$< rc|rp ||g|RdS#t$rW}tjd|d||jr%||jur"|||Yd}~dSYd}~dSYd}~dSd}~wwxYwdS)Nzerror from callback z: )rgrrr$)r@callbackargsrhs rr}zWebSocketApp._callbackbs  + +%%%%%%% + + +EhEE!EEFFF=+XT]%B%BMM$*********++++++%B%B%B%B%B%B  + + +s  A0AA++A0)NNNNNNNNNTNNNNN)rN)NNrNr0NNNNNFNNNFNN)NFN)%__name__ __module__ __qualname____doc__rrrlistdictrrrr.rAr rIrrrFrJ bytearrayrMrPrZrarVrktupler2rrrrrrr|r}rOrrrr0s >BCGFJDHIM&*&*.2!+/ $,0&**./u7u7 u7 S S#XU49d38n#<==>@  u7(N#3T#9:;u7x(8$(>?@u7X~s&;T&ABCu78^S$94$?@Au78^S#$>$DEFu7(#u7 (#!u7""(+#u7$%u7&x('u7( )u7*tCy)+u7,(#-u7.'/u70 1u7u7u7u7n;?:JVVucz*VCVtVVVV V3V4VVVVVuUI%56V4VVVV!!!!9999* @ @ @ @111 +,48#+/"!%.2%* %%{ { { { UCZ( { uUCZ01 {  { { sCx{ { { %UO{ #{ { { !{ "#{ $%{ & '{ { { { @ 04%) ) )uUCZ01 )^, ) ) # ) z=*;; < ) ) ) ) 4 D    . + + + + + +r)"rr.r=rdtypingrrrrr0r_abnfr _corer r _exceptionsr r r _ssl_compatr_urlr _dispatcherrrrr__all__rrrrrOrrrsz  111111111111//////// %$$$$$UUUUUUUUUUUU&   "S"T"""" |+|+|+|+|+|+|+|+|+|+r