#1834 - Service task identifier for subprocesses (#1842)

Created single mocked worker to handle subprocesses mocks. Further details on PR description.
bcgov · Apr 5, 2023 · 2145c5b · 2145c5b
1 parent e7d519c
commit 2145c5b
Show file tree

Hide file tree

Showing 26 changed files with 1,057 additions and 363 deletions.
diff --git a/sources/packages/backend/workflow/BPMN/camunda-8/assessment-gateway.bpmn b/sources/packages/backend/workflow/BPMN/camunda-8/assessment-gateway.bpmn
@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:zeebe="http://camunda.org/schema/zeebe/1.0" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:modeler="http://camunda.org/schema/modeler/1.0" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="5.7.0" modeler:executionPlatform="Camunda Cloud" modeler:executionPlatformVersion="8.1.0" camunda:diagramRelationId="f874f098-96b6-491d-81ec-ecf7a0d8c67a">
+<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:zeebe="http://camunda.org/schema/zeebe/1.0" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:modeler="http://camunda.org/schema/modeler/1.0" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="5.9.0" modeler:executionPlatform="Camunda Cloud" modeler:executionPlatformVersion="8.1.0" camunda:diagramRelationId="f874f098-96b6-491d-81ec-ecf7a0d8c67a">
   <bpmn:collaboration id="Collaboration_0z9wj8q">
     <bpmn:participant id="application-in-progress" name="Assessment" processRef="assessment-gateway" />
     <bpmn:group id="Group_1k2osho" categoryValueRef="CategoryValue_1yy7g02" />
@@ -179,8 +179,10 @@
         <zeebe:calledElement processId="supporting-user-information-request" propagateAllChildVariables="false" />
         <zeebe:ioMapping>
           <zeebe:input source="=createdSupportingUsersIds[1]" target="supportingUserId" />
+          <zeebe:input source="=append(parentSubprocesses, &#34;retrieveSupportingInfoParent1Subprocess&#34;)" target="parentSubprocesses" />
           <zeebe:output source="=supportingUserId" target="parent1SupportingUserId" />
           <zeebe:output source="=totalIncome" target="supportingUserParent1TotalIncome" />
+          <zeebe:output source="=&#34;retrieveSupportingInfoParent1Subprocess&#34;" target="retrieveSupportingInfoParent1Subprocess" />
         </zeebe:ioMapping>
       </bpmn:extensionElements>
       <bpmn:incoming>Flow_1u5ion6</bpmn:incoming>
@@ -191,8 +193,10 @@
         <zeebe:calledElement processId="supporting-user-information-request" propagateAllChildVariables="false" />
         <zeebe:ioMapping>
           <zeebe:input source="=createdSupportingUsersIds[2]" target="supportingUserId" />
+          <zeebe:input source="=append(parentSubprocesses, &#34;retrieveSupportingInfoParent2Subprocess&#34;)" target="parentSubprocesses" />
           <zeebe:output source="=supportingUserId" target="parent2SupportingUserId" />
           <zeebe:output source="=totalIncome" target="parent2TotalIncome" />
+          <zeebe:output source="=&#34;retrieveSupportingInfoParent2Subprocess&#34;" target="retrieveSupportingInfoParent2Subprocess" />
         </zeebe:ioMapping>
       </bpmn:extensionElements>
       <bpmn:incoming>Flow_1lbai2h</bpmn:incoming>
@@ -204,6 +208,8 @@
         <zeebe:ioMapping>
           <zeebe:input source="=parent2TotalIncome" target="reportedIncome" />
           <zeebe:input source="=parent2SupportingUserId" target="supportingUserId" />
+          <zeebe:input source="=append(parentSubprocesses, &#34;parent2IncomeVerificationSubprocess&#34;)" target="parentSubprocesses" />
+          <zeebe:output source="=&#34;parent2IncomeVerificationSubprocess&#34;" target="parent2IncomeVerificationSubprocess" />
         </zeebe:ioMapping>
       </bpmn:extensionElements>
       <bpmn:incoming>Flow_0l30wbo</bpmn:incoming>
@@ -215,6 +221,8 @@
         <zeebe:ioMapping>
           <zeebe:input source="=supportingUserParent1TotalIncome" target="reportedIncome" />
           <zeebe:input source="=parent1SupportingUserId" target="supportingUserId" />
+          <zeebe:input source="=append(parentSubprocesses, &#34;parent1IncomeVerificationSubprocess&#34;)" target="parentSubprocesses" />
+          <zeebe:output source="=&#34;parent1IncomeVerificationSubprocess&#34;" target="parent1IncomeVerificationSubprocess" />
         </zeebe:ioMapping>
       </bpmn:extensionElements>
       <bpmn:incoming>Flow_1g59sq3</bpmn:incoming>
