refactor: conversation trigger

openimsdk · Jul 17, 2023 · 746cb9e · 746cb9e
1 parent 5edcd9e
commit 746cb9e
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/internal/conversation_msg/sync.go b/internal/conversation_msg/sync.go
@@ -85,12 +85,14 @@ func (c *Conversation) SyncConversationHashReadSeqs(ctx context.Context) error {
 		}
 		if err := c.db.UpdateColumnsConversation(ctx, conversationID, map[string]interface{}{"unread_count": unreadCount, "has_read_seq": v.HasReadSeq}); err != nil {
 			log.ZError(ctx, "UpdateColumnsConversation err", err, "conversationID", conversationID)
+			continue
 		}
 		conversationIDs = append(conversationIDs, conversationID)
 	}
 	log.ZDebug(ctx, "update conversations", "conversations", conversations)
-
-	common.TriggerCmdUpdateConversation(ctx, common.UpdateConNode{Action: constant.ConChange, Args: conversationIDs}, c.GetCh())
-	common.TriggerCmdUpdateConversation(ctx, common.UpdateConNode{Action: constant.TotalUnreadMessageChanged, Args: conversationIDs}, c.GetCh())
+	if len(conversationIDs) > 0 {
+		common.TriggerCmdUpdateConversation(ctx, common.UpdateConNode{Action: constant.ConChange, Args: conversationIDs}, c.GetCh())
+		common.TriggerCmdUpdateConversation(ctx, common.UpdateConNode{Action: constant.TotalUnreadMessageChanged, Args: conversationIDs}, c.GetCh())
+	}
 	return nil
 }