Merge remote-tracking branch 'origin/release/0.2.0' into main

Author: hhund

codex-process-data-transfer/pom.xml

@@ -8,7 +8,7 @@
 	<parent>
 		<groupId>de.netzwerk-universitaetsmedizin.codex</groupId>
 		<artifactId>codex-processes-ap1</artifactId>
-		<version>0.1.0</version>
+		<version>0.2.0</version>
 	</parent>
 
 	<properties>

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/ConstantsDataTransfer.java

@@ -7,6 +7,7 @@ public interface ConstantsDataTransfer
 	String BPMN_EXECUTION_VARIABLE_PSEUDONYMS_LIST = "pseudonyms";
 	String BPMN_EXECUTION_VARIABLE_PSEUDONYM = "pseudonym";
 	String BPMN_EXECUTION_VARIABLE_STOP_TIMER = "stopTimer";
+	String BPMN_EXECUTION_VARIABLE_LAST_EXPORT_TO = "lastExportTo";
 	String BPMN_EXECUTION_VARIABLE_EXPORT_FROM = "exportFrom";
 	String BPMN_EXECUTION_VARIABLE_EXPORT_FROM_PRECISION = "exportFromPrecision";
 	String BPMN_EXECUTION_VARIABLE_EXPORT_TO = "exportTo";

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/DataTransferProcessPluginDefinition.java

@@ -16,10 +16,11 @@
 
 import ca.uhn.fhir.context.FhirContext;
 import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.spring.config.TransferDataConfig;
+import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.spring.config.TransferDataSerializerConfig;
 
 public class DataTransferProcessPluginDefinition implements ProcessPluginDefinition
 {
-	public static final String VERSION = "0.1.0";
+	public static final String VERSION = "0.2.0";
 
 	@Override
 	public String getName()
@@ -42,7 +43,7 @@ public Stream<String> getBpmnFiles()
 	@Override
 	public Stream<Class<?>> getSpringConfigClasses()
 	{
-		return Stream.of(TransferDataConfig.class);
+		return Stream.of(TransferDataConfig.class, TransferDataSerializerConfig.class);
 	}
 
 	@Override

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/client/FhirClient.java

@@ -0,0 +1,35 @@
+package de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.client;
+
+import java.util.Date;
+import java.util.stream.Stream;
+
+import org.hl7.fhir.r4.model.Bundle;
+import org.hl7.fhir.r4.model.DomainResource;
+
+import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.domain.DateWithPrecision;
+import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.variables.PseudonymList;
+
+public interface FhirClient
+{
+	/**
+	 * @param exportFrom
+	 *            may be <code>null</code>
+	 * @param exportTo
+	 *            not <code>null</code>
+	 * @return
+	 */
+	PseudonymList getPseudonymsWithNewData(DateWithPrecision exportFrom, Date exportTo);
+
+	/**
+	 * @param pseudonym
+	 *            not <code>null</code>
+	 * @param exportFrom
+	 *            may be <code>null</code>
+	 * @param exportTo
+	 *            not <code>null</code>
+	 * @return
+	 */
+	Stream<DomainResource> getNewData(String pseudonym, DateWithPrecision exportFrom, Date exportTo);
+
+	void storeBundle(Bundle bundle);
+}