fixed sleep time of aggregation

cs-23-sw-7-06 · Dec 18, 2023 · b9b8d6b · b9b8d6b
1 parent 5e5a180
commit b9b8d6b
Showing 1 changed file with 18 additions and 2 deletions.
diff --git a/CentralHub.Api/Services/LocalizationService.cs b/CentralHub.Api/Services/LocalizationService.cs
@@ -12,14 +12,30 @@ public class LocalizationService(
     IRoomRepository roomRepository)
     : IScopedProcessingService
 {
-    private static readonly TimeSpan SleepTime = TimeSpan.FromMinutes(5);
+    private static readonly TimeSpan SleepTime = TimeSpan.FromMinutes(1);
 
     public async Task DoWorkAsync(CancellationToken stoppingToken)
     {
         while (!stoppingToken.IsCancellationRequested)
         {
+            var now = DateTime.UtcNow;
+            logger.LogInformation("Starting measurement aggregation {Time}", now);
             await AggregateMeasurementsAsync(stoppingToken);
-            await Task.Delay(SleepTime, stoppingToken);
+            var after = DateTime.UtcNow;
+            logger.LogInformation("Ending aggregation {Time}", after);
+
+            var aggregationTime = after - now;
+            logger.LogInformation("Aggregation took: {Time} s", aggregationTime.TotalSeconds);
+
+            if (aggregationTime <= SleepTime)
+            {
+                logger.LogInformation("Aggregation finished sleeping {Time} until next aggregation", SleepTime - aggregationTime);
+                await Task.Delay(SleepTime - aggregationTime, stoppingToken);
+            }
+            else
+            {
+                logger.LogWarning("Aggregation of measurements took {Time}, which is longer than what has been allocated.", aggregationTime);
+            }
         }
     }