Updated Generic publication methods to force using a non-abstract eve…

…nt since it's not supported yet
gsoft-inc · Dec 27, 2023 · 4796da5 · 4796da5
1 parent 6a39df0
commit 4796da5
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 8 deletions.
diff --git a/src/Shared/DomainEventWrapper.cs b/src/Shared/DomainEventWrapper.cs
@@ -71,7 +71,7 @@ public object Unwrap(Type returnType)
     }
 
     public static DomainEventWrapper Wrap<T>(T domainEvent)
-        where T : IDomainEvent
+        where T : IDomainEvent, new()
     {
         var domainEventName = DomainEventNameCache.GetName<T>();
         var domainEventSchema = DomainEventSchemaCache.GetEventSchema<T>();

diff --git a/src/Shared/DomainEventWrapperCollection.cs b/src/Shared/DomainEventWrapperCollection.cs
@@ -21,7 +21,7 @@ public DomainEventWrapperCollection(IEnumerable<DomainEventWrapper> domainEventW
     public EventSchema DomainSchema { get; }
 
     public static DomainEventWrapperCollection Create<T>(IEnumerable<T> domainEvents)
-        where T : IDomainEvent
+        where T : IDomainEvent, new()
     {
         var domainEventWrappers = domainEvents.Select(DomainEventWrapper.Wrap).ToArray();
         if (domainEventWrappers.Select(x => x.DomainEventName).Distinct().Count() > 1)

diff --git a/src/Workleap.DomainEventPropagation.Abstractions/DomainEventNameCache.cs b/src/Workleap.DomainEventPropagation.Abstractions/DomainEventNameCache.cs
@@ -9,7 +9,7 @@ internal static class DomainEventNameCache
     private static readonly ConcurrentDictionary<Type, string> DomainEventNameTypeMappings = new ConcurrentDictionary<Type, string>();
 
     public static string GetName<T>()
-        where T : IDomainEvent
+        where T : IDomainEvent, new()
     {
         return GetName(typeof(T));
     }

diff --git a/src/Workleap.DomainEventPropagation.Abstractions/DomainEventSchemaCache.cs b/src/Workleap.DomainEventPropagation.Abstractions/DomainEventSchemaCache.cs
@@ -9,7 +9,7 @@ internal static class DomainEventSchemaCache
     private static readonly ConcurrentDictionary<Type, EventSchema> DomainEventSchemaTypeMappings = new ConcurrentDictionary<Type, EventSchema>();
 
     public static EventSchema GetEventSchema<T>()
-        where T : IDomainEvent
+        where T : IDomainEvent, new()
     {
         return GetEventSchema(typeof(T));
     }

diff --git a/src/Workleap.DomainEventPropagation.Abstractions/IEventPropagationClient.cs b/src/Workleap.DomainEventPropagation.Abstractions/IEventPropagationClient.cs
@@ -3,8 +3,8 @@ namespace Workleap.DomainEventPropagation;
 public interface IEventPropagationClient
 {
     Task PublishDomainEventAsync<T>(T domainEvent, CancellationToken cancellationToken)
-        where T : IDomainEvent;
+        where T : IDomainEvent, new();
 
     Task PublishDomainEventsAsync<T>(IEnumerable<T> domainEvents, CancellationToken cancellationToken)
-        where T : IDomainEvent;
+        where T : IDomainEvent, new();
 }
diff --git a/src/Workleap.DomainEventPropagation.Publishing/EventPropagationClient.cs b/src/Workleap.DomainEventPropagation.Publishing/EventPropagationClient.cs
@@ -31,11 +31,11 @@ private static DomainEventsHandlerDelegate BuildPipeline(DomainEventsHandlerDele
     }
 
     public Task PublishDomainEventAsync<T>(T domainEvent, CancellationToken cancellationToken)
-        where T : IDomainEvent
+        where T : IDomainEvent, new()
         => this.PublishDomainEventsAsync(new[] { domainEvent }, cancellationToken);
 
     public async Task PublishDomainEventsAsync<T>(IEnumerable<T> domainEvents, CancellationToken cancellationToken)
-        where T : IDomainEvent
+        where T : IDomainEvent, new()
     {
         if (domainEvents == null)
         {