feat: add Multiple Notification support

Author: codewithmecoder

CommandQuery/CommandQuery.csproj

@@ -6,9 +6,9 @@
     <Nullable>enable</Nullable>
     <Features>strict</Features>
     <Authors>Ros Sokcheanith</Authors>
-    <Description>Simple, unambitious mediator CQRS implementation in .NET</Description>
+    <Description>Simple, unambitious CQRS implementation in .NET</Description>
     <Copyright>Copyright Ros Sokcheanith</Copyright>
-    <PackageTags>mediator;request;response;queries;commands;notifications</PackageTags>
+    <PackageTags>request;response;queries;commands;notifications</PackageTags>
     <PackageReadmeFile>README.md</PackageReadmeFile>
     <SignAssembly>true</SignAssembly>
     <AssemblyOriginatorKeyFile>..\CommandQuery.snk</AssemblyOriginatorKeyFile>
@@ -23,7 +23,8 @@
     <Deterministic>true</Deterministic>
     <ContinuousIntegrationBuild Condition="'$(GITHUB_ACTIONS)' == 'true'">true</ContinuousIntegrationBuild>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-    <Title>BAS24.Libs</Title>
+    <Title>CommandQuery</Title>
+    <PackageId>CommandQuery</PackageId>
     <PackageProjectUrl>https://github.com/codewithmecoder/CommandQuery</PackageProjectUrl>
     <RepositoryUrl>https://github.com/codewithmecoder/CommandQuery</RepositoryUrl>
   </PropertyGroup>

CommandQuery/Notifications/INotification.cs

@@ -3,4 +3,9 @@
 /// <summary>
 /// INotification interface for notifications in the CommandQuery library.
 /// </summary>
-public interface INotification;
+public interface INotification;
+
+/// <summary>
+/// IPriorityNotification priority interface for notifications in the CommandQuery library.
+/// </summary>
+public interface IPriorityNotification : INotification;

CommandQuery/Notifications/IParallelNotification.cs

@@ -0,0 +1,6 @@
+namespace CommandQuery.Notifications;
+
+/// <summary>
+/// For execute parallel notification
+/// </summary>
+public interface IParallelNotification : INotification;

CommandQuery/Notifications/IPriorityNotificationHandler.cs

@@ -0,0 +1,15 @@
+namespace CommandQuery.Notifications;
+
+/// <summary>
+/// 
+/// </summary>
+/// <typeparam name="TNotification"></typeparam>
+public interface IPriorityNotificationHandler<in TNotification>
+    : INotificationHandler<TNotification>
+    where TNotification : IPriorityNotification
+{
+    /// <summary>
+    /// 
+    /// </summary>
+    public int Priority { get; }
+}

CommandQuery/Notifications/MultipleNotificationPublisher.cs

@@ -0,0 +1,40 @@
+namespace CommandQuery.Notifications;
+
+/// <summary>
+/// 
+/// </summary>
+public class MultipleNotificationPublisher : INotificationPublisher
+{
+    private readonly TaskWhenAllPublisher _taskWhenAllPublisher = new();
+    private readonly ForeachAwaitPublisher _foreachAwaitPublisher = new();
+    private readonly PriorityNotificationPublisher _priorityNotificationPublisher = new();
+
+    /// <summary>
+    /// 
+    /// </summary>
+    /// <param name="handlerExecutors"></param>
+    /// <param name="notification"></param>
+    /// <param name="cancellationToken"></param>
+    /// <returns></returns>
+    public async Task Publish(
+        IEnumerable<NotificationHandlerExecutor> handlerExecutors,
+        INotification notification,
+        CancellationToken cancellationToken
+    )
+    {
+        switch (notification)
+        {
+            case IPriorityNotification:
+                await _priorityNotificationPublisher.Publish(handlerExecutors, notification, cancellationToken);
+                break;
+            case IParallelNotification:
+                await _taskWhenAllPublisher
+                    .Publish(handlerExecutors, notification, cancellationToken)
+                    .ConfigureAwait(false);
+                break;
+            default:
+                await _foreachAwaitPublisher.Publish(handlerExecutors, notification, cancellationToken);
+                break;
+        }
+    }
+}

CommandQuery/Notifications/PriorityNotificationPublisher.cs

