fix: online notifications do not push to herself.

FGadvancer · Dec 15, 2023 · 6dd625c · 6dd625c
1 parent 7ca764d
commit 6dd625c
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 27 deletions.
diff --git a/internal/rpc/msg/send.go b/internal/rpc/msg/send.go
@@ -149,16 +149,16 @@ func (m *msgServer) sendMsgSingleChat(ctx context.Context, req *pbmsg.SendMsgReq
 	isSend := true
 	isNotification := msgprocessor.IsNotificationByMsg(req.MsgData)
 	if !isNotification {
-		isSend, err = m.modifyMessageByUserMessageReceiveOpt(
-			ctx,
-			req.MsgData.RecvID,
-			utils.GenConversationIDForSingle(req.MsgData.SendID, req.MsgData.RecvID),
-			constant.SingleChatType,
-			req,
-		)
-		if err != nil {
-			return nil, err
-		}
+		//isSend, err = m.modifyMessageByUserMessageReceiveOpt(
+		//	ctx,
+		//	req.MsgData.RecvID,
+		//	utils.GenConversationIDForSingle(req.MsgData.SendID, req.MsgData.RecvID),
+		//	constant.SingleChatType,
+		//	req,
+		//)
+		//if err != nil {
+		//	return nil, err
+		//}
 	}
 	if !isSend {
 		prommetrics.SingleChatMsgProcessFailedCounter.Inc()

diff --git a/internal/rpc/msg/verify.go b/internal/rpc/msg/verify.go
@@ -58,23 +58,23 @@ func (m *msgServer) messageVerification(ctx context.Context, data *msg.SendMsgRe
 			data.MsgData.ContentType >= constant.NotificationBegin {
 			return nil
 		}
-		black, err := m.friend.IsBlocked(ctx, data.MsgData.SendID, data.MsgData.RecvID)
-		if err != nil {
-			return err
-		}
-		if black {
-			return errs.ErrBlockedByPeer.Wrap()
-		}
-		if *config.Config.MessageVerify.FriendVerify {
-			friend, err := m.friend.IsFriend(ctx, data.MsgData.SendID, data.MsgData.RecvID)
-			if err != nil {
-				return err
-			}
-			if !friend {
-				return errs.ErrNotPeersFriend.Wrap()
-			}
-			return nil
-		}
+		//black, err := m.friend.IsBlocked(ctx, data.MsgData.SendID, data.MsgData.RecvID)
+		//if err != nil {
+		//	return err
+		//}
+		//if black {
+		//	return errs.ErrBlockedByPeer.Wrap()
+		//}
+		//if *config.Config.MessageVerify.FriendVerify {
+		//	friend, err := m.friend.IsFriend(ctx, data.MsgData.SendID, data.MsgData.RecvID)
+		//	if err != nil {
+		//		return err
+		//	}
+		//	if !friend {
+		//		return errs.ErrNotPeersFriend.Wrap()
+		//	}
+		//	return nil
+		//}
 		return nil
 	case constant.SuperGroupChatType:
 		groupInfo, err := m.Group.GetGroupInfoCache(ctx, data.MsgData.GroupID)