feat: update health

node/pkg/checker/dal/app.go

@@ -6,11 +6,13 @@ import (
 	"errors"
 	"fmt"
 	"os"
+	"slices"
 	"strconv"
 	"strings"
 	"time"
 
 	"bisonai.com/miko/node/pkg/alert"
+	"bisonai.com/miko/node/pkg/checker"
 	"bisonai.com/miko/node/pkg/db"
 	"bisonai.com/miko/node/pkg/secrets"
 	"bisonai.com/miko/node/pkg/utils/request"
@@ -32,6 +34,10 @@ func (u *UpdateTimes) CheckLastUpdateOffsets(alarmCount map[string]int) []string
 	websocketNotPushedCount := 0
 	var messages []string
 	for symbol, updateTime := range u.lastUpdates {
+		if slices.Contains(checker.DelistedSymbols, symbol) {
+			continue
+		}
+
 		elapsedTime := time.Since(updateTime)
 		if elapsedTime > WsPushThreshold {
 			alarmCount[symbol]++
@@ -164,6 +170,10 @@ func checkDal(endpoint string, key string, alarmCount map[string]int, networkDel
 
 	totalDelayed := 0
 	for _, data := range resp {
+		if slices.Contains(checker.DelistedSymbols, data.Symbol) {
+			continue
+		}
+
 		rawTimestamp, err := strconv.ParseInt(data.AggregateTime, 10, 64)
 		if err != nil {
 			log.Error().Str("Player", "DalChecker").Err(err).Msg("failed to convert timestamp string to int64")

node/pkg/checker/delisted.go

@@ -0,0 +1,5 @@
+package checker
+
+var DelistedSymbols = []string{
+	"JOY-USDT",
+}

node/pkg/checker/event/app.go

@@ -4,10 +4,12 @@ import (
 	"context"
 	"fmt"
 	"os"
+	"slices"
 	"strings"
 	"time"
 
 	"bisonai.com/miko/node/pkg/alert"
+	"bisonai.com/miko/node/pkg/checker"
 	"bisonai.com/miko/node/pkg/db"
 	"bisonai.com/miko/node/pkg/utils/request"
 	"github.com/rs/zerolog/log"
@@ -53,6 +55,10 @@ func setUp(ctx context.Context) (*CheckList, error) {
 
 	FeedsToCheck := []FeedToCheck{}
 	for _, config := range configs {
+		if slices.Contains(checker.DelistedSymbols, config.Name) {
+			continue
+		}
+
 		subgraphInfo, ok := subgraphInfoMap[config.Name]
 		if !ok {
 			continue