Fix bugs

sillsdev · Jun 27, 2024 · 06cb085 · 06cb085
1 parent cd6f3f0
commit 06cb085
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 3 deletions.
diff --git a/src/SIL.Machine.AspNetCore/Services/MessageOutboxDeliveryService.cs b/src/SIL.Machine.AspNetCore/Services/MessageOutboxDeliveryService.cs
@@ -3,7 +3,7 @@
 public class MessageOutboxDeliveryService(
     IRepository<OutboxMessage> messages,
     IEnumerable<IOutboxMessageHandler> outboxMessageHandlers,
-    MessageOutboxOptions options,
+    IOptionsMonitor<MessageOutboxOptions> options,
     ILogger<MessageOutboxDeliveryService> logger
 ) : BackgroundService
 {
@@ -13,7 +13,8 @@ ILogger<MessageOutboxDeliveryService> logger
 
     private readonly ILogger<MessageOutboxDeliveryService> _logger = logger;
     protected TimeSpan Timeout { get; set; } = TimeSpan.FromSeconds(10);
-    protected TimeSpan MessageExpiration { get; set; } = TimeSpan.FromHours(options.MessageExpirationInHours);
+    protected TimeSpan MessageExpiration { get; set; } =
+        TimeSpan.FromHours(options.CurrentValue.MessageExpirationInHours);
 
     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {

diff --git a/src/SIL.Machine.Serval.EngineServer/appsettings.json b/src/SIL.Machine.Serval.EngineServer/appsettings.json
@@ -32,6 +32,9 @@
   "ClearML": {
     "BuildPollingEnabled": true
   },
+  "MessageOutbox": {
+    "MessageExpirationInHours": 48
+  },
   "Logging": {
     "LogLevel": {
       "System.Net.Http.HttpClient.Default": "Warning"

diff --git a/tests/SIL.Machine.AspNetCore.Tests/Services/MessageOutboxDeliveryServiceTests.cs b/tests/SIL.Machine.AspNetCore.Tests/Services/MessageOutboxDeliveryServiceTests.cs
@@ -128,7 +128,13 @@ public class TestMessageOutboxDeliveryService(
         IRepository<OutboxMessage> messages,
         IEnumerable<IOutboxMessageHandler> outboxMessageHandlers,
         ILogger<MessageOutboxDeliveryService> logger
-    ) : MessageOutboxDeliveryService(messages, outboxMessageHandlers, new MessageOutboxOptions(), logger)
+    )
+        : MessageOutboxDeliveryService(
+            messages,
+            outboxMessageHandlers,
+            Substitute.For<IOptionsMonitor<MessageOutboxOptions>>(),
+            logger
+        )
     {
         public async Task ProcessMessagesOnceAsync() => await ProcessMessagesAsync();