Changed outbox namespace. Added standalone Outbox service to add messages when no transaction is needed.

Author: FelixCCWork

src/DotNetElements.AppFramework.AspNet/Outbox/WebApplicationExtensions.cs

@@ -1,4 +1,5 @@
-using Microsoft.AspNetCore.Builder;
+using DotNetElements.AppFramework.Outbox;
+using Microsoft.AspNetCore.Builder;
 
 namespace DotNetElements.AppFramework.AspNet.Outbox;
 

src/DotNetElements.AppFramework/Outbox/IDbSetOutbox.cs

@@ -1,8 +1,8 @@
 using DotNetElements.AppFramework.Abstractions.Outbox;
 
-namespace DotNetElements.AppFramework;
+namespace DotNetElements.AppFramework.Outbox;
 
 public interface IDbSetOutbox
 {
-    public DbSet<OutboxMessage> OutboxMessages { get; }
+	public DbSet<OutboxMessage> OutboxMessages { get; }
 }

src/DotNetElements.AppFramework/Outbox/IDbSetOutboxExtensions.cs

@@ -1,7 +1,7 @@
 using System.Text.Json;
 using DotNetElements.AppFramework.Abstractions.Outbox;
 
-namespace DotNetElements.AppFramework;
+namespace DotNetElements.AppFramework.Outbox;
 
 public static class IDbSetOutboxExtensions
 {

src/DotNetElements.AppFramework/Outbox/IOutbox.cs

@@ -1,7 +1,7 @@
-namespace DotNetElements.AppFramework;
+namespace DotNetElements.AppFramework.Outbox;
 
 public interface IOutbox<TDbContext>
-    where TDbContext : DbContext, IDbSetOutbox
+	where TDbContext : DbContext, IDbSetOutbox
 {
-    void AddMessage<T>(T message);
+	Task AddMessageAsync<T>(T message);
 }

src/DotNetElements.AppFramework/Outbox/Outbox.cs

@@ -0,0 +1,19 @@
+namespace DotNetElements.AppFramework.Outbox;
+
+public sealed class Outbox<TDbContext> : IOutbox<TDbContext>
+	where TDbContext : DbContext, IDbSetOutbox
+{
+	private readonly TDbContext dbContext;
+
+	public Outbox(TDbContext dbContext)
+	{
+		this.dbContext = dbContext;
+	}
+
+	public async Task AddMessageAsync<T>(T message)
+	{
+		dbContext.AddMessage(message);
+
+		await dbContext.SaveChangesAsync();
+	}
+}

src/DotNetElements.AppFramework/Outbox/OutboxMessageProcessor.cs

@@ -1,19 +1,19 @@
-namespace DotNetElements.AppFramework;
+namespace DotNetElements.AppFramework.Outbox;
 
 public interface IOutboxMessageProcessor
 {
-    Task<ResultWithError> ProcessAsync(object message, CancellationToken cancellation);
+	Task<ResultWithError> ProcessAsync(object message, CancellationToken cancellation);
 }
 
 public abstract class OutboxMessageProcessor<T> : IOutboxMessageProcessor
 {
-    public Task<ResultWithError> ProcessAsync(object message, CancellationToken cancellation)
-    {
-        if (message is not T typedMessage)
-            throw new ArgumentException($"Invalid message type: {message.GetType().Name}. Expected: {typeof(T).Name}.");
+	public Task<ResultWithError> ProcessAsync(object message, CancellationToken cancellation)
+	{
+		if (message is not T typedMessage)
+			throw new ArgumentException($"Invalid message type: {message.GetType().Name}. Expected: {typeof(T).Name}.");
 
-        return ProcessAsync(typedMessage, cancellation);
-    }
+		return ProcessAsync(typedMessage, cancellation);
+	}
 
-    protected abstract Task<ResultWithError> ProcessAsync(T message, CancellationToken cancellation);
+	protected abstract Task<ResultWithError> ProcessAsync(T message, CancellationToken cancellation);
 }

src/DotNetElements.AppFramework/Outbox/OutboxOptions.cs

@@ -1,43 +1,43 @@
 using System.Reflection;
 
-namespace DotNetElements.AppFramework;
+namespace DotNetElements.AppFramework.Outbox;
 
 public sealed class JobInterval
 {
-    public static JobInterval FromSeconds(int seconds) => new JobInterval { Value = seconds, Unit = IntervalUnit.Seconds };
-    public static JobInterval FromMinutes(int minutes) => new JobInterval { Value = minutes, Unit = IntervalUnit.Minutes };
+	public static JobInterval FromSeconds(int seconds) => new JobInterval { Value = seconds, Unit = IntervalUnit.Seconds };
+	public static JobInterval FromMinutes(int minutes) => new JobInterval { Value = minutes, Unit = IntervalUnit.Minutes };
 
-    [Range(1, 59, ErrorMessage = "Interval needs to be between {0} and {1}")]
-    public int Value { get; private init; }
+	[Range(1, 59, ErrorMessage = "Interval needs to be between {0} and {1}")]
+	public int Value { get; private init; }
 
-    [Required]
-    public IntervalUnit Unit { get; private init; }
+	[Required]
+	public IntervalUnit Unit { get; private init; }
 
-    private JobInterval() { }
+	private JobInterval() { }
 }
 
 public enum IntervalUnit
 {
-    Seconds,
-    Minutes
+	Seconds,
+	Minutes
 }
 
 public sealed class OutboxOptions : IValidatableObject
 {
-    [Required]
-    public Assembly? MessagesAssembly { get; set; }
+	[Required]
+	public Assembly? MessagesAssembly { get; set; }
 
-    [Range(minimum: 1, maximum: 10)]
-    public int MaxRetryCount { get; set; } = 3;
+	[Range(minimum: 1, maximum: 10)]
+	public int MaxRetryCount { get; set; } = 3;
 
-    [Required]
-    public JobInterval JobInterval { get; set; } = JobInterval.FromSeconds(30);
+	[Required]
+	public JobInterval JobInterval { get; set; } = JobInterval.FromSeconds(30);
 
-    public IEnumerable<ValidationResult> Validate(ValidationContext validationContext)
-    {
-        List<ValidationResult> results = [];
-        Validator.TryValidateObject(JobInterval, new ValidationContext(JobInterval), results, true);
+	public IEnumerable<ValidationResult> Validate(ValidationContext validationContext)
+	{
+		List<ValidationResult> results = [];
+		Validator.TryValidateObject(JobInterval, new ValidationContext(JobInterval), results, true);
 
-        return results;
-    }
+		return results;
+	}
 }