Add mediatr domain event dispatcher

src/Ardalis.SharedKernel/Ardalis.SharedKernel.csproj

@@ -13,9 +13,9 @@
     <RepositoryUrl>https://github.com/ardalis/Ardalis.SharedKernel</RepositoryUrl>
     <PackageTags>DDD;Shared Kernel;SharedKernel;Domain-Driven Design;Repository;Specification;ValueObject;Value Object;Ardalis;Clean;Clean Architecture;Clean Architecture Template</PackageTags>
     <PackageIcon>icon.png</PackageIcon>
-    <Version>1.0.0</Version>
+    <Version>1.1.0</Version>
     <PackageReleaseNotes>
-      * Initial Release
+      * Add MediatR Domain Event Dispatcher
     </PackageReleaseNotes>
     <PublishRepositoryUrl>true</PublishRepositoryUrl>
     <EmbedUntrackedSources>true</EmbedUntrackedSources>

src/Ardalis.SharedKernel/IDomainEventDispatcher.cs

@@ -7,4 +7,3 @@ public interface IDomainEventDispatcher
 {
   Task DispatchAndClearEvents(IEnumerable<EntityBase> entitiesWithEvents);
 }
-

src/Ardalis.SharedKernel/MediatRDomainEventDispatcher.cs

@@ -0,0 +1,26 @@
+using MediatR;
+
+namespace Ardalis.SharedKernel;
+
+public class MediatRDomainEventDispatcher : IDomainEventDispatcher
+{
+  private readonly IMediator _mediator;
+
+  public MediatRDomainEventDispatcher(IMediator mediator)
+  {
+    _mediator = mediator;
+  }
+
+  public async Task DispatchAndClearEvents(IEnumerable<EntityBase> entitiesWithEvents)
+  {
+    foreach (var entity in entitiesWithEvents)
+    {
+      var events = entity.DomainEvents.ToArray();
+      entity.ClearDomainEvents();
+      foreach (var domainEvent in events)
+      {
+        await _mediator.Publish(domainEvent).ConfigureAwait(false);
+      }
+    }
+  }
+}