Skip to content

Commit

Permalink
refactor: conversation trigger
Browse files Browse the repository at this point in the history
  • Loading branch information
FGadvancer committed Jul 17, 2023
1 parent 746cb9e commit 1b22fe7
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion internal/conversation_msg/sync.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ func (c *Conversation) SyncConversationHashReadSeqs(ctx context.Context) error {
unreadCount = int32(v.MaxSeq - v.HasReadSeq)
}
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)
log.ZWarn(ctx, "UpdateColumnsConversation err", err, "conversationID", conversationID)
continue
}
conversationIDs = append(conversationIDs, conversationID)
Expand Down

0 comments on commit 1b22fe7

Please sign in to comment.