content: /*
   * Copyright 2010-2025 Hyland Software, Inc. and its affiliates.
   *
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  package org.activiti.engine.test.bpmn.gateway;
  
  import static org.assertj.core.api.Assertions.assertThat;
  
  import java.util.List;
  import org.activiti.engine.history.HistoricActivityInstance;
  import org.activiti.engine.impl.history.HistoryLevel;
  import org.activiti.engine.impl.test.PluggableActivitiTestCase;
  import org.activiti.engine.runtime.ProcessInstance;
  import org.activiti.engine.task.Task;
  import org.activiti.engine.task.TaskQuery;
  import org.activiti.engine.test.Deployment;
  
  /**
  
   */
  public class ParallelGatewayTest extends PluggableActivitiTestCase {
  
      /**
       * Case where there is a parallel gateway that splits into 3 paths of execution, that are immediately joined, without any wait states in between. In the end, no executions should be in the database.
       */
      @Deployment
      public void testSplitMergeNoWaitstates() {
          ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("forkJoinNoWaitStates");
          assertThat(processInstance.isEnded()).isTrue();
      }
  
      @Deployment
      public void testUnstructuredConcurrencyTwoForks() {
          ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("unstructuredConcurrencyTwoForks");
          assertThat(processInstance.isEnded()).isTrue();
      }
  
      @Deployment
      public void testUnstructuredConcurrencyTwoJoins() {
          ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("unstructuredConcurrencyTwoJoins");
          assertThat(processInstance.isEnded()).isTrue();
      }
  
      @Deployment
      public void testForkFollowedByOnlyEndEvents() {
          ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("forkFollowedByEndEvents");
          assertThat(processInstance.isEnded()).isTrue();
      }
  
      @Deployment
      public void testNestedForksFollowedByEndEvents() {
          ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("nestedForksFollowedByEndEvents");
          assertThat(processInstance.isEnded()).isTrue();
      }
  
      // ACT-482
      @Deployment
      public void testNestedForkJoin() {
          runtimeService.startProcessInstanceByKey("nestedForkJoin");
  
          // After process startm, only task 0 should be active
          TaskQuery query = taskService.createTaskQuery().orderByTaskName().asc();
          List<Task> tasks = query.list();
          assertThat(tasks).hasSize(1);
          assertThat(tasks.get(0).getName()).isEqualTo("Task 0");
  
          // Completing task 0 will create Task A and B
          taskService.complete(tasks.get(0).getId());
          tasks = query.list();
          assertThat(tasks).hasSize(2);
          assertThat(tasks.get(0).getName()).isEqualTo("Task A");
          assertThat(tasks.get(1).getName()).isEqualTo("Task B");
  
          // Completing task A should not trigger any new tasks
          taskService.complete(tasks.get(0).getId());
          tasks = query.list();
          assertThat(tasks).hasSize(1);
          assertThat(tasks.get(0).getName()).isEqualTo("Task B");
  
          // Completing task B creates tasks B1 and B2
          taskService.complete(tasks.get(0).getId());
          tasks = query.list();
          assertThat(tasks).hasSize(2);
          assertThat(tasks.get(0).getName()).isEqualTo("Task B1");
          assertThat(tasks.get(1).getName()).isEqualTo("Task B2");
  
          // Completing B1 and B2 will activate both joins, and process reaches
          // task C
          taskService.complete(tasks.get(0).getId());
          taskService.complete(tasks.get(1).getId());
          tasks = query.list();
          assertThat(tasks).hasSize(1);
          assertThat(tasks.get(0).getName()).isEqualTo("Task C");
      }
  
      /**
       * https://activiti.atlassian.net/browse/ACT-1222
       */
      @Deployment
      public void testReceyclingExecutionWithCallActivity() {
          runtimeService.startProcessInstanceByKey("parent-process");
  
          // After process start we have two tasks, one from the parent and one
          // from the sub process
          TaskQuery query = taskService.createTaskQuery().orderByTaskName().asc();
          List<Task> tasks = query.list();
          assertThat(tasks).hasSize(2);
          assertThat(tasks.get(0).getName()).isEqualTo("Another task");
          assertThat(tasks.get(1).getName()).isEqualTo("Some Task");
  
          // we complete the task from the parent process, the root execution is
          // receycled, the task in the sub process is still there
          taskService.complete(tasks.get(1).getId());
          tasks = query.list();
          assertThat(tasks).hasSize(1);
          assertThat(tasks.get(0).getName()).isEqualTo("Another task");
  
          // we end the task in the sub process and the sub process instance end
          // is propagated to the parent process
          taskService.complete(tasks.get(0).getId());
          assertThat(taskService.createTaskQuery().count()).isEqualTo(0);
  
          // There is a QA config without history, so we cannot work with this:
          // assertThat(1,
          // historyService.createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).finished().count());
      }
  
      // Test to verify ACT-1755
      @Deployment
      public void testHistoryTables() {
          ProcessInstance pi = runtimeService.startProcessInstanceByKey("testHistoryRecords");
  
          List<HistoricActivityInstance> history = historyService
              .createHistoricActivityInstanceQuery()
              .processInstanceId(pi.getId())
              .list();
  
          for (HistoricActivityInstance h : history) {
              if (h.getActivityId().equals("parallelgateway2")) {
                  assertThat(h.getEndTime()).isNotNull();
              }
          }
      }
  
      @Deployment
      public void testAsyncBehavior() {
          ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("async");
          waitForJobExecutorToProcessAllJobs(5000L, 250L);
          assertThat(
              runtimeService.createProcessInstanceQuery().processInstanceId(processInstance.getId()).count()
          ).isEqualTo(0);
      }
  
      /*
       * @Deployment public void testAsyncBehavior() { for (int i = 0; i < 100; i++) { ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("async"); } assertThat(200,
       * managementService.createJobQuery().count()); waitForJobExecutorToProcessAllJobs(120000, 5000); assertThat(managementService.createJobQuery().count()).isEqualTo(0); assertThat(0,
       * runtimeService.createProcessInstanceQuery().count()); }
       */
  
      @Deployment
      public void testHistoricActivityInstanceEndTimes() {
          if (processEngineConfiguration.getHistoryLevel().isAtLeast(HistoryLevel.AUDIT)) {
              runtimeService.startProcessInstanceByKey("nestedForkJoin");
              List<HistoricActivityInstance> historicActivityInstances = historyService
                  .createHistoricActivityInstanceQuery()
                  .list();
              assertThat(historicActivityInstances).hasSize(21);
              for (HistoricActivityInstance historicActivityInstance : historicActivityInstances) {
                  assertThat(historicActivityInstance.getStartTime() != null).isTrue();
                  assertThat(historicActivityInstance.getEndTime() != null).isTrue();
              }
          }
      }
  }
  