From 8491023896925362b029fe7c2dbb82f5c5e355b8 Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Fri, 29 Dec 2023 10:56:53 +0800
Subject: [PATCH] ws

---
 internal/msggateway/n_ws_server.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/internal/msggateway/n_ws_server.go b/internal/msggateway/n_ws_server.go
index 77b4c01ec..862431ed8 100644
--- a/internal/msggateway/n_ws_server.go
+++ b/internal/msggateway/n_ws_server.go
@@ -488,7 +488,7 @@ type WSArgs struct {
 func (ws *WsServer) wsHandler(w http.ResponseWriter, r *http.Request) {
 	connContext := newContext(w, r)
 	args, pErr := ws.ParseWSArgs(r)
-	log.ZDebug(connContext, "ws req", "MsgResp", args.MsgResp, "query", r.URL.RawQuery)
+	log.ZDebug(connContext, "http websocket req", "MsgResp", args.MsgResp, "query", r.URL.RawQuery)
 	var wsLongConn *GWebSocket
 	if args.MsgResp {
 		wsLongConn = newGWebSocket(WebSocket, ws.handshakeTimeout, ws.writeBufferSize)
@@ -501,7 +501,8 @@ func (ws *WsServer) wsHandler(w http.ResponseWriter, r *http.Request) {
 			_ = wsLongConn.Close()
 			return
 		}
-		if err := wsLongConn.WriteMessage(MessageBinary, data); err != nil {
+		log.ZDebug(connContext, "http websocket MsgResp", "data", string(data))
+		if err := wsLongConn.WriteMessage(MessageText, data); err != nil {
 			_ = wsLongConn.Close()
 			return
 		}