From 563c6cb36618580b3cb9cab17ca2cddfa96dfb31 Mon Sep 17 00:00:00 2001 From: self4m <57866775+self4m@users.noreply.github.com> Date: Fri, 12 Jun 2026 15:31:22 +0800 Subject: [PATCH] feat(tron): add rpc node availability check on startup --- src/task/listen_trc20_block.go | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/src/task/listen_trc20_block.go b/src/task/listen_trc20_block.go index f4c9bfe0..951f4e39 100644 --- a/src/task/listen_trc20_block.go +++ b/src/task/listen_trc20_block.go @@ -473,14 +473,17 @@ func (s *Scanner) recordRpcFailure(reason string) { func StartTronBlockScannerListener() { for { - scanner := NewScanner() - if err := scanner.Init(); err != nil { - log.Sugar.Errorf("[TRON-BLOCK] init: %v, retrying...", err) - time.Sleep(10 * time.Second) - continue + if data.IsChainEnabled(mdb.NetworkTron) { + scanner := NewScanner() + if err := scanner.Init(); err != nil { + log.Sugar.Warnf("[TRON-BLOCK] init: %v, retrying...", err) + time.Sleep(10 * time.Second) + continue + } + scanner.Run() + log.Sugar.Warn("[TRON-BLOCK] scanner stopped, restarting...") + time.Sleep(3 * time.Second) } - scanner.Run() - log.Sugar.Warn("[TRON-BLOCK] scanner stopped, restarting...") - time.Sleep(3 * time.Second) + time.Sleep(10 * time.Second) } }