(Node) Reduce logs (#2342)

* fix: reduce logs * fix: reduce log spamming * fix: reduce error logs
Bisonai · Dec 23, 2024 · 08b79cd · 08b79cd
1 parent 8bfa0b1
commit 08b79cd
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git 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
@@ -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
@@ -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
 	}
 
@@ -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
 		}
@@ -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