added some other variations

JoshuaNitschke · Oct 6, 2023 · 839709b · 839709b
1 parent f1910b5
commit 839709b
Showing 1 changed file with 59 additions and 0 deletions.
diff --git a/src/EventSourcingTests/Bugs/Bug_xxxx_inline_projections_should_always_update.cs b/src/EventSourcingTests/Bugs/Bug_xxxx_inline_projections_should_always_update.cs
@@ -119,6 +119,65 @@ async Task<TDetail> CreateFromEvents<TAggregate, TEvent, TDetail>(IEnumerable<TE
         }
     }
 
+    [Fact]
+    public async Task projection_updates_with_save_strategy_variation_1b_generics_version()
+    {
+        StoreOptions(c =>
+        {
+            c.Projections.Add<WeeklyFoodTrackerDetailsProjection>(ProjectionLifecycle.Inline);
+        });
+
+        var streamId = Guid.NewGuid();
+        var events = new List<WeeklyFoodTrackerEvent>();
+        events.Add(new WeekStarted(streamId));
+        events.Add(new ApplesBought(streamId, 1));
+        events.Add(new BananasBought(streamId, 8));
+
+        var weekDetails = await CreateFromEvents<WeeklyFoodTracker, WeeklyFoodTrackerEvent, WeeklyFoodTrackerDetails>(events.ToArray());
+        weekDetails.ShouldNotBeNull();
+        weekDetails.Apples.ShouldBe(1);
+        weekDetails.Bananas.ShouldBe(8);
+
+        async Task<TDetail> CreateFromEvents<TAggregate, TEvent, TDetail>(TEvent[] events)
+            where TEvent : IAggregateStreamEvent
+            where TAggregate : class
+        {
+            if (!events.Any()) throw new InvalidOperationException("Must have at least one event");
+            var id = events.First().Id;
+            await using var session = theStore.LightweightSession();
+            session.Events.StartStream<TAggregate>(id, events);
+            await session.SaveChangesAsync();
+            return await session.LoadAsync<TDetail>(id) ?? throw new Exception("Should not be null)");
+        }
+    }
+
+    [Fact]
+    public async Task projection_updates_with_save_strategy_variation_1c_generics_version()
+    {
+        StoreOptions(c =>
+        {
+            c.Projections.Add<WeeklyFoodTrackerDetailsProjection>(ProjectionLifecycle.Inline);
+        });
+
+        var streamId = Guid.NewGuid();
+        var weekDetails = await CreateFromEvents<WeeklyFoodTracker, WeeklyFoodTrackerEvent, WeeklyFoodTrackerDetails>(new WeekStarted(streamId), new ApplesBought(streamId, 1), new BananasBought(streamId, 8));
+        weekDetails.ShouldNotBeNull();
+        weekDetails.Apples.ShouldBe(1);
+        weekDetails.Bananas.ShouldBe(8);
+
+        async Task<TDetail> CreateFromEvents<TAggregate, TEvent, TDetail>(params TEvent[] events)
+            where TEvent : IAggregateStreamEvent
+            where TAggregate : class
+        {
+            if (!events.Any()) throw new InvalidOperationException("Must have at least one event");
+            var id = events.First().Id;
+            await using var session = theStore.LightweightSession();
+            session.Events.StartStream<TAggregate>(id, events);
+            await session.SaveChangesAsync();
+            return await session.LoadAsync<TDetail>(id) ?? throw new Exception("Should not be null)");
+        }
+    }
+
     [Fact]
     public async Task projection_updates_with_save_strategy_variation_2_generics_version()
     {