Add support for versioned events with SomethingHappenedEvent2 and corresponding aggregate update logic

Author: lucabriguglia

tests/Memoria.EventSourcing.Store.Tests/Features/UpdateAggregateTests.cs

@@ -68,5 +68,33 @@ public async Task GivenEventsHandledByTheAggregateAreStoredSeparately_WhenAggreg
             updatedAggregateResult.Value.Description.Should().Be("Updated Description");
         }
     }
+    
+    [Fact]
+    public async Task GivenEventWithNewVersion_WhenAggregateIsUpdated_ThenNewEventVersionIsApplied()
+    {
+        var id = Guid.NewGuid().ToString();
+        var streamId = new TestStreamId(id);
+        var aggregateId = new TestAggregate1Id(id);
+        var aggregate = new TestAggregate1(id, "Test Name", "Test Description");
+
+        await DomainService.SaveAggregate(streamId, aggregateId, aggregate, expectedEventSequence: 0);
+        await DomainService.SaveEvents(streamId, [new SomethingHappenedEvent2("Something 2")], expectedEventSequence: 1);
+        var updatedAggregateResult = await DomainService.UpdateAggregate(streamId, aggregateId);
+
+        using (new AssertionScope())
+        {
+            updatedAggregateResult.IsSuccess.Should().BeTrue();
+
+            updatedAggregateResult.Value.Should().NotBeNull();
+
+            updatedAggregateResult.Value.StreamId.Should().Be(streamId.Id);
+            updatedAggregateResult.Value.AggregateId.Should().Be(aggregateId.ToStoreId());
+            updatedAggregateResult.Value.Version.Should().Be(2);
+
+            updatedAggregateResult.Value.Id.Should().Be(id);
+            updatedAggregateResult.Value.Name.Should().Be("Something 2");
+            updatedAggregateResult.Value.Description.Should().Be("Test Description");
+        }
+    }
 }
 

tests/Memoria.EventSourcing.Store.Tests/Models/Aggregates/TestAggregate1.cs

@@ -10,7 +10,8 @@ public class TestAggregate1 : AggregateRoot
     [
         typeof(TestAggregateCreatedEvent),
         typeof(TestAggregateUpdatedEvent),
-        typeof(SomethingHappenedEvent)
+        typeof(SomethingHappenedEvent),
+        typeof(SomethingHappenedEvent2)
     ];
 
     public string Id { get; set; } = null!;
@@ -37,6 +38,7 @@ protected override bool Apply<T>(T @event)
         {
             TestAggregateCreatedEvent testAggregateCreated => Apply(testAggregateCreated),
             TestAggregateUpdatedEvent testAggregateUpdated => Apply(testAggregateUpdated),
+            SomethingHappenedEvent2 somethingHappened2 => Apply(somethingHappened2),
             _ => false
         };
     }
@@ -57,4 +59,11 @@ private bool Apply(TestAggregateUpdatedEvent @event)
 
         return true;
     }
+
+    private bool Apply(SomethingHappenedEvent2 @event)
+    {
+        Name = @event.Something2;
+        
+        return true;
+    }
 }

tests/Memoria.EventSourcing.Store.Tests/Models/Events/SomethingHappenedEvent.cs

@@ -4,3 +4,6 @@ namespace Memoria.EventSourcing.Store.Tests.Models.Events;
 
 [EventType("SomethingHappened")]
 public record SomethingHappenedEvent(string Something) : IEvent;
+
+[EventType("SomethingHappened", version: 2)]
+public record SomethingHappenedEvent2(string Something2) : IEvent;