resolve comment

config/config.go

@@ -141,7 +141,8 @@ func (cfg *LogConfig) Validate() {
 }
 
 type AlertConfig struct {
-	EnableAlert bool `json:"enable_alert"`
+	EnableAlert bool  `json:"enable_alert"`
+	Interval    int64 `json:"interval"`
 
 	TelegramBotId  string `json:"telegram_bot_id"`
 	TelegramChatId string `json:"telegram_chat_id"`
@@ -153,6 +154,9 @@ func (cfg *AlertConfig) Validate() {
 	if !cfg.EnableAlert {
 		return
 	}
+	if cfg.Interval <= 0 {
+		panic("alert interval should be positive")
+	}
 	balanceThreshold, ok := big.NewInt(1).SetString(cfg.BalanceThreshold, 10)
 	if !ok {
 		panic(fmt.Sprintf("unrecognized balance_threshold"))

config/config.json

@@ -41,6 +41,7 @@
   },
   "alert_config": {
     "enable_alert": false,
+    "interval": 300,
     "telegram_bot_id": "your_bot_id",
     "telegram_chat_id": "your_chat_id",
     "balance_threshold": "1000000000000000000"

relayer/alert.go

@@ -11,7 +11,7 @@ import (
 )
 
 const (
-	AlertInterval = 60 * time.Second
+	RetryInterval = 5 * time.Second
 )
 
 func (r *Relayer) alert() {
@@ -25,19 +25,21 @@ func (r *Relayer) alert() {
 	for {
 		balance, err := r.bscExecutor.GetRelayerBalance()
 		if err != nil {
-			util.SendTelegramMessage(r.cfg.AlertConfig.TelegramBotId, r.cfg.AlertConfig.TelegramChatId, fmt.Sprintf("got relayer balance failure: %s", err.Error()))
+			time.Sleep(RetryInterval)
+			continue
 		} else {
 			balance, err := decimal.NewFromString(balance.String())
 			if err != nil {
 				common.Logger.Error(err.Error())
 			}
+			util.SendTelegramMessage(r.cfg.AlertConfig.TelegramBotId, r.cfg.AlertConfig.TelegramChatId, fmt.Sprintf("relayer balance: %s", balance.String()))
 			if balance.Cmp(balanceThreshold) <= 0 {
 				msg := fmt.Sprintf("bsc-relayer balance (%s:BNB) on Binance Smart Chain is less than threshold (%s:BNB)",
 					balance.Div(decimal.NewFromInt(1e18)).String(), balanceThreshold.Div(decimal.NewFromInt(1e18)).String())
 				util.SendTelegramMessage(r.cfg.AlertConfig.TelegramBotId, r.cfg.AlertConfig.TelegramChatId, msg)
 			}
 		}
 
-		time.Sleep(AlertInterval)
+		time.Sleep(time.Duration(r.cfg.AlertConfig.Interval) * time.Second)
 	}
 }

relayer/cleanup.go

@@ -4,7 +4,7 @@ import (
 	"github.com/binance-chain/bsc-relayer/common"
 )
 
-func (r *Relayer)cleanPreviousPackages(height uint64) error {
+func (r *Relayer) cleanPreviousPackages(height uint64) error {
 	blockSynced := false
 	common.Logger.Info("enter CleanPreviousPackages mode")
 	for _, channelId := range r.bbcExecutor.Config.CrossChainConfig.MonitorChannelList {

relayer/register.go

@@ -6,7 +6,7 @@ import (
 	"github.com/binance-chain/bsc-relayer/common"
 )
 
-func (r *Relayer)registerRelayerHub() {
+func (r *Relayer) registerRelayerHub() {
 	isRelayer, err := r.bscExecutor.IsRelayer()
 	if err != nil {
 		panic(err)