run ktlint

navikt · Nov 12, 2024 · 8019693 · 8019693
1 parent 95fe83a
commit 8019693
Show file tree

Hide file tree

Showing 31 changed files with 360 additions and 409 deletions.
diff --git a/common/domain/src/main/kotlin/no/nav/mulighetsrommet/domain/dto/AvbruttAarsak.kt b/common/domain/src/main/kotlin/no/nav/mulighetsrommet/domain/dto/AvbruttAarsak.kt
@@ -29,14 +29,13 @@ sealed class AvbruttAarsak {
     }
 
     companion object {
-        fun fromString(value: String): AvbruttAarsak =
-            when (value) {
-                "ENDRING_HOS_ARRANGOR" -> EndringHosArrangor
-                "BUDSJETT_HENSYN" -> BudsjettHensyn
-                "FOR_FAA_DELTAKERE" -> ForFaaDeltakere
-                "FEILREGISTRERING" -> Feilregistrering
-                "AVBRUTT_I_ARENA" -> AvbruttIArena
-                else -> Annet(value)
-            }
+        fun fromString(value: String): AvbruttAarsak = when (value) {
+            "ENDRING_HOS_ARRANGOR" -> EndringHosArrangor
+            "BUDSJETT_HENSYN" -> BudsjettHensyn
+            "FOR_FAA_DELTAKERE" -> ForFaaDeltakere
+            "FEILREGISTRERING" -> Feilregistrering
+            "AVBRUTT_I_ARENA" -> AvbruttIArena
+            else -> Annet(value)
+        }
     }
 }
