From 8fd0f4d32faebdc535d8c1a5592dea26d008862c Mon Sep 17 00:00:00 2001 From: nick Date: Mon, 20 Jan 2025 11:23:19 +0900 Subject: [PATCH] fix: reduce log spamming --- node/pkg/websocketfetcher/providers/xt/utils.go | 2 +- node/pkg/websocketfetcher/providers/xt/xt.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/node/pkg/websocketfetcher/providers/xt/utils.go b/node/pkg/websocketfetcher/providers/xt/utils.go index cd8f025b2..1a2a4bcb3 100644 --- a/node/pkg/websocketfetcher/providers/xt/utils.go +++ b/node/pkg/websocketfetcher/providers/xt/utils.go @@ -13,7 +13,7 @@ func ResponseToFeedData(response Response, feedMap map[string][]int32) ([]*commo symbol := strings.ToUpper(strings.ReplaceAll(response.Data.Symbol, "_", "-")) ids, exists := feedMap[symbol] if !exists { - log.Error().Str("Player", "xt").Str("key", symbol).Msg("feed not found") + log.Warn().Str("Player", "xt").Str("raw", response.Data.Symbol).Str("key", symbol).Msg("feed not found") return nil, fmt.Errorf("feed not found from xt for symbol: %s", symbol) } timestamp := time.UnixMilli(response.Data.Time) diff --git a/node/pkg/websocketfetcher/providers/xt/xt.go b/node/pkg/websocketfetcher/providers/xt/xt.go index 6106b556e..9511e6c9a 100644 --- a/node/pkg/websocketfetcher/providers/xt/xt.go +++ b/node/pkg/websocketfetcher/providers/xt/xt.go @@ -70,7 +70,7 @@ func (f *XtFetcher) handleMessage(ctx context.Context, message map[string]any) e feedDataList, err := ResponseToFeedData(raw, f.FeedMap) if err != nil { - log.Error().Str("Player", "Xt").Err(err).Msg("error in xt.handleMessage, failed to convert response to feed data") + log.Warn().Str("Player", "Xt").Err(err).Msg("error in xt.handleMessage, failed to convert response to feed data") return err }