fix: change prometheus port.

FGadvancer · Dec 5, 2023 · 8c1633e · 8c1633e
1 parent 4461d91
commit 8c1633e
Showing 1 changed file with 17 additions and 18 deletions.
diff --git a/internal/msggateway/message_handler.go b/internal/msggateway/message_handler.go
@@ -18,7 +18,6 @@ import (
 	"context"
 	"sync"
 
-	"github.com/OpenIMSDK/protocol/msg"
 	"github.com/OpenIMSDK/tools/log"
 
 	"github.com/OpenIMSDK/protocol/push"
@@ -139,23 +138,23 @@ func (g GrpcHandler) GetSeq(context context.Context, data *Req) ([]byte, error)
 
 func (g GrpcHandler) SendMessage(context context.Context, data *Req) ([]byte, error) {
 	log.ZWarn(context, "SendMessage for statistic", nil, "operationID", data.OperationID)
-	msgData := sdkws.MsgData{}
-	if err := proto.Unmarshal(data.Data, &msgData); err != nil {
-		return nil, err
-	}
-	if err := g.validate.Struct(&msgData); err != nil {
-		return nil, err
-	}
-	req := msg.SendMsgReq{MsgData: &msgData}
-	resp, err := g.msgRpcClient.SendMsg(context, &req)
-	if err != nil {
-		return nil, err
-	}
-	c, err := proto.Marshal(resp)
-	if err != nil {
-		return nil, err
-	}
-	return c, nil
+	//msgData := sdkws.MsgData{}
+	//if err := proto.Unmarshal(data.Data, &msgData); err != nil {
+	//	return nil, err
+	//}
+	//if err := g.validate.Struct(&msgData); err != nil {
+	//	return nil, err
+	//}
+	//req := msg.SendMsgReq{MsgData: &msgData}
+	//resp, err := g.msgRpcClient.SendMsg(context, &req)
+	//if err != nil {
+	//	return nil, err
+	//}
+	//c, err := proto.Marshal(resp)
+	//if err != nil {
+	//	return nil, err
+	//}
+	return nil, nil
 }
 
 func (g GrpcHandler) SendSignalMessage(context context.Context, data *Req) ([]byte, error) {