patch

stream/json.go

@@ -5,6 +5,6 @@ import jsoniter "github.com/json-iterator/go"
 var json = jsoniter.Config{
 	EscapeHTML:             true,
 	SortMapKeys:            true,
-	ValidateJsonRawMessage: true,
+	ValidateJsonRawMessage: false,
 	CaseSensitive:          true,
 }.Froze()

stream/websocket.go

@@ -52,7 +52,14 @@ func (ws *WebsocketServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		var cmd command
 		err = json.Unmarshal(message, &cmd)
 		if err != nil {
-			return
+			c.WriteJSON(map[string]any{
+				"error": map[string]any{
+					"code":    -32600,
+					"message": "invalid message",
+					"data":    err.Error(),
+				},
+			})
+			continue
 		}
 		switch cmd.Method {
 		case "topic_subscribe":