|
41 | 41 | import dev.dsf.bpe.util.task.input.generator.DownloadedBytesGenerator; |
42 | 42 | import dev.dsf.bpe.util.task.input.generator.DownloadedDurationGenerator; |
43 | 43 | import dev.dsf.bpe.util.task.input.generator.ErrorInputComponentGenerator; |
44 | | -import dev.dsf.bpe.util.task.output.generator.ErrorOutputComponentGenerator; |
45 | 44 | import dev.dsf.bpe.util.task.output.generator.PingStatusGenerator; |
46 | 45 | import dev.dsf.bpe.v1.constants.CodeSystems.BpmnMessage; |
47 | 46 | import dev.dsf.bpe.v1.constants.NamingSystems.EndpointIdentifier; |
@@ -203,7 +202,7 @@ public void testTaskStartPingProcessProfileValidWithErrorMessages() |
203 | 202 | { |
204 | 203 | Task task = createValidTaskStartPingProcess(); |
205 | 204 |
|
206 | | - ErrorOutputComponentGenerator.create(processErrors(4)).forEach(task::addOutput); |
| 205 | + ProcessError.toTaskOutput(processErrors(4)).forEach(task::addOutput); |
207 | 206 |
|
208 | 207 | ValidationResult result = resourceValidator.validate(task); |
209 | 208 | ValidationSupportRule.logValidationMessages(logger, result); |
@@ -331,8 +330,8 @@ public String getCorrelationKey() |
331 | 330 | Task task = createValidTaskStartPingProcess(); |
332 | 331 | task.addInput().setValue(new StringType(UUID.randomUUID().toString())).getType() |
333 | 332 | .addCoding(BpmnMessage.businessKey()); |
334 | | - task.addOutput(PingStatusGenerator.createPingStatusOutput(target, CodeSystem.DsfPingStatus.Code.COMPLETED, |
335 | | - BigDecimal.ZERO, BigDecimal.ZERO, CodeSystem.DsfPingUnits.Code.bps)); |
| 333 | + task.addOutput(createPingStatusOutput(target, CodeSystem.DsfPingStatus.Code.COMPLETED, BigDecimal.ZERO, |
| 334 | + BigDecimal.ZERO, CodeSystem.DsfPingUnits.Code.bps)); |
336 | 335 |
|
337 | 336 | ValidationResult result = resourceValidator.validate(task); |
338 | 337 | ValidationSupportRule.logValidationMessages(logger, result); |
@@ -443,7 +442,7 @@ public String getCorrelationKey() |
443 | 442 | } |
444 | 443 | }; |
445 | 444 | Task task = createValidTaskPing(); |
446 | | - task.addOutput(PingStatusGenerator.createPongStatusOutput(target, CodeSystem.DsfPingStatus.Code.COMPLETED)); |
| 445 | + task.addOutput(createPongStatusOutput(target, CodeSystem.DsfPingStatus.Code.COMPLETED)); |
447 | 446 |
|
448 | 447 | ValidationResult result = resourceValidator.validate(task); |
449 | 448 | ValidationSupportRule.logValidationMessages(logger, result); |
@@ -483,7 +482,7 @@ public String getCorrelationKey() |
483 | 482 | } |
484 | 483 | }; |
485 | 484 | Task task = createValidTaskPing(); |
486 | | - task.addOutput(PingStatusGenerator.createPongStatusOutput(target, CodeSystem.DsfPingStatus.Code.COMPLETED)); |
| 485 | + task.addOutput(createPongStatusOutput(target, CodeSystem.DsfPingStatus.Code.COMPLETED)); |
487 | 486 |
|
488 | 487 | task.addInput(DownloadResourceSizeGenerator.create(1000)); |
489 | 488 | task.addInput(DownloadResourceReferenceGenerator.create("https://test.endpoint.org/fhir/Binary")); |
@@ -696,4 +695,15 @@ private String fillPlaceholders(String xml) |
696 | 695 | dtf.format(LocalDate.ofInstant(Instant.now(), TimeZone.getDefault().toZoneId()))); |
697 | 696 | return xml; |
698 | 697 | } |
| 698 | + |
| 699 | + private Task.TaskOutputComponent createPingStatusOutput(Target target, CodeSystem.DsfPingStatus.Code statusCode, |
| 700 | + BigDecimal downloadSpeed, BigDecimal uploadSpeed, CodeSystem.DsfPingUnits.Code unit) |
| 701 | + { |
| 702 | + return PingStatusGenerator.createPingStatusOutput(target, statusCode, null, downloadSpeed, uploadSpeed, unit); |
| 703 | + } |
| 704 | + |
| 705 | + private Task.TaskOutputComponent createPongStatusOutput(Target target, CodeSystem.DsfPingStatus.Code statusCode) |
| 706 | + { |
| 707 | + return PingStatusGenerator.createPongStatusOutput(target, statusCode, null); |
| 708 | + } |
699 | 709 | } |
0 commit comments