Legg til endepunkter for å sende og motta klage

navikt · Oct 10, 2023 · eb41947 · eb41947
1 parent bb92279
commit eb41947
Show file tree

Hide file tree

Showing 25 changed files with 498 additions and 175 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -31,6 +31,7 @@ object Versions {
     const val gson = "2.10"
     const val log4j = "2.19.0"
     const val snakeyaml = "2.0"
+    const val fiksIO = "3.2.2"
 
     const val javaJwt = "4.3.0"
     const val jwksRsa = "0.22.0"
@@ -126,6 +127,9 @@ dependencies {
 //    Filformat
     implementation("no.nav.sbl.dialogarena:soknadsosialhjelp-filformat:${Versions.filformat}")
 
+//  Fiks IO
+    implementation("no.ks.fiks:fiks-io-klient-java:${Versions.fiksIO}")
+
 //    Jackson
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin:${Versions.jackson}")
 

diff --git a/nais/dev/mock.yaml b/nais/dev/mock.yaml
@@ -30,6 +30,7 @@ spec:
       external:
         - host: unleash.nais.io
         - host: digisos.ekstern.dev.nav.no
+        - host: test.maskinporten.no
       rules:
         - application: sosialhjelp-mock-alt-api-mock
         - application: sosialhjelp-soknad-api-mock
@@ -45,8 +46,16 @@ spec:
     requests:
       cpu: 10m
       memory: 512Mi
+  maskinporten:
+    enabled: true
+    scopes:
+      consumes:
+        - name: "ks:fiks"
   envFrom:
     - configmap: loginservice-idporten
+    - secret: innsyn-api-fiks-io-integrasjonspassord
+  filesFrom:
+    - secret: innyn-api-fiks-io-private-key
   env:
     - name: SPRING_PROFILES_ACTIVE
       value: "mock-alt,log-console,mock-redis"
@@ -72,7 +81,7 @@ spec:
       value: "http://sosialhjelp-mock-alt-api-mock/sosialhjelp/mock-alt-api/well-known/tokenx"
     - name: TOKEN_X_CLIENT_ID
       value: "dev-gcp:teamdigisos:sosialhjelp-innsyn-api-mock"
-    - name: MASKINPORTEN_WELL_KNOWN_URL
+    - name: MOCK_ALT_MASKINPORTEN_WELL_KNOWN_URL
       value: "http://sosialhjelp-mock-alt-api-mock/sosialhjelp/mock-alt-api/well-known/maskinporten"
     - name: VILKAR_DOKKRAV_FAGSYSTEM_VERSJONER
       value: "Socio;10.1.16,mock-alt;1.0-MOCKVERSJON,Testsystemet;1.0.0"

diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/app/maskinporten/MaskinportenClientConfig.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/app/maskinporten/MaskinportenClientConfig.kt
@@ -5,29 +5,27 @@ import no.nav.sosialhjelp.innsyn.utils.objectMapper
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Profile
 import org.springframework.http.client.reactive.ReactorClientHttpConnector
 import org.springframework.http.codec.json.Jackson2JsonDecoder
 import org.springframework.http.codec.json.Jackson2JsonEncoder
 import org.springframework.web.reactive.function.client.WebClient
 import org.springframework.web.reactive.function.client.bodyToMono
 import reactor.netty.http.client.HttpClient
 
-@Configuration
-class MaskinportenClientConfig(
-    @Value("\${maskinporten_clientid}") private val clientId: String,
-    @Value("\${maskinporten_scopes}") private val scopes: String,
-    @Value("\${maskinporten_well_known_url}") private val wellKnownUrl: String,
-    @Value("\${maskinporten_client_jwk}") private val clientJwk: String,
+sealed class MaskinportenClientConfig(
+    clientId: String,
+    scopes: String,
+    private val wellKnownUrl: String,
+    clientJwk: String,
     webClientBuilder: WebClient.Builder,
     proxiedHttpClient: HttpClient,
 ) {
 
-    @Bean
-    fun maskinportenClient(): MaskinportenClient {
-        return MaskinportenClient(maskinportenWebClient, maskinportenProperties, wellknown)
-    }
+    private val log by logger()
+    abstract fun maskinportenClient(): MaskinportenClient
 
-    private val maskinportenWebClient: WebClient =
+    protected val maskinportenWebClient: WebClient =
         webClientBuilder
             .clientConnector(ReactorClientHttpConnector(proxiedHttpClient))
             .codecs {
@@ -37,25 +35,49 @@ class MaskinportenClientConfig(
             }
             .build()
 
-    private val maskinportenProperties = MaskinportenProperties(
+    protected val maskinportenProperties = MaskinportenProperties(
         clientId = clientId,
         clientJwk = clientJwk,
         scope = scopes,
         wellKnownUrl = wellKnownUrl
     )
 
-    private val wellknown: WellKnown
+    protected val wellknown: WellKnown
         get() = maskinportenWebClient.get()
             .uri(wellKnownUrl)
             .retrieve()
             .bodyToMono<WellKnown>()
             .doOnSuccess { log.info("Hentet WellKnown for Maskinporten.") }
             .doOnError { log.warn("Feil ved henting av WellKnown for Maskinporten", it) }
             .block() ?: throw RuntimeException("Feil ved henting av WellKnown for Maskinporten")
+}
+
+@Configuration
+class MaskinportenClientConfigImpl(
+    @Value("\${maskinporten_clientid}") clientId: String,
+    @Value("\${maskinporten_scopes}") scopes: String,
+    @Value("\${maskinporten_well_known_url}") wellKnownUrl: String,
+    @Value("\${maskinporten_client_jwk}") clientJwk: String,
+    webClientBuilder: WebClient.Builder,
+    proxiedHttpClient: HttpClient,
+) : MaskinportenClientConfig(clientId, scopes, wellKnownUrl, clientJwk, webClientBuilder, proxiedHttpClient) {
 
-    companion object {
-        private val log by logger()
-    }
+    @Bean("maskinportenClient")
+    override fun maskinportenClient(): MaskinportenClient = MaskinportenClient(maskinportenWebClient, maskinportenProperties, wellknown)
+}
+
+@Configuration
+@Profile("!local")
+class SpecialMaskinportenClientConfig(
+    @Value("\${special_maskinporten_clientid}") clientId: String,
+    @Value("\${special_maskinporten_scopes}") scopes: String,
+    @Value("\${special_well_known_url}") wellKnownUrl: String,
+    @Value("\${special_maskinporten_client_jwk}") clientJwk: String,
+    webClientBuilder: WebClient.Builder,
+    proxiedHttpClient: HttpClient,
+) : MaskinportenClientConfig(clientId, scopes, wellKnownUrl, clientJwk, webClientBuilder, proxiedHttpClient) {
+    @Bean("specialMaskinportenClient")
+    override fun maskinportenClient(): MaskinportenClient = MaskinportenClient(maskinportenWebClient, maskinportenProperties, wellknown)
 }
 
 data class WellKnown(

diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/digisosapi/DokumentlagerClient.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/digisosapi/DokumentlagerClient.kt
@@ -6,6 +6,7 @@ import no.nav.sosialhjelp.innsyn.app.exceptions.BadStateException
 import no.nav.sosialhjelp.innsyn.app.maskinporten.MaskinportenClient
 import no.nav.sosialhjelp.innsyn.utils.IntegrationUtils.BEARER
 import no.nav.sosialhjelp.innsyn.utils.logger
+import org.springframework.beans.factory.annotation.Qualifier
 import org.springframework.http.HttpHeaders.AUTHORIZATION
 import org.springframework.http.MediaType.APPLICATION_JSON
 import org.springframework.stereotype.Component
@@ -24,6 +25,7 @@ interface DokumentlagerClient {
 @Component
 class DokumentlagerClientImpl(
     private val fiksWebClient: WebClient,
+    @Qualifier("maskinportenClient")
     private val maskinportenClient: MaskinportenClient
 ) : DokumentlagerClient {
 

diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/digisosapi/test/DigisosApiTestClientImpl.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/digisosapi/test/DigisosApiTestClientImpl.kt
@@ -13,6 +13,7 @@ import no.nav.sosialhjelp.innsyn.utils.IntegrationUtils.BEARER
 import no.nav.sosialhjelp.innsyn.utils.logger
 import no.nav.sosialhjelp.innsyn.utils.objectMapper
 import no.nav.sosialhjelp.innsyn.vedlegg.FilForOpplasting
+import org.springframework.beans.factory.annotation.Qualifier
 import org.springframework.context.annotation.Profile
 import org.springframework.http.HttpHeaders.AUTHORIZATION
 import org.springframework.http.MediaType
@@ -31,6 +32,7 @@ import org.springframework.web.reactive.function.client.bodyToMono
 class DigisosApiTestClientImpl(
     private val fiksWebClient: WebClient,
     private val digisosApiTestWebClient: WebClient,
+    @Qualifier("maskinportenClient")
     private val maskinportenClient: MaskinportenClient,
     private val fiksClientImpl: FiksClientImpl,
 ) : DigisosApiTestClient {

diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/digisossak/saksstatus/SaksStatusResponse.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/digisossak/saksstatus/SaksStatusResponse.kt
@@ -8,11 +8,12 @@ data class SaksStatusResponse(
     val tittel: String,
     val status: SaksStatus?,
     val skalViseVedtakInfoPanel: Boolean,
-    val vedtaksfilUrlList: List<VedtaksfilUrl>?
+    val vedtaksfilUrlList: List<FilUrl>?,
 )
 
-data class VedtaksfilUrl(
+data class FilUrl(
     @JsonFormat(pattern = "yyyy-MM-dd")
     val dato: LocalDate?,
-    val vedtaksfilUrl: String
+    val url: String,
+    val id: String,
 )
diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/digisossak/saksstatus/SaksStatusService.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/digisossak/saksstatus/SaksStatusService.kt
@@ -8,11 +8,14 @@ import no.nav.sosialhjelp.innsyn.event.EventService
 import no.nav.sosialhjelp.innsyn.utils.logger
 import org.springframework.stereotype.Component
 
+const val DEFAULT_SAK_TITTEL = "default_sak_tittel"
+
 @Component
 class SaksStatusService(
     private val eventService: EventService,
-    private val fiksClient: FiksClient
+    private val fiksClient: FiksClient,
 ) {
+    private val log by logger()
 
     fun hentSaksStatuser(fiksDigisosId: String, token: String): List<SaksStatusResponse> {
         val digisosSak = fiksClient.hentDigisosSak(fiksDigisosId, token, true)
@@ -29,39 +32,16 @@ class SaksStatusService(
     }
 
     private fun mapToResponse(sak: Sak): SaksStatusResponse {
-        val saksStatus = hentStatusNavn(sak)
-        val vedtakfilUrlList = when {
-            sak.vedtak.isEmpty() -> null
-            else -> sak.vedtak.map {
-                log.info("Hentet url til vedtaksfil: ${it.vedtaksFilUrl}")
-                VedtaksfilUrl(it.dato, it.vedtaksFilUrl)
-            }
+        val saksStatus = if (sak.vedtak.isEmpty()) {
+            sak.saksStatus ?: SaksStatus.UNDER_BEHANDLING
+        } else {
+            SaksStatus.FERDIGBEHANDLET
         }
-        val skalViseVedtakInfoPanel = getSkalViseVedtakInfoPanel(sak)
+        val vedtakfilUrlList = sak.vedtak.map {
+            log.info("Hentet url til vedtaksfil: ${it.vedtaksFilUrl}")
+            FilUrl(it.dato, it.vedtaksFilUrl, it.id)
+        }.ifEmpty { null }
+        val skalViseVedtakInfoPanel = sak.vedtak.all { it.utfall in listOf(UtfallVedtak.DELVIS_INNVILGET, UtfallVedtak.INNVILGET) }
         return SaksStatusResponse(sak.tittel ?: DEFAULT_SAK_TITTEL, saksStatus, skalViseVedtakInfoPanel, vedtakfilUrlList)
     }
-
-    private fun hentStatusNavn(sak: Sak): SaksStatus {
-        return when {
-            sak.vedtak.isEmpty() -> sak.saksStatus ?: SaksStatus.UNDER_BEHANDLING
-            else -> SaksStatus.FERDIGBEHANDLET
-        }
-    }
-
-    fun getSkalViseVedtakInfoPanel(sak: Sak): Boolean {
-        var sakHarVedtakslisteMedGjeldendeVedtakInnvilgetEllerDelvisInnvilget = false
-        for (vedtak in sak.vedtak) {
-            when {
-                vedtak.utfall == UtfallVedtak.DELVIS_INNVILGET || vedtak.utfall == UtfallVedtak.INNVILGET -> sakHarVedtakslisteMedGjeldendeVedtakInnvilgetEllerDelvisInnvilget = true
-                vedtak.utfall == UtfallVedtak.AVSLATT || vedtak.utfall == UtfallVedtak.AVVIST -> sakHarVedtakslisteMedGjeldendeVedtakInnvilgetEllerDelvisInnvilget = false
-            }
-        }
-        return sakHarVedtakslisteMedGjeldendeVedtakInnvilgetEllerDelvisInnvilget
-    }
-
-    companion object {
-        private val log by logger()
-
-        const val DEFAULT_SAK_TITTEL: String = "default_sak_tittel"
-    }
 }
diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/domain/DigisosSoker.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/domain/DigisosSoker.kt
@@ -58,6 +58,7 @@ data class Sak(
 )
 
 data class Vedtak(
+    val id: String,
     var utfall: UtfallVedtak?,
     var vedtaksFilUrl: String,
     var dato: LocalDate?,

diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/event/VedtakFattet.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/event/VedtakFattet.kt
@@ -1,8 +1,10 @@
 package no.nav.sosialhjelp.innsyn.event
 
+import no.nav.sbl.soknadsosialhjelp.digisos.soker.filreferanse.JsonDokumentlagerFilreferanse
+import no.nav.sbl.soknadsosialhjelp.digisos.soker.filreferanse.JsonSvarUtFilreferanse
 import no.nav.sbl.soknadsosialhjelp.digisos.soker.hendelse.JsonVedtakFattet
 import no.nav.sosialhjelp.innsyn.app.ClientProperties
-import no.nav.sosialhjelp.innsyn.digisossak.saksstatus.SaksStatusService.Companion.DEFAULT_SAK_TITTEL
+import no.nav.sosialhjelp.innsyn.digisossak.saksstatus.DEFAULT_SAK_TITTEL
 import no.nav.sosialhjelp.innsyn.domain.Hendelse
 import no.nav.sosialhjelp.innsyn.domain.HendelseTekstType
 import no.nav.sosialhjelp.innsyn.domain.InternalDigisosSoker
@@ -23,7 +25,14 @@ fun InternalDigisosSoker.apply(hendelse: JsonVedtakFattet, clientProperties: Cli
     val utfall = utfallString?.let { UtfallVedtak.valueOf(it) }
     val vedtaksfilUrl = hentUrlFraFilreferanse(clientProperties, hendelse.vedtaksfil.referanse)
 
-    val vedtakFattet = Vedtak(utfall, vedtaksfilUrl, hendelse.hendelsestidspunkt.toLocalDateTime().toLocalDate())
+    val id = when (val referanse = hendelse.vedtaksfil.referanse) {
+        is JsonDokumentlagerFilreferanse -> referanse.id
+        is JsonSvarUtFilreferanse -> referanse.id
+        else -> error("Ikke støttet referansetype ${referanse.type}")
+    }
+    val vedtakFattet = Vedtak(
+        id, utfall, vedtaksfilUrl, hendelse.hendelsestidspunkt.toLocalDateTime().toLocalDate()
+    )
 
     var sakForReferanse = saker.firstOrNull { it.referanse == hendelse.saksreferanse || it.referanse == "default" }
 
@@ -42,7 +51,14 @@ fun InternalDigisosSoker.apply(hendelse: JsonVedtakFattet, clientProperties: Cli
 
     log.info("Hendelse: Tidspunkt: ${hendelse.hendelsestidspunkt} Vedtak fattet. <skjult tittel> er ferdigbehandlet")
     if (sakForReferanse.tittel != null) {
-        historikk.add(Hendelse(HendelseTekstType.SAK_FERDIGBEHANDLET_MED_TITTEL, hendelse.hendelsestidspunkt.toLocalDateTime(), UrlResponse(HendelseTekstType.VIS_BREVET_LENKETEKST, vedtaksfilUrl), tekstArgument = sakForReferanse.tittel))
+        historikk.add(
+            Hendelse(
+                HendelseTekstType.SAK_FERDIGBEHANDLET_MED_TITTEL,
+                hendelse.hendelsestidspunkt.toLocalDateTime(),
+                UrlResponse(HendelseTekstType.VIS_BREVET_LENKETEKST, vedtaksfilUrl),
+                tekstArgument = sakForReferanse.tittel
+            )
+        )
     } else {
         historikk.add(Hendelse(HendelseTekstType.SAK_FERDIGBEHANDLET_UTEN_TITTEL, hendelse.hendelsestidspunkt.toLocalDateTime(), UrlResponse(HendelseTekstType.VIS_BREVET_LENKETEKST, vedtaksfilUrl)))
     }

diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/klage/FiksIOConfig.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/klage/FiksIOConfig.kt
@@ -0,0 +1,51 @@
+package no.nav.sosialhjelp.innsyn.klage
+
+import no.ks.fiks.io.client.konfigurasjon.FiksIOKonfigurasjon
+import no.ks.fiks.io.client.konfigurasjon.KontoKonfigurasjon
+import no.ks.fiks.io.client.konfigurasjon.VirksomhetssertifikatKonfigurasjon
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Profile
+import java.security.KeyStore
+import java.util.UUID
+
+@Configuration
+@Profile("!local")
+class FiksIOConfig(
+    private val kontoKonfigurasjon: KontoKonfigurasjon,
+    @Value("\${fiks-io.integrasjonspassord}")
+    private val integrasjonspassord: String,
+    @Value("\${fiks-io.integrasjonid}")
+    private val integrasjonId: String,
+    @Value("\${MASKINPORTEN_CLIENT_ID}")
+    private val maskinportenClientId: String,
+) {
+
+    private val virksomhetssertifikatKonfigurasjon =
+        VirksomhetssertifikatKonfigurasjon.builder().keyStore(KeyStore.getInstance("pkcs12")).keyStorePassword("bogus").keyAlias("bogus").keyPassword("bogus").build()
+
+    @Bean
+    @Profile("!prod")
+    fun fiksIOTestConfig(): FiksIOKonfigurasjon {
+        val integrasjonId = UUID.fromString(integrasjonId)
+
+        return FiksIOKonfigurasjon.defaultTestConfiguration(
+            maskinportenClientId, integrasjonId, integrasjonspassord,
+            kontoKonfigurasjon,
+            virksomhetssertifikatKonfigurasjon
+        )
+    }
+
+    @Bean
+    @Profile("prod")
+    fun fiksIOProdConfig(): FiksIOKonfigurasjon {
+        val integrasjonId = UUID.fromString(integrasjonId)
+
+        return FiksIOKonfigurasjon.defaultProdConfiguration(
+            maskinportenClientId, integrasjonId, integrasjonspassord,
+            kontoKonfigurasjon,
+            virksomhetssertifikatKonfigurasjon
+        )
+    }
+}
diff --git a/src/main/kotlin/no/nav/sosialhjelp/innsyn/klage/FiksIoKontoConfig.kt b/src/main/kotlin/no/nav/sosialhjelp/innsyn/klage/FiksIoKontoConfig.kt
@@ -0,0 +1,32 @@
+package no.nav.sosialhjelp.innsyn.klage
+
+import no.ks.fiks.io.client.konfigurasjon.KontoKonfigurasjon
+import no.ks.fiks.io.client.model.KontoId
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Profile
+import java.nio.file.Files
+import java.security.KeyFactory
+import java.security.spec.PKCS8EncodedKeySpec
+import java.util.UUID
+import kotlin.io.path.Path
+
+@Configuration
+@Profile("!local")
+class FiksIoKontoConfig(
+    @Value("\${fiks-io.private-key-path}")
+    private val privateKeyPath: String,
+    @Value("\${fiks-io.kontoId}")
+    private val kontoId: String,
+
+) {
+    @Bean
+    fun kontoKonfigurasjon(): KontoKonfigurasjon {
+        val kontoId = KontoId(UUID.fromString(kontoId))
+        val key = Files.readAllBytes(Path(privateKeyPath))
+        val keySpec = PKCS8EncodedKeySpec(key)
+        val privateKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec)
+        return KontoKonfigurasjon.builder().kontoId(kontoId).privatNokkel(privateKey).build()
+    }
+}