From 2d13a5fd358f39b14036910071b83a5abc90edb4 Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Mon, 21 Feb 2022 18:18:53 +0800
Subject: [PATCH] msg judge

---
 internal/rpc/msg/send_msg.go | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/internal/rpc/msg/send_msg.go b/internal/rpc/msg/send_msg.go
index 281ac2ed3..576d5f8bb 100644
--- a/internal/rpc/msg/send_msg.go
+++ b/internal/rpc/msg/send_msg.go
@@ -44,6 +44,17 @@ type MsgCallBackResp struct {
 	}
 }
 
+func userRelationshipVerification(data *pbChat.SendMsgReq) {
+
+	//etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImOfflineMessageName)
+	//client := pbChat.NewChatClient(etcdConn)
+	//reply, err := client.SendMsg(context.Background(), &req)
+	//if err != nil {
+	//	log.NewError(req.OperationID, "SendMsg rpc failed, ", req.String(), err.Error())
+	//} else if reply.ErrCode != 0 {
+	//	log.NewError(req.OperationID, "SendMsg rpc failed, ", req.String())
+	//}
+}
 func (rpc *rpcChat) encapsulateMsgData(msg *sdk_ws.MsgData) {
 	msg.ServerMsgID = GetMsgID(msg.SendID)
 	if msg.SendTime == 0 {
@@ -96,6 +107,7 @@ func (rpc *rpcChat) encapsulateMsgData(msg *sdk_ws.MsgData) {
 func (rpc *rpcChat) SendMsg(_ context.Context, pb *pbChat.SendMsgReq) (*pbChat.SendMsgResp, error) {
 	replay := pbChat.SendMsgResp{}
 	log.NewDebug(pb.OperationID, "rpc sendMsg come here", pb.String())
+	userRelationshipVerification(pb)
 	//if !utils.VerifyToken(pb.Token, pb.SendID) {
 	//	return returnMsg(&replay, pb, http.StatusUnauthorized, "token validate err,not authorized", "", 0)
 	rpc.encapsulateMsgData(pb.MsgData)