Added FlowIdCanBeExtractedFromWorkflowInstance-test

stidsborg · Nov 3, 2024 · bcf53b6 · bcf53b6
1 parent 1ffa031
commit bcf53b6
Show file tree

Hide file tree

Showing 5 changed files with 43 additions and 0 deletions.
diff --git a/Core/Cleipnir.ResilientFunctions.Tests/InMemoryTests/RFunctionTests/SunshineTests.cs b/Core/Cleipnir.ResilientFunctions.Tests/InMemoryTests/RFunctionTests/SunshineTests.cs
@@ -59,4 +59,8 @@ public override Task EffectsAreNotFetchedOnFirstInvocation()
     [TestMethod]
     public override Task EffectsAreFetchedOnSecondInvocation()
         => EffectsAreFetchedOnSecondInvocation(FunctionStoreFactory.Create());
+
+    [TestMethod]
+    public override Task FlowIdCanBeExtractedFromWorkflowInstance()
+        => FlowIdCanBeExtractedFromWorkflowInstance(FunctionStoreFactory.Create());
 }
diff --git a/Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/RFunctionTests/SunshineTests.cs b/Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/RFunctionTests/SunshineTests.cs
@@ -471,4 +471,31 @@ await BusyWait.Until(
 
         controlPanel.Status.ShouldBe(Status.Failed);
     }
+
+    public abstract Task FlowIdCanBeExtractedFromWorkflowInstance();
+    public async Task FlowIdCanBeExtractedFromWorkflowInstance(Task<IFunctionStore> storeTask)
+    {
+        var store = await storeTask;
+        var flowType = nameof(SunshineScenarioFunc).ToFlowType();
+        var flowInstance = Guid.NewGuid().ToString();
+
+        var unhandledExceptionHandler = new UnhandledExceptionCatcher();
+
+        using var functionsRegistry = new FunctionsRegistry(store, new Settings(unhandledExceptionHandler.Catch));
+
+        FlowId? flowId = null;
+        var reg = functionsRegistry
+            .RegisterParamless(
+                flowType,
+                workflow =>
+                {
+                    flowId = workflow.FlowId;
+                    return Task.CompletedTask;
+                }
+            );
+        await reg.Invoke(flowInstance);
+
+        flowId.ShouldBe(new FlowId(flowType, flowInstance));
+        unhandledExceptionHandler.ShouldNotHaveExceptions();
+    }
 }
diff --git a/Stores/MySQL/Cleipnir.ResilientFunctions.MySQL.Tests/RFunctionTests/SunshineTests.cs b/Stores/MySQL/Cleipnir.ResilientFunctions.MySQL.Tests/RFunctionTests/SunshineTests.cs
@@ -56,4 +56,8 @@ public override Task EffectsAreNotFetchedOnFirstInvocation()
     [TestMethod]
     public override Task EffectsAreFetchedOnSecondInvocation()
         => EffectsAreFetchedOnSecondInvocation(FunctionStoreFactory.Create());
+
+    [TestMethod]
+    public override Task FlowIdCanBeExtractedFromWorkflowInstance()
+        => FlowIdCanBeExtractedFromWorkflowInstance(FunctionStoreFactory.Create());
 }
diff --git a/...s/PostgreSQL/Cleipnir.ResilientFunctions.PostgreSQL.Tests/RFunctionTests/SunshineTests.cs b/...s/PostgreSQL/Cleipnir.ResilientFunctions.PostgreSQL.Tests/RFunctionTests/SunshineTests.cs
@@ -57,4 +57,8 @@ public override Task EffectsAreNotFetchedOnFirstInvocation()
     [TestMethod]
     public override Task EffectsAreFetchedOnSecondInvocation()
         => EffectsAreFetchedOnSecondInvocation(FunctionStoreFactory.Create());
+
+    [TestMethod]
+    public override Task FlowIdCanBeExtractedFromWorkflowInstance()
+        => FlowIdCanBeExtractedFromWorkflowInstance(FunctionStoreFactory.Create());
 }
diff --git a/Stores/SqlServer/Cleipnir.ResilientFunctions.SqlServer.Tests/RFunctionTests/SunshineTests.cs b/Stores/SqlServer/Cleipnir.ResilientFunctions.SqlServer.Tests/RFunctionTests/SunshineTests.cs
@@ -57,4 +57,8 @@ public override Task EffectsAreNotFetchedOnFirstInvocation()
     [TestMethod]
     public override Task EffectsAreFetchedOnSecondInvocation()
         => EffectsAreFetchedOnSecondInvocation(FunctionStoreFactory.Create());
+
+    [TestMethod]
+    public override Task FlowIdCanBeExtractedFromWorkflowInstance()
+        => FlowIdCanBeExtractedFromWorkflowInstance(FunctionStoreFactory.Create());
 }