Used Events definition as Disciminated Union in exercises

Replaced When method name into Evolve, as it's now more aligned with how people are doing it.
oskardudycz · Apr 30, 2024 · 4b57e1d · 4b57e1d
1 parent d83478c
commit 4b57e1d
Show file tree

Hide file tree

Showing 83 changed files with 1,269 additions and 978 deletions.
diff --git a/Core.ElasticSearch/Projections/ElasticSearchProjection.cs b/Core.ElasticSearch/Projections/ElasticSearchProjection.cs
@@ -30,7 +30,7 @@ public async Task Handle(EventEnvelope<TEvent> eventEnvelope, CancellationToken
         var entity = (await elasticClient.GetAsync<TView>(id, i => i.Index(indexName), ct).ConfigureAwait(false))?.Source ??
                      (TView) Activator.CreateInstance(typeof(TView), true)!;
 
-        entity.When(eventEnvelope);
+        entity.Evolve(eventEnvelope);
 
         await elasticClient.IndexAsync(
             entity,

diff --git a/Core.EventStoreDB/Events/AggregateStreamExtensions.cs b/Core.EventStoreDB/Events/AggregateStreamExtensions.cs
@@ -30,7 +30,7 @@ await foreach (var @event in readResult)
         {
             var eventData = @event.Deserialize();
 
-            aggregate.When(eventData!);
+            aggregate.Evolve(eventData!);
         }
 
         return aggregate;

diff --git a/Core.Marten/ExternalProjections/MartenExternalProjection.cs b/Core.Marten/ExternalProjections/MartenExternalProjection.cs
@@ -33,7 +33,7 @@ public async Task Handle(EventEnvelope<TEvent> eventEnvelope, CancellationToken
         if (entity.LastProcessedPosition >= eventLogPosition)
             return;
 
-        entity.When(@event);
+        entity.Evolve(@event);
 
         entity.LastProcessedPosition = eventLogPosition;
 

diff --git a/Core.Tests/AggregateWithWhenTests.cs b/Core.Tests/AggregateWithWhenTests.cs
@@ -55,7 +55,7 @@ public class Invoice: Aggregate<string>
     public InvoiceSendMethod SentVia { get; private set; }
     public DateTime SentAt { get; private set; }
 
-    public override void When(object @event)
+    public override void Evolve(object @event)
     {
         switch (@event)
         {
@@ -125,7 +125,7 @@ public void AggregationWithWhenShouldGetTheCurrentState()
         // 3. Apply each event on the entity.
         foreach (var @event in events)
         {
-            invoice.When(@event);
+            invoice.Evolve(@event);
         }
 
         invoice.Id.Should().Be(invoiceInitiated.Number);

diff --git a/Core/Aggregates/Aggregate.cs b/Core/Aggregates/Aggregate.cs
@@ -12,7 +12,7 @@ public abstract class Aggregate<T>: IAggregate<T> where T : notnull
 
     [NonSerialized] private readonly Queue<object> uncommittedEvents = new();
 
-    public virtual void When(object @event) { }
+    public virtual void Evolve(object @event) { }
 
     public object[] DequeueUncommittedEvents()
     {

diff --git a/Core/ProcessManagers/ProcessManager.cs b/Core/ProcessManagers/ProcessManager.cs
@@ -29,7 +29,7 @@ public EventOrCommand[] DequeuePendingMessages()
     protected void ScheduleCommand(object @event) =>
         scheduledCommands.Enqueue(EventOrCommand.Command(@event));
 
-    public virtual void When(object @event)
+    public virtual void Evolve(object @event)
     {
     }
 }
diff --git a/Core/Projections/IProjection.cs b/Core/Projections/IProjection.cs
@@ -2,7 +2,7 @@
 
 public interface IProjection
 {
-    void When(object @event);
+    void Evolve(object @event);
 }
 
 public interface IVersionedProjection: IProjection

diff --git a/Sample/EventStoreDB/ECommerce/Carts/Carts.Tests/Builders/CartBuilder.cs b/Sample/EventStoreDB/ECommerce/Carts/Carts.Tests/Builders/CartBuilder.cs
@@ -25,7 +25,7 @@ public ShoppingCart Build()
 
         foreach (var @event in eventsToApply)
         {
-            cart.When(@event);
+            cart.Evolve(@event);
         }
 
         return cart;

diff --git a/...e/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCartById/ShoppingCartDetails.cs b/...e/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCartById/ShoppingCartDetails.cs
@@ -23,7 +23,7 @@ public class ShoppingCartDetails: IVersionedProjection
     public long Version { get; set; }
 
 
-    public void When(object @event)
+    public void Evolve(object @event)
     {
         switch (@event)
         {

diff --git a/Sample/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCartHistory/CartHistory.cs b/Sample/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCartHistory/CartHistory.cs
@@ -14,7 +14,7 @@ public class CartHistory: IVersionedProjection
     public string Description { get; set; } = default!;
     public ulong LastProcessedPosition { get; set; }
 
-    public void When(object @event)
+    public void Evolve(object @event)
     {
         switch (@event)
         {

diff --git a/...le/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCarts/ShoppingCartShortInfo.cs b/...le/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCarts/ShoppingCartShortInfo.cs
@@ -17,7 +17,7 @@ public class ShoppingCartShortInfo: IVersionedProjection
 
     public ulong LastProcessedPosition { get; set; }
 
-    public void When(object @event)
+    public void Evolve(object @event)
     {
         switch (@event)
         {

diff --git a/Sample/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/ShoppingCart.cs b/Sample/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/ShoppingCart.cs
@@ -29,7 +29,7 @@ public class ShoppingCart: Aggregate
 
     private ShoppingCart(){}
 
-    public override void When(object @event)
+    public override void Evolve(object @event)
     {
         switch (@event)
         {

diff --git a/Workshops/IntroductionToEventSourcing/04-AppendingEvents.EventStoreDB/AppendingEvents.cs b/Workshops/IntroductionToEventSourcing/04-AppendingEvents.EventStoreDB/AppendingEvents.cs
@@ -3,32 +3,39 @@
 using Xunit;
 
 namespace IntroductionToEventSourcing.AppendingEvents;
+using static ShoppingCartEvent;
 
 // EVENTS
-public record ShoppingCartOpened(
-    Guid ShoppingCartId,
-    Guid ClientId
-);
-
-public record ProductItemAddedToShoppingCart(
-    Guid ShoppingCartId,
-    PricedProductItem ProductItem
-);
-
-public record ProductItemRemovedFromShoppingCart(
-    Guid ShoppingCartId,
-    PricedProductItem ProductItem
-);
-
-public record ShoppingCartConfirmed(
-    Guid ShoppingCartId,
-    DateTime ConfirmedAt
-);
-
-public record ShoppingCartCanceled(
-    Guid ShoppingCartId,
-    DateTime CanceledAt
-);
+public abstract record ShoppingCartEvent
+{
+    public record ShoppingCartOpened(
+        Guid ShoppingCartId,
+        Guid ClientId
+    ): ShoppingCartEvent;
+
+    public record ProductItemAddedToShoppingCart(
+        Guid ShoppingCartId,
+        PricedProductItem ProductItem
+    ): ShoppingCartEvent;
+
+    public record ProductItemRemovedFromShoppingCart(
+        Guid ShoppingCartId,
+        PricedProductItem ProductItem
+    ): ShoppingCartEvent;
+
+    public record ShoppingCartConfirmed(
+        Guid ShoppingCartId,
+        DateTime ConfirmedAt
+    ): ShoppingCartEvent;
+
+    public record ShoppingCartCanceled(
+        Guid ShoppingCartId,
+        DateTime CanceledAt
+    ): ShoppingCartEvent;
+
+    // This won't allow
+    private ShoppingCartEvent(){}
+}
 
 // VALUE OBJECTS
 public record PricedProductItem(

diff --git a/...ToEventSourcing/05-GettingStateFromEvents.Marten/Immutable/GettingStateFromEventsTests.cs b/...ToEventSourcing/05-GettingStateFromEvents.Marten/Immutable/GettingStateFromEventsTests.cs
@@ -4,32 +4,39 @@
 using Xunit;
 
 namespace IntroductionToEventSourcing.GettingStateFromEvents.Immutable;
+using static ShoppingCartEvent;
 
 // EVENTS
-public record ShoppingCartOpened(
-    Guid ShoppingCartId,
-    Guid ClientId
-);
-
-public record ProductItemAddedToShoppingCart(
-    Guid ShoppingCartId,
-    PricedProductItem ProductItem
-);
-
-public record ProductItemRemovedFromShoppingCart(
-    Guid ShoppingCartId,
-    PricedProductItem ProductItem
-);
-
-public record ShoppingCartConfirmed(
-    Guid ShoppingCartId,
-    DateTime ConfirmedAt
-);
-
-public record ShoppingCartCanceled(
-    Guid ShoppingCartId,
-    DateTime CanceledAt
-);
+public abstract record ShoppingCartEvent
+{
+    public record ShoppingCartOpened(
+        Guid ShoppingCartId,
+        Guid ClientId
+    ): ShoppingCartEvent;
+
+    public record ProductItemAddedToShoppingCart(
+        Guid ShoppingCartId,
+        PricedProductItem ProductItem
+    ): ShoppingCartEvent;
+
+    public record ProductItemRemovedFromShoppingCart(
+        Guid ShoppingCartId,
+        PricedProductItem ProductItem
+    ): ShoppingCartEvent;
+
+    public record ShoppingCartConfirmed(
+        Guid ShoppingCartId,
+        DateTime ConfirmedAt
+    ): ShoppingCartEvent;
+
+    public record ShoppingCartCanceled(
+        Guid ShoppingCartId,
+        DateTime CanceledAt
+    ): ShoppingCartEvent;
+
+    // This won't allow
+    private ShoppingCartEvent(){}
+}
 
 // VALUE OBJECTS
 public record PricedProductItem(

diff --git a/...onToEventSourcing/05-GettingStateFromEvents.Marten/Mutable/GettingStateFromEventsTests.cs b/...onToEventSourcing/05-GettingStateFromEvents.Marten/Mutable/GettingStateFromEventsTests.cs
@@ -4,32 +4,39 @@
 using Xunit;
 
 namespace IntroductionToEventSourcing.GettingStateFromEvents.Mutable;
+using static ShoppingCartEvent;
 
 // EVENTS
-public record ShoppingCartOpened(
-    Guid ShoppingCartId,
-    Guid ClientId
-);
-
-public record ProductItemAddedToShoppingCart(
-    Guid ShoppingCartId,
-    PricedProductItem ProductItem
-);
-
-public record ProductItemRemovedFromShoppingCart(
-    Guid ShoppingCartId,
-    PricedProductItem ProductItem
-);
-
-public record ShoppingCartConfirmed(
-    Guid ShoppingCartId,
-    DateTime ConfirmedAt
-);
-
-public record ShoppingCartCanceled(
-    Guid ShoppingCartId,
-    DateTime CanceledAt
-);
+public abstract record ShoppingCartEvent
+{
+    public record ShoppingCartOpened(
+        Guid ShoppingCartId,
+        Guid ClientId
+    ): ShoppingCartEvent;
+
+    public record ProductItemAddedToShoppingCart(
+        Guid ShoppingCartId,
+        PricedProductItem ProductItem
+    ): ShoppingCartEvent;
+
+    public record ProductItemRemovedFromShoppingCart(
+        Guid ShoppingCartId,
+        PricedProductItem ProductItem
+    ): ShoppingCartEvent;
+
+    public record ShoppingCartConfirmed(
+        Guid ShoppingCartId,
+        DateTime ConfirmedAt
+    ): ShoppingCartEvent;
+
+    public record ShoppingCartCanceled(
+        Guid ShoppingCartId,
+        DateTime CanceledAt
+    ): ShoppingCartEvent;
+
+    // This won't allow
+    private ShoppingCartEvent(){}
+}
 
 // VALUE OBJECTS
 public class PricedProductItem

diff --git a/...tSourcing/06-GettingStateFromEvents.EventStoreDB/Immutable/GettingStateFromEventsTests.cs b/...tSourcing/06-GettingStateFromEvents.EventStoreDB/Immutable/GettingStateFromEventsTests.cs
@@ -4,32 +4,39 @@
 using Xunit;
 
 namespace IntroductionToEventSourcing.GettingStateFromEvents.Immutable;
+using static ShoppingCartEvent;
 
 // EVENTS
-public record ShoppingCartOpened(
-    Guid ShoppingCartId,
-    Guid ClientId
-);
-
-public record ProductItemAddedToShoppingCart(
-    Guid ShoppingCartId,
-    PricedProductItem ProductItem
-);
-
-public record ProductItemRemovedFromShoppingCart(
-    Guid ShoppingCartId,
-    PricedProductItem ProductItem
-);
-
-public record ShoppingCartConfirmed(
-    Guid ShoppingCartId,
-    DateTime ConfirmedAt
-);
-
-public record ShoppingCartCanceled(
-    Guid ShoppingCartId,
-    DateTime CanceledAt
-);
+public abstract record ShoppingCartEvent
+{
+    public record ShoppingCartOpened(
+        Guid ShoppingCartId,
+        Guid ClientId
+    ): ShoppingCartEvent;
+
+    public record ProductItemAddedToShoppingCart(
+        Guid ShoppingCartId,
+        PricedProductItem ProductItem
+    ): ShoppingCartEvent;
+
+    public record ProductItemRemovedFromShoppingCart(
+        Guid ShoppingCartId,
+        PricedProductItem ProductItem
+    ): ShoppingCartEvent;
+
+    public record ShoppingCartConfirmed(
+        Guid ShoppingCartId,
+        DateTime ConfirmedAt
+    ): ShoppingCartEvent;
+
+    public record ShoppingCartCanceled(
+        Guid ShoppingCartId,
+        DateTime CanceledAt
+    ): ShoppingCartEvent;
+
+    // This won't allow
+    private ShoppingCartEvent(){}
+}
 
 // VALUE OBJECTS
 public record PricedProductItem(