Fix archive message

filipbekic01 · Sep 23, 2024 · 299574a · 299574a
1 parent 0e63f0e
commit 299574a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/backend/ResQueue/ResQueue/Features/Messages/ArchiveMessages/ArchiveMessagesFeature.cs b/backend/ResQueue/ResQueue/Features/Messages/ArchiveMessages/ArchiveMessagesFeature.cs
@@ -51,6 +51,9 @@ public async Task<OperationResult<ArchiveMessagesFeatureResponse>> ExecuteAsync(
         await queuesCollection.UpdateOneAsync(session, x => x.Id == ObjectId.Parse(request.Dto.QueueId),
             Builders<Queue>.Update.Inc(x => x.TotalMessages, -result.ModifiedCount));
 
+        await queuesCollection.UpdateOneAsync(session, x => x.Id == ObjectId.Parse(request.Dto.QueueId),
+            Builders<Queue>.Update.Max(x => x.TotalMessages, 0));
+
         await session.CommitTransactionAsync();
 
         return OperationResult<ArchiveMessagesFeatureResponse>.Success(new ArchiveMessagesFeatureResponse());