From a29ed1021b5429cec31552defc54e190f406975b Mon Sep 17 00:00:00 2001 From: Paul-Christian Volkmer Date: Fri, 6 Nov 2026 12:11:56 +0100 Subject: chore: update dependencies and fix code style inconsistencies (#337) --- .../dnpm/etl/processor/config/AppRestConfiguration.kt | 1 + .../dev/dnpm/etl/processor/consent/ConsentEvaluator.kt | 12 +++++++----- .../dev/dnpm/etl/processor/input/KafkaInputListener.kt | 10 ++++++++-- .../dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt | 16 ++++++++++++---- .../dnpm/etl/processor/pseudonym/PseudonymizeService.kt | 8 ++++++-- .../dnpm/etl/processor/web/StatisticsRestController.kt | 4 ++++ 6 files changed, 38 insertions(+), 13 deletions(-) (limited to 'src/main/kotlin/dev/dnpm') diff --git a/src/main/kotlin/dev/dnpm/etl/processor/config/AppRestConfiguration.kt b/src/main/kotlin/dev/dnpm/etl/processor/config/AppRestConfiguration.kt index 70cfca9..7965f96 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/config/AppRestConfiguration.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/config/AppRestConfiguration.kt @@ -57,6 +57,7 @@ class AppRestConfiguration { logger.info("Selected 'RestDipMtbFileSender'") RestDipMtbFileSender(restTemplate, restTargetProperties, retryTemplate, reportService) } + RestTargetType.NNGM -> { logger.info("Selected 'RestNngmMtbFileSender'") RestNngmMtbFileSender(restTemplate, restTargetProperties, retryTemplate, reportService) diff --git a/src/main/kotlin/dev/dnpm/etl/processor/consent/ConsentEvaluator.kt b/src/main/kotlin/dev/dnpm/etl/processor/consent/ConsentEvaluator.kt index 1f867e8..cc5e54e 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/consent/ConsentEvaluator.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/consent/ConsentEvaluator.kt @@ -36,11 +36,13 @@ class ConsentEvaluator( ttpConsentStatus == TtpConsentStatus.BROAD_CONSENT_GIVEN || ttpConsentStatus == TtpConsentStatus.GENOM_DE_CONSENT_SEQUENCING_PERMIT || // Aktuell nur Modellvorhaben Consent im File - ttpConsentStatus == TtpConsentStatus.UNKNOWN_CHECK_FILE && - mtbFile.metadata?.modelProjectConsent?.provisions?.any { - it.purpose == ModelProjectConsentPurpose.SEQUENCING && - it.type == ConsentProvisionType.PERMIT - } == true + ( + ttpConsentStatus == TtpConsentStatus.UNKNOWN_CHECK_FILE && + mtbFile.metadata?.modelProjectConsent?.provisions?.any { + it.purpose == ModelProjectConsentPurpose.SEQUENCING && + it.type == ConsentProvisionType.PERMIT + } == true + ) return ConsentEvaluation(ttpConsentStatus, consentGiven) } diff --git a/src/main/kotlin/dev/dnpm/etl/processor/input/KafkaInputListener.kt b/src/main/kotlin/dev/dnpm/etl/processor/input/KafkaInputListener.kt index 51d093b..b752473 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/input/KafkaInputListener.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/input/KafkaInputListener.kt @@ -43,8 +43,14 @@ class KafkaInputListener( override fun onMessage(record: ConsumerRecord) { when (guessMimeType(record)) { - MediaType.APPLICATION_JSON_VALUE -> handleDnpmV2Message(record) - CustomMediaType.APPLICATION_VND_DNPM_V2_MTB_JSON_VALUE -> handleDnpmV2Message(record) + MediaType.APPLICATION_JSON_VALUE -> { + handleDnpmV2Message(record) + } + + CustomMediaType.APPLICATION_VND_DNPM_V2_MTB_JSON_VALUE -> { + handleDnpmV2Message(record) + } + else -> { // ignore other messages } diff --git a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt index e198952..dd988ed 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt @@ -51,13 +51,14 @@ class KafkaMtbFileSender( record.headers().add("requestId", request.requestId.value.toByteArray()) record.headers().add("requestMethod", "POST".toByteArray()) when (request) { - is DnpmV2MtbFileRequest -> + is DnpmV2MtbFileRequest -> { record .headers() .add( "contentType", CustomMediaType.APPLICATION_VND_DNPM_V2_MTB_JSON_VALUE.toByteArray(), ) + } } val result = kafkaTemplate.send(record) @@ -114,9 +115,16 @@ class KafkaMtbFileSender( private fun key(request: MtbRequest): String = when (request) { - is DnpmV2MtbFileRequest -> "{\"pid\": \"${request.content.patient?.id}\"}" - is DeleteRequest -> "{\"pid\": \"${request.patientId.value}\"}" - else -> + is DnpmV2MtbFileRequest -> { + "{\"pid\": \"${request.content.patient?.id}\"}" + } + + is DeleteRequest -> { + "{\"pid\": \"${request.patientId.value}\"}" + } + + else -> { throw IllegalArgumentException("Unsupported request type: ${request::class.simpleName}") + } } } diff --git a/src/main/kotlin/dev/dnpm/etl/processor/pseudonym/PseudonymizeService.kt b/src/main/kotlin/dev/dnpm/etl/processor/pseudonym/PseudonymizeService.kt index c74345d..e8619bc 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/pseudonym/PseudonymizeService.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/pseudonym/PseudonymizeService.kt @@ -32,9 +32,13 @@ class PseudonymizeService( when (generator) { is GpasPseudonymGenerator, is VfpsPseudonymGenerator, - -> PatientPseudonym(generator.generate(patientId.value)) - else -> + -> { + PatientPseudonym(generator.generate(patientId.value)) + } + + else -> { PatientPseudonym("${configProperties.prefix}_${generator.generate(patientId.value)}") + } } fun genomDeTan(patientId: PatientId): String = generator.generateGenomDeTan(patientId.value) diff --git a/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt b/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt index 3ea9667..bba2b2a 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt @@ -49,11 +49,15 @@ class StatisticsRestController( private fun statusColor(status: RequestStatus) = when (status) { RequestStatus.ERROR -> "#FF0000" + RequestStatus.WARNING -> "#FF8C00" + RequestStatus.SUCCESS -> "#008000" + RequestStatus.NO_CONSENT, RequestStatus.BLOCKED_INITIAL, -> "#004A9D" + else -> "#708090" } -- cgit v1.2.3