@@ -261,8 +269,10 @@
         <zeebe:calledElement processId="supporting-user-information-request" propagateAllChildVariables="false" />
         <zeebe:ioMapping>
           <zeebe:input source="=createdSupportingUsersIds[1]" target="supportingUserId" />
+          <zeebe:input source="=append(parentSubprocesses, &#34;retrieveSupportingInfoPartnerSubprocess&#34;)" target="parentSubprocesses" />
           <zeebe:output source="=totalIncome" target="partner1TotalIncome" />
           <zeebe:output source="=supportingUserId" target="partnerSupportingUserId" />
+          <zeebe:output source="=&#34;retrieveSupportingInfoPartnerSubprocess&#34;" target="retrieveSupportingInfoPartnerSubprocess" />
         </zeebe:ioMapping>
       </bpmn:extensionElements>
       <bpmn:incoming>Flow_03zfrkx</bpmn:incoming>
@@ -274,6 +284,9 @@
         <zeebe:ioMapping>
           <zeebe:input source="=partner1TotalIncome" target="reportedIncome" />
           <zeebe:input source="=partnerSupportingUserId" target="supportingUserId" />
+          <zeebe:input source="=append(parentSubprocesses, &#34;partnerIncomeVerificationSubprocess&#34;)" target="parentSubprocesses" />
+          <zeebe:output source="=true" target="partnerIncomeVerification" />
+          <zeebe:output source="=&#34;partnerIncomeVerificationSubprocess&#34;" target="partnerIncomeVerificationSubprocess" />
         </zeebe:ioMapping>
       </bpmn:extensionElements>
       <bpmn:incoming>Flow_1wde0bi</bpmn:incoming>
@@ -285,6 +298,8 @@
         <zeebe:ioMapping>
           <zeebe:input source="=studentDataTaxReturnIncome" target="reportedIncome" />
           <zeebe:input source="=null" target="supportingUserId" />
+          <zeebe:input source="=append(parentSubprocesses, &#34;studentIncomeVerificationSubprocess&#34;)" target="parentSubprocesses" />
+          <zeebe:output source="=&#34;studentIncomeVerificationSubprocess&#34;" target="studentIncomeVerificationSubprocess" />
         </zeebe:ioMapping>
       </bpmn:extensionElements>
       <bpmn:incoming>Flow_18qbsu1</bpmn:incoming>
@@ -393,6 +408,7 @@
           <zeebe:output source="=null" target="parent2TotalIncome" />
           <zeebe:output source="=null" target="partner1TotalIncome" />
           <zeebe:output source="=null" target="studentDataTaxReturnIncome" />
+          <zeebe:output source="=[]" target="parentSubprocesses" />
         </zeebe:ioMapping>
       </bpmn:extensionElements>
       <bpmn:outgoing>Flow_1ef3map</bpmn:outgoing>

diff --git a/sources/packages/backend/workflow/BPMN/camunda-8/income-verification.bpmn b/sources/packages/backend/workflow/BPMN/camunda-8/income-verification.bpmn
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:zeebe="http://camunda.org/schema/zeebe/1.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:modeler="http://camunda.org/schema/modeler/1.0" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="5.4.1" modeler:executionPlatform="Camunda Cloud" modeler:executionPlatformVersion="8.1.0" camunda:diagramRelationId="b3bf876c-2be7-42a8-a6ea-299e16ab067a">
+<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:zeebe="http://camunda.org/schema/zeebe/1.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:modeler="http://camunda.org/schema/modeler/1.0" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="5.9.0" modeler:executionPlatform="Camunda Cloud" modeler:executionPlatformVersion="8.1.0" camunda:diagramRelationId="b3bf876c-2be7-42a8-a6ea-299e16ab067a">
   <bpmn:process id="cra-integration-income-verification" name="CRA Integration Income Verification" isExecutable="true">
-    <bpmn:startEvent id="StartEvent_1">
+    <bpmn:startEvent id="cra-integration-income-verification-start-event">
       <bpmn:extensionElements>
         <zeebe:ioMapping>
           <zeebe:output source="=null" target="incomeVerificationId" />
@@ -23,7 +23,7 @@
       <bpmn:incoming>Flow_0d8rkkl</bpmn:incoming>
       <bpmn:outgoing>Flow_19jr8ct</bpmn:outgoing>
     </bpmn:intermediateThrowEvent>
