while

Author: danielgerlag

WorkflowCore.Sample10/Program.cs

@@ -0,0 +1,12 @@
+using System;
+
+namespace WorkflowCore.Sample10
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            Console.WriteLine("Hello World!");
+        }
+    }
+}

WorkflowCore.Sample10/WorkflowCore.Sample10.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp1.1</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="1.1.0" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="1.1.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\src\providers\WorkflowCore.Persistence.MongoDB\WorkflowCore.Persistence.MongoDB.csproj" />
+    <ProjectReference Include="..\src\WorkflowCore\WorkflowCore.csproj" />
+  </ItemGroup>
+
+</Project>

WorkflowCore.sln

@@ -1,7 +1,7 @@
 
 Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio 15
-VisualStudioVersion = 15.0.26403.7
+VisualStudioVersion = 15.0.26228.4
 MinimumVisualStudioVersion = 10.0.40219.1
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{EF47161E-E399-451C-BDE8-E92AAD3BD761}"
 EndProject
@@ -76,6 +76,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "WorkflowCore.WebAPI", "src\
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkflowCore.Sample09", "WorkflowCore.Sample09\WorkflowCore.Sample09.csproj", "{CFFE642C-E9ED-4662-B5BB-6586A06BC58E}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkflowCore.Sample10", "WorkflowCore.Sample10\WorkflowCore.Sample10.csproj", "{334DECAC-6CFC-4E0E-AC09-6AD12006A250}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -198,6 +200,10 @@ Global
 		{CFFE642C-E9ED-4662-B5BB-6586A06BC58E}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{CFFE642C-E9ED-4662-B5BB-6586A06BC58E}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{CFFE642C-E9ED-4662-B5BB-6586A06BC58E}.Release|Any CPU.Build.0 = Release|Any CPU
+		{334DECAC-6CFC-4E0E-AC09-6AD12006A250}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{334DECAC-6CFC-4E0E-AC09-6AD12006A250}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{334DECAC-6CFC-4E0E-AC09-6AD12006A250}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{334DECAC-6CFC-4E0E-AC09-6AD12006A250}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -235,5 +241,6 @@ Global
 		{ED5074AF-A09E-4357-A419-FE3476C0FAE7} = {5080DB09-CBE8-4C45-9957-C3BB7651755E}
 		{FBF8D151-A3BF-4EB3-8F80-D71618696362} = {6803696C-B19A-4B27-9193-082A02B6F205}
 		{CFFE642C-E9ED-4662-B5BB-6586A06BC58E} = {5080DB09-CBE8-4C45-9957-C3BB7651755E}
+		{334DECAC-6CFC-4E0E-AC09-6AD12006A250} = {5080DB09-CBE8-4C45-9957-C3BB7651755E}
 	EndGlobalSection
 EndGlobal

src/WorkflowCore/Interface/IStepBuilder.cs

@@ -88,5 +88,7 @@ public interface IStepBuilder<TData, TStepBody>
         IStepBuilder<TData, TStepBody> EndWorkflow();
 
         IParentStepBuilder<TData, Foreach> ForEach(Expression<Func<TData, IEnumerable>> collection);
+
+        IParentStepBuilder<TData, While> While(Expression<Func<TData, bool>> condition);
     }
 }

src/WorkflowCore/Models/While.cs

@@ -0,0 +1,50 @@
+using System;
+using System.Linq;
+using System.Collections;
+using System.Collections.Generic;
+using System.Linq.Expressions;
+using System.Text;
+using WorkflowCore.Interface;
+
+namespace WorkflowCore.Models
+{
+    public class While : StepBody
+    {        
+        public bool ConditionResult { get; set; }                
+
+        public override ExecutionResult Run(IStepExecutionContext context)
+        {
+            if (ConditionResult)
+            {                
+                return ExecutionResult.Branch(new List<object>() { null }, null);
+            }
+
+            bool complete = true;
+            foreach (var childId in context.ExecutionPointer.Children)
+                complete = complete && IsBranchComplete(context.Workflow.ExecutionPointers, childId);
+
+            if (complete)
+                return ExecutionResult.Next();
+
+            return ExecutionResult.Persist(context.PersistenceData);
+        }
+
+        private bool IsBranchComplete(IEnumerable<ExecutionPointer> pointers, string rootId)
+        {
+            var root = pointers.First(x => x.Id == rootId);
+
+            if (root.EndTime == null)
+                return false;
+
+            var list = pointers.Where(x => x.PredecessorId == rootId).ToList();
+
+            bool result = true;
+
+            foreach (var item in list)
+                result = result && IsBranchComplete(pointers, item.Id);
+
+            return result;
+        }
+
+    }
+}

src/WorkflowCore/Services/StepBuilder.cs

@@ -170,6 +170,27 @@ public IParentStepBuilder<TData, Foreach> ForEach(Expression<Func<TData, IEnumer
             return stepBuilder;
         }
 
+        public IParentStepBuilder<TData, While> While(Expression<Func<TData, bool>> condition)
+        {
+            var newStep = new WorkflowStep<While>();
+
+            Expression<Func<While, bool>> inputExpr = (x => x.ConditionResult);
+
+            var mapping = new DataMapping()
+            {
+                Source = condition,
+                Target = inputExpr
+            };
+            newStep.Inputs.Add(mapping);
+
+            WorkflowBuilder.AddStep(newStep);
+            var stepBuilder = new StepBuilder<TData, While>(WorkflowBuilder, newStep);
+
+            Step.Outcomes.Add(new StepOutcome() { NextStep = newStep.Id });
+
+            return stepBuilder;
+        }
+
         public IStepBuilder<TData, TStepBody> Do(Action<IWorkflowBuilder<TData>> builder)
         {
             builder.Invoke(WorkflowBuilder);

src/WorkflowCore/Services/WorkflowExecutor.cs

@@ -152,6 +152,7 @@ public WorkflowExecutorResult Execute(WorkflowInstance workflow, WorkflowOptions
 
         private void ProcessExecutionResult(WorkflowInstance workflow, WorkflowDefinition def, ExecutionPointer pointer, WorkflowStep step, ExecutionResult result)
         {
+            //TODO: refactor this into it's own class
             pointer.PersistenceData = result.PersistenceData;
             if (result.SleepFor.HasValue)
                 pointer.SleepUntil = DateTime.Now.ToUniversalTime().Add(result.SleepFor.Value);