From 2c7077f8695c8d7dc7157b61da93fa09cc4b46ba Mon Sep 17 00:00:00 2001 From: nick Date: Mon, 23 Dec 2024 11:19:51 +0900 Subject: [PATCH 1/3] fix: reduce logs --- node/pkg/wss/utils.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/node/pkg/wss/utils.go b/node/pkg/wss/utils.go index 7e6970233..9fe4b58f9 100644 --- a/node/pkg/wss/utils.go +++ b/node/pkg/wss/utils.go @@ -185,7 +185,7 @@ func (ws *WebsocketHelper) Read(ctx context.Context, ch chan any) error { var t any err := wsjson.Read(ctx, ws.Conn, &t) if err != nil { - log.Error().Err(err).Str("endpoint", ws.Endpoint).Msg("error reading from websocket") + log.Warn().Err(err).Str("endpoint", ws.Endpoint).Msg("error reading from websocket") return err } ch <- t @@ -198,7 +198,7 @@ func (ws *WebsocketHelper) Close() error { } err := ws.Conn.Close(websocket.StatusNormalClosure, "") if err != nil { - log.Error().Err(err).Str("endpoint", ws.Endpoint).Msg("error closing websocket") + log.Warn().Err(err).Str("endpoint", ws.Endpoint).Msg("error closing websocket") return err } return nil From 365271afbf3cb075866853a0ea9346ab3ccf632c Mon Sep 17 00:00:00 2001 From: nick Date: Mon, 23 Dec 2024 11:32:02 +0900 Subject: [PATCH 2/3] fix: reduce log spamming --- node/pkg/websocketfetcher/providers/bingx/bingx.go | 2 +- node/pkg/websocketfetcher/providers/coinex/coinex.go | 2 +- node/pkg/wss/utils.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/node/pkg/websocketfetcher/providers/bingx/bingx.go b/node/pkg/websocketfetcher/providers/bingx/bingx.go index 7170933cf..a5a124ab6 100644 --- a/node/pkg/websocketfetcher/providers/bingx/bingx.go +++ b/node/pkg/websocketfetcher/providers/bingx/bingx.go @@ -92,7 +92,7 @@ func (f *BingxFetcher) customReadFunc(ctx context.Context, conn *websocket.Conn) var result map[string]interface{} _, data, err := conn.Read(ctx) if err != nil { - log.Error().Str("Player", "Bingx").Err(err).Msg("error in bingx.customReadFunc, failed to read from websocket") + log.Warn().Str("Player", "Bingx").Err(err).Msg("error in bingx.customReadFunc, failed to read from websocket") return nil, err } diff --git a/node/pkg/websocketfetcher/providers/coinex/coinex.go b/node/pkg/websocketfetcher/providers/coinex/coinex.go index 52694dcda..b82f4faa7 100644 --- a/node/pkg/websocketfetcher/providers/coinex/coinex.go +++ b/node/pkg/websocketfetcher/providers/coinex/coinex.go @@ -80,7 +80,7 @@ func (f *CoinexFetcher) customReadFunc(ctx context.Context, conn *websocket.Conn var result map[string]interface{} _, data, err := conn.Read(ctx) if err != nil { - log.Error().Str("Player", "coinex").Err(err).Msg("error in coinex.customReadFunc, failed to read from websocket") + log.Warn().Str("Player", "coinex").Err(err).Msg("error in coinex.customReadFunc, failed to read from websocket") return nil, err } diff --git a/node/pkg/wss/utils.go b/node/pkg/wss/utils.go index 9fe4b58f9..2f97b2d1b 100644 --- a/node/pkg/wss/utils.go +++ b/node/pkg/wss/utils.go @@ -53,7 +53,7 @@ func (ws *WebsocketHelper) Dial(ctx context.Context) error { } conn, _, err := dialFunc(ctx, ws.Endpoint, dialOption) if err != nil { - log.Error().Err(err).Str("endpoint", ws.Endpoint).Msg("error opening websocket connection") + log.Warn().Err(err).Str("endpoint", ws.Endpoint).Msg("error opening websocket connection") return err } From a45fb6b7ace9e309595ca75d41c53001abbcb2ce Mon Sep 17 00:00:00 2001 From: nick Date: Mon, 23 Dec 2024 11:33:10 +0900 Subject: [PATCH 3/3] fix: reduce error logs --- node/pkg/wss/utils.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/node/pkg/wss/utils.go b/node/pkg/wss/utils.go index 2f97b2d1b..072e3b52d 100644 --- a/node/pkg/wss/utils.go +++ b/node/pkg/wss/utils.go @@ -88,7 +88,7 @@ func (ws *WebsocketHelper) Run(ctx context.Context, router func(context.Context, for { err := ws.dialAndSubscribe(ctx) if err != nil { - log.Error().Err(err).Str("endpoint", ws.Endpoint).Msg("error dialing and subscribing to websocket") + log.Warn().Err(err).Str("endpoint", ws.Endpoint).Msg("error dialing and subscribing to websocket") time.Sleep(time.Second) continue }