diff --git a/internal/msggateway/message_handler.go b/internal/msggateway/message_handler.go index 811a1b7485..c39ef06c69 100644 --- 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) {