diff --git a/common/domain/src/main/kotlin/no/nav/mulighetsrommet/domain/dto/AvtaleStatus.kt b/common/domain/src/main/kotlin/no/nav/mulighetsrommet/domain/dto/AvtaleStatus.kt
@@ -16,16 +16,15 @@ sealed class AvtaleStatus {
     }
 
     companion object {
-        fun fromString(name: String, tidspunkt: LocalDateTime?, aarsak: AvbruttAarsak?): AvtaleStatus =
-            when (Enum.valueOf(name)) {
-                Enum.AKTIV -> AKTIV
-                Enum.AVSLUTTET -> AVSLUTTET
-                Enum.AVBRUTT -> {
-                    requireNotNull(tidspunkt)
-                    requireNotNull(aarsak)
-                    AVBRUTT(tidspunkt, aarsak)
-                }
+        fun fromString(name: String, tidspunkt: LocalDateTime?, aarsak: AvbruttAarsak?): AvtaleStatus = when (Enum.valueOf(name)) {
+            Enum.AKTIV -> AKTIV
+            Enum.AVSLUTTET -> AVSLUTTET
+            Enum.AVBRUTT -> {
+                requireNotNull(tidspunkt)
+                requireNotNull(aarsak)
+                AVBRUTT(tidspunkt, aarsak)
             }
+        }
     }
 
     enum class Enum {

diff --git a/common/domain/src/main/kotlin/no/nav/mulighetsrommet/domain/dto/Avtaletype.kt b/common/domain/src/main/kotlin/no/nav/mulighetsrommet/domain/dto/Avtaletype.kt
@@ -14,16 +14,15 @@ enum class Avtaletype {
     }
 }
 
-fun allowedAvtaletypes(tiltakskode: Tiltakskode?): List<Avtaletype> =
-    when (tiltakskode) {
-        ARBEIDSFORBEREDENDE_TRENING, VARIG_TILRETTELAGT_ARBEID_SKJERMET ->
-            listOf(Avtaletype.Forhaandsgodkjent)
+fun allowedAvtaletypes(tiltakskode: Tiltakskode?): List<Avtaletype> = when (tiltakskode) {
+    ARBEIDSFORBEREDENDE_TRENING, VARIG_TILRETTELAGT_ARBEID_SKJERMET ->
+        listOf(Avtaletype.Forhaandsgodkjent)
 
-        AVKLARING, OPPFOLGING, ARBEIDSRETTET_REHABILITERING, JOBBKLUBB, DIGITALT_OPPFOLGINGSTILTAK ->
-            listOf(Avtaletype.Rammeavtale, Avtaletype.Avtale)
+    AVKLARING, OPPFOLGING, ARBEIDSRETTET_REHABILITERING, JOBBKLUBB, DIGITALT_OPPFOLGINGSTILTAK ->
+        listOf(Avtaletype.Rammeavtale, Avtaletype.Avtale)
 
-        GRUPPE_ARBEIDSMARKEDSOPPLAERING, GRUPPE_FAG_OG_YRKESOPPLAERING ->
-            listOf(Avtaletype.Rammeavtale, Avtaletype.Avtale, Avtaletype.OffentligOffentlig)
+    GRUPPE_ARBEIDSMARKEDSOPPLAERING, GRUPPE_FAG_OG_YRKESOPPLAERING ->
+        listOf(Avtaletype.Rammeavtale, Avtaletype.Avtale, Avtaletype.OffentligOffentlig)
 
-        else -> Avtaletype.entries
-    }
+    else -> Avtaletype.entries
+}
diff --git a/...on/domain/src/main/kotlin/no/nav/mulighetsrommet/domain/dto/TiltaksgjennomforingStatus.kt b/...on/domain/src/main/kotlin/no/nav/mulighetsrommet/domain/dto/TiltaksgjennomforingStatus.kt
@@ -19,13 +19,12 @@ data class TiltaksgjennomforingStatusDto(
     val status: TiltaksgjennomforingStatus,
     val avbrutt: AvbruttDto?,
 ) {
-    fun toAvslutningsstatus(): Avslutningsstatus =
-        when (status) {
-            TiltaksgjennomforingStatus.PLANLAGT, TiltaksgjennomforingStatus.GJENNOMFORES -> Avslutningsstatus.IKKE_AVSLUTTET
-            TiltaksgjennomforingStatus.AVSLUTTET -> Avslutningsstatus.AVSLUTTET
-            TiltaksgjennomforingStatus.AVBRUTT -> Avslutningsstatus.AVBRUTT
-            TiltaksgjennomforingStatus.AVLYST -> Avslutningsstatus.AVLYST
-        }
+    fun toAvslutningsstatus(): Avslutningsstatus = when (status) {
+        TiltaksgjennomforingStatus.PLANLAGT, TiltaksgjennomforingStatus.GJENNOMFORES -> Avslutningsstatus.IKKE_AVSLUTTET
+        TiltaksgjennomforingStatus.AVSLUTTET -> Avslutningsstatus.AVSLUTTET
+        TiltaksgjennomforingStatus.AVBRUTT -> Avslutningsstatus.AVBRUTT
+        TiltaksgjennomforingStatus.AVLYST -> Avslutningsstatus.AVLYST
+    }
 }
 
 @Serializable

diff --git a/common/kafka/src/main/kotlin/no/nav/mulighetsrommet/kafka/KafkaConsumerOrchestrator.kt b/common/kafka/src/main/kotlin/no/nav/mulighetsrommet/kafka/KafkaConsumerOrchestrator.kt
@@ -165,8 +165,7 @@ class KafkaConsumerOrchestrator(
         topicRepository.setAll(topics)
     }
 
-    private fun getUpdatedTopicsOnly(updated: List<Topic>, current: List<Topic>) =
-        updated.filter { x -> current.any { y -> y.id == x.id && y.running != x.running } }
+    private fun getUpdatedTopicsOnly(updated: List<Topic>, current: List<Topic>) = updated.filter { x -> current.any { y -> y.id == x.id && y.running != x.running } }
 }
 
 private fun validateConsumers(consumers: List<KafkaTopicConsumer<*, *>>) {

diff --git a/common/token-provider/src/main/kotlin/no/nav/mulighetsrommet/tokenprovider/TokenProvider.kt b/common/token-provider/src/main/kotlin/no/nav/mulighetsrommet/tokenprovider/TokenProvider.kt
@@ -79,64 +79,60 @@ class CachedTokenProvider(
     }
 }
 
