From 8269e61163d5f85ec31e7adaa898896ffb96a902 Mon Sep 17 00:00:00 2001
From: skiffer-git <44203734@qq.com>
Date: Sat, 11 Jun 2022 12:03:12 +0800
Subject: [PATCH] debug log

---
 internal/msg_gateway/gate/rpc_server.go | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/internal/msg_gateway/gate/rpc_server.go b/internal/msg_gateway/gate/rpc_server.go
index 5f5d3646c..af6e62e16 100644
--- a/internal/msg_gateway/gate/rpc_server.go
+++ b/internal/msg_gateway/gate/rpc_server.go
@@ -254,7 +254,13 @@ func (r *RPCServer) OnlineBatchPushOneMsg(_ context.Context, req *pbRelay.Online
 	}, nil
 }
 func (r *RPCServer) encodeWsData(wsData *sdk_ws.MsgData, operationID string) (bytes.Buffer, error) {
-	msgBytes, _ := proto.Marshal(wsData)
+	log.Debug(operationID, "encodeWsData begin", wsData.String())
+	msgBytes, err := proto.Marshal(wsData)
+	if err != nil {
+		log.NewError(operationID, "Marshal", err.Error())
+		return bytes.Buffer{}, utils.Wrap(err, "")
+	}
+	log.Debug(operationID, "encodeWsData begin", wsData.String())
 	mReply := Resp{
 		ReqIdentifier: constant.WSPushMsg,
 		OperationID:   operationID,
@@ -262,10 +268,10 @@ func (r *RPCServer) encodeWsData(wsData *sdk_ws.MsgData, operationID string) (by
 	}
 	var replyBytes bytes.Buffer
 	enc := gob.NewEncoder(&replyBytes)
-	err := enc.Encode(mReply)
+	err = enc.Encode(mReply)
 	if err != nil {
 		log.NewError(operationID, "data encode err", err.Error())
-		return bytes.Buffer{}, err
+		return bytes.Buffer{}, utils.Wrap(err, "")
 	}
 	return replyBytes, nil
 }