Test for dialogportenservice

Author: magnusae

.nais/dev.yaml

@@ -59,7 +59,7 @@ spec:
     - name: DIALOGPORTEN_SCOPE
       value: "digdir:dialogporten.serviceprovider"
     - name: NAV_ARBEIDSGIVER_API_BASEURL
-      value: "https://sykepenger-im-lps-api.ekstern.dev.nav.no"
+      value: "https://sykepenger-api.ekstern.dev.nav.no"
     - name: DIALOG_KAFKA_TOPIC
       value: helsearbeidsgiver.dialog
 

src/main/kotlin/App.kt

@@ -32,11 +32,14 @@ fun startServer() {
     logger.info("Setter opp DialogportenService...")
     val dialogportenClient =
         DialogportenClient(
-            baseUrl = Env.altinnBaseUrl,
-            ressurs = Env.altinnImRessurs,
+            baseUrl = Env.Altinn.altinnBaseUrl,
+            ressurs = Env.Altinn.altinnImRessurs,
             getToken = authClient.dialogportenTokenGetter(),
         )
 
+    logger.info("Setter opp DialogRepository...")
+    val dialogRepository = DialogRepository(database.db)
+
     logger.info("Starter server...")
     embeddedServer(
         factory = Netty,
@@ -46,7 +49,11 @@ fun startServer() {
                 meldingTolker =
                     MeldingTolker(
                         unleashFeatureToggles = unleashFeatureToggles,
-                        dialogportenService = DialogportenService(dialogportenClient),
+                        dialogportenService =
+                            DialogportenService(
+                                dialogportenClient,
+                                dialogRepository,
+                            ),
                     ),
             )
         },

src/main/kotlin/Env.kt

@@ -28,15 +28,19 @@ object Env {
         val name = "${databasePrefix}_DATABASE".fromEnv()
     }
 
-    val navArbeidsgiverApiBaseUrl = "NAV_ARBEIDSGIVER_API_BASEURL".fromEnv()
-    val altinnBaseUrl = "ALTINN_3_BASE_URL".fromEnv()
-    val altinnImRessurs = "ALTINN_IM_RESSURS".fromEnv()
-    val tokenEndpoint = "NAIS_TOKEN_ENDPOINT".fromEnv()
-    val tokenAltinn3ExchangeEndpoint = "${"ALTINN_3_BASE_URL".fromEnv()}/authentication/api/v1/exchange/maskinporten"
+    object Nav {
+        val arbeidsgiverApiBaseUrl = "arbeidsgiver.baseUrl".fromEnv()
+        val naisTokenEndpoint = "NAIS_TOKEN_ENDPOINT".fromEnv()
+    }
 
-    val dialogportenScope = "DIALOGPORTEN_SCOPE".fromEnv()
+    object Altinn {
+        val altinnBaseUrl = "ALTINN_3_BASE_URL".fromEnv()
+        val altinnImRessurs = "ALTINN_IM_RESSURS".fromEnv()
+        val tokenAltinn3ExchangeEndpoint = "${"ALTINN_3_BASE_URL".fromEnv()}/authentication/api/v1/exchange/maskinporten"
+        val dialogportenScope = "DIALOGPORTEN_SCOPE".fromEnv()
+    }
 
-    private fun String.fromEnv(): String =
+    fun String.fromEnv(): String =
         System.getenv(this)
             ?: appConfig.propertyOrNull(this)?.getString()
             ?: throw RuntimeException("Missing required environment variable \"$this\".")

src/main/kotlin/auth/AuthClient.kt

@@ -27,7 +27,7 @@ class AuthClient {
         try {
             httpClient
                 .submitForm(
-                    url = Env.tokenEndpoint,
+                    url = Env.Nav.naisTokenEndpoint,
                     formParameters =
                         parameters {
                             append("identity_provider", "maskinporten")
@@ -40,7 +40,7 @@ class AuthClient {
 
     suspend fun altinnExchange(token: String): String =
         httpClient
-            .get(Env.tokenAltinn3ExchangeEndpoint) {
+            .get(Env.Altinn.tokenAltinn3ExchangeEndpoint) {
                 bearerAuth(token)
             }.bodyAsText()
             .replace("\"", "")
@@ -64,4 +64,4 @@ private fun AuthClient.hentAltinnToken(target: String): () -> String {
     }
 }
 
-fun AuthClient.dialogportenTokenGetter() = hentAltinnToken(Env.dialogportenScope)
+fun AuthClient.dialogportenTokenGetter() = hentAltinnToken(Env.Altinn.dialogportenScope)

src/main/kotlin/dialogporten/DialogportenService.kt

@@ -1,33 +1,60 @@
 package no.nav.helsearbeidsgiver.dialogporten
 
 import kotlinx.coroutines.runBlocking
+import no.nav.helsearbeidsgiver.DialogRepository
 import no.nav.helsearbeidsgiver.Env
+import no.nav.helsearbeidsgiver.Env.fromEnv
 import no.nav.helsearbeidsgiver.kafka.Sykepengesoknad
 import no.nav.helsearbeidsgiver.kafka.Sykmelding
 import no.nav.helsearbeidsgiver.kafka.Sykmeldingsperiode
+import no.nav.helsearbeidsgiver.utils.log.logger
 import no.nav.helsearbeidsgiver.utils.tilNorskFormat
+import no.nav.helsearbeidsgiver.utils.toUuid
 import java.util.UUID
 
 class DialogportenService(
     private val dialogportenClient: DialogportenClient,
+    private val dialogRepository: DialogRepository,
 ) {
-    fun opprettNyDialogMedSykmelding(sykmelding: Sykmelding): String =
+    private val logger = logger()
+
+    fun behandleSykmelding(sykmelding: Sykmelding) {
+        val dialogId = opprettNyDialogMedSykmelding(sykmelding)
+        dialogRepository.lagreDialog(dialogId = dialogId, sykmeldingId = sykmelding.sykmeldingId)
+    }
+
+    fun behandleSykepengesoknad(sykepengesoknad: Sykepengesoknad) {
+        when (val dialogId = dialogRepository.finnDialogId(sykmeldingId = sykepengesoknad.sykmeldingId)) {
+            null ->
+                logger.warn(
+                    "Fant ikke dialog for sykmeldingId ${sykepengesoknad.sykmeldingId}. " +
+                        "Klarer derfor ikke oppdatere dialogen med sykepengesøknad ${sykepengesoknad.soknadId}.",
+                )
+
+            else -> oppdaterDialogMedSykepengesoknad(dialogId = dialogId, sykepengesoknad = sykepengesoknad)
+        }
+    }
+
+    private fun opprettNyDialogMedSykmelding(sykmelding: Sykmelding): UUID =
         runBlocking {
             dialogportenClient
                 .opprettDialogMedSykmelding(
                     orgnr = sykmelding.orgnr.toString(),
                     dialogTittel = "Sykepenger for ${sykmelding.fulltNavn} (f. ${sykmelding.foedselsdato.tilNorskFormat()})",
                     dialogSammendrag = sykmelding.sykmeldingsperioder.getSykmeldingsPerioderString(),
                     sykmeldingId = sykmelding.sykmeldingId,
-                    sykmeldingJsonUrl = "${Env.navArbeidsgiverApiBaseUrl}/sykmelding/${sykmelding.sykmeldingId}",
+                    sykmeldingJsonUrl = "${"arbeidsgiver.baseUrl".fromEnv()}/sykmelding/${sykmelding.sykmeldingId}",
                 )
-        }
+        }.toUuid()
 
-    fun oppdaterDialogMedSykepengesoknad(sykepengesoknad: Sykepengesoknad) {
+    private fun oppdaterDialogMedSykepengesoknad(
+        dialogId: UUID,
+        sykepengesoknad: Sykepengesoknad,
+    ) {
         runBlocking {
             dialogportenClient.oppdaterDialogMedSykepengesoknad(
-                dialogId = UUID.randomUUID(), // TODO: Hent dialogId fra database,
-                soknadJsonUrl = "${Env.navArbeidsgiverApiBaseUrl}/soknad/${sykepengesoknad.soknadId}",
+                dialogId = dialogId,
+                soknadJsonUrl = "${Env.Nav.arbeidsgiverApiBaseUrl}/soknad/${sykepengesoknad.soknadId}",
             )
         }
     }

src/main/kotlin/kafka/MeldingTolker.kt

@@ -28,7 +28,7 @@ class MeldingTolker(
                 is Sykmelding -> {
                     if (unleashFeatureToggles.skalOppretteDialogVedMottattSykmelding(orgnr = dekodetMelding.orgnr)) {
                         logger.info("Oppretter dialog for sykmelding.")
-                        dialogportenService.opprettNyDialogMedSykmelding(sykmelding = dekodetMelding)
+                        dialogportenService.behandleSykmelding(sykmelding = dekodetMelding)
                     } else {
                         logger.info("Feature toggle for dialogopprettelse for sykmelding er avskrudd, ignorerer melding.")
                     }
@@ -37,7 +37,7 @@ class MeldingTolker(
                 is Sykepengesoknad -> {
                     if (unleashFeatureToggles.skalOppdatereDialogVedMottattSoknad(orgnr = dekodetMelding.orgnr)) {
                         logger.info("Oppdaterer dialog med sykepengesøknad.")
-                        dialogportenService.oppdaterDialogMedSykepengesoknad(sykepengesoknad = dekodetMelding)
+                        dialogportenService.behandleSykepengesoknad(sykepengesoknad = dekodetMelding)
                     } else {
                         logger.info("Feature toggle for oppdatering av dialog med sykepengesøknad er avskrudd, ignorerer melding.")
                     }

src/main/kotlin/utils/UuidUtils.kt

@@ -0,0 +1,5 @@
+package no.nav.helsearbeidsgiver.utils
+
+import java.util.UUID
+
+fun String.toUuid(): UUID = UUID.fromString(this)

src/main/resources/application.conf

@@ -3,3 +3,8 @@ kafkaConsumer {
     topic = helsearbeidsgiver.dialog
   }
 }
+
+arbeidsgiver {
+  baseUrl = "https://sykepenger1-api.ekstern.dev.nav.no"
+  baseUrl = ${?NAV_ARBEIDSGIVER_API_BASEURL}
+}

src/test/kotlin/DialogportenServiceTest.kt

@@ -0,0 +1,47 @@
+import io.kotest.core.spec.style.FunSpec
+import io.mockk.Runs
+import io.mockk.coEvery
+import io.mockk.coVerify
+import io.mockk.every
+import io.mockk.just
+import io.mockk.mockk
+import io.mockk.verify
+import no.nav.helsearbeidsgiver.DialogRepository
+import no.nav.helsearbeidsgiver.dialogporten.DialogportenClient
+import no.nav.helsearbeidsgiver.dialogporten.DialogportenService
+import java.util.UUID
+
+class DialogportenServiceTest :
+    FunSpec({
+        val dialogportenClientMock = mockk<DialogportenClient>()
+        val dialogRepositoryMock = mockk<DialogRepository>()
+        val dialogportenService = DialogportenService(dialogportenClientMock, dialogRepositoryMock)
+
+        test("behandler sykmelding") {
+            val dialogId = UUID.randomUUID()
+            coEvery {
+                dialogportenClientMock.opprettDialogMedSykmelding(
+                    any(),
+                    any(),
+                    any(),
+                    any(),
+                    any(),
+                )
+            } returns dialogId.toString()
+
+            every { dialogRepositoryMock.lagreDialog(any(), any()) } just Runs
+
+            dialogportenService.behandleSykmelding(sykmelding)
+
+            coVerify(exactly = 1) {
+                dialogportenClientMock.opprettDialogMedSykmelding(
+                    any(),
+                    any(),
+                    any(),
+                    any(),
+                    any(),
+                )
+            }
+            verify(exactly = 1) { dialogRepositoryMock.lagreDialog(any(), any()) }
+        }
+    })

src/test/kotlin/MeldingTolkerTest.kt

@@ -7,41 +7,51 @@ import io.mockk.verify
 import no.nav.helsearbeidsgiver.dialogporten.DialogportenService
 import no.nav.helsearbeidsgiver.kafka.Melding
 import no.nav.helsearbeidsgiver.kafka.MeldingTolker
-import no.nav.helsearbeidsgiver.kafka.Sykmelding
-import no.nav.helsearbeidsgiver.kafka.Sykmeldingsperiode
+import no.nav.helsearbeidsgiver.kafka.Sykepengesoknad
 import no.nav.helsearbeidsgiver.utils.UnleashFeatureToggles
 import no.nav.helsearbeidsgiver.utils.json.toJson
 import no.nav.helsearbeidsgiver.utils.test.wrapper.genererGyldig
 import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr
-import java.time.LocalDate
 import java.util.UUID
 
 class MeldingTolkerTest :
     FunSpec({
-        test("Opprett dialog ved gyldig sykmelding") {
+        test("Behandle gyldig sykmelding") {
             val orgnr = Orgnr.genererGyldig()
-            val sykmelding =
-                Sykmelding(
+            val melding = sykmelding.toJson(Melding.serializer()).toString()
+
+            val dialogportenServiceMock = mockk<DialogportenService>()
+            val unleashFeatureTogglesMock = mockk<UnleashFeatureToggles>()
+
+            every { dialogportenServiceMock.behandleSykmelding(any()) } just Runs
+            every { unleashFeatureTogglesMock.skalOppretteDialogVedMottattSykmelding(orgnr) } returns true
+
+            val meldingTolker =
+                MeldingTolker(
+                    unleashFeatureToggles = unleashFeatureTogglesMock,
+                    dialogportenService = dialogportenServiceMock,
+                )
+
+            meldingTolker.lesMelding(melding)
+
+            verify(exactly = 1) { dialogportenServiceMock.behandleSykmelding(sykmelding) }
+        }
+
+        test("Behandle gyldig sykepengesøknad") {
+            val orgnr = Orgnr.genererGyldig()
+            val sykepengesoknad =
+                Sykepengesoknad(
+                    soknadId = UUID.randomUUID(),
                     sykmeldingId = UUID.randomUUID(),
                     orgnr = orgnr,
-                    foedselsdato = LocalDate.of(1990, 1, 1),
-                    fulltNavn = "OLA NORDMANN",
-                    sykmeldingsperioder =
-                        listOf(
-                            Sykmeldingsperiode(
-                                fom = LocalDate.of(2023, 1, 1),
-                                tom = LocalDate.of(2023, 1, 31),
-                            ),
-                        ),
                 )
-            val melding = sykmelding.toJson(Melding.serializer()).toString()
+            val melding = sykepengesoknad.toJson(Melding.serializer()).toString()
 
             val dialogportenServiceMock = mockk<DialogportenService>()
             val unleashFeatureTogglesMock = mockk<UnleashFeatureToggles>()
 
-            every { dialogportenServiceMock.opprettNyDialogMedSykmelding(any()) } returns "123"
-            every { dialogportenServiceMock.oppdaterDialogMedSykepengesoknad(any()) } just Runs
-            every { unleashFeatureTogglesMock.skalOppretteDialogVedMottattSykmelding(orgnr) } returns true
+            every { dialogportenServiceMock.behandleSykepengesoknad(any()) } just Runs
+            every { unleashFeatureTogglesMock.skalOppdatereDialogVedMottattSoknad(orgnr) } returns true
 
             val meldingTolker =
                 MeldingTolker(
@@ -51,6 +61,6 @@ class MeldingTolkerTest :
 
             meldingTolker.lesMelding(melding)
 
-            verify(exactly = 1) { dialogportenServiceMock.opprettNyDialogMedSykmelding(sykmelding) }
+            verify(exactly = 1) { dialogportenServiceMock.behandleSykepengesoknad(sykepengesoknad) }
         }
     })