@@ -0,0 +1,49 @@
+namespace CommandQuery.Notifications;
+
+/// <summary>
+/// 
+/// </summary>
+public class PriorityNotificationPublisher : INotificationPublisher
+{
+    private const int DefaultPriority = 99;
+
+    /// <summary>
+    /// 
+    /// </summary>
+    /// <param name="handlerExecutors"></param>
+    /// <param name="notification"></param>
+    /// <param name="cancellationToken"></param>
+    /// <returns></returns>
+    public async Task Publish(
+        IEnumerable<NotificationHandlerExecutor> handlerExecutors,
+        INotification notification,
+        CancellationToken cancellationToken
+    )
+    {
+        var lookUp = handlerExecutors
+            .ToLookup(key => GetPriority(key.HandlerInstance), value => value)
+            .OrderBy(k => k.Key);
+
+        foreach (var handler in lookUp)
+        {
+            foreach (var notificationHandler in handler.ToList())
+            {
+                await notificationHandler
+                    .HandlerCallback(notification, cancellationToken)
+                    .ConfigureAwait(false);
+            }
+        }
+    }
+
+    private static int GetPriority(object handler)
+    {
+        var priority = handler
+            .GetType()
+            .GetProperties().ToList()
+            .Find(t =>
+                t.Name == nameof(IPriorityNotificationHandler<IPriorityNotification>.Priority)
+            );
+
+        return priority == null ? DefaultPriority : int.Parse(priority.GetValue(handler)?.ToString() ?? DefaultPriority.ToString());
+    }
+}

CommandQuery/Notifications/TaskWhenAllPublisher.cs

@@ -0,0 +1,23 @@
+namespace CommandQuery.Notifications;
+
+/// <summary>
+/// 
+/// </summary>
+public class TaskWhenAllPublisher : INotificationPublisher
+{
+    /// <summary>
+    /// 
+    /// </summary>
+    /// <param name="handlerExecutors"></param>
+    /// <param name="notification"></param>
+    /// <param name="cancellationToken"></param>
+    /// <returns></returns>
+    public Task Publish(IEnumerable<NotificationHandlerExecutor> handlerExecutors, INotification notification, CancellationToken cancellationToken)
+    {
+        var tasks = handlerExecutors
+            .Select(handler => handler.HandlerCallback(notification, cancellationToken))
+            .ToArray();
+
+        return Task.WhenAll(tasks);
+    }
+}

Sample/Program.cs

@@ -1,4 +1,5 @@
 using CommandQuery;
+using CommandQuery.Notifications;
 using Sample;
 
 var builder = WebApplication.CreateBuilder(args);
@@ -29,9 +30,9 @@
 builder.Services.AddCommandQuery(cq =>
 {
     cq.RegisterAssembly(typeof(Program).Assembly);
-    //cq.NotificationPublisher = new MultipleNotificationPublisher();
-    //cq.NotificationPublisherType = typeof(MultipleNotificationPublisher);
-
+    cq.NotificationPublisher = new MultipleNotificationPublisher();
+    cq.NotificationPublisherType = typeof(MultipleNotificationPublisher);
+    
     cq.AddBehavior(typeof(LoggingPipelineBehavior<,>));
     cq.AddRequestPreProcessor(typeof(GenericRequestPreProcessor<>));
     cq.AddRequestPostProcessor(typeof(GenericRequestPostProcessor<,>));

Sample/UserCreatedNotification.cs

@@ -11,7 +11,7 @@ public class EmailService(ILogger<EmailService> logger) : IEmailService
 {
     public Task SendWelcomeEmailAsync(Guid notificationUserId, string notificationName)
     {
-        logger.LogDebug("EmailService: Sending welcome email to {notificationName} with ID {notificationUserId}", notificationName, notificationUserId);
+        logger.LogDebug("EmailService: Sending welcome email to {NotificationName} with ID {NotificationUserId}", notificationName, notificationUserId);
         return Task.CompletedTask;
     }
 }
@@ -24,7 +24,7 @@ public class SmsService(ILogger<SmsService> logger) : ISmsService
 {
     public Task SendWelcomeSmsAsync(Guid notificationUserId, string notificationName)
     {
-        logger.LogDebug("SmsService: Sending welcome SMS to {notificationName} with ID {notificationUserId}", notificationName, notificationUserId);
+        logger.LogDebug("SmsService: Sending welcome SMS to {NotificationName} with ID {NotificationUserId}", notificationName, notificationUserId);
         return Task.CompletedTask;
     }
 }