added DSF MailService impl for validation errors and failed processes

Auto generated mails include a links to the Task resource that started
the process instance. Mails for validation errors and failed processes
can be enabled by corresponding config variables.

Fixed wrong logData...Failed method called by the LogError classes of
the send and translate processes.

Author: hhund

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

@@ -1,41 +1,90 @@
 package de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.logging;
 
+import java.util.Objects;
+
+import org.highmed.dsf.bpe.service.MailService;
 import org.hl7.fhir.r4.model.IdType;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.InitializingBean;
 
-public class ErrorLogger
+public class ErrorLogger implements InitializingBean
 {
 	private static final Logger validationLogger = LoggerFactory.getLogger("validation-error-logger");
 	private static final Logger errorLogger = LoggerFactory.getLogger("error-logger");
 
+	private final MailService mailService;
+
+	private final boolean sendValidationFailedMail;
+	private final boolean sendProcessFailedMail;
+
+	public ErrorLogger(MailService mailService, boolean sendValidationFailedMail, boolean sendProcessFailedMail)
+	{
+		this.mailService = mailService;
+
+		this.sendValidationFailedMail = sendValidationFailedMail;
+		this.sendProcessFailedMail = sendProcessFailedMail;
+	}
+
+	@Override
+	public void afterPropertiesSet() throws Exception
+	{
+		Objects.requireNonNull(mailService, "mailService");
+	}
+
 	public void logValidationFailed(IdType taskId)
 	{
-		validationLogger.debug("Validation of FHIR resources failed, started by Task {}", taskId.getValue());
+		validationLogger.debug("Validation of FHIR resources failed in process started by {}",
+				taskId.toVersionless().getValue());
+
+		if (sendValidationFailedMail)
+			mailService.send("Validation Error",
+					"Validation of FHIR resources failed in process started by " + taskId.toVersionless().getValue());
 	}
 
 	public void logValidationFailedLocal(IdType taskId)
 	{
-		validationLogger.debug("Local validation of FHIR resources failed, started by Task {}", taskId.getValue());
+		validationLogger.debug("Local validation of FHIR resources failed in process started by {}",
+				taskId.toVersionless().getValue());
+
+		if (sendValidationFailedMail)
+			mailService.send("Validation Error", "Local validation of FHIR resources failed in process started by "
+					+ taskId.toVersionless().getValue());
 	}
 
 	public void logValidationFailedRemote(IdType taskId)
 	{
-		validationLogger.debug("Remote validation of FHIR resources failed, started by Task {}", taskId.getValue());
+		validationLogger.debug("Remote validation of FHIR resources failed in process started by {}",
+				taskId.toVersionless().getValue());
+
+		if (sendValidationFailedMail)
+			mailService.send("Validation Error", "Remote validation of FHIR resources failed in process started by "
+					+ taskId.toVersionless().getValue());
 	}
 
 	public void logDataSendFailed(IdType taskId)
 	{
-		errorLogger.debug("Send process failed, started by Task {}", taskId.getValue());
+		errorLogger.debug("Send process failed started by {}", taskId.toVersionless().getValue());
+
+		if (sendProcessFailedMail)
+			mailService.send("Proccess Failed", "Send process failed started by " + taskId.toVersionless().getValue());
 	}
 
 	public void logDataTranslateFailed(IdType taskId)
 	{
-		errorLogger.debug("Translate process failed, started by Task {}", taskId.getValue());
+		errorLogger.debug("Translate process failed started by {}", taskId.toVersionless().getValue());
+
+		if (sendProcessFailedMail)
+			mailService.send("Proccess Failed",
+					"Translate process failed started by " + taskId.toVersionless().getValue());
 	}
 
 	public void logDataReceiveFailed(IdType taskId)
 	{
-		errorLogger.debug("Receive process failed, started by Task {}", taskId.getValue());
+		errorLogger.debug("Receive process failed started by {}", taskId.toVersionless().getValue());
+
+		if (sendProcessFailedMail)
+			mailService.send("Proccess Failed",
+					"Receive process failed started by " + taskId.toVersionless().getValue());
 	}
 }

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/send/LogError.java

