test(auditlog): pin OriginExecutionId preservation in forwarder + Parked NotifyDeliver

tests/ScadaLink.StoreAndForward.Tests/NotificationForwarderTests.cs

@@ -26,7 +26,8 @@ public class NotificationForwarderTests : TestKit
     private static StoreAndForwardMessage BufferedNotification(
         string id = "msg-1", string listName = "Operators",
         string subject = "Pump alarm", string message = "Pump 3 tripped",
-        string? originInstance = "Plant.Pump3", string? sourceScript = "alarmScript")
+        string? originInstance = "Plant.Pump3", string? sourceScript = "alarmScript",
+        Guid? originExecutionId = null)
     {
         var payload = JsonSerializer.Serialize(new NotificationSubmit(
             NotificationId: id,
@@ -37,7 +38,8 @@ public class NotificationForwarderTests : TestKit
             SourceSiteId: string.Empty,
             SourceInstanceId: originInstance,
             SourceScript: sourceScript,
-            SiteEnqueuedAt: DateTimeOffset.UtcNow));
+            SiteEnqueuedAt: DateTimeOffset.UtcNow,
+            OriginExecutionId: originExecutionId));
         return new StoreAndForwardMessage
         {
             Id = id,
@@ -78,6 +80,33 @@ public class NotificationForwarderTests : TestKit
         Assert.True(await deliverTask);
     }
 
+    [Fact]
+    public async Task Deliver_PreservesOriginExecutionId_FromBufferedPayload()
+    {
+        // Audit Log #23: the buffered payload's OriginExecutionId is the per-run
+        // id stamped at Notify.Send time. The forwarder re-stamps only the four
+        // fields it authoritatively owns (NotificationId, ListName, SourceSiteId,
+        // SourceInstanceId) via the `with` expression — OriginExecutionId is
+        // preserved precisely BY being absent from that `with` block. This test
+        // pins that: if OriginExecutionId is ever added to the `with` expression
+        // (e.g. reset to null), the forwarded NotificationSubmit would lose the
+        // per-run id and central could not echo it onto NotifyDeliver rows.
+        var centralProbe = CreateTestProbe();
+        var forwarder = new NotificationForwarder(
+            centralProbe.Ref, "site-7", ForwardTimeout);
+
+        var executionId = Guid.NewGuid();
+        var msg = BufferedNotification(id: "msg-exec", originExecutionId: executionId);
+
+        var deliverTask = forwarder.DeliverAsync(msg);
+
+        var submit = centralProbe.ExpectMsg<NotificationSubmit>();
+        Assert.Equal(executionId, submit.OriginExecutionId);
+        centralProbe.Reply(new NotificationSubmitAck(submit.NotificationId, Accepted: true, Error: null));
+
+        Assert.True(await deliverTask);
+    }
+
     [Fact]
     public async Task Deliver_FallsBackToTarget_WhenPayloadListNameIsEmpty()
     {