IdentityFromEvent interface needs to have IdentityFromEvent as well

JasperFx · Feb 6, 2025 · 9a6aa64 · 9a6aa64
1 parent 11d8dc6
commit 9a6aa64
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/Marten/Events/Aggregation/AggregationRuntime.cs b/src/Marten/Events/Aggregation/AggregationRuntime.cs
@@ -325,7 +325,7 @@ public IAggregateCache<TId, TDoc> CacheFor(Tenant tenant)
         }
     }
 
-    public TId IdentityFromEvent(IEvent e)
+    public TId IdentityFromEvent(StreamIdentity streamIdentity, IEvent e)
     {
         return _identitySource(e);
     }

diff --git a/src/Marten/Events/Aggregation/IAggregationRuntime.cs b/src/Marten/Events/Aggregation/IAggregationRuntime.cs
@@ -40,5 +40,5 @@ ValueTask ApplyChangesAsync(DocumentSessionBase session,
 
     IAggregateCache<TId, TDoc> CacheFor(Tenant tenant);
 
-    TId IdentityFromEvent(IEvent e);
+    TId IdentityFromEvent(StreamIdentity streamIdentity, IEvent e);
 }
diff --git a/src/Marten/Events/Aggregation/Rebuilds/AggregatePageHandler.cs b/src/Marten/Events/Aggregation/Rebuilds/AggregatePageHandler.cs
@@ -192,7 +192,7 @@ private async Task collateAndPostSlices(IAsyncEnumerable<IEvent> events, ITarget
         EventSlice<TDoc, TId> slice = null;
         await foreach (var e in events)
         {
-            var aggregateId = _runtime.IdentityFromEvent(e);
+            var aggregateId = _runtime.IdentityFromEvent(_session.Options.Events.StreamIdentity, e);
             slice ??= new EventSlice<TDoc, TId>(aggregateId, _session);
 
             if (!slice.Id.Equals(aggregateId))
-Original file line number
+Diff line change
@@ Expand Up / @@ -325,7 +325,7 @@ public IAggregateCache<TId, TDoc> CacheFor(Tenant tenant) @@
             }
         }
-        public TId IdentityFromEvent(IEvent e)
+        public TId IdentityFromEvent(StreamIdentity streamIdentity, IEvent e)
         {
             return _identitySource(e);
         }
@@ Expand Down @@