Deleted ErrorOutputComponentGenerator and moved create method to ProcessError class

Author: jaboehri

src/main/java/dev/dsf/bpe/ProcessError.java

@@ -1,11 +1,15 @@
 package dev.dsf.bpe;
 
 import java.io.Serializable;
+import java.util.List;
 import java.util.Objects;
+import java.util.stream.Collectors;
 
+import org.hl7.fhir.r4.model.CodeType;
 import org.hl7.fhir.r4.model.Coding;
 import org.hl7.fhir.r4.model.Extension;
 import org.hl7.fhir.r4.model.StringType;
+import org.hl7.fhir.r4.model.Task;
 import org.hl7.fhir.r4.model.UrlType;
 
 //todo: remove process and processStep + CodeSystems, make message never contain e.getMessage() becaus security
@@ -70,4 +74,26 @@ public static ProcessError toError(Extension extension)
 
 		return new ProcessError(processCode, stepCode, action, potentialFixUrl, message);
 	}
+
+	public static List<Task.TaskOutputComponent> toTaskOutput(List<ProcessError> errors)
+	{
+		if (errors == null || errors.isEmpty())
+			return List.of();
+		return errors.stream().map(ProcessError::toTaskOutput).collect(Collectors.toList());
+	}
+
+	public static Task.TaskOutputComponent toTaskOutput(ProcessError error)
+	{
+		Task.TaskOutputComponent param = new Task.TaskOutputComponent();
+
+		param.getType().addCoding(new Coding(CodeSystem.DsfPing.URL, CodeSystem.DsfPing.Code.ERROR.getValue(), null));
+		param.addExtension(ProcessError.toExtension(error));
+		Extension dataAbsentReason = new Extension()
+				.setUrl("http://hl7.org/fhir/StructureDefinition/data-absent-reason")
+				.setValue(new CodeType("not-applicable"));
+		param.setValue(new StringType());
+		param.getValue().addExtension(dataAbsentReason);
+
+		return param;
+	}
 }

src/main/java/dev/dsf/bpe/service/ping/StoreResults.java

@@ -22,7 +22,6 @@
 import dev.dsf.bpe.mail.AggregateErrorMailService;
 import dev.dsf.bpe.util.ErrorListUtils;
 import dev.dsf.bpe.util.task.NetworkSpeedCalculator;
-import dev.dsf.bpe.util.task.output.generator.ErrorOutputComponentGenerator;
 import dev.dsf.bpe.util.task.output.generator.PingStatusGenerator;
 import dev.dsf.bpe.v1.ProcessPluginApi;
 import dev.dsf.bpe.v1.activity.AbstractServiceDelegate;
@@ -61,8 +60,7 @@ protected void doExecute(DelegateExecution execution, Variables variables) throw
 		Targets targets = variables.getTargets();
 		Map<Target, List<ProcessError>> errorsPerTarget = new HashMap<>();
 
-		ErrorOutputComponentGenerator.create(ErrorListUtils.getErrorList(execution).getEntries())
-				.forEach(task::addOutput);
+		ProcessError.toTaskOutput(ErrorListUtils.getErrorList(execution).getEntries()).forEach(task::addOutput);
 
 		targets.getEntries().stream().sorted(Comparator.comparing(Target::getEndpointIdentifierValue)).forEach(target ->
 		{