Added Tests for persistence with dynamic data

Author: dr-BEat

test/WorkflowCore.IntegrationTests/Scenarios/DynamicDataIOScenario.cs

@@ -0,0 +1,70 @@
+using System;
+using System.Collections.Generic;
+using FluentAssertions;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+using WorkflowCore.Testing;
+using Xunit;
+
+namespace WorkflowCore.IntegrationTests.Scenarios
+{
+    public class DynamicDataIOScenario : WorkflowTest<DynamicDataIOScenario.DataIOWorkflow, DynamicDataIOScenario.MyDataClass>
+    {
+        public class AddNumbers : StepBody
+        {
+            public int Input1 { get; set; }
+            public int Input2 { get; set; }
+            public int Output { get; set; }
+
+            public override ExecutionResult Run(IStepExecutionContext context)
+            {
+                Output = (Input1 + Input2);
+                return ExecutionResult.Next();
+            }
+        }
+
+        public class MyDataClass
+        {
+            public int Value1 { get; set; }
+            public int Value2 { get; set; }
+
+            public Dictionary<string, int> _storage = new Dictionary<string, int>();
+
+            public int this[string propertyName]
+            {
+                get => _storage[propertyName];
+                set => _storage[propertyName] = value;
+            }
+        }
+
+        public class DataIOWorkflow : IWorkflow<MyDataClass>
+        {
+            public string Id => "DataIOWorkflow";
+            public int Version => 1;
+            public void Build(IWorkflowBuilder<MyDataClass> builder)
+            {
+                builder
+                    .StartWith<AddNumbers>()
+                    .Input(step => step.Input1, data => data.Value1)
+                    .Input(step => step.Input2, data => data.Value2)
+                    .Output(data => data["Value3"], step => step.Output);
+            }
+        }
+
+        public DynamicDataIOScenario()
+        {
+            Setup();
+        }
+
+        [Fact]
+        public void Scenario()
+        {
+            var workflowId = StartWorkflow(new MyDataClass() { Value1 = 2, Value2 = 3 });
+            WaitForWorkflowToComplete(workflowId, TimeSpan.FromSeconds(30));
+
+            GetStatus(workflowId).Should().Be(WorkflowStatus.Complete);
+            UnhandledStepErrors.Count.Should().Be(0);
+            GetData(workflowId)["Value3"].Should().Be(5);
+        }
+    }
+}

test/WorkflowCore.Tests.MongoDB/Scenarios/MongoDynamicDataScenario.cs

@@ -0,0 +1,16 @@
+using System;
+using Microsoft.Extensions.DependencyInjection;
+using WorkflowCore.IntegrationTests.Scenarios;
+using Xunit;
+
+namespace WorkflowCore.Tests.MongoDB.Scenarios
+{
+    [Collection("Mongo collection")]
+    public class MongoDynamicDataScenario : DynamicDataIOScenario
+    {
+        protected override void ConfigureServices(IServiceCollection services)
+        {
+            services.AddWorkflow(x => x.UseMongoDB(MongoDockerSetup.ConnectionString, "integration-tests"));
+        }
+    }
+}

test/WorkflowCore.Tests.PostgreSQL/Scenarios/PostgresDynamicDataScenario.cs

@@ -0,0 +1,16 @@
+using System;
+using Microsoft.Extensions.DependencyInjection;
+using WorkflowCore.IntegrationTests.Scenarios;
+using Xunit;
+
+namespace WorkflowCore.Tests.PostgreSQL.Scenarios
+{
+    [Collection("Postgres collection")]
+    public class PostgresDynamicDataScenario : DynamicDataIOScenario
+    {
+        protected override void ConfigureServices(IServiceCollection services)
+        {
+            services.AddWorkflow(x => x.UsePostgreSQL(PostgresDockerSetup.ScenarioConnectionString, true, true));
+        }
+    }
+}

test/WorkflowCore.Tests.SqlServer/Scenarios/SqlServerDynamicDataScenario.cs

@@ -0,0 +1,16 @@
+using System;
+using Microsoft.Extensions.DependencyInjection;
+using WorkflowCore.IntegrationTests.Scenarios;
+using Xunit;
+
+namespace WorkflowCore.Tests.SqlServer.Scenarios
+{
+    [Collection("SqlServer collection")]
+    public class SqlServerDynamicDataScenario : DynamicDataIOScenario
+    {
+        protected override void ConfigureServices(IServiceCollection services)
+        {
+            services.AddWorkflow(x => x.UseSqlServer(SqlDockerSetup.ScenarioConnectionString, true, true));
+        }
+    }
+}