Merge pull request #5 from demidov-ad/Issue/644

Update to Support Dispatching Events with Non-Integer IDs

src/Ardalis.SharedKernel/IDomainEventDispatcher.cs

@@ -6,4 +6,5 @@
 public interface IDomainEventDispatcher
 {
   Task DispatchAndClearEvents(IEnumerable<EntityBase> entitiesWithEvents);
+  Task DispatchAndClearEvents<TId>(IEnumerable<EntityBase<TId>> entitiesWithEvents) where TId : struct, IEquatable<TId>;
 }

src/Ardalis.SharedKernel/MediatRDomainEventDispatcher.cs

@@ -24,5 +24,19 @@ public async Task DispatchAndClearEvents(IEnumerable<EntityBase> entitiesWithEve
       }
     }
   }
+
+  public async Task DispatchAndClearEvents<TId>(IEnumerable<EntityBase<TId>> entitiesWithEvents) 
+    where TId : struct, IEquatable<TId> 
+  {
+    foreach (var entity in entitiesWithEvents)
+    {
+      var events = entity.DomainEvents.ToArray();
+      entity.ClearDomainEvents();
+      foreach (var domainEvent in events)
+      {
+        await _mediator.Publish(domainEvent).ConfigureAwait(false);
+      }
+    }
+  }
 }
 

tests/Ardalis.SharedKernel.UnitTests/MediatRDomainEventDispatcherTests/DispatchAndClearEventsWithGuidId.cs

@@ -0,0 +1,36 @@
+using FluentAssertions;
+using MediatR;
+using Moq;
+using Xunit;
+
+namespace Ardalis.SharedKernel.UnitTests.MediatRDomainEventDispatcherTests;
+
+public class DispatchAndClearEventsWithGuidId
+{
+  private class TestDomainEvent : DomainEventBase { }
+  private class TestEntity : EntityBase<Guid>
+  {
+    public void AddTestDomainEvent()
+    {
+      var domainEvent = new TestDomainEvent();
+      RegisterDomainEvent(domainEvent);
+    }
+  }
+
+  [Fact]
+  public async void CallsPublishAndClearDomainEvents()
+  {
+    // Arrange
+    var mediatorMock = new Mock<IMediator>();
+    var domainEventDispatcher = new MediatRDomainEventDispatcher(mediatorMock.Object);
+    var entity = new TestEntity();
+    entity.AddTestDomainEvent();
+
+    // Act
+    await domainEventDispatcher.DispatchAndClearEvents(new List<EntityBase<Guid>> { entity });
+
+    // Assert
+    mediatorMock.Verify(m => m.Publish(It.IsAny<DomainEventBase>(), It.IsAny<CancellationToken>()), Times.Once);
+    entity.DomainEvents.Should().BeEmpty();
+  }
+}