Added DefinitionLoader unittests for dynamic stored workflow definitions

Author: dr-BEat

test/WorkflowCore.TestAssets/DataTypes/DynamicData.cs

@@ -0,0 +1,15 @@
+using System.Collections.Generic;
+
+namespace WorkflowCore.TestAssets.DataTypes
+{
+    public class DynamicData
+    {
+        public Dictionary<string, object> Storage { get; set; } = new Dictionary<string, object>();
+
+        public object this[string propertyName]
+        {
+            get => Storage.TryGetValue(propertyName, out var value) ? value : null;
+            set => Storage[propertyName] = value;
+        }
+    }
+}

test/WorkflowCore.TestAssets/Utils.cs

@@ -23,6 +23,11 @@ public static string GetTestDefinitionJson()
             //return Properties.Resources.ResourceManager.GetString("stored_definition");
             return File.ReadAllText("stored-definition.json");
         }
+
+        public static string GetTestDefinitionDynamicJson()
+        {
+            return File.ReadAllText("stored-dynamic-definition.json");
+        }
     }
 }
 

test/WorkflowCore.TestAssets/WorkflowCore.TestAssets.csproj

@@ -13,9 +13,13 @@
 
   <ItemGroup>
     <None Remove="stored-definition.json" />
+    <None Remove="stored-dynamic-definition.json" />
   </ItemGroup>
 
   <ItemGroup>
+    <EmbeddedResource Include="stored-dynamic-definition.json">
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+    </EmbeddedResource>
     <EmbeddedResource Include="stored-definition.json">
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>
     </EmbeddedResource>

test/WorkflowCore.TestAssets/stored-dynamic-definition.json

@@ -0,0 +1,70 @@
+{
+  "Id": "Test",
+  "Version": 1,
+  "Description": "",
+  "DataType": "WorkflowCore.TestAssets.DataTypes.DynamicData, WorkflowCore.TestAssets",
+  "Steps": [
+    {
+      "Id": "Step1",
+      "StepType": "WorkflowCore.TestAssets.Steps.Counter, WorkflowCore.TestAssets",
+      "Inputs": { "Value": "data[\"Counter1\"]" },
+      "Outputs": { "Counter1": "step.Value" },
+      "NextStepId": "Step2"
+    },
+    {
+      "Id": "Step2",
+      "StepType": "WorkflowCore.TestAssets.Steps.Counter, WorkflowCore.TestAssets",
+      "Inputs": { "Value": "data[\"Counter2\"]" },
+      "Outputs": { "Counter2": "step.Value" },
+      "NextStepId": "Step3"
+    },
+    {
+      "Id": "Step3",
+      "StepType": "WorkflowCore.Primitives.If, WorkflowCore",
+      "NextStepId": "Step4",
+      "Inputs": { "Condition": "object.Equals(data[\"Flag1\"], true)" },
+      "Do": [
+        [
+          {
+            "Id": "Step3.1.1",
+            "StepType": "WorkflowCore.TestAssets.Steps.Counter, WorkflowCore.TestAssets",
+            "Inputs": { "Value": "data[\"Counter3\"]" },
+            "Outputs": { "Counter3": "step.Value" },
+            "NextStepId": "Step3.1.2"
+          },
+          {
+            "Id": "Step3.1.2",
+            "StepType": "WorkflowCore.TestAssets.Steps.Counter, WorkflowCore.TestAssets",
+            "Inputs": { "Value": "data[\"Counter4\"]" },
+            "Outputs": { "Counter4": "step.Value" }
+          }
+        ],
+        [
+          {
+            "Id": "Step3.2.1",
+            "StepType": "WorkflowCore.Primitives.WaitFor, WorkflowCore",
+            "NextStepId": "Step3.2.2",
+            "CancelCondition": "object.Equals(data[\"Flag2\"], true)",
+            "Inputs": {
+              "EventName": "\"Event1\"",
+              "EventKey": "\"Key1\"",
+              "EffectiveDate": "DateTime.Now"
+            }
+          },
+          {
+            "Id": "Step3.2.2",
+            "StepType": "WorkflowCore.TestAssets.Steps.Counter, WorkflowCore.TestAssets",
+            "Inputs": { "Value": "data[\"Counter5\"]" },
+            "Outputs": { "Counter5": "step.Value" }
+          }
+        ]
+      ]
+    },
+    {
+      "Id": "Step4",
+      "StepType": "WorkflowCore.TestAssets.Steps.Counter, WorkflowCore.TestAssets",
+      "Inputs": { "Value": "data[\"Counter6\"]" },
+      "Outputs": { "Counter6": "step.Value" }
+    }
+  ]
+}

test/WorkflowCore.UnitTests/Services/DefinitionStorage/DefinitionLoaderTests.cs

@@ -43,7 +43,19 @@ public void ParseDefinition()
 
             A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(x => x.Id == "Test"))).MustHaveHappened();
             A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(x => x.Version == 1))).MustHaveHappened();
-            A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(x => x.DataType == typeof(TestAssets.DataTypes.CounterBoard)))).MustHaveHappened();
+            A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(x => x.DataType == typeof(CounterBoard)))).MustHaveHappened();
+            A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(MatchTestDefinition, ""))).MustHaveHappened();
+        }
+
+
+        [Fact(DisplayName = "Should parse definition")]
+        public void ParseDefinitionDynamic()
+        {
+            _subject.LoadDefinition(TestAssets.Utils.GetTestDefinitionDynamicJson());
+
+            A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(x => x.Id == "Test"))).MustHaveHappened();
+            A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(x => x.Version == 1))).MustHaveHappened();
+            A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(x => x.DataType == typeof(DynamicData)))).MustHaveHappened();
             A.CallTo(() => _registry.RegisterWorkflow(A<WorkflowDefinition>.That.Matches(MatchTestDefinition, ""))).MustHaveHappened();
         }