Fix cascading message SagaId propagation with Separated mode

src/Testing/CoreTests/Internal/Generated/WolverineHandlers/CascadedFromStartHandler594867920.cs

@@ -0,0 +1,62 @@
+// <auto-generated/>
+#pragma warning disable
+using Wolverine.Persistence.Sagas;
+
+namespace Internal.Generated.WolverineHandlers
+{
+    // START: CascadedFromStartHandler594867920
+    [global::System.CodeDom.Compiler.GeneratedCode("JasperFx", "1.0.0")]
+    public sealed class CascadedFromStartHandler594867920 : Wolverine.Runtime.Handlers.MessageHandler
+    {
+        private readonly Wolverine.Persistence.Sagas.InMemorySagaPersistor _inMemorySagaPersistor;
+
+        public CascadedFromStartHandler594867920(Wolverine.Persistence.Sagas.InMemorySagaPersistor inMemorySagaPersistor)
+        {
+            _inMemorySagaPersistor = inMemorySagaPersistor;
+        }
+
+
+
+        public override System.Threading.Tasks.Task HandleAsync(Wolverine.Runtime.MessageContext context, System.Threading.CancellationToken cancellation)
+        {
+            // The actual message body
+            var cascadedFromStart = (CoreTests.Persistence.Sagas.CascadedFromStart)context.Envelope.Message;
+
+            if (!System.Guid.TryParse(context.Envelope.SagaId, out System.Guid sagaId)) throw new Wolverine.Persistence.Sagas.IndeterminateSagaStateIdException(context.Envelope);
+            var cascadingFromStartSaga = _inMemorySagaPersistor.Load<CoreTests.Persistence.Sagas.CascadingFromStartSaga>(sagaId);
+            if (cascadingFromStartSaga == null)
+            {
+                throw new Wolverine.Persistence.Sagas.UnknownSagaException(typeof(CoreTests.Persistence.Sagas.CascadingFromStartSaga), sagaId);
+            }
+
+            else
+            {
+                context.SetSagaId(sagaId);
+
+                // The actual message execution
+                cascadingFromStartSaga.Handle(cascadedFromStart);
+
+                // Delete the saga if completed, otherwise update it
+                if (cascadingFromStartSaga.IsCompleted())
+                {
+                    _inMemorySagaPersistor.Delete<CoreTests.Persistence.Sagas.CascadingFromStartSaga>(sagaId);
+                }
+
+                else
+                {
+                    _inMemorySagaPersistor.Store<CoreTests.Persistence.Sagas.CascadingFromStartSaga>(cascadingFromStartSaga);
+                }
+
+                // No unit of work
+            }
+
+            return System.Threading.Tasks.Task.CompletedTask;
+        }
+
+    }
+
+    // END: CascadedFromStartHandler594867920
+
+
+}
+

src/Testing/CoreTests/Internal/Generated/WolverineHandlers/CascadedMessageHandler1271130813.cs

@@ -0,0 +1,62 @@
+// <auto-generated/>
+#pragma warning disable
+using Wolverine.Persistence.Sagas;
+
+namespace Internal.Generated.WolverineHandlers
+{
+    // START: CascadedMessageHandler1271130813
+    [global::System.CodeDom.Compiler.GeneratedCode("JasperFx", "1.0.0")]
+    public sealed class CascadedMessageHandler1271130813 : Wolverine.Runtime.Handlers.MessageHandler
+    {
+        private readonly Wolverine.Persistence.Sagas.InMemorySagaPersistor _inMemorySagaPersistor;
+
+        public CascadedMessageHandler1271130813(Wolverine.Persistence.Sagas.InMemorySagaPersistor inMemorySagaPersistor)
+        {
+            _inMemorySagaPersistor = inMemorySagaPersistor;
+        }
+
+
+
+        public override System.Threading.Tasks.Task HandleAsync(Wolverine.Runtime.MessageContext context, System.Threading.CancellationToken cancellation)
+        {
+            // The actual message body
+            var cascadedMessage = (CoreTests.Persistence.Sagas.CascadedMessage)context.Envelope.Message;
+
+            if (!System.Guid.TryParse(context.Envelope.SagaId, out System.Guid sagaId)) throw new Wolverine.Persistence.Sagas.IndeterminateSagaStateIdException(context.Envelope);
+            var cascadingTestSaga = _inMemorySagaPersistor.Load<CoreTests.Persistence.Sagas.CascadingTestSaga>(sagaId);
+            if (cascadingTestSaga == null)
+            {
+                throw new Wolverine.Persistence.Sagas.UnknownSagaException(typeof(CoreTests.Persistence.Sagas.CascadingTestSaga), sagaId);
+            }
+
+            else
+            {
+                context.SetSagaId(sagaId);
+
+                // The actual message execution
+                cascadingTestSaga.Handle(cascadedMessage);
+
+                // Delete the saga if completed, otherwise update it
+                if (cascadingTestSaga.IsCompleted())
+                {
+                    _inMemorySagaPersistor.Delete<CoreTests.Persistence.Sagas.CascadingTestSaga>(sagaId);
+                }
+
+                else
+                {
+                    _inMemorySagaPersistor.Store<CoreTests.Persistence.Sagas.CascadingTestSaga>(cascadingTestSaga);
+                }
+
+                // No unit of work
+            }
+
+            return System.Threading.Tasks.Task.CompletedTask;
+        }
+
+    }
+
+    // END: CascadedMessageHandler1271130813
+
+
+}
+

