From d7370e5a8895a9bd08fd49143b44d5380a592518 Mon Sep 17 00:00:00 2001
From: nick <nick@bisonai.com>
Date: Fri, 17 Jan 2025 09:48:00 +0900
Subject: [PATCH] fix: skip empty message

---
 node/pkg/wss/utils.go | 20 ++++++++++++++------
 1 file changed, 14 insertions(+), 6 deletions(-)

diff --git a/node/pkg/wss/utils.go b/node/pkg/wss/utils.go
index 072e3b52d..a6dd5539d 100644
--- a/node/pkg/wss/utils.go
+++ b/node/pkg/wss/utils.go
@@ -117,14 +117,17 @@ func (ws *WebsocketHelper) Run(ctx context.Context, router func(context.Context,
 					log.Error().Err(err).Str("endpoint", ws.Endpoint).Msg("error reading from websocket")
 					break innerLoop
 				}
+
 				ws.lastMessageTime = time.Now()
 
-				go func(context.Context, map[string]any) {
-					routerErr := router(ctx, data)
-					if routerErr != nil {
-						log.Warn().Err(routerErr).Str("endpoint", ws.Endpoint).Msg("error processing websocket message")
-					}
-				}(ctx, data)
+				if len(data) != 0 {
+					go func(context.Context, map[string]any) {
+						routerErr := router(ctx, data)
+						if routerErr != nil {
+							log.Warn().Err(routerErr).Str("endpoint", ws.Endpoint).Msg("error processing websocket message")
+						}
+					}(ctx, data)
+				}
 			}
 		}
 		ws.Close()
@@ -228,5 +231,10 @@ func defaultReader(ctx context.Context, conn *websocket.Conn) (map[string]interf
 	if err != nil {
 		return nil, err
 	}
+
+	if len(data) == 0 {
+		return nil, nil
+	}
+
 	return data, nil
 }