-    <bpmn:sequenceFlow id="Flow_0d8rkkl" sourceRef="StartEvent_1" targetRef="calculate-tax-year-event" />
+    <bpmn:sequenceFlow id="Flow_0d8rkkl" sourceRef="cra-integration-income-verification-start-event" targetRef="calculate-tax-year-event" />
     <bpmn:sequenceFlow id="Flow_19jr8ct" sourceRef="calculate-tax-year-event" targetRef="create-income-request-task" />
     <bpmn:serviceTask id="create-income-request-task" name="Create Income request">
       <bpmn:extensionElements>
@@ -53,9 +53,9 @@
       </bpmn:timerEventDefinition>
     </bpmn:intermediateCatchEvent>
     <bpmn:sequenceFlow id="Flow_1352ogd" sourceRef="Gateway_0sxwbl5" targetRef="cra-income-verified-timer" />
-    <bpmn:sequenceFlow id="Flow_0hhegzg" sourceRef="cra-income-verified-event" targetRef="load-supporting-user-data-task" />
-    <bpmn:sequenceFlow id="Flow_02eq5ax" sourceRef="cra-income-verified-timer" targetRef="load-supporting-user-data-task" />
-    <bpmn:serviceTask id="load-supporting-user-data-task" name="Check income request">
+    <bpmn:sequenceFlow id="Flow_0hhegzg" sourceRef="cra-income-verified-event" targetRef="check-income-request-task" />
+    <bpmn:sequenceFlow id="Flow_02eq5ax" sourceRef="cra-income-verified-timer" targetRef="check-income-request-task" />
+    <bpmn:serviceTask id="check-income-request-task" name="Check income request">
       <bpmn:extensionElements>
         <zeebe:taskDefinition type="check-income-request" />
       </bpmn:extensionElements>
@@ -68,7 +68,7 @@
       <bpmn:outgoing>Flow_0xhsjgf</bpmn:outgoing>
       <bpmn:outgoing>Flow_06vobta</bpmn:outgoing>
     </bpmn:exclusiveGateway>
-    <bpmn:sequenceFlow id="Flow_1echf5j" sourceRef="load-supporting-user-data-task" targetRef="Gateway_0j46aqm" />
+    <bpmn:sequenceFlow id="Flow_1echf5j" sourceRef="check-income-request-task" targetRef="Gateway_0j46aqm" />
     <bpmn:sequenceFlow id="Flow_0xhsjgf" name="Not ready" sourceRef="Gateway_0j46aqm" targetRef="Gateway_0sxwbl5">
       <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">=incomeVerificationCompleted = false</bpmn:conditionExpression>
     </bpmn:sequenceFlow>
@@ -86,7 +86,7 @@
   </bpmn:message>
   <bpmndi:BPMNDiagram id="BPMNDiagram_1">
     <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="cra-integration-income-verification">
-      <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="StartEvent_1">
+      <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="cra-integration-income-verification-start-event">
         <dc:Bounds x="152" y="150" width="36" height="36" />
       </bpmndi:BPMNShape>
       <bpmndi:BPMNShape id="Event_1xmdatx_di" bpmnElement="calculate-tax-year-event">
@@ -111,7 +111,7 @@
           <dc:Bounds x="531" y="235" width="38" height="14" />
         </bpmndi:BPMNLabel>
       </bpmndi:BPMNShape>
-      <bpmndi:BPMNShape id="Activity_103m7ml_di" bpmnElement="load-supporting-user-data-task">
+      <bpmndi:BPMNShape id="Activity_103m7ml_di" bpmnElement="check-income-request-task">
         <dc:Bounds x="620" y="128" width="100" height="80" />
         <bpmndi:BPMNLabel />
       </bpmndi:BPMNShape>
@@ -181,4 +181,4 @@
       </bpmndi:BPMNEdge>
     </bpmndi:BPMNPlane>
   </bpmndi:BPMNDiagram>
-</bpmn:definitions>
+</bpmn:definitions>
diff --git a/...kflow/test/2021-2022/assessment-gateway/assessment-gateway.originalAssessment.e2e-spec.ts b/...kflow/test/2021-2022/assessment-gateway/assessment-gateway.originalAssessment.e2e-spec.ts
diff --git a/...d/workflow/test/2021-2022/assessment-gateway/assessment-gateway.studentAppeal.e2e-spec.ts b/...d/workflow/test/2021-2022/assessment-gateway/assessment-gateway.studentAppeal.e2e-spec.ts
diff --git a/sources/packages/backend/workflow/test/2021-2022/constants/program-year.constants.ts b/sources/packages/backend/workflow/test/2021-2022/constants/program-year.constants.ts