src/Testing/CoreTests/Internal/Generated/WolverineHandlers/ExternalHandlerHandler843781595.cs

@@ -0,0 +1,31 @@
+// <auto-generated/>
+#pragma warning disable
+
+namespace Internal.Generated.WolverineHandlers
+{
+    // START: ExternalHandlerHandler843781595
+    [global::System.CodeDom.Compiler.GeneratedCode("JasperFx", "1.0.0")]
+    public sealed class ExternalHandlerHandler843781595 : Wolverine.Runtime.Handlers.MessageHandler
+    {
+
+
+        public override System.Threading.Tasks.Task HandleAsync(Wolverine.Runtime.MessageContext context, System.Threading.CancellationToken cancellation)
+        {
+            // The actual message body
+            var cascadedMessage = (CoreTests.Persistence.Sagas.CascadedMessage)context.Envelope.Message;
+
+            System.Diagnostics.Activity.Current?.SetTag("message.handler", "CoreTests.Persistence.Sagas.ExternalHandler");
+
+            // The actual message execution
+            CoreTests.Persistence.Sagas.ExternalHandler.Handle(cascadedMessage);
+
+            return System.Threading.Tasks.Task.CompletedTask;
+        }
+
+    }
+
+    // END: ExternalHandlerHandler843781595
+
+
+}
+

src/Testing/CoreTests/Internal/Generated/WolverineHandlers/StartCascadingTestHandler687561505.cs

@@ -0,0 +1,48 @@
+// <auto-generated/>
+#pragma warning disable
+using Wolverine.Persistence.Sagas;
+
+namespace Internal.Generated.WolverineHandlers
+{
+    // START: StartCascadingTestHandler687561505
+    [global::System.CodeDom.Compiler.GeneratedCode("JasperFx", "1.0.0")]
+    public sealed class StartCascadingTestHandler687561505 : Wolverine.Runtime.Handlers.MessageHandler
+    {
+        private readonly Wolverine.Persistence.Sagas.InMemorySagaPersistor _inMemorySagaPersistor;
+
+        public StartCascadingTestHandler687561505(Wolverine.Persistence.Sagas.InMemorySagaPersistor inMemorySagaPersistor)
+        {
+            _inMemorySagaPersistor = inMemorySagaPersistor;
+        }
+
+
+
+        public override System.Threading.Tasks.Task HandleAsync(Wolverine.Runtime.MessageContext context, System.Threading.CancellationToken cancellation)
+        {
+            // The actual message body
+            var startCascadingTest = (CoreTests.Persistence.Sagas.StartCascadingTest)context.Envelope.Message;
+
+            // Application-specific Open Telemetry auditing
+            System.Diagnostics.Activity.Current?.SetTag("Id", startCascadingTest.Id);
+
+            // The actual message execution
+            var outgoing1 = CoreTests.Persistence.Sagas.CascadingTestSaga.Start(startCascadingTest);
+
+            context.SetSagaId(outgoing1.Id);
+            _inMemorySagaPersistor.Store<CoreTests.Persistence.Sagas.CascadingTestSaga>(outgoing1);
+            if (!outgoing1.IsCompleted())
+            {
+                _inMemorySagaPersistor.Store<CoreTests.Persistence.Sagas.CascadingTestSaga>(outgoing1);
+            }
+
+            // No unit of work
+            return System.Threading.Tasks.Task.CompletedTask;
+        }
+
+    }
+
+    // END: StartCascadingTestHandler687561505
+
+
+}
+

src/Testing/CoreTests/Internal/Generated/WolverineHandlers/StartWithCascadeHandler2016986428.cs