-private fun AccessType.subject(): String =
-    when (this) {
-        AccessType.M2M -> ""
-        is AccessType.OBO -> {
-            try {
-                val token = JWTParser.parse(this.token)
-                val subject = token.jwtClaimsSet.subject
-                    ?: throw IllegalArgumentException("Unable to get subject, access token is missing subject")
-                subject
-            } catch (e: ParseException) {
-                throw IllegalArgumentException("Unable to get subject, access token is invalid")
-            }
+private fun AccessType.subject(): String = when (this) {
+    AccessType.M2M -> ""
+    is AccessType.OBO -> {
+        try {
+            val token = JWTParser.parse(this.token)
+            val subject = token.jwtClaimsSet.subject
+                ?: throw IllegalArgumentException("Unable to get subject, access token is missing subject")
+            subject
+        } catch (e: ParseException) {
+            throw IllegalArgumentException("Unable to get subject, access token is invalid")
         }
     }
+}
 
-private fun createOboTokenClient(clientId: String, tokenEndpointUrl: String): OnBehalfOfTokenClient =
-    when (NaisEnv.current()) {
-        NaisEnv.Local -> AzureAdTokenClientBuilder.builder()
-            .withClientId(clientId)
-            .withPrivateJwk(createMockRSAKey("azure").toJSONString())
-            .withTokenEndpointUrl(tokenEndpointUrl)
-            .buildOnBehalfOfTokenClient()
+private fun createOboTokenClient(clientId: String, tokenEndpointUrl: String): OnBehalfOfTokenClient = when (NaisEnv.current()) {
+    NaisEnv.Local -> AzureAdTokenClientBuilder.builder()
+        .withClientId(clientId)
+        .withPrivateJwk(createMockRSAKey("azure").toJSONString())
+        .withTokenEndpointUrl(tokenEndpointUrl)
+        .buildOnBehalfOfTokenClient()
 
-        else -> AzureAdTokenClientBuilder.builder().withNaisDefaults().buildOnBehalfOfTokenClient()
-    }
+    else -> AzureAdTokenClientBuilder.builder().withNaisDefaults().buildOnBehalfOfTokenClient()
+}
 
-private fun createM2mTokenClient(clientId: String, tokenEndpointUrl: String): MachineToMachineTokenClient =
-    when (NaisEnv.current()) {
-        NaisEnv.Local -> AzureAdTokenClientBuilder.builder()
-            .withClientId(clientId)
-            .withPrivateJwk(createMockRSAKey("azure").toJSONString())
-            .withTokenEndpointUrl(tokenEndpointUrl)
-            .buildMachineToMachineTokenClient()
+private fun createM2mTokenClient(clientId: String, tokenEndpointUrl: String): MachineToMachineTokenClient = when (NaisEnv.current()) {
+    NaisEnv.Local -> AzureAdTokenClientBuilder.builder()
+        .withClientId(clientId)
+        .withPrivateJwk(createMockRSAKey("azure").toJSONString())
+        .withTokenEndpointUrl(tokenEndpointUrl)
+        .buildMachineToMachineTokenClient()
 
-        else -> AzureAdTokenClientBuilder.builder().withNaisDefaults().buildMachineToMachineTokenClient()
-    }
+    else -> AzureAdTokenClientBuilder.builder().withNaisDefaults().buildMachineToMachineTokenClient()
+}
 
 fun createMaskinportenM2mTokenClient(
     clientId: String,
     tokenEndpointUrl: String,
     issuer: String,
     engine: HttpClientEngine,
-): MaskinPortenTokenProvider? =
-    when (NaisEnv.current()) {
-        NaisEnv.Local -> MaskinPortenTokenProvider(
-            clientId = clientId,
-            tokenEndpointUrl = tokenEndpointUrl,
-            privateJwk = createMockRSAKey("maskinporten").toJSONString(),
-            issuer = issuer,
-        )
-        NaisEnv.ProdGCP -> null // TODO: Remove when prod
-        else -> MaskinPortenTokenProvider(
-            clientId = clientId,
-            tokenEndpointUrl = tokenEndpointUrl,
-            privateJwk = System.getenv("MASKINPORTEN_CLIENT_JWK"),
-            issuer = issuer,
-        )
-    }
+): MaskinPortenTokenProvider? = when (NaisEnv.current()) {
+    NaisEnv.Local -> MaskinPortenTokenProvider(
+        clientId = clientId,
+        tokenEndpointUrl = tokenEndpointUrl,
+        privateJwk = createMockRSAKey("maskinporten").toJSONString(),
+        issuer = issuer,
+    )
+    NaisEnv.ProdGCP -> null // TODO: Remove when prod
+    else -> MaskinPortenTokenProvider(
+        clientId = clientId,
+        tokenEndpointUrl = tokenEndpointUrl,
+        privateJwk = System.getenv("MASKINPORTEN_CLIENT_JWK"),
+        issuer = issuer,
+    )
+}
 
 private fun createMockRSAKey(keyID: String): RSAKey = KeyPairGenerator
     .getInstance("RSA").let {

diff --git a/mulighetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/altinn/AltinnClient.kt b/mulighetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/altinn/AltinnClient.kt
@@ -44,18 +44,17 @@ class AltinnClient(
 
     private fun findAltinnRoller(
         parties: List<AuthorizedParty>,
-    ): List<BedriftRettigheter> =
-        parties
-            .flatMap { party ->
-                findAltinnRoller(party.subunits) +
-                    BedriftRettigheter(
-                        organisasjonsnummer = Organisasjonsnummer(party.organizationNumber),
-                        rettigheter = AltinnRessurs
-                            .entries
-                            .filter { it.ressursId in party.authorizedResources },
-                    )
-            }
-            .filter { it.rettigheter.isNotEmpty() }
+    ): List<BedriftRettigheter> = parties
+        .flatMap { party ->
+            findAltinnRoller(party.subunits) +
+                BedriftRettigheter(
+                    organisasjonsnummer = Organisasjonsnummer(party.organizationNumber),
+                    rettigheter = AltinnRessurs
+                        .entries
+                        .filter { it.ressursId in party.authorizedResources },
+                )
+        }
+        .filter { it.rettigheter.isNotEmpty() }
 
     private suspend fun hentAuthorizedParties(norskIdent: NorskIdent): List<AuthorizedParty> {
         val response = client.post("$baseUrl/accessmanagement/api/v1/resourceowner/authorizedparties") {

diff --git a/...tsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/altinn/AltinnRettigheterRepository.kt b/...tsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/altinn/AltinnRettigheterRepository.kt
@@ -11,8 +11,7 @@ import org.intellij.lang.annotations.Language
 import java.time.LocalDateTime
 
 class AltinnRettigheterRepository(private val db: Database) {
-    fun upsertRettighet(personBedriftRettigheter: PersonBedriftRettigheter) =
-        db.transaction { tx -> upsertRettighet(personBedriftRettigheter, tx) }
+    fun upsertRettighet(personBedriftRettigheter: PersonBedriftRettigheter) = db.transaction { tx -> upsertRettighet(personBedriftRettigheter, tx) }
 
     private fun upsertRettighet(personBedriftRettigheter: PersonBedriftRettigheter, tx: Session) {
         @Language("PostgreSQL")

diff --git a/...ghetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/altinn/AltinnRettigheterService.kt b/...ghetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/altinn/AltinnRettigheterService.kt
@@ -34,8 +34,7 @@ class AltinnRettigheterService(
     }
 }
 
-fun BedriftRettigheterDbo.toBedriftRettigheter() =
-    BedriftRettigheter(
-        organisasjonsnummer = this.organisasjonsnummer,
-        rettigheter = this.rettigheter.map { it.rettighet },
-    )
+fun BedriftRettigheterDbo.toBedriftRettigheter() = BedriftRettigheter(
+    organisasjonsnummer = this.organisasjonsnummer,
+    rettigheter = this.rettigheter.map { it.rettighet },
+)
diff --git a/mulighetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/api/domain/dto/AvtaleDto.kt b/mulighetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/api/domain/dto/AvtaleDto.kt
@@ -99,50 +99,48 @@ data class AvtaleDto(
         val status: OpsjonLoggRequest.OpsjonsLoggStatus,
     )
 
-    fun toDbo() =
-        AvtaleDbo(
-            id = id,
-            navn = navn,
-            tiltakstypeId = tiltakstype.id,
-            avtalenummer = avtalenummer,
-            websaknummer = websaknummer,
-            arrangorId = arrangor.id,
-            arrangorUnderenheter = arrangor.underenheter.map { it.id },
-            arrangorKontaktpersoner = arrangor.kontaktpersoner.map { it.id },
-            startDato = startDato,
-            sluttDato = sluttDato,
-            navEnheter = this.kontorstruktur.flatMap { it.kontorer.map { kontor -> kontor.enhetsnummer } + it.region.enhetsnummer },
-            avtaletype = avtaletype,
-            prisbetingelser = prisbetingelser,
-            antallPlasser = antallPlasser,
-            administratorer = administratorer.map { it.navIdent },
-            beskrivelse = null,
-            faneinnhold = null,
-            personopplysninger = personopplysninger,
-            personvernBekreftet = personvernBekreftet,
-            amoKategorisering = amoKategorisering,
-            opsjonMaksVarighet = opsjonsmodellData?.opsjonMaksVarighet,
-            opsjonsmodell = opsjonsmodellData?.opsjonsmodell,
-            customOpsjonsmodellNavn = opsjonsmodellData?.customOpsjonsmodellNavn,
-            utdanningslop = utdanningslop?.toDbo(),
-        )
+    fun toDbo() = AvtaleDbo(
+        id = id,
+        navn = navn,
+        tiltakstypeId = tiltakstype.id,
+        avtalenummer = avtalenummer,
+        websaknummer = websaknummer,
+        arrangorId = arrangor.id,
+        arrangorUnderenheter = arrangor.underenheter.map { it.id },
+        arrangorKontaktpersoner = arrangor.kontaktpersoner.map { it.id },
+        startDato = startDato,
+        sluttDato = sluttDato,
+        navEnheter = this.kontorstruktur.flatMap { it.kontorer.map { kontor -> kontor.enhetsnummer } + it.region.enhetsnummer },
+        avtaletype = avtaletype,
+        prisbetingelser = prisbetingelser,
+        antallPlasser = antallPlasser,
+        administratorer = administratorer.map { it.navIdent },
+        beskrivelse = null,
+        faneinnhold = null,
+        personopplysninger = personopplysninger,
+        personvernBekreftet = personvernBekreftet,
+        amoKategorisering = amoKategorisering,
+        opsjonMaksVarighet = opsjonsmodellData?.opsjonMaksVarighet,
+        opsjonsmodell = opsjonsmodellData?.opsjonsmodell,
+        customOpsjonsmodellNavn = opsjonsmodellData?.customOpsjonsmodellNavn,
+        utdanningslop = utdanningslop?.toDbo(),
+    )
 
-    fun toArenaAvtaleDbo() =
-        ArenaAvtaleDbo(
-            id = id,
-            navn = navn,
-            tiltakstypeId = tiltakstype.id,
-            avtalenummer = avtalenummer,
-            arrangorOrganisasjonsnummer = arrangor.organisasjonsnummer.value,
-            startDato = startDato,
-            sluttDato = sluttDato,
-            arenaAnsvarligEnhet = arenaAnsvarligEnhet?.enhetsnummer,
-            avtaletype = avtaletype,
-            avslutningsstatus = when (status) {
-                is AvtaleStatus.AKTIV -> Avslutningsstatus.IKKE_AVSLUTTET
-                is AvtaleStatus.AVBRUTT -> Avslutningsstatus.AVBRUTT
-                is AvtaleStatus.AVSLUTTET -> Avslutningsstatus.AVSLUTTET
-            },
-            prisbetingelser = prisbetingelser,
-        )
+    fun toArenaAvtaleDbo() = ArenaAvtaleDbo(
+        id = id,
+        navn = navn,
+        tiltakstypeId = tiltakstype.id,
+        avtalenummer = avtalenummer,
+        arrangorOrganisasjonsnummer = arrangor.organisasjonsnummer.value,
+        startDato = startDato,
+        sluttDato = sluttDato,
+        arenaAnsvarligEnhet = arenaAnsvarligEnhet?.enhetsnummer,
+        avtaletype = avtaletype,
+        avslutningsstatus = when (status) {
+            is AvtaleStatus.AKTIV -> Avslutningsstatus.IKKE_AVSLUTTET
+            is AvtaleStatus.AVBRUTT -> Avslutningsstatus.AVBRUTT
+            is AvtaleStatus.AVSLUTTET -> Avslutningsstatus.AVSLUTTET
+        },
+        prisbetingelser = prisbetingelser,
+    )
 }