Ticket #9 : Manage concurrency

Author: Thierry Habart

src/CaseManagement.BPMN/ProcessInstance/Processors/BPMNEndEventProcessor.cs

@@ -9,7 +9,7 @@ namespace CaseManagement.BPMN.ProcessInstance.Processors
 {
     public class BPMNEndEventProcessor : IProcessFlowElementProcessor
     {
-        public Type ProcessFlowElementType => typeof(BPMNEndEvent);
+        public string ProcessFlowElementType => "";
 
         public Task Handle(WorkflowHandlerContext context, CancellationToken token)
         {

src/CaseManagement.BPMN/ProcessInstance/Processors/BPMNReceiveTaskProcessor.cs

@@ -8,7 +8,7 @@ namespace CaseManagement.BPMN.ProcessInstance.Processors
 {
     public class BPMNReceiveTaskProcessor : IProcessFlowElementProcessor
     {
-        public Type ProcessFlowElementType { get => typeof(BPMNReceiveTask); }
+        public string ProcessFlowElementType => "";
 
         public Task Handle(WorkflowHandlerContext context, CancellationToken token)
         {

src/CaseManagement.BPMN/ProcessInstance/Processors/BPMNServiceTaskProcessor.cs

@@ -8,7 +8,7 @@ namespace CaseManagement.BPMN.ProcessInstance.Processors
 {
     public class BPMNServiceTaskProcessor : IProcessFlowElementProcessor
     {
-        public Type ProcessFlowElementType => typeof(BPMNServiceTask);
+        public string ProcessFlowElementType => "";
 
         public Task Handle(WorkflowHandlerContext context, CancellationToken token)
         {

src/CaseManagement.BPMN/ProcessInstance/Processors/BPMNStartEventProcessor.cs

@@ -8,7 +8,7 @@ namespace CaseManagement.BPMN.ProcessInstance.Processors
 {
     public class BPMNStartEventProcessor : IProcessFlowElementProcessor
     {
-        public Type ProcessFlowElementType => typeof(BPMNStartEvent);
+        public string ProcessFlowElementType => "";
 
         public Task Handle(WorkflowHandlerContext context, CancellationToken token)
         {

src/CaseManagement.BPMN/ProcessInstance/Processors/BPMNTaskProcessor.cs

@@ -8,7 +8,7 @@ namespace CaseManagement.BPMN.ProcessInstance.Processors
 {
     public class BPMNTaskProcessor : IProcessFlowElementProcessor
     {
-        public Type ProcessFlowElementType => typeof(BPMNTask);
+        public string ProcessFlowElementType => "";
 
         public Task Handle(WorkflowHandlerContext context, CancellationToken token)
         {

src/CaseManagement.CMMN/Builders/CMMNHumanTaskBuilder.cs

@@ -2,15 +2,29 @@
 
 namespace CaseManagement.CMMN.Builders
 {
-    public class CMMNHumanTaskBuilder : CMMNTaskBuilder
+    public class CMMNHumanTaskBuilder : CMMNPlanItemBuilder
     {
         public CMMNHumanTaskBuilder(CMMNPlanItem planItem) : base(planItem)
         {
         }
 
+        public CMMNHumanTaskBuilder SetIsBlocking(bool isBlocking)
+        {
+            var cmmnTask = PlanItem.PlanItemDefinitionHumanTask;
+            cmmnTask.IsBlocking = isBlocking;
+            return this;
+        }
+
+        public CMMNHumanTaskBuilder SetState(CMMNTaskStates state)
+        {
+            var cmmnTask = PlanItem.PlanItemDefinitionHumanTask;
+            cmmnTask.State = state;
+            return this;
+        }
+
         public CMMNHumanTaskBuilder SetFormId(string formId)
         {
-            var cmmnTask = (CMMNHumanTask)PlanItem.PlanItemDefinition;
+            var cmmnTask = PlanItem.PlanItemDefinitionHumanTask;
             cmmnTask.FormId = formId;
             return this;
         }

src/CaseManagement.CMMN/Builders/CMMNPlanItemBuilder.cs

@@ -33,7 +33,7 @@ public CMMNPlanItemBuilder AddExitCriterion(string name, Action<CMMNSEntryBuilde
         public CMMNPlanItemBuilder SetManualActivationRule(string name, CMMNExpression expression)
         {
             var manualActivationRule = new CMMNManualActivationRule(name, expression);
-            PlanItem.PlanItemControl = manualActivationRule;
+            PlanItem.SetManualActivationRule(manualActivationRule);
             return this;
         }
     }

src/CaseManagement.CMMN/Builders/CMMNProcessFlowInstanceBuilder.cs

@@ -0,0 +1,61 @@
+using CaseManagement.CMMN.Domains;
+using CaseManagement.Workflow.Builders;
+using CaseManagement.Workflow.Domains;
+using System;
+using System.Linq;
+
+namespace CaseManagement.CMMN.Builders
+{
+    public class CMMNProcessFlowInstanceBuilder : ProcessFlowInstanceBuilder
+    {
+        private CMMNProcessFlowInstanceBuilder(string processFlowTemplateId, string processFlowName) : base(processFlowTemplateId, processFlowName) { }
+
+        public override ProcessFlowInstanceBuilder AddElement(ProcessFlowInstanceElement node)
+        {
+            return base.AddElement(node);
+        }
+
+        public CMMNProcessFlowInstanceBuilder AddCMMNTask(string id, string name, Action<CMMNTaskBuilder> callback)
+        {
+            var planItemDef = new CMMNTask(name);
+            var processTask = CMMNPlanItem.New(id, name, planItemDef);
+            callback(new CMMNTaskBuilder(processTask));
+            AddElement(processTask);
+            return this;
+        }
+
+        public CMMNProcessFlowInstanceBuilder AddCMMNHumanTask(string id, string name, Action<CMMNHumanTaskBuilder> callback)
+        {
+            var planItemDef = new CMMNHumanTask(name);
+            var humanTask = CMMNPlanItem.New(id, name, planItemDef);
+            callback(new CMMNHumanTaskBuilder(humanTask));
+            AddElement(humanTask);
+            return this;
+        }
+
+        public CMMNProcessFlowInstanceBuilder AddCMMNProcessTask(string id, string name, Action<CMMNProcessTaskBuilder> callback)
+        {
+            var planItemDef = new CMMNProcessTask(name);
+            var processTask = CMMNPlanItem.New(id, name, planItemDef);
+            callback(new CMMNProcessTaskBuilder(processTask));
+            AddElement(processTask);
+            return this;
+        }
+
+        public CMMNProcessFlowInstanceBuilder AddPlanItem(CMMNPlanItem planItem)
+        {
+            AddElement(planItem);
+            return this;
+        }
+
+        public override ProcessFlowInstance Build()
+        {
+            return CMMNProcessFlowInstance.NewCMMNProcess(ProcessFlowTemplateId, ProcessFlowName, Elements.Cast<CMMNPlanItem>().ToList(), Connectors);
+        }
+
+        public static new CMMNProcessFlowInstanceBuilder New(string processFlowTemplateId, string processFlowName)
+        {
+            return new CMMNProcessFlowInstanceBuilder(processFlowTemplateId, processFlowName);
+        }
+    }
+}

src/CaseManagement.CMMN/Builders/CMMNProcessTaskBuilder.cs

@@ -2,22 +2,36 @@
 
 namespace CaseManagement.CMMN.Builders
 {
-    public class CMMNProcessTaskBuilder : CMMNTaskBuilder
+    public class CMMNProcessTaskBuilder : CMMNPlanItemBuilder
     {
         public CMMNProcessTaskBuilder(CMMNPlanItem planItem) : base(planItem)
         {
         }
 
+        public CMMNProcessTaskBuilder SetIsBlocking(bool isBlocking)
+        {
+            var cmmnTask = PlanItem.PlanItemDefinitionProcessTask;
+            cmmnTask.IsBlocking = isBlocking;
+            return this;
+        }
+
+        public CMMNProcessTaskBuilder SetState(CMMNTaskStates state)
+        {
+            var cmmnTask = PlanItem.PlanItemDefinitionProcessTask;
+            cmmnTask.State = state;
+            return this;
+        }
+
         public CMMNProcessTaskBuilder SetProcessRef(string processRef)
         {
-            var cmmnTask = (CMMNProcessTask)PlanItem.PlanItemDefinition;
+            var cmmnTask = PlanItem.PlanItemDefinitionProcessTask;
             cmmnTask.ProcessRef = processRef;
             return this;
         }
 
         public CMMNProcessTaskBuilder AddMapping(string sourceRef, string targetRef)
         {
-            var cmmnTask = (CMMNProcessTask)PlanItem.PlanItemDefinition;
+            var cmmnTask = PlanItem.PlanItemDefinitionProcessTask;
             cmmnTask.Mappings.Add(new CMMNParameterMapping
             {
                 SourceRef = new CMMNParameter { Name = sourceRef },

src/CaseManagement.CMMN/Builders/CMMNTaskBuilder.cs

@@ -10,14 +10,14 @@ public CMMNTaskBuilder(CMMNPlanItem planItem) : base(planItem)
 
         public CMMNTaskBuilder SetIsBlocking(bool isBlocking)
         {
-            var cmmnTask = (CMMNTask)PlanItem.PlanItemDefinition;
+            var cmmnTask = PlanItem.PlanItemDefinitionTask;
             cmmnTask.IsBlocking = isBlocking;
             return this;
         }
 
         public CMMNTaskBuilder SetState(CMMNTaskStates state)
         {
-            var cmmnTask = (CMMNTask)PlanItem.PlanItemDefinition;
+            var cmmnTask = PlanItem.PlanItemDefinitionTask;
             cmmnTask.State = state;
             return this;
         }