Merge branch 'master' into utsatt-oppgave-normal-timeout

navikt · Dec 17, 2024 · f6125b9 · f6125b9
2 parents 19b3e19 + 6698663
commit f6125b9
Show file tree

Hide file tree

Showing 57 changed files with 423 additions and 363 deletions.
diff --git a/.github/workflows/ktlint.yml b/.github/workflows/ktlint.yml
@@ -14,6 +14,6 @@ jobs:
       - name: "Install ktlint"
         uses: nbadal/action-ktlint-setup@v1
         with:
-          ktlint_version: '1.2.1'
+          ktlint_version: '1.5.0'
       - run: ktlint
         shell: bash
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -68,7 +68,11 @@ tasks.jar {
     }
     doLast {
         configurations.runtimeClasspath.get().forEach {
-            val file = layout.buildDirectory.file("libs/${it.name}").get().asFile
+            val file =
+                layout.buildDirectory
+                    .file("libs/${it.name}")
+                    .get()
+                    .asFile
             if (!file.exists()) {
                 it.copyTo(file)
             }

diff --git a/gradle.properties b/gradle.properties
@@ -2,7 +2,7 @@ kotlin.code.style=official
 
 # Plugin versions
 kotlinVersion=2.0.21
-kotlinterVersion=4.3.0
+kotlinterVersion=5.0.1
 versionsVersion=0.50.0
 
 # Dependency versions

diff --git a/src/main/kotlin/no/nav/syfo/App.kt b/src/main/kotlin/no/nav/syfo/App.kt
@@ -31,7 +31,9 @@ import org.koin.core.context.stopKoin
 import org.slf4j.Logger
 import kotlin.concurrent.thread
 
-class SpinnApplication(val port: Int = 8080) : KoinComponent {
+class SpinnApplication(
+    val port: Int = 8080,
+) : KoinComponent {
     private val logger: Logger = this.logger()
     private var webserver: NettyApplicationEngine? = null
     private var appConfig: HoconApplicationConfig = HoconApplicationConfig(ConfigFactory.load())
@@ -127,7 +129,9 @@ class SpinnApplication(val port: Int = 8080) : KoinComponent {
     private fun migrateDatabase() {
         logger.info("Starter databasemigrering")
 
-        Flyway.configure().baselineOnMigrate(true)
+        Flyway
+            .configure()
+            .baselineOnMigrate(true)
             .dataSource(GlobalContext.getKoinApplicationOrNull()?.koin?.get())
             .load()
             .migrate()

diff --git a/src/main/kotlin/no/nav/syfo/Metrikker.kt b/src/main/kotlin/no/nav/syfo/Metrikker.kt
@@ -12,7 +12,8 @@ class MetrikkVarsler : Bakgrunnsvarsler {
 }
 
 val FEILET_JOBB_COUNTER =
-    Counter.build()
+    Counter
+        .build()
         .namespace(METRICS_NS)
         .name("feilet_jobb")
         .help("Counts the number of permanently failed jobs")

diff --git a/src/main/kotlin/no/nav/syfo/behandling/BehandlingException.kt b/src/main/kotlin/no/nav/syfo/behandling/BehandlingException.kt
@@ -1,18 +1,32 @@
 package no.nav.syfo.behandling
 
-open class BehandlingException(val feiltype: Feiltype, message: String, cause: Exception?) : RuntimeException(message, cause)
+open class BehandlingException(
+    val feiltype: Feiltype,
+    message: String,
+    cause: Exception?,
+) : RuntimeException(message, cause)
 
 // AktorClient
-open class AktørException(feiltype: Feiltype, message: String, causedBy: Exception?) : BehandlingException(feiltype, message, causedBy)
+open class AktørException(
+    feiltype: Feiltype,
+    message: String,
+    causedBy: Exception?,
+) : BehandlingException(feiltype, message, causedBy)
 
-open class FantIkkeAktørException(causedBy: java.lang.Exception?) : AktørException(
-    Feiltype.AKTØR_IKKE_FUNNET,
-    "Fant ikke aktørId",
-    causedBy,
-)
+open class FantIkkeAktørException(
+    causedBy: java.lang.Exception?,
+) : AktørException(
+        Feiltype.AKTØR_IKKE_FUNNET,
+        "Fant ikke aktørId",
+        causedBy,
+    )
 
 // OppgaveClient
-open class OppgaveException(feiltype: Feiltype, message: String, causedBy: Exception?) : BehandlingException(feiltype, message, causedBy)
+open class OppgaveException(
+    feiltype: Feiltype,
+    message: String,
+    causedBy: Exception?,
+) : BehandlingException(feiltype, message, causedBy)
 
 open class HentOppgaveException(
     journalpostId: String,
@@ -35,7 +49,11 @@ open class OpprettFordelingsOppgaveException(
 ) : OppgaveException(Feiltype.OPPGAVE_OPPRETT_FORDELING, "Klarte ikke opprette fordelingsoppgave for journalpostId $journalpostId!", cause)
 
 // BehandlendeEnhetConsumer
-open class BehandlendeEnhetException(feiltype: Feiltype, message: String, cause: Exception?) : BehandlingException(feiltype, message, cause)
+open class BehandlendeEnhetException(
+    feiltype: Feiltype,
+    message: String,
+    cause: Exception?,
+) : BehandlingException(feiltype, message, cause)
 
 open class IngenAktivEnhetException(
     geografiskTilknytning: String?,
@@ -47,7 +65,11 @@ open class BehandlendeEnhetFeiletException(
 ) : BehandlendeEnhetException(Feiltype.BEHANDLENDE_FEILET, "Feil ved henting av geografisk tilknytning", cause)
 
 // JournalConsumer
-open class JournalException(feiltype: Feiltype, message: String, cause: Exception?) : BehandlingException(feiltype, message, cause)
+open class JournalException(
+    feiltype: Feiltype,
+    message: String,
+    cause: Exception?,
+) : BehandlingException(feiltype, message, cause)
 
 open class HentDokumentFeiletException(
     journalpostId: String,

diff --git a/src/main/kotlin/no/nav/syfo/behandling/Feiltype.kt b/src/main/kotlin/no/nav/syfo/behandling/Feiltype.kt
@@ -1,6 +1,8 @@
 package no.nav.syfo.behandling
 
-enum class Feiltype(var navn: String) {
+enum class Feiltype(
+    var navn: String,
+) {
     USPESIFISERT("uspesifisert"),
     AKTØR_IKKE_FUNNET("aktor_ikkefunnet"),
     DOKUMENT_FEILET("dokument_feilet"),

diff --git a/src/main/kotlin/no/nav/syfo/client/dokarkiv/FeilregistrertRequest.kt b/src/main/kotlin/no/nav/syfo/client/dokarkiv/FeilregistrertRequest.kt
@@ -3,8 +3,8 @@ package no.nav.syfo.client.dokarkiv
 fun mapFeilregistrertRequest(
     fnr: String,
     dokumentId: String,
-): OppdaterJournalpostRequest {
-    return OppdaterJournalpostRequest(
+): OppdaterJournalpostRequest =
+    OppdaterJournalpostRequest(
         bruker =
             Bruker(
                 fnr,
@@ -14,4 +14,3 @@ fun mapFeilregistrertRequest(
         tema = "SYK",
         dokumenter = listOf(Dokument(dokumentId, "Inntektsmelding duplikat")),
     )
-}
diff --git a/src/main/kotlin/no/nav/syfo/client/dokarkiv/OppdaterRequest.kt b/src/main/kotlin/no/nav/syfo/client/dokarkiv/OppdaterRequest.kt
@@ -41,8 +41,8 @@ data class Sak(
     val arkivsaksystem: String? = null,
 )
 
-fun mapOppdaterRequest(fnr: String): OppdaterJournalpostRequest {
-    return OppdaterJournalpostRequest(
+fun mapOppdaterRequest(fnr: String): OppdaterJournalpostRequest =
+    OppdaterJournalpostRequest(
         bruker =
             Bruker(
                 fnr,
@@ -51,4 +51,3 @@ fun mapOppdaterRequest(fnr: String): OppdaterJournalpostRequest {
         sak = Sak("GENERELL_SAK"),
         tema = "SYK",
     )
-}
diff --git a/src/main/kotlin/no/nav/syfo/client/saf/LagQuery.kt b/src/main/kotlin/no/nav/syfo/client/saf/LagQuery.kt
@@ -1,7 +1,7 @@
 package no.nav.syfo.client.saf
 
-fun lagQuery(journalpostId: String): String {
-    return """query {
+fun lagQuery(journalpostId: String): String =
+    """query {
         journalpost(journalpostId: "$journalpostId") {
             tittel,
             journalstatus,
@@ -12,4 +12,3 @@ fun lagQuery(journalpostId: String): String {
             }
         }
 }""".trim()
-}
diff --git a/src/main/kotlin/no/nav/syfo/client/saf/SafJournalpostClient.kt b/src/main/kotlin/no/nav/syfo/client/saf/SafJournalpostClient.kt
@@ -28,12 +28,14 @@ class SafJournalpostClient(
         try {
             val response: JournalResponse =
                 runBlocking {
-                    httpClient.post(basePath) {
-                        contentType(ContentType.Application.Json)
-                        header("Authorization", "Bearer $accessToken")
-                        header("X-Correlation-ID", journalpostId)
-                        setBody(GetJournalpostRequest(query = lagQuery(journalpostId)))
-                    }.call.response.body<JournalResponse>()
+                    httpClient
+                        .post(basePath) {
+                            contentType(ContentType.Application.Json)
+                            header("Authorization", "Bearer $accessToken")
+                            header("X-Correlation-ID", journalpostId)
+                            setBody(GetJournalpostRequest(query = lagQuery(journalpostId)))
+                        }.call.response
+                        .body<JournalResponse>()
                 }
             if (response.errors != null && response.errors.isNotEmpty()) {
                 throw ErrorException(journalpostId, response.errors.toString())
@@ -51,14 +53,23 @@ class SafJournalpostClient(
     }
 }
 
-open class SafJournalpostException(journalpostId: String) : Exception(journalpostId)
+open class SafJournalpostException(
+    journalpostId: String,
+) : Exception(journalpostId)
 
-open class NotAuthorizedException(journalpostId: String) : SafJournalpostException(
-    "SAF ga ikke tilgang til å lese ut journalpost '$journalpostId'",
-)
+open class NotAuthorizedException(
+    journalpostId: String,
+) : SafJournalpostException(
+        "SAF ga ikke tilgang til å lese ut journalpost '$journalpostId'",
+    )
 
-open class ErrorException(journalpostId: String, errors: String) : SafJournalpostException(
-    "SAF returnerte feil journalpost '$journalpostId': $errors",
-)
+open class ErrorException(
+    journalpostId: String,
+    errors: String,
+) : SafJournalpostException(
+        "SAF returnerte feil journalpost '$journalpostId': $errors",
+    )
 
-open class EmptyException(journalpostId: String) : SafJournalpostException("SAF returnerte tom journalpost '$journalpostId'")
+open class EmptyException(
+    journalpostId: String,
+) : SafJournalpostException("SAF returnerte tom journalpost '$journalpostId'")
diff --git a/src/main/kotlin/no/nav/syfo/domain/inntektsmelding/Inntektsmelding.kt b/src/main/kotlin/no/nav/syfo/domain/inntektsmelding/Inntektsmelding.kt
@@ -42,8 +42,8 @@ data class Inntektsmelding(
     val rapportertInntekt: RapportertInntekt? = null,
     val vedtaksperiodeId: UUID? = null,
 ) {
-    fun isDuplicate(inntektsmelding: Inntektsmelding): Boolean {
-        return this.equals(
+    fun isDuplicate(inntektsmelding: Inntektsmelding): Boolean =
+        this.equals(
             inntektsmelding.copy(
                 id = this.id,
                 fnr = this.fnr,
@@ -57,10 +57,9 @@ data class Inntektsmelding(
                 avsenderSystem = this.avsenderSystem,
             ),
         )
-    }
 
-    fun isDuplicateExclusiveArsakInnsending(inntektsmelding: Inntektsmelding): Boolean {
-        return this.equals(
+    fun isDuplicateExclusiveArsakInnsending(inntektsmelding: Inntektsmelding): Boolean =
+        this.equals(
             inntektsmelding.copy(
                 id = this.id,
                 fnr = this.fnr,
@@ -75,10 +74,7 @@ data class Inntektsmelding(
                 arsakTilInnsending = this.arsakTilInnsending,
             ),
         )
-    }
 
     // TODO: kanskje kan vi fjerne dette, hvis vedtaksperiodeId *alltid* skal komme i selvbestemtIM
-    fun matcherSpleis(): Boolean {
-        return !(avsenderSystem.navn == NAV_NO_SELVBESTEMT && vedtaksperiodeId == null)
-    }
+    fun matcherSpleis(): Boolean = !(avsenderSystem.navn == NAV_NO_SELVBESTEMT && vedtaksperiodeId == null)
 }
diff --git a/src/main/kotlin/no/nav/syfo/integration/kafka/UtsattOppgaveConsumer.kt b/src/main/kotlin/no/nav/syfo/integration/kafka/UtsattOppgaveConsumer.kt
@@ -26,7 +26,8 @@ class UtsattOppgaveConsumer(
     val om: ObjectMapper,
     val utsattOppgaveService: UtsattOppgaveService,
     val bakgrunnsjobbRepo: BakgrunnsjobbRepository,
-) : ReadynessComponent, LivenessComponent {
+) : ReadynessComponent,
+    LivenessComponent {
     private val consumer: KafkaConsumer<String, String> = KafkaConsumer(props, StringDeserializer(), StringDeserializer())
     private val logger = this.logger()
     private val sikkerlogger = sikkerLogger()

diff --git a/src/main/kotlin/no/nav/syfo/integration/kafka/journalpost/JournalpostHendelseConsumer.kt b/src/main/kotlin/no/nav/syfo/integration/kafka/journalpost/JournalpostHendelseConsumer.kt
@@ -25,7 +25,8 @@ class JournalpostHendelseConsumer(
     topicName: String,
     private val bakgrunnsjobbRepo: BakgrunnsjobbRepository,
     private val om: ObjectMapper,
-) : ReadynessComponent, LivenessComponent {
+) : ReadynessComponent,
+    LivenessComponent {
     private val log = LoggerFactory.getLogger(JournalpostHendelseConsumer::class.java)
     private val sikkerlogger = sikkerLogger()
     private val consumer: KafkaConsumer<String, GenericRecord> = KafkaConsumer(props)
@@ -113,5 +114,4 @@ class JournalpostHendelseConsumer(
     }
 }
 
-fun isInntektsmelding(hendelse: InngaaendeJournalpostDTO): Boolean =
-    hendelse.temaNytt == "SYK" && hendelse.mottaksKanal == "ALTINN" && hendelse.journalpostStatus == "MOTTATT"
+fun isInntektsmelding(hendelse: InngaaendeJournalpostDTO): Boolean = hendelse.temaNytt == "SYK" && hendelse.mottaksKanal == "ALTINN" && hendelse.journalpostStatus == "MOTTATT"
diff --git a/src/main/kotlin/no/nav/syfo/integration/kafka/journalpost/MapJournalpost.kt b/src/main/kotlin/no/nav/syfo/integration/kafka/journalpost/MapJournalpost.kt
@@ -3,8 +3,8 @@ package no.nav.syfo.integration.kafka.journalpost
 import no.nav.syfo.kafkamottak.InngaaendeJournalpostDTO
 import org.apache.avro.generic.GenericRecord
 
-fun mapJournalpostHendelse(record: GenericRecord): InngaaendeJournalpostDTO {
-    return InngaaendeJournalpostDTO(
+fun mapJournalpostHendelse(record: GenericRecord): InngaaendeJournalpostDTO =
+    InngaaendeJournalpostDTO(
         record.get("hendelsesId") as String,
         record.get("versjon") as Int,
         record.get("hendelsesType") as String,
@@ -16,4 +16,3 @@ fun mapJournalpostHendelse(record: GenericRecord): InngaaendeJournalpostDTO {
         record.get("kanalReferanseId") as String,
         record.get("behandlingstema") as String,
     )
-}
diff --git a/src/main/kotlin/no/nav/syfo/kafkamottak/InntektsmeldingConsumerException.kt b/src/main/kotlin/no/nav/syfo/kafkamottak/InntektsmeldingConsumerException.kt
@@ -1,3 +1,5 @@
 package no.nav.syfo.kafkamottak
 
-class InntektsmeldingConsumerException(exception: Exception) : RuntimeException(exception)
+class InntektsmeldingConsumerException(
+    exception: Exception,
+) : RuntimeException(exception)