Merge ae54b7a9cef3d08a935862fd33712bb43c555f22 into 07badb162f42036ee0263f72c47e896c30f58f43

internal/rpc/msg/as_read.go

@@ -146,7 +146,8 @@ func (m *msgServer) MarkConversationAsRead(ctx context.Context, req *msg.MarkCon
 	var seqs []int64
 
 	log.ZDebug(ctx, "MarkConversationAsRead", "hasReadSeq", hasReadSeq, "req.HasReadSeq", req.HasReadSeq)
-	if conversation.ConversationType == constant.SingleChatType {
+	switch conversation.ConversationType {
+	case constant.SingleChatType:
 		for i := hasReadSeq + 1; i <= req.HasReadSeq; i++ {
 			seqs = append(seqs, i)
 		}
@@ -171,8 +172,7 @@ func (m *msgServer) MarkConversationAsRead(ctx context.Context, req *msg.MarkCon
 		}
 		m.sendMarkAsReadNotification(ctx, req.ConversationID, conversation.ConversationType, req.UserID,
 			m.conversationAndGetRecvID(conversation, req.UserID), seqs, hasReadSeq)
-	} else if conversation.ConversationType == constant.ReadGroupChatType ||
-		conversation.ConversationType == constant.NotificationChatType {
+	case constant.ReadGroupChatType, constant.NotificationChatType:
 		if req.HasReadSeq > hasReadSeq {
 			err = m.MsgDatabase.SetHasReadSeq(ctx, req.UserID, req.ConversationID, req.HasReadSeq)
 			if err != nil {
@@ -184,7 +184,8 @@ func (m *msgServer) MarkConversationAsRead(ctx context.Context, req *msg.MarkCon
 			req.UserID, seqs, hasReadSeq)
 	}
 
-	if conversation.ConversationType == constant.SingleChatType {
+	switch conversation.ConversationType {
+	case constant.SingleChatType:
 		reqCall := &cbapi.CallbackSingleMsgReadReq{
 			ConversationID: conversation.ConversationID,
 			UserID:         conversation.OwnerUserID,
@@ -192,7 +193,7 @@ func (m *msgServer) MarkConversationAsRead(ctx context.Context, req *msg.MarkCon
 			ContentType:    conversation.ConversationType,
 		}
 		m.webhookAfterSingleMsgRead(ctx, &m.config.WebhooksConfig.AfterSingleMsgRead, reqCall)
-	} else if conversation.ConversationType == constant.ReadGroupChatType {
+	case constant.ReadGroupChatType:
 		reqCall := &cbapi.CallbackGroupMsgReadReq{
 			SendID:       conversation.OwnerUserID,
 			ReceiveID:    req.UserID,