@@ -0,0 +1,51 @@
+// <auto-generated/>
+#pragma warning disable
+using Wolverine.Persistence.Sagas;
+
+namespace Internal.Generated.WolverineHandlers
+{
+    // START: StartWithCascadeHandler2016986428
+    [global::System.CodeDom.Compiler.GeneratedCode("JasperFx", "1.0.0")]
+    public sealed class StartWithCascadeHandler2016986428 : Wolverine.Runtime.Handlers.MessageHandler
+    {
+        private readonly Wolverine.Persistence.Sagas.InMemorySagaPersistor _inMemorySagaPersistor;
+
+        public StartWithCascadeHandler2016986428(Wolverine.Persistence.Sagas.InMemorySagaPersistor inMemorySagaPersistor)
+        {
+            _inMemorySagaPersistor = inMemorySagaPersistor;
+        }
+
+
+
+        public override async System.Threading.Tasks.Task HandleAsync(Wolverine.Runtime.MessageContext context, System.Threading.CancellationToken cancellation)
+        {
+            // The actual message body
+            var startWithCascade = (CoreTests.Persistence.Sagas.StartWithCascade)context.Envelope.Message;
+
+            // Application-specific Open Telemetry auditing
+            System.Diagnostics.Activity.Current?.SetTag("Id", startWithCascade.Id);
+
+            // The actual message execution
+            (var outgoing1, var outgoing2) = CoreTests.Persistence.Sagas.CascadingFromStartSaga.Start(startWithCascade);
+
+            context.SetSagaId(outgoing1.Id);
+            _inMemorySagaPersistor.Store<CoreTests.Persistence.Sagas.CascadingFromStartSaga>(outgoing1);
+
+            // Outgoing, cascaded message
+            await context.EnqueueCascadingAsync(outgoing2).ConfigureAwait(false);
+
+            if (!outgoing1.IsCompleted())
+            {
+                _inMemorySagaPersistor.Store<CoreTests.Persistence.Sagas.CascadingFromStartSaga>(outgoing1);
+            }
+
+            // No unit of work
+        }
+
+    }
+
+    // END: StartWithCascadeHandler2016986428
+
+
+}
+

src/Testing/CoreTests/Internal/Generated/WolverineHandlers/TriggerCascadeHandler1822172080.cs

@@ -0,0 +1,68 @@
+// <auto-generated/>
+#pragma warning disable
+using Wolverine.Persistence.Sagas;
+
+namespace Internal.Generated.WolverineHandlers
+{
+    // START: TriggerCascadeHandler1822172080
+    [global::System.CodeDom.Compiler.GeneratedCode("JasperFx", "1.0.0")]
+    public sealed class TriggerCascadeHandler1822172080 : Wolverine.Runtime.Handlers.MessageHandler
+    {
+        private readonly Wolverine.Persistence.Sagas.InMemorySagaPersistor _inMemorySagaPersistor;
+
+        public TriggerCascadeHandler1822172080(Wolverine.Persistence.Sagas.InMemorySagaPersistor inMemorySagaPersistor)
+        {
+            _inMemorySagaPersistor = inMemorySagaPersistor;
+        }
+
+
+
+        public override async System.Threading.Tasks.Task HandleAsync(Wolverine.Runtime.MessageContext context, System.Threading.CancellationToken cancellation)
+        {
+            // The actual message body
+            var triggerCascade = (CoreTests.Persistence.Sagas.TriggerCascade)context.Envelope.Message;
+
+            // Application-specific Open Telemetry auditing
+            System.Diagnostics.Activity.Current?.SetTag("Id", triggerCascade.Id);
+            if (!System.Guid.TryParse(context.Envelope.SagaId, out System.Guid sagaId)) sagaId = triggerCascade.Id;
+            if (sagaId == System.Guid.Empty) throw new Wolverine.Persistence.Sagas.IndeterminateSagaStateIdException(context.Envelope);
+            var cascadingTestSaga = _inMemorySagaPersistor.Load<CoreTests.Persistence.Sagas.CascadingTestSaga>(sagaId);
+            if (cascadingTestSaga == null)
+            {
+                throw new Wolverine.Persistence.Sagas.UnknownSagaException(typeof(CoreTests.Persistence.Sagas.CascadingTestSaga), sagaId);
+            }
+
+            else
+            {
+                context.SetSagaId(sagaId);
+
+                // The actual message execution
+                var outgoing1 = cascadingTestSaga.Handle(triggerCascade);
+
+
+                // Outgoing, cascaded message
+                await context.EnqueueCascadingAsync(outgoing1).ConfigureAwait(false);
+
+                // Delete the saga if completed, otherwise update it
+                if (cascadingTestSaga.IsCompleted())
+                {
+                    _inMemorySagaPersistor.Delete<CoreTests.Persistence.Sagas.CascadingTestSaga>(sagaId);
+                }
+
+                else
+                {
+                    _inMemorySagaPersistor.Store<CoreTests.Persistence.Sagas.CascadingTestSaga>(cascadingTestSaga);
+                }
+
+                // No unit of work
+            }
+
+        }
+
+    }
+
+    // END: TriggerCascadeHandler1822172080
+
+
+}
+