reworked trigger process with unique instances based on BPMN signals

The new trigger process implementation uses an event based gateway to
either wait for a timer to fire after 24 hours or a global signal to
abort.
The abort signal is send as the first step of the trigger process to
stop existing instances and based on a stopDataTrigger Task resource.
The new implementation does not require (and actually does not allow) to
specify a business-key via Task resource.
If a stopDataTrigger Task resource is send while the trigger process is
searching for new/changed data, nothing happens. Stopping the trigger
process is only possible while the process is sleeping but than is
stopped immediately.

Author: hhund

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/trigger/StartTimer.java

@@ -7,22 +7,13 @@
 import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.message.StartSendProcess;
 import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.service.trigger.FindNewData;
 import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.service.trigger.SaveLastExportTo;
-import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.service.trigger.StartTimer;
-import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.service.trigger.StopTimer;
 
 @Configuration
 public class TriggerConfig
 {
 	@Autowired
 	private TransferDataConfig transferDataConfig;
 
-	@Bean
-	public StartTimer startTimer()
-	{
-		return new StartTimer(transferDataConfig.fhirClientProvider(), transferDataConfig.taskHelper(),
-				transferDataConfig.readAccessHelper());
-	}
-
 	@Bean
 	public FindNewData findNewData()
 	{
@@ -39,13 +30,6 @@ public StartSendProcess startSendProcess()
 				transferDataConfig.fhirContext());
 	}
 
-	@Bean
-	public StopTimer stopTimer()
-	{
-		return new StopTimer(transferDataConfig.fhirClientProvider(), transferDataConfig.taskHelper(),
-				transferDataConfig.readAccessHelper());
-	}
-
 	@Bean
 	public SaveLastExportTo saveLastExportTo()
 	{

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/trigger/StopTimer.java

@@ -27,8 +27,8 @@
     </element>
     <element id="Task.input">
       <path value="Task.input" />
-      <min value="2" />
-      <max value="3" />
+      <min value="1" />
+      <max value="2" />
     </element>
     <element id="Task.input:message-name">
       <path value="Task.input" />
@@ -41,7 +41,7 @@
     <element id="Task.input:business-key">
       <path value="Task.input" />
       <sliceName value="business-key" />
-      <min value="1" />
+      <max value="0" />
     </element>
     <element id="Task.input:correlation-key">
       <path value="Task.input" />

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/spring/config/TriggerConfig.java

@@ -27,8 +27,8 @@
     </element>
     <element id="Task.input">
       <path value="Task.input" />
-      <min value="2" />
-      <max value="2" />
+      <min value="1" />
+      <max value="1" />
     </element>
     <element id="Task.input:message-name">
       <path value="Task.input" />
@@ -41,7 +41,7 @@
     <element id="Task.input:business-key">
       <path value="Task.input" />
       <sliceName value="business-key" />
-      <min value="1" />
+      <max value="0" />
     </element>
     <element id="Task.input:correlation-key">
       <path value="Task.input" />

codex-process-data-transfer/src/main/resources/bpe/trigger.bpmn

@@ -170,8 +170,6 @@ private Task createValidTaskStartDataTrigger()
 				.setSystem(NAMINGSYSTEM_HIGHMED_ORGANIZATION_IDENTIFIER).setValue("Test_DIC");
 		task.addInput().setValue(new StringType(PROFILE_NUM_CODEX_TASK_START_DATA_TRIGGER_MESSAGE_NAME)).getType()
 				.addCoding().setSystem(CODESYSTEM_HIGHMED_BPMN).setCode(CODESYSTEM_HIGHMED_BPMN_VALUE_MESSAGE_NAME);
-		task.addInput().setValue(new StringType(UUID.randomUUID().toString())).getType().addCoding()
-				.setSystem(CODESYSTEM_HIGHMED_BPMN).setCode(CODESYSTEM_HIGHMED_BPMN_VALUE_BUSINESS_KEY);
 
 		return task;
 	}
@@ -203,8 +201,6 @@ private Task createValidTaskStopDataTrigger()
 				.setSystem(NAMINGSYSTEM_HIGHMED_ORGANIZATION_IDENTIFIER).setValue("Test_DIC");
 		task.addInput().setValue(new StringType(PROFILE_NUM_CODEX_TASK_STOP_DATA_TRIGGER_MESSAGE_NAME)).getType()
 				.addCoding().setSystem(CODESYSTEM_HIGHMED_BPMN).setCode(CODESYSTEM_HIGHMED_BPMN_VALUE_MESSAGE_NAME);
-		task.addInput().setValue(new StringType(UUID.randomUUID().toString())).getType().addCoding()
-				.setSystem(CODESYSTEM_HIGHMED_BPMN).setCode(CODESYSTEM_HIGHMED_BPMN_VALUE_BUSINESS_KEY);
 
 		return task;
 	}

codex-process-data-transfer/src/main/resources/fhir/StructureDefinition/num-codex-task-start-data-trigger.xml

@@ -31,16 +31,6 @@
       </type>
       <valueString value="startDataTrigger"/>
    </input>
-   <input>
-      <type>
-         <coding>
-            <system value="http://highmed.org/fhir/CodeSystem/bpmn-message"/>
-            <code value="business-key"/>
-         </coding>
-      </type>
-      <!-- random business-key UUID, value also used in stop data trigger task, do not use the same value twice -->
-      <valueString value="7f7fd1e7-f10f-4aeb-9ac5-c8be86fab21a"/>
-   </input>
    <!-- optional date specifying what data is defined as 'new', if not defined 
 		every GECCO resource is new and triggers the send process -->
    <!-- <input>

codex-process-data-transfer/src/main/resources/fhir/StructureDefinition/num-codex-task-stop-data-trigger.xml

@@ -31,14 +31,4 @@
       </type>
       <valueString value="stopDataTrigger"/>
    </input>
-   <input>
-      <type>
-         <coding>
-            <system value="http://highmed.org/fhir/CodeSystem/bpmn-message"/>
-            <code value="business-key"/>
-         </coding>
-      </type>
-      <!-- same business-key UUID used to start the data trigger process -->
-      <valueString value="7f7fd1e7-f10f-4aeb-9ac5-c8be86fab21a"/>
-   </input>
 </Task>