[incubator-kie-issues-861] Process instance migration (apache#2005)

* [incubator-kie-issues-916] Process Instance Migration

apps-integration-tests/integration-tests-data-index-service/integration-tests-data-index-service-common/src/test/java/org/kie/kogito/index/AbstractProcessDataIndexIT.java

@@ -308,10 +308,10 @@ public void testProcessGatewayAPI() throws IOException {
                         .statusCode(200)
                         .body("data.ProcessInstances[0].nodeDefinitions", notNullValue())
                         .body("data.ProcessInstances[0].nodeDefinitions.size()", is(4))
-                        .body("data.ProcessInstances[0].nodeDefinitions[0].id", is("1"))
+                        .body("data.ProcessInstances[0].nodeDefinitions[0].id", is("_8B62D3CA-5D03-4B2B-832B-126469288BB4"))
                         .body("data.ProcessInstances[0].nodeDefinitions[0].name", is("First Line Approval"))
                         .body("data.ProcessInstances[0].nodeDefinitions[0].type", is("HumanTaskNode"))
-                        .body("data.ProcessInstances[0].nodeDefinitions[0].uniqueId", is("1"))
+                        .body("data.ProcessInstances[0].nodeDefinitions[0].uniqueId", is("_8B62D3CA-5D03-4B2B-832B-126469288BB4"))
                         .body("data.ProcessInstances[0].nodeDefinitions[0].metadata.UniqueId", is("_8B62D3CA-5D03-4B2B-832B-126469288BB4"))
                         .body("data.ProcessInstances[0].nodes.size()", is(2))
                         .body("data.ProcessInstances[0].nodes.name", hasItem("First Line Approval"))

data-audit/kogito-addons-data-audit-jpa/kogito-addons-data-audit-jpa-common/src/main/java/org/kie/kogito/app/audit/jpa/JPADataAuditStore.java

@@ -56,6 +56,7 @@
 import org.kie.kogito.event.process.ProcessInstanceNodeEventBody;
 import org.kie.kogito.event.process.ProcessInstanceSLADataEvent;
 import org.kie.kogito.event.process.ProcessInstanceStateDataEvent;
+import org.kie.kogito.event.process.ProcessInstanceStateEventBody;
 import org.kie.kogito.event.process.ProcessInstanceVariableDataEvent;
 import org.kie.kogito.event.usertask.UserTaskInstanceAssignmentDataEvent;
 import org.kie.kogito.event.usertask.UserTaskInstanceAttachmentDataEvent;
@@ -64,7 +65,6 @@
 import org.kie.kogito.event.usertask.UserTaskInstanceDeadlineDataEvent;
 import org.kie.kogito.event.usertask.UserTaskInstanceStateDataEvent;
 import org.kie.kogito.event.usertask.UserTaskInstanceVariableDataEvent;
-import org.kie.kogito.internal.process.runtime.KogitoProcessInstance;
 import org.kie.kogito.jobs.service.model.ScheduledJob;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -95,29 +95,17 @@ public void storeProcessInstanceDataEvent(DataAuditContext context, ProcessInsta
         log.setRoles(event.getData().getRoles());
 
         EntityManager entityManager = context.getContext();
-        switch (event.getData().getState()) {
-            case KogitoProcessInstance.STATE_ACTIVE:
+        switch (event.getData().getEventType()) {
+            case ProcessInstanceStateEventBody.EVENT_TYPE_STARTED:
                 log.setEventType(ProcessStateLogType.ACTIVE);
                 entityManager.persist(log);
                 break;
-            case KogitoProcessInstance.STATE_ABORTED:
-                log.setEventType(ProcessStateLogType.ABORTED);
-                entityManager.persist(log);
-                break;
-            case KogitoProcessInstance.STATE_COMPLETED:
+            case ProcessInstanceStateEventBody.EVENT_TYPE_ENDED:
                 log.setEventType(ProcessStateLogType.COMPLETED);
                 entityManager.persist(log);
                 break;
-            case KogitoProcessInstance.STATE_PENDING:
-                log.setEventType(ProcessStateLogType.PENDING);
-                entityManager.persist(log);
-                break;
-            case KogitoProcessInstance.STATE_SUSPENDED:
-                log.setEventType(ProcessStateLogType.SUSPENDING);
-                entityManager.persist(log);
-                break;
-            case KogitoProcessInstance.STATE_ERROR:
-                log.setEventType(ProcessStateLogType.ERROR);
+            case ProcessInstanceStateEventBody.EVENT_TYPE_MIGRATED:
+                log.setEventType(ProcessStateLogType.MIGRATED);
                 entityManager.persist(log);
                 break;
         }

data-audit/kogito-addons-data-audit-jpa/kogito-addons-data-audit-jpa-common/src/main/java/org/kie/kogito/app/audit/jpa/model/ProcessInstanceStateLog.java

@@ -52,13 +52,9 @@ public class ProcessInstanceStateLog extends AbstractProcessInstanceLog {
 
     public enum ProcessStateLogType {
         ACTIVE,
-        STARTED,
         COMPLETED,
-        ABORTED,
+        MIGRATED,
         SLA_VIOLATION,
-        PENDING,
-        SUSPENDING,
-        ERROR
     }
 
     @Id

data-audit/kogito-addons-data-audit-jpa/kogito-addons-data-audit-jpa-common/src/main/resources/db/data-audit/h2/V1.2.0__Add migration event type.sql

@@ -0,0 +1,2 @@
+ALTER TABLE Process_Instance_State_Log DROP CONSTRAINT Process_Instance_State_Log_event_type_check;
+ALTER TABLE Process_Instance_State_Log ADD CONSTRAINT Process_Instance_State_Log_event_type_check CHECK (event_type IN ( 'ACTIVE','COMPLETED','SLA_VIOLATION', 'MIGRATED' ));

data-audit/kogito-addons-data-audit-jpa/kogito-addons-data-audit-jpa-common/src/main/resources/db/data-audit/postgresql/V1.2.0__Add migration event type.sql

@@ -0,0 +1,2 @@
+ALTER TABLE Process_Instance_State_Log DROP CONSTRAINT Process_Instance_State_Log_event_type_check;
+ALTER TABLE Process_Instance_State_Log ADD CONSTRAINT Process_Instance_State_Log_event_type_check CHECK (event_type IN ( 'ACTIVE','COMPLETED','SLA_VIOLATION', 'MIGRATED' ));

data-index/kogito-addons-quarkus-data-index-persistence/kogito-addons-quarkus-data-index-persistence-common/runtime/src/main/java/org/kie/kogito/index/addon/api/KogitoAddonRuntimeClientImpl.java

@@ -157,7 +157,7 @@ public CompletableFuture<List<Node>> getProcessDefinitionNodes(String serviceURL
             List<org.kie.api.definition.process.Node> nodes = ((KogitoWorkflowProcess) ((AbstractProcess<?>) process).get()).getNodesRecursively();
             List<Node> list = nodes.stream().map(n -> {
                 Node data = new Node();
-                data.setId(String.valueOf(n.getId()));
+                data.setId(n.getId().toExternalFormat());
                 data.setUniqueId(((org.jbpm.workflow.core.Node) n).getUniqueId());
                 data.setMetadata(n.getMetaData() == null ? null : mapMetadata(n));
                 data.setType(n.getClass().getSimpleName());

data-index/kogito-addons-quarkus-data-index-persistence/kogito-addons-quarkus-data-index-persistence-infinispan/integration-tests-process/src/test/java/org/kie/kogito/addons/quarkus/data/index/it/InfinispanQuarkusAddonDataIndexPersistenceIT.java

@@ -63,10 +63,10 @@ void testDataIndexAddon() {
                 .body("data.ProcessDefinitions[0].addons", hasItem("infinispan-persistence"))
                 .body("data.ProcessDefinitions[0].source", is(not(emptyOrNullString())))
                 .body("data.ProcessDefinitions[0].nodes.size()", is(2))
-                .body("data.ProcessDefinitions[0].nodes[0].id", is("1"))
+                .body("data.ProcessDefinitions[0].nodes[0].id", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"))
                 .body("data.ProcessDefinitions[0].nodes[0].name", is("End"))
                 .body("data.ProcessDefinitions[0].nodes[0].type", is("EndNode"))
-                .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("1"))
+                .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"))
                 .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"));
 
         given().contentType(ContentType.JSON)

data-index/kogito-addons-quarkus-data-index-persistence/kogito-addons-quarkus-data-index-persistence-infinispan/integration-tests-sw/src/test/java/org/kie/kogito/addons/quarkus/data/index/it/InfinispanQuarkusAddonDataIndexPersistenceIT.java

@@ -68,7 +68,7 @@ void testDataIndexAddon() {
                 .body("data.ProcessDefinitions[0].nodes[0].name", is("Start"))
                 .body("data.ProcessDefinitions[0].nodes[0].type", is("StartNode"))
                 .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("1"))
-                .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("_jbpm-unique-0"))
+                .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("1"))
                 .extract().path("data.ProcessDefinitions[0].source");
 
         assertThat(JsonPath.from(source).getString("id")).isEqualTo("greet");

data-index/kogito-addons-quarkus-data-index-persistence/kogito-addons-quarkus-data-index-persistence-mongodb/integration-tests-process/src/test/java/org/kie/kogito/addons/quarkus/data/index/it/MongoQuarkusAddonDataIndexPersistenceIT.java

@@ -63,10 +63,10 @@ void testDataIndexAddon() {
                 .body("data.ProcessDefinitions[0].addons", hasItem("mongodb-persistence"))
                 .body("data.ProcessDefinitions[0].source", is(not(emptyOrNullString())))
                 .body("data.ProcessDefinitions[0].nodes.size()", is(2))
-                .body("data.ProcessDefinitions[0].nodes[0].id", is("1"))
+                .body("data.ProcessDefinitions[0].nodes[0].id", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"))
                 .body("data.ProcessDefinitions[0].nodes[0].name", is("End"))
                 .body("data.ProcessDefinitions[0].nodes[0].type", is("EndNode"))
-                .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("1"))
+                .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"))
                 .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"));
 
         given().contentType(ContentType.JSON)

data-index/kogito-addons-quarkus-data-index-persistence/kogito-addons-quarkus-data-index-persistence-mongodb/integration-tests-sw/src/test/java/org/kie/kogito/addons/quarkus/data/index/it/MongoQuarkusAddonDataIndexPersistenceIT.java

@@ -68,7 +68,7 @@ void testDataIndexAddon() {
                 .body("data.ProcessDefinitions[0].nodes[0].name", is("Start"))
                 .body("data.ProcessDefinitions[0].nodes[0].type", is("StartNode"))
                 .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("1"))
-                .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("_jbpm-unique-0"))
+                .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("1"))
                 .extract().path("data.ProcessDefinitions[0].source");
 
         assertThat(JsonPath.from(source).getString("id")).isEqualTo("greet");

data-index/kogito-addons-quarkus-data-index-persistence/kogito-addons-quarkus-data-index-persistence-postgresql/integration-tests-process/src/test/java/org/kie/kogito/addons/quarkus/data/index/it/PostgreSQLQuarkusAddonDataIndexPersistenceIT.java

@@ -67,10 +67,10 @@ void testDataIndexAddon() {
                 .body("data.ProcessDefinitions[0].addons", hasItem("jdbc-persistence"))
                 .body("data.ProcessDefinitions[0].source", is(not(emptyOrNullString())))
                 .body("data.ProcessDefinitions[0].nodes.size()", is(2))
-                .body("data.ProcessDefinitions[0].nodes[0].id", is("1"))
+                .body("data.ProcessDefinitions[0].nodes[0].id", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"))
                 .body("data.ProcessDefinitions[0].nodes[0].name", is("End"))
                 .body("data.ProcessDefinitions[0].nodes[0].type", is("EndNode"))
-                .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("1"))
+                .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"))
                 .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("_B3241ACF-97BE-443B-A49F-964AB3DD006C"));
 
         given().contentType(ContentType.JSON)

data-index/kogito-addons-quarkus-data-index-persistence/kogito-addons-quarkus-data-index-persistence-postgresql/integration-tests-sw/src/test/java/org/kie/kogito/addons/quarkus/data/index/it/PostgreSQLQuarkusAddonDataIndexPersistenceIT.java

@@ -74,7 +74,7 @@ void testDataIndexAddon() {
                 .body("data.ProcessDefinitions[0].nodes[0].name", is("Start"))
                 .body("data.ProcessDefinitions[0].nodes[0].type", is("StartNode"))
                 .body("data.ProcessDefinitions[0].nodes[0].uniqueId", is("1"))
-                .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("_jbpm-unique-0"))
+                .body("data.ProcessDefinitions[0].nodes[0].metadata.UniqueId", is("1"))
                 .extract().path("data.ProcessDefinitions[0].source");
 
         assertThat(JsonPath.from(source).getString("id")).isEqualTo("greet");

jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/EmbeddedJobExecutor.java

@@ -18,6 +18,8 @@
  */
 package org.kie.kogito.jobs.embedded;
 
+import java.util.Optional;
+
 import org.kie.kogito.Application;
 import org.kie.kogito.Model;
 import org.kie.kogito.jobs.service.api.Recipient;
@@ -53,12 +55,21 @@ public Uni<JobExecutionResponse> execute(JobDetails jobDetails) {
         RecipientInstance recipientModel = (RecipientInstance) jobDetails.getRecipient();
         InVMRecipient recipient = (InVMRecipient) recipientModel.getRecipient();
         String timerId = recipient.getPayload().getData().timerId();
-        String processId = recipient.getPayload().getData().processId();
-        Process<? extends Model> process = processes.processById(processId);
         String processInstanceId = recipient.getPayload().getData().processInstanceId();
+        Optional<Process<? extends Model>> process = processes.processByProcessInstanceId(processInstanceId);
+        if (process.isEmpty()) {
+            return Uni.createFrom().item(
+                    JobExecutionResponse.builder()
+                            .code("401")
+                            .jobId(jobDetails.getId())
+                            .now()
+                            .message("job does not belong to this container")
+                            .build());
+        }
+
         Integer limit = jobDetails.getRetries();
 
-        TriggerJobCommand command = new TriggerJobCommand(processInstanceId, correlationId, timerId, limit, process, application.unitOfWorkManager());
+        TriggerJobCommand command = new TriggerJobCommand(processInstanceId, correlationId, timerId, limit, process.get(), application.unitOfWorkManager());
 
         return Uni.createFrom().item(command::execute)
                 .onFailure()

pom.xml

@@ -22,6 +22,7 @@
 <project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 
+
   <modelVersion>4.0.0</modelVersion>
 
   <parent>