Additional tests

ElemarJR · Jul 27, 2018 · 02c318b · 02c318b
1 parent e901bed
commit 02c318b
Show file tree

Hide file tree

Showing 2 changed files with 41 additions and 2 deletions.
diff --git a/src/TheFlow/CoreConcepts/Token.cs b/src/TheFlow/CoreConcepts/Token.cs
@@ -36,7 +36,7 @@ public Token AllocateChild()
                 throw new InvalidOperationException("AllocationChild is not allowed after releasing.");
             }
 
-            var allocateChild = new Token(
+                var allocateChild = new Token(
                 Id,
                 Guid.NewGuid(),
                 ExecutionPoint

diff --git a/test/TheFlow.Tests/Functional/RunningTwoPathsInParallel.cs b/test/TheFlow.Tests/Functional/RunningTwoPathsInParallel.cs
@@ -44,7 +44,7 @@ public void ActivitiesRanInTheRightSequence()
         }
 
         [Fact]
-        public void ReturnTwoTokensWhenThereIsAnEventHandlerInOneOfThePaths()
+        public void ReturnTwoTokensWhenThereAreEventHandlersInBothPaths()
         {
             var model = ProcessModel.Create()
                 .AddEventCatcher("start")
@@ -70,5 +70,44 @@ public void ReturnTwoTokensWhenThereIsAnEventHandlerInOneOfThePaths()
             var result = manager.HandleEvent(null);
             result.FirstOrDefault().AffectedTokens.Count().Should().Be(2);
         }
+
+        [Fact]
+        public void ReturnOneTokenWhenThereIsAnEventHandlerInOneOfThePaths()
+        {
+            var model = ProcessModel.Create()
+                .AddEventCatcher("start")
+                .AddActivity("msgBefore", () => { })
+                .AddParallelGateway("split")
+                .AddSequenceFlow("start", "msgBefore", "split")
+                .AddActivity("msgLeft", () => { })
+                .AddEventCatcher("evtLeft")
+                .AddActivity("msgRight", () => { })
+                .AddParallelGateway("join")
+                .AddSequenceFlow("split", "msgLeft", "evtLeft", "join")
+                .AddSequenceFlow("split", "msgRight", "join")
+                .AddActivity("msgAfter", () => { })
+                .AddEventThrower("end")
+                .AddSequenceFlow("join", "msgAfter", "end");
+
+            var models = new InMemoryProcessModelsStore(model);
+            var instances = new InMemoryProcessInstancesStore();
+
+            var manager = new ProcessManager(models, instances);
+
+            var results = manager.HandleEvent(null).ToArray();
+            results.Length.Should().Be(1);
+
+            var result = results[0];
+            var affectedTokens = result.AffectedTokens.ToArray();
+
+            affectedTokens.Length.Should().Be(1);
+
+            result = manager
+                .HandleEvent(result.ProcessInstanceId, affectedTokens[0], null);
+            //.AffectedTokens.
+
+            var instance = manager.InstancesStore.GetById(result.ProcessInstanceId);
+            instance.IsDone.Should().BeTrue();
+        }
     }
 }