feat(outbox): remove InMemory provider and update delivery options

- Eliminates the InMemory outbox provider to simplify the architecture.
- Updates outbox delivery options to accept null for delivery and transaction commit timeouts.
- Adjusts outbox delivery implementation to use a default provider instead of the removed InMemory provider.
- Renames and moves related tests to maintain clarity and functionality.

Author: winromulus

ES.FX.slnx

@@ -9,7 +9,6 @@
     <Project Path="src/ES.FX.Migrations/ES.FX.Migrations.csproj" />
     <Project Path="src/ES.FX.TransactionalOutbox.EntityFrameworkCore.SqlServer/ES.FX.TransactionalOutbox.EntityFrameworkCore.SqlServer.csproj" />
     <Project Path="src/ES.FX.TransactionalOutbox.EntityFrameworkCore.PostgreSql/ES.FX.TransactionalOutbox.EntityFrameworkCore.PostgreSql.csproj" />
-    <Project Path="src/ES.FX.TransactionalOutbox.EntityFrameworkCore.InMemory/ES.FX.TransactionalOutbox.EntityFrameworkCore.InMemory.csproj" />
     <Project Path="src/ES.FX.TransactionalOutbox.EntityFrameworkCore.MySql/ES.FX.TransactionalOutbox.EntityFrameworkCore.MySql.csproj" />
     <Project Path="src/ES.FX.TransactionalOutbox.EntityFrameworkCore/ES.FX.TransactionalOutbox.EntityFrameworkCore.csproj" />
     <Project Path="src/ES.FX.TransactionalOutbox.MassTransit/ES.FX.TransactionalOutbox.MassTransit.csproj" Id="513497bb-2cd5-49e5-84a3-98bd5eea6f42" />
@@ -84,7 +83,6 @@
     <Project Path="tests/ES.FX.Tests/ES.FX.Tests.csproj" />
     <Project Path="tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.SqlServer.Tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.SqlServer.Tests.csproj" />
     <Project Path="tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.PostgreSql.Tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.PostgreSql.Tests.csproj" />
-    <Project Path="tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.InMemory.Tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.InMemory.Tests.csproj" />
     <Project Path="tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.MySql.Tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.MySql.Tests.csproj" />
     <Project Path="tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.Tests/ES.FX.TransactionalOutbox.EntityFrameworkCore.Tests.csproj" />
   </Folder>

src/ES.FX.TransactionalOutbox.EntityFrameworkCore.InMemory/ES.FX.TransactionalOutbox.EntityFrameworkCore.InMemory.csproj

@@ -12,13 +12,14 @@ namespace ES.FX.TransactionalOutbox.EntityFrameworkCore.Delivery;
 public class DefaultOutboxProvider<TDbContext> : IOutboxProvider<TDbContext>
     where TDbContext : DbContext
 {
-    public Task<Outbox?> GetNextExclusiveOutboxWithoutDelay(TDbContext dbContext,
+    public async Task<Outbox?> GetNextExclusiveOutboxWithoutDelay(TDbContext dbContext,
         CancellationToken cancellationToken = default)
     {
-        return dbContext.Set<Outbox>()
+        return await dbContext.Set<Outbox>()
             .Where(o => o.Lock == null &&
                         (o.DeliveryDelayedUntil == null || o.DeliveryDelayedUntil < DateTimeOffset.UtcNow))
             .OrderBy(o => o.AddedAt)
-            .FirstOrDefaultAsync(cancellationToken);
+            .AsTracking()
+            .FirstOrDefaultAsync(cancellationToken).ConfigureAwait(false);
     }
 }

src/ES.FX.TransactionalOutbox.EntityFrameworkCore.InMemory/InMemoryOutboxExtensions.cs

@@ -18,7 +18,13 @@ public abstract class OutboxDeliveryOptions
     ///     The timeout for the delivery of a batch. This includes acquiring the outbox, processing the messages and releasing
     ///     the lock.
     /// </summary>
-    public TimeSpan DeliveryTimeout { get; set; } = TimeSpan.FromSeconds(5);
+    public TimeSpan? DeliveryTimeout { get; set; }
+
+
+    /// <summary>
+    ///     The timeout used to commit changes after processing a batch of messages.
+    /// </summary>
+    public TimeSpan? TransactionCommitTimeout { get; set; }
 
 
     /// <summary>

src/ES.FX.TransactionalOutbox.EntityFrameworkCore.InMemory/InMemoryOutboxProvider.cs

@@ -96,7 +96,9 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
             try
             {
                 using var handlerReadyTimeout = CancellationTokenSource.CreateLinkedTokenSource(stoppingToken,
-                    new CancellationTokenSource(outboxDeliveryOptions.DeliveryTimeout).Token);
+                    outboxDeliveryOptions.DeliveryTimeout.HasValue
+                        ? new CancellationTokenSource(outboxDeliveryOptions.DeliveryTimeout.Value).Token
+                        : CancellationToken.None);
                 messageHandlerReady =
                     await messageHandler.IsReadyAsync(handlerReadyTimeout.Token).ConfigureAwait(false);
             }
@@ -128,7 +130,9 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                 await dbContext.Database.CreateExecutionStrategy().ExecuteAsync(async () =>
                     {
                         using var deliveryTimeout = CancellationTokenSource.CreateLinkedTokenSource(stoppingToken,
-                            new CancellationTokenSource(outboxDeliveryOptions.DeliveryTimeout).Token);
+                            outboxDeliveryOptions.DeliveryTimeout.HasValue
+                                ? new CancellationTokenSource(outboxDeliveryOptions.DeliveryTimeout.Value).Token
+                                : CancellationToken.None);
 
 
                         await using var transaction = await dbContext.Database
@@ -295,8 +299,14 @@ await DeliverMessage(message, messageContext, messageHandler, deliveryTimeout.To
 
                             try
                             {
-                                await dbContext.SaveChangesAsync(deliveryTimeout.Token).ConfigureAwait(false);
-                                await transaction.CommitAsync(deliveryTimeout.Token).ConfigureAwait(false);
+                                using var commitTimeout = CancellationTokenSource.CreateLinkedTokenSource(stoppingToken,
+                                    outboxDeliveryOptions.TransactionCommitTimeout.HasValue
+                                        ? new CancellationTokenSource(outboxDeliveryOptions.TransactionCommitTimeout
+                                            .Value).Token
+                                        : CancellationToken.None);
+
+                                await dbContext.SaveChangesAsync(commitTimeout.Token).ConfigureAwait(false);
+                                await transaction.CommitAsync(commitTimeout.Token).ConfigureAwait(false);
                             }
                             catch (Exception exception)
                             {

src/ES.FX.TransactionalOutbox.EntityFrameworkCore/Delivery/DefaultOutboxProvider.cs

@@ -21,7 +21,7 @@
 
 
 	<ItemGroup>
-	  <Folder Include="Extensions\" />
+		<Folder Include="Extensions\" />
 	</ItemGroup>
 
 </Project>