@@ -77,7 +77,7 @@ protected void doExecute(DelegateExecution execution) throws BpmnError, Exceptio
 				logger.error("Error while executing process at {}; code: '{}', message: {}", errorSource, errorCode,
 						errorMessage);
 
-			errorLogger.logDataReceiveFailed(getLeadingTaskFromExecutionVariables().getIdElement()
+			errorLogger.logDataSendFailed(getLeadingTaskFromExecutionVariables().getIdElement()
 					.withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name()));
 		}
 

codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/service/translate/LogError.java

@@ -79,7 +79,7 @@ protected void doExecute(DelegateExecution execution) throws BpmnError, Exceptio
 				logger.warn("Error while executing process at {}; code: '{}', message: {}", errorSource, errorCode,
 						errorMessage);
 
-			errorLogger.logDataReceiveFailed(getLeadingTaskFromExecutionVariables().getIdElement()
+			errorLogger.logDataTranslateFailed(getLeadingTaskFromExecutionVariables().getIdElement()
 					.withServerBase(getFhirWebserviceClientProvider().getLocalBaseUrl(), ResourceType.Task.name()));
 		}
 

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

@@ -5,6 +5,7 @@
 import java.nio.file.Paths;
 import java.util.List;
 
+import org.highmed.dsf.bpe.service.MailService;
 import org.highmed.dsf.fhir.authorization.read.ReadAccessHelper;
 import org.highmed.dsf.fhir.client.FhirWebserviceClientProvider;
 import org.highmed.dsf.fhir.organization.EndpointProvider;
@@ -53,6 +54,9 @@ public class TransferDataConfig
 	@Autowired
 	private BundleValidatorFactory bundleValidatorFactory;
 
+	@Autowired
+	private MailService mailService;
+
 	@ProcessDocumentation(description = "PEM encoded file with trusted certificates to validate the server-certificate of the GECCO FHIR server", processNames = {
 			"wwwnetzwerk-universitaetsmedizinde_dataSend",
 			"wwwnetzwerk-universitaetsmedizinde_dataReceive" }, recommendation = "Use docker secret file to configure", example = "/run/secrets/gecco_fhir_server_ca.pem")
@@ -278,6 +282,18 @@ public class TransferDataConfig
 	@Value("${de.netzwerk.universitaetsmedizin.codex.fttp.proxy.password:#{null}}")
 	private String fttpProxyPassword;
 
+	@ProcessDocumentation(description = "To enable mails being send on validation errors, set to 'true'. This requires the SMPT mail service client to be configured in the DSF", processNames = {
+			"wwwnetzwerk-universitaetsmedizinde_dataSend", "wwwnetzwerk-universitaetsmedizinde_dataTranslate",
+			"wwwnetzwerk-universitaetsmedizinde_dataReceive" })
+	@Value("${de.netzwerk.universitaetsmedizin.codex.mail.sendValidationFailedMails:false}")
+	private boolean sendValidationFailedMail;
+
+	@ProcessDocumentation(description = "To enable a mail being send if a 'send', 'translate' or 'receive' process instance fails, set to 'true'. This requires the SMPT mail service client to be configured in the DSF", processNames = {
+			"wwwnetzwerk-universitaetsmedizinde_dataSend", "wwwnetzwerk-universitaetsmedizinde_dataTranslate",
+			"wwwnetzwerk-universitaetsmedizinde_dataReceive" })
+	@Value("${de.netzwerk.universitaetsmedizin.codex.mail.sendProcessFailedMails:false}")
+	private boolean sendProcessFailedMail;
+
 	@Value("${org.highmed.dsf.bpe.fhir.server.organization.identifier.value}")
 	private String localIdentifierValue;
 
@@ -422,6 +438,6 @@ public ErrorOutputParameterGenerator errorOutputParameterGenerator()
 	@Bean
 	public ErrorLogger errorLogger()
 	{
-		return new ErrorLogger();
+		return new ErrorLogger(mailService, sendValidationFailedMail, sendProcessFailedMail);
 	}
 }