Fix on the quick append function generation for causation ids

JasperFx · Jul 4, 2024 · f433b52 · f433b52
1 parent b19e782
commit f433b52
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/src/EventSourcingTests/QuickAppend/quick_append_end_to_end.cs b/src/EventSourcingTests/QuickAppend/quick_append_end_to_end.cs
@@ -30,6 +30,9 @@ public async Task append_with_metadata_using_function()
             theSession.Events.StartStream<Quest>(new QuestStarted(), new MembersJoined(1, "Hobbiton", "Frodo", "Sam")).Id;
         await theSession.SaveChangesAsync();
 
+        theSession.Events.Append(streamId, new MembersDeparted { Members = new string[] { "Frodo" } });
+        await theSession.SaveChangesAsync();
+
         var events = await theSession.Events.FetchStreamAsync(streamId);
 
         foreach (var e in events)

diff --git a/src/Marten/Events/Schema/QuickAppendEventFunction.cs b/src/Marten/Events/Schema/QuickAppendEventFunction.cs
@@ -40,7 +40,7 @@ public override void WriteCreateStatement(Migrator migrator, TextWriter writer)
             {
                 metadataColumns += ", " + CausationIdColumn.ColumnName;
                 metadataParameters += ", causation_ids varchar[]";
-                metadataValues += ", causations_ids[index]";
+                metadataValues += ", causation_ids[index]";
             }
 
             if (table.Columns.OfType<CorrelationIdColumn>().Any())