Merge pull request #477 from bcgov/yj

chore: Throttle export frequency: Prevent running if less than 2 hour…
bcgov · Jul 18, 2024 · 9031523 · 9031523
2 parents 862d204 + f792d6c
commit 9031523
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/server/StrDss.Data/Repositories/RentalListingRepository.cs b/server/StrDss.Data/Repositories/RentalListingRepository.cs
@@ -22,6 +22,7 @@ public interface IRentalListingRepository
         Task<RentalListingExtractDto?> GetRetalListingExportAsync(long extractId);
         Task ConfirmAddressAsync(long rentalListingId);
         Task<DssRentalListing> UpdateAddressAsync(UpdateListingAddressDto dto);
+        DateTime GetLatestRentalListingExportTime();
     }
     public class RentalListingRepository : RepositoryBase<DssRentalListingVw>, IRentalListingRepository
     {
@@ -539,5 +540,17 @@ public async Task<DssRentalListing> UpdateAddressAsync(UpdateListingAddressDto d
 
             return listing;
         }
+
+        public DateTime GetLatestRentalListingExportTime()
+        {
+            if (_dbContext.DssRentalListingExtracts.Any())
+            {
+                return _dbContext.DssRentalListingExtracts.Max(x => x.UpdDtm);
+            }
+            else
+            {
+                return DateTime.UtcNow.AddDays(-1);
+            }
+        }
     }
 }
diff --git a/server/StrDss.Service/RentalListingService.cs b/server/StrDss.Service/RentalListingService.cs
@@ -93,6 +93,17 @@ private void ProcessHosts(RentalListingViewDto listing, bool clearHosts = false)
 
         public async Task CreateRentalListingExportFiles()
         {
+            // Throttle export frequency: Prevent running if less than 2 hours since last export
+            var latestExtractTime = _listingRepo.GetLatestRentalListingExportTime();
+            var currentTime = DateTime.UtcNow;
+            var timeDifference = currentTime - latestExtractTime;
+
+            if (timeDifference < TimeSpan.FromHours(2))
+            {
+                _logger.LogInformation("Skipping CreateRentalListingExportFiles: Last export was {TimeDifference:hh\\:mm\\:ss} ago, less than 2 hours", timeDifference);
+                return;
+            }
+
             var listingIds = await _listingRepo.GetRentalListingIdsToExport();
             var headers = RentalListingExport.GetHeadersAsCsv();