update persistence providers

Author: danielgerlag

WorkflowCore.Sample09/Program.cs

@@ -29,10 +29,11 @@ private static IServiceProvider ConfigureServices()
             //setup dependency injection
             IServiceCollection services = new ServiceCollection();
             services.AddLogging();
-            //services.AddWorkflow();
-            services.AddWorkflow(x => x.UseMongoDB(@"mongodb://localhost:27017", "workflow-test001"));
+            services.AddWorkflow();
+            //services.AddWorkflow(x => x.UseMongoDB(@"mongodb://localhost:27017", "workflow-test002"));
             //services.AddWorkflow(x => x.UseSqlServer(@"Server=.;Database=WorkflowCore3;Trusted_Connection=True;", true, true));            
             //services.AddWorkflow(x => x.UseSqlite(@"Data Source=database2.db;", true));            
+            //services.AddWorkflow(x => x.UsePostgreSQL(@"Server=127.0.0.1;Port=32768;Database=workflow_test001;User Id=postgres;", true, true));
 
 
             var serviceProvider = services.BuildServiceProvider();

WorkflowCore.Sample09/WorkflowCore.Sample09.csproj

@@ -13,6 +13,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\src\providers\WorkflowCore.Persistence.MongoDB\WorkflowCore.Persistence.MongoDB.csproj" />
+    <ProjectReference Include="..\src\providers\WorkflowCore.Persistence.PostgreSQL\WorkflowCore.Persistence.PostgreSQL.csproj" />
     <ProjectReference Include="..\src\WorkflowCore\WorkflowCore.csproj" />
   </ItemGroup>
 

WorkflowCore.Sample10/Program.cs

@@ -1,12 +1,46 @@
-using System;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using System;
+using WorkflowCore.Interface;
 
 namespace WorkflowCore.Sample10
 {
     class Program
     {
-        static void Main(string[] args)
+        public static void Main(string[] args)
         {
-            Console.WriteLine("Hello World!");
+            IServiceProvider serviceProvider = ConfigureServices();
+
+            //start the workflow host
+            var host = serviceProvider.GetService<IWorkflowHost>();
+            host.RegisterWorkflow<WhileWorkflow, MyData>();
+            host.Start();
+
+            Console.WriteLine("Starting workflow...");
+            string workflowId = host.StartWorkflow("While", new MyData() { Counter = 0 }).Result;
+
+
+            Console.ReadLine();
+            host.Stop();
+        }
+
+        private static IServiceProvider ConfigureServices()
+        {
+            //setup dependency injection
+            IServiceCollection services = new ServiceCollection();
+            services.AddLogging();
+            services.AddWorkflow();
+            //services.AddWorkflow(x => x.UseMongoDB(@"mongodb://localhost:27017", "workflow-test001"));
+            //services.AddWorkflow(x => x.UseSqlServer(@"Server=.\SQLEXPRESS;Database=WorkflowCore;Trusted_Connection=True;", true, true));
+            //services.AddWorkflow(x => x.UseSqlite(@"Data Source=database2.db;", true));            
+
+
+            var serviceProvider = services.BuildServiceProvider();
+
+            //config logging
+            var loggerFactory = serviceProvider.GetService<ILoggerFactory>();
+            //loggerFactory.AddDebug(LogLevel.Debug);
+            return serviceProvider;
         }
     }
 }

WorkflowCore.Sample10/Steps/DoSomething.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace WorkflowCore.Sample10
+{    
+    public class DoSomething : StepBody
+    {
+        public override ExecutionResult Run(IStepExecutionContext context)
+        {
+            Console.WriteLine("Doing something...");
+            return ExecutionResult.Next();
+        }
+    }
+}

WorkflowCore.Sample10/Steps/IncrementStep.cs

@@ -0,0 +1,20 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace WorkflowCore.Sample10
+{
+    public class IncrementStep : StepBody
+    {
+        public int Value1 { get; set; }
+        public int Value2 { get; set; }
+
+        public override ExecutionResult Run(IStepExecutionContext context)
+        {
+            Value2 = Value1 + 1;
+            return ExecutionResult.Next();
+        }
+    }
+}

WorkflowCore.Sample10/Steps/SayGoodbye.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace WorkflowCore.Sample10
+{    
+    public class SayGoodbye : StepBody
+    {
+        public override ExecutionResult Run(IStepExecutionContext context)
+        {
+            Console.WriteLine("Goodbye");
+            return ExecutionResult.Next();
+        }
+    }
+}

WorkflowCore.Sample10/Steps/SayHello.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace WorkflowCore.Sample10
+{    
+    public class SayHello : StepBody
+    {
+        public override ExecutionResult Run(IStepExecutionContext context)
+        {
+            Console.WriteLine("Hello");
+            return ExecutionResult.Next();
+        }
+    }
+}

WorkflowCore.Sample10/WhileWorkflow.cs

@@ -0,0 +1,32 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace WorkflowCore.Sample10
+{    
+    public class WhileWorkflow : IWorkflow<MyData>
+    {
+        public string Id => "While";
+        public int Version => 1;
+
+        public void Build(IWorkflowBuilder<MyData> builder)
+        {
+            builder
+                .StartWith<SayHello>()
+                .While(data => data.Counter < 3)
+                    .Do(x => x
+                        .StartWith<DoSomething>()
+                        .Then<IncrementStep>()
+                            .Input(step => step.Value1, data => data.Counter)
+                            .Output(data => data.Counter, step => step.Value2))
+                .Then<SayGoodbye>();
+        }        
+    }
+
+    public class MyData
+    {
+        public int Counter { get; set; }
+    }
+}

WorkflowCore.Sample10/WorkflowCore.Sample10.csproj

@@ -12,6 +12,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\src\providers\WorkflowCore.Persistence.MongoDB\WorkflowCore.Persistence.MongoDB.csproj" />
+    <ProjectReference Include="..\src\providers\WorkflowCore.Persistence.SqlServer\WorkflowCore.Persistence.SqlServer.csproj" />
     <ProjectReference Include="..\src\WorkflowCore\WorkflowCore.csproj" />
   </ItemGroup>
 

src/WorkflowCore/Models/ControlStructures/ControlPersistenceData.cs

@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace WorkflowCore.Models
+{
+    public class ControlPersistenceData
+    {
+        public bool ChildrenActive { get; set; }
+    }
+}