vKgp^SSKrSSKrSSKrSSKrSSKrSSKJrJrJrJ r SSK J r SSK J r SSKJrJr SSKJrJrJr SSKJr SS KJr S /rSqS \S S4S jr"SS5r"SS\5r"SS\5r"SS5r "SS 5r!g)N)AnyCallableOptionalUnion)_logging)ABNF) WebSocketgetdefaulttimeout)"WebSocketConnectionClosedExceptionWebSocketExceptionWebSocketTimeoutException) SSLEOFError) parse_url WebSocketAppreconnectIntervalreturncUqgN) RECONNECT)rs N/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/websocket/_app.py setReconnectr+s!Icr\rSrSrSrS\S\\\S4SS4Sjr S\\\S4S \ SS4S jr S\S \ SS4S jr S r g)DispatcherBase0z DispatcherBase app ping_timeoutNrcXlX lgrrr)selfrrs r__init__DispatcherBase.__init__5s (rsecondscallbackc>[R"U5 U"5 gr)timesleepr!r$r%s rtimeoutDispatcherBase.timeout9s 7 r reconnectorc  [R"SUS[[R"55S35 [ R "U5 U"SS9 g![a n[R"SU35 UeSnAff=f)Nzreconnect() - retrying in z seconds [ frames in stack]T) reconnectingz User exited )rinfoleninspectstackr'r(KeyboardInterrupt)r!r$r,es r reconnectDispatcherBase.reconnect=sp  MM,WIZGMMO@T?UUfg  JJw  T *   MML, -G sAA B"A==Br )__name__ __module__ __qualname____firstlineno____doc__rrfloatintr"rr*r6__static_attributes__rrrr0sm)C)uUC5E/F)4)uUC%56(t  8  rrcF\rSrSrSrS\R S\S\SS4SjrS rg) DispatcherIz Dispatcher sock read_callbackcheck_callbackrNc[R"5nURURRR[R 5 URR (aQURUR5(a U"5(dO$U"5 URR (aMQUR5 g!UR5 f=fr) selectorsDefaultSelectorregisterrrD EVENT_READ keep_runningselectrcloser!rDrErFsels rreadDispatcher.readNs '') TXX]]'')=)=> ((''::d//00(?? ((''' IIKCIIKs A*CC$r@) r8r9r:r;r<socketrrQr?r@rrrBrBIs6mm !   rrBch\rSrSrSrS\R S\S\SS4SjrS \R4S jr S r g) SSLDispatcher`z SSLDispatcher rDrErFrNcURRRn[R"5nUR U[R 5 URR (aGURX5(a U"5(dO$U"5 URR (aMGUR5 g!UR5 f=fr) rrDrHrIrJrKrLrMrNrOs rrQSSLDispatcher.reades xx}}!!'') T9//0 (('';;t))(?? ((''' IIKCIIKs A C CrPcURRRnUR5(aU/$URUR5n[ U5S:aUSS$g)Nr)rrDpendingrMrr1)r!rDrPrs rrMSSLDispatcher.selectws`xx}}!! <<>>  JJt(( ) q6A:Q47N rr@) r8r9r:r;r<rSrrQrHrIrMr?r@rrrUrU`sHmm !   $  9 9 rrUc\rSrSrSrS\\\S4SS4SjrS\ RS\ S \ SS4S jr S \S \ SS4S jr S \S\ SS4Sjr Srg)WrappedDispatcherz WrappedDispatcher rNrc`XlX lX0lURSUR5 g)N)rr dispatchersignalabort)r!rrrbs rr"WrappedDispatcher.__init__s(($!Z--.rrDrErFcURRX5 UR=(a URURU5 g gr)rbrQrr*)r!rDrErFs rrQWrappedDispatcher.reads8 T1 Mdll4+<+r"rSrrQr*r6r?r@rrr^r^s/%sD0@*A/RV/ NmmN N! N  N3u33T3++8++rr^c#\rSrSrSrS8S\S\\\\ S4S\ \ \ /S4S\ \ \ /S4S\ \ \ \ /S4S \ \ \ \ /S4S \ \ \ \ \ /S4S \ \ S \ \ S \ \ S\ S\ \ S\ \S\ \S\ \ S\ \RSS4"Sjjr\R"4S\\\4S\SS4SjjrS\SS4SjrS\\\4SS4SjrS9SjrS9SjrS9SjrS9SjrS:S \S!\S"\\\4S#\\\S4S$\S%\S&\\\4S'\S(\S)\ \S*\ S+\S,\S-\ S.\S/\S\ 4"S0jjrS;S#\\\S4S1\ \S2\ S\\ \!\"44S3jjr#S4\S\4S5jr$S9S6jr%S7r&g)r text_datacUR(a.URRU[R5S:Xa [ S5eg)z Sends UTF-8 encoded text. rrN)rDrr OPCODE_TEXTr )r!rs r send_textWebSocketApp.send_text%s9yyDIINN9d6F6FG1L45TU UMrcUR(a.URRU[R5S:Xa [ S5eg)z Sends a sequence of bytes. rrN)rDrr OPCODE_BINARYr )r!rs r send_bytesWebSocketApp.send_bytes,s9yyDIINN41C1CDI45TU UJrc |SUlUR(a$URR"S0UD6 SUlgg)z Close websocket connection. FNr@)rLrDrN)r!kwargss rrNWebSocketApp.close3s2" 99 IIOO %f %DI rc[S5=UlUl[R"5Ul[R "URS9UlSURl URR5 g)Nr)targetT) r=r~rrEventrThread _send_pingrdaemonstartr!s r_start_ping_threadWebSocketApp._start_ping_thread<s[05a8D-"*$++4??C"&  rcUR(aURR5 UR(a:URR5(aURR S5 [ S5=UlUlg)Nr)rsetris_alivejoinr=r~rrs r_stop_ping_threadWebSocketApp._stop_ping_threadCs^ >> NN      0 0 9 9 ; ;    ! !! $05a8D-rcURRUR5(dURSLagURRUR5(dURSLaUR(aV[ R "5Ul[R"S5 URRUR5 URRUR5(dURSLaMgggg![a#n[R"SU35 SnANgSnAff=f)NFTz Sending pingzFailed to send ping: ) rwaitrrLrDr'r~rdebugpingr Exception)r!r5s rrWebSocketApp._send_pingJs >>  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 E$EEsockoptssloptrrrhttp_proxy_hosthttp_proxy_port http_no_proxyhttp_proxy_authhttp_proxy_timeoutskip_utf8_validationhostoriginsuppress_origin proxy_typer6c^^^^^^^ ^ ^ ^ ^ ^^^^^^^^^^Tc[mUbUS::a [S5eUbUS:a [S5eU(aU(aX4::a [S5eT(dSmT(d0mTR(a [S5eUTlUTlUTlSTlS TlSS [4U4S jjjmSS [S S4UUUU UU UUU U UUUU UUU4SjjjmS [4UUUUU U4SjjmS [4U4SjjmSS[[[[[[4S [S [4UUUUUU4Sjjjm[T5mTR!UT[#TR$5S5mT"5 T(dsT(alTR(a[[&R("S[+[,R."55S35 TR1TT5 TR(aM[T(dT"5 TR4$![[4a*n[&R2"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_timeoutr@zsocket is already openedFT close_framec>TR TR(a SSS5 gSTlSSS5 TR5 STlTR(aTRR 5 TR U(aUOS5upSTlTRTRX5 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) rrrrLrDrN_get_close_args _callbackrt)rclose_status_code close_reasonr!s rteardown*WebSocketApp.run_forever..teardowns,,))-,*.&-  " " $ %D yy !.2.B.B* / + DI NN4==*; J-,sB;B;; C r/rc>U(a+TR(aTRR5 [TRTTTRSLTSS9TlTRR [ 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)rrfire_cont_framerenable_multithread) roryrrrrrrzrrrrrSzWebsocket connected)rDshutdownr rxrw settimeoutr callableroconnectrnryrzrrr0rrrqrrprQr ConnectionRefusedErrorr4 SystemExitr)r/ror5checkrbhandleDisconnectrrrrrrrrrQr!rrrrs rsetSock)WebSocketApp.run_forever..setSockss  ""$!!! $ 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 2sD1F33G$GG$c`>TR(dT "5$TRRS5upU[R:XaT "U5$U[R:Xa'TRTRUR5 gU[R:XaA[R"5TlTRTR UR5 gU[R":XaTR$(anTRTR&URUR(UR*5 TRTR$URUR*5 gURnU[R,:XaT(dUR/S5nTRTR&X1R(S5 TRTR0U5 g![[[ 4a%nT(aT"U[ T55sSnA$UeSnAff=f)NTutf-8)rLrDrecv_data_framer r4rboolr OPCODE_CLOSE OPCODE_PINGrrur OPCODE_PONGr'rrv OPCODE_CONTrwr{rfinrdecoderr) op_codeframer5rcustom_dispatcherrr6r!rrs rrQ&WebSocketApp.run_forever..read s$$z! !%!:!:4!@$+++&D,,,t||UZZ8D,,,$(IIK!t||UZZ8D,,,1E1Et||UZZuyyQt33UZZK zzd...7K;;w/Dt||T<<Ft553!  %+AtI??G s#G33H-H( H-&H((H-cl>TR(a[R"5TR- TR:nTRTR- S:nTRTR- TR:nTR(a U(aU(dU(a [ S5eg)Nrzping/pong timed outT)rr'r~rr)has_timeout_expired$has_pong_not_arrived_after_last_pinghas_pong_arrived_too_later!s rr'WebSocketApp.run_forever..check,s  IIK$"3"33d6G6GG$%%(9(99A=5%%(9(99DSTlTR5 U(dTRTRU5 [ U[ [ 45(aT"5 eT(aj[R"US35 T(aI[R"S[[R"55S35 TRTT5 gg[R"US35 T"5 g)NTz - reconnectz%Calling custom dispatcher reconnect [r.z - goodbye)rrrrs isinstancer4rrr0rr1r2r3r6error)r5r/rrbr6r!rrs rr2WebSocketApp.run_forever..handleDisconnectCs $D   " " $t}}a0!/<==  <01$NN?GMMO@T?UUfg((G< % !J/0 rrzCalling dispatcher reconnect [r.ztearing down on exception r)F)rr rDrrrrrLr rrr rr4rrcreate_dispatcherrrnrrr1r2r3r6r0r)r!rrrrrrrrrrrrrrbrrr6r5rrrrQrrs``` ```````````` @@@@@@r run_foreverWebSocketApp.run_foreverVs&R  !I  # (9$%>? ?  $):$%@A A Mm.K$%JK KGF 99$%?@ @*((!&  K$ K K<4 2$4 244 24 24 24 2l! d! ! F t >"' 2&!     >!,++ *i&9!&<   I$''NN8W]]_9M8NN_`((G< '''% "9-  MM6qc: ; JJ % %s+rbytesr)r!rrreasons rrWebSocketApp._get_close_argss}}K$<    K$4$4 5 : #c+*:*:1*=&> >  #B! !%%ab)F&%((w/%. .$< rcU(a U"U/UQ76 gg![aMn[R"SUSU35 UR(aURX5 SnAgSnAgSnAff=f)Nzerror from callback z: )rrrrs)r!r%argsr5s rrWebSocketApp._callbacksc  +%%  +!5hZr!EF==MM$**! +s  A+>A&&A+)ryrxrrrrorLr~rrtrwr{rsrrrprurvrqrrrrrrDrrzrn)NNNNNNNNNTNNNNN)rN)NNrNr}NNNNNFNNNFNN)NF)'r8r9r:r;r<strrlistdictrrr rrrSr"r rrr>rr bytearrayrrNrrrtupler=rrrBrUr^rrrr?r@rrrrs599=>BAE?CDH&*&*.2!+/ $'+&**.#o7 o7dD(D01o7(I;#456 o7 x T(9:; o7 Xy#&6&<=> o78Y$4d$:;<o78YS$94$?@Ao7(#o7(#o7"(+o7o7x(o7 o7tno7 (#!o7"'#o7$ %o7b;?:J:JVucz*VCVtV V3V4VVuUI%56V4V!9 @+,04#+/"!%.2%* %%a a a UCZ( a E3,- a  a a sCxa a a %UOa #a a a !a "#a $%a & 'a L 04 )E3,- )^, ) ) z=*;; < ) 4 D .+r)"r2rHrSrr'typingrrrrr}r_abnfr _corer r _exceptionsr r r _ssl_compatr_urlr__all__rr>rrrBrUr^rr@rrrs  11/ %&   "C"D" 2.!N!H++6F+F+r