chore: update dependencies and fix code style inconsistencies (#337)HEADmaster

6 files changed, 38 insertions, 13 deletions

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<String, String>) {
         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"
         }