i\SSKrSSKrSSKrSSKrSSKJrJrJrJr SSK J r SSK J r SSK JrJr SSKJrJrJr SSKJr SS KJr SS KJrJrJrJr S /rSqS \S S4Sjr "SS 5r!g)N)AnyCallableOptionalUnion)_logging)ABNF) WebSocketgetdefaulttimeout)"WebSocketConnectionClosedExceptionWebSocketExceptionWebSocketTimeoutException) SSLEOFError) parse_url) DispatcherDispatcherBase SSLDispatcherWrappedDispatcher WebSocketAppreconnectIntervalreturncUqgN) RECONNECT)rs K/home/mande/repo/quber/.venv/lib/python3.13/site-packages/websocket/_app.py set_reconnectr+s!Ic#\rSrSrSrS:S\S\\\\\ \\4\ /\\\\ \\4444S\\ S/S4S\\ S/S4S\\ S\ /S4S \\ S\ /S4S \\ S\ \ /S4S \\ S \\ S \\ S\ S\\ S\\S\\\S\\ S\\ RSS4"Sjjr\R 4S\\\4S\SS4SjjrS\SS4SjrS\\\4SS4SjrS;SjrS;SjrS;SjrS;SjrS rSr0zW Higher level of APIs are provided. The interface is like JavaScript WebSocket object. Nurlheaderon_open on_reconnect on_messageon_erroron_closeon_pingon_pongon_cont_message keep_running get_mask_keycookie subprotocolson_datasocketrcXlUbUO/UlXlX0lX@lXPlXlX`lXplXl Xl Xl SUl Xl SUl[S5Ul[S5UlSUlSUl[S5UlSUlSUlXlUUlSUlSUl[6R8"5Ulg)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)r r!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)selfr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/s r__init__WebSocketApp.__init__5st & 2f   ($     .!()- !!H!!H7;48"1X9=(% !&&/nn&6#rdataopcodeczUR(aURRX5S:Xa [S5eg)z 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)r2sendr )rArDrEs rrHWebSocketApp.sends0yyDIINN48A=45TU U>r text_datacUR(a.URRU[R5S:Xa [ S5eg)z Sends UTF-8 encoded text. rrGN)r2rHr OPCODE_TEXTr )rArJs r send_textWebSocketApp.send_texts9yyDIINN9d6F6FG1L45TU UMrcUR(a.URRU[R5S:Xa [ S5eg)z Sends a sequence of bytes. rrGN)r2rHr OPCODE_BINARYr )rArDs r send_bytesWebSocketApp.send_bytess9yyDIINN41C1CDI45TU UJrc |SUlUR(a$URR"S0UD6 SUlgg)z Close websocket connection. FN)r*r2close)rAkwargss rrUWebSocketApp.closes2" 99 IIOO %f %DI rc[S5=UlUl[R"5Ul[R "URS9UlSURl URR5 g)Nr)targetT) r3r4r5r>Eventr7Thread _send_pingr6daemonstartrAs r_start_ping_threadWebSocketApp._start_ping_threads[05a8D-"*$++4??C"&  rcUR(aURR5 UR(aoURR5(aPURR S5 URR5(a[ R "S5 SUlSUl[S5=UlUl g)NzYPing thread failed to terminate within 3 seconds, forcing cleanup. Thread may be blocked.r) r7setr6is_alivejoinrwarningr3r4r5r_s r_stop_ping_threadWebSocketApp._stop_ping_threads >> NN      0 0 9 9 ; ;    ! !! $((**  > 05a8D-rcURcgURRUR5(dURSLagURRUR5(dURSLaUR(aV[ R "5Ul[R"S5 URRUR5 URRUR5(dURSLaMgggg![a#n[R"SU35 SnANgSnAff=f)NFTz Sending pingzFailed to send ping: ) r7waitr8r*r2timer4rdebugpingr: Exception)rAes rr\WebSocketApp._send_pings >> !  >>  t11 2 2d6G6G56P ..%%d&8&899d>O>OSW>Wyy$(IIK!@NN>2IINN4#4#45 ..%%d&8&899d>O>OSW>W9>W9 !@NN%:1##>??@s.;D(( E2EEcTUR=(a URR$r)r2 connectedr_s rreadyWebSocketApp.readysyy0TYY000rsockoptssloptr8r9r:http_proxy_hosthttp_proxy_port http_no_proxyhttp_proxy_authhttp_proxy_timeoutskip_utf8_validationhostoriginsuppress_origin proxy_type reconnectcD^^^^^^^ ^ ^ ^ ^ ^^^^^^^^^^^Tc[mUbUS::a [S5eUbUS:a [S5eU(aU(aX4::a [S5eT(dSmT(d0mTR(a [S5eUTlUTlUTlSTlS TlSS [4U4S jjjmSS [S S4UUUU UU UUU U UUUU UUU4SjjjmS [4UUUU U4SjjmS [4U4SjjmSS[[[[[[[ 4S [4UU4SjjjmSS[[[[[[4S [S [4UUUUUU4Sjjjm[T5mTR#UT[%TR&5ST5mT"5 T(dsT(alTR(a[[(R*"S[-[.R0"55S35 TR3TT5 TR(aM[T(dT"5 TR6$![[4a*n[(R4"SU35 T"5 SnANOSnAff=f!T(dT"5 ff=f)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_timeoutrTzsocket is already openedFT close_framec>TR TR(a SSS5 gSTlSSS5 TR5 STlTR(a#TRnSTlUR 5 TR U(aUOS5up#TRTRX#5 g!,(df  N=f)z 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=rhr*r2rU_get_close_args _callbackr&)r current_sockclose_status_code close_reasonrAs rteardown*WebSocketApp.run_forever..teardown_s,,))-,*.&-  " " $ %D yy $yy   ""$.2.B.B* / +  NN4==*; J+-,sB=B== C  reconnectingrc>U(a+TR(aTRR5 [TRTTTRSLTSTS9TlTRR [ 55 [TR5(aTR5O TRnTRRTRUTRT T TTT TRTT TT TRS9 [R"S5 TR (aTR#5 U(a-TR$(aTR'TR$5 OTR'TR(5 TR+TRRTT5 g![,[.[0[2[44anT"X 5 SnAgSnAff=f)NT)rvrwfire_cont_framer}enable_multithread dispatcher) r!r,rxryrzr{r|r-r~rrrr/zWebsocket connected)r2shutdownr r+r) settimeoutr callabler!connectr r,r-r;rinfor8r`r#rr"readr ConnectionRefusedErrorKeyboardInterrupt SystemExitro)rr!rpcheckrhandleDisconnectr~rzr{rxryr|rrrrAr}rvrwrs rinitialize_socket3WebSocketApp.run_forever..initialize_socketsv  ""$!!! $ 4 4D @%9#'%DI II !2!4 5& 2*24;;*?*?T[[ !!HH!;;$3$3"/$3'9!%!2!2!$3)//"" 34%%++-D$5$5NN4#4#45NN4<<0 e<2&!  2!11 2sD1F44G%G  G%cj>TR(dT"5 gTRcgTRRS5upU[ R:XaT"U5$U[ R:Xa'TRTRUR5 gU[ R:XaA[R"5TlTRTRUR5 gU[ R :XaTR"(anTRTR$URUR&UR(5 TRTR"URUR(5 gURnU[ R*:XaT(dUR-S5nTRTR$X1R&S5 TRTR.U5 g![[[ 4anT(a T"U5sSnA$UeSnAff=f)NFTutf-8)r*r2recv_data_framer rrr OPCODE_CLOSE OPCODE_PINGrr'rD OPCODE_PONGrlr5r( OPCODE_CONTr)r.rEfinrLdecoder$) op_codeframerprDclosedcustom_dispatcherrAr}rs rr&WebSocketApp.run_forever..reads$$ yy  !%!:!:4!@$+++e}$D,,,t||UZZ8D,,,$(IIK!t||UZZ8D,,,1E1Et||UZZuyyQt33UZZK zzd...7K;;w/Dt||T<<Ft553!  %!!9$G s#HH2H-%H2+H--H2cl>TR(a[R"5TR- TR:nTRTR- S:nTRTR- TR:nTR(a U(aU(dU(a [ S5eg)Nrzping/pong timed outT)r9rlr4r5r)has_timeout_expired$has_pong_not_arrived_after_last_pinghas_pong_arrived_too_laterAs rr'WebSocketApp.run_forever..checks  IIK$"3"33d6G6GG$%%(9(99A=5%%(9(99D[U5[La [U5nT"U[T55$r)typestrr bool)rprrs rr(WebSocketApp.run_forever..closeds+Aw#~6q9#AtI7 7rc >STlTR5 U(dTRTRU5 [ U[ [ 45(aT"5 eT(at[R"US35 T(aH[R"S[[R"55S35 TRTT5 TR$[R"US35 T"5 TR$)NTz - reconnectz%Calling custom dispatcher reconnect [ frames in stack]z - goodbye)r<rhrr% isinstancerrrrrmleninspectstackrerror)rprrrrrrArs rr2WebSocketApp.run_forever..handleDisconnects $D   " " $t}}a0!/<==  <01$NN?GMMO@T?UUfg((4EF## #!J/0 ## #rrczCalling dispatcher reconnect [rztearing down on exception r)F)zclosed unexpectedly)rr r2r8r9r:r=r*r rrr rrrrorcreate_dispatcherrr rrmrrrrrr<)rArvrwr8r9r:rxryrzr{r|r}r~rrrrrrprrrrrrrs``` ```````````` @@@@@@@r run_foreverWebSocketApp.run_foreversiR  !I  # (9$%>? ?  $):$%@A A Mm.K$%JK KGF 99$%?@ @*((!& " K$" K" KH5 2D5 2T5 25 25 25 2n% d% % N t >& 82&!  8 8 8,"' $2&!  $ $ $ $@!,++ *i&9!& >  #B! !%%ab)F&%((w/%. .$< rcU(a U"U/UQ76 gg![a`n[R"SUSU35 UR(a)XRLaURX5 SnAgSnAgSnAgSnAff=f)Nzerror from callback z: )rorrr%)rAcallbackargsrps rrWebSocketApp._callbackbsq  +%%  +!5hZr!EF==X]]%BMM$**&C=  +s  A>A A99A>)r,r+r=r@r<r!r*r4r5r&r)r.r%r$r"r'r(r#r8r:r6r9r;r2r7r-r )NNNNNNNNNTNNNNN)rN)NNrNr1NNNNNFNNNFNN)NFN)'__name__ __module__ __qualname____firstlineno____doc__rrrlistdictrrrr/rBr rLrrrHrM bytearrayrQrUr`rhr\rttupler3rrrrrrrr__static_attributes__rTrrrr0s >BCGFJDHIM&*&*.2!+/ $,0&**./u7 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 1u7n;?:J:JVucz*VCVtV V3V4VVuUI%56V4V!9* @1 +,48#+/"!%.2%* %%{ { { UCZ( { uUCZ01 {  { { sCx{ { { %UO{ #{ { { !{ "#{ $%{ & '{ @ 04%) )uUCZ01 )^, ) ) # ) z=*;; < ) 4 D . +r)"rr/r>rltypingrrrrr1r_abnfr _corer r _exceptionsr r r _ssl_compatr_urlr _dispatcherrrrr__all__rrrrrTrrrsk  11/ %UU&   "S"T" |+|+r