Oppdaterte til siste versjon av bekreftelse schema

navikt · Oct 21, 2024 · fa3162e · fa3162e
1 parent 9867510
commit fa3162e
Show file tree

Hide file tree

Showing 9 changed files with 22 additions and 18 deletions.
diff --git a/apps/bekreftelse-api/nais/nais-dev.yaml b/apps/bekreftelse-api/nais/nais-dev.yaml
@@ -10,7 +10,7 @@ spec:
   port: 8080
   env:
     - name: KAFKA_PAW_ARBEIDSSOKER_BEKREFTELSE_TOPIC
-      value: "paw.arbeidssoker-bekreftelse-beta-v1"
+      value: "paw.arbeidssoker-bekreftelse-beta-v2"
     - name: KAFKA_PAW_ARBEIDSSOKER_BEKREFTELSE_HENDELSESLOGG_TOPIC
       value: "paw.arbeidssoker-bekreftelse-hendelseslogg-beta-v2"
     - name: CORS_ALLOW_ORIGINS

diff --git a/...kreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/model/MottaBekreftelseRequest.kt b/...kreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/model/MottaBekreftelseRequest.kt
@@ -2,6 +2,7 @@ package no.nav.paw.bekreftelse.api.model
 
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseTilgjengelig
 import no.nav.paw.bekreftelse.melding.v1.Bekreftelse
+import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning
 import no.nav.paw.bekreftelse.melding.v1.vo.Bruker
 import no.nav.paw.bekreftelse.melding.v1.vo.Metadata
 import no.nav.paw.bekreftelse.melding.v1.vo.Svar
@@ -21,10 +22,10 @@ fun BekreftelseTilgjengelig.asBekreftelse(
     bruker: Bruker,
     kilde: String,
     aarsak: String,
-    namespace: String
+    bekreftelsesloesning: Bekreftelsesloesning
 ): Bekreftelse {
     return Bekreftelse.newBuilder()
-        .setNamespace(namespace)
+        .setBekreftelsesloesning(bekreftelsesloesning)
         .setId(bekreftelseId)
         .setPeriodeId(periodeId)
         .setSvar(

diff --git a/...bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/services/BekreftelseService.kt b/...bekreftelse-api/src/main/kotlin/no/nav/paw/bekreftelse/api/services/BekreftelseService.kt
@@ -31,8 +31,8 @@ import no.nav.paw.bekreftelse.internehendelser.BekreftelseMeldingMottatt
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseTilgjengelig
 import no.nav.paw.bekreftelse.internehendelser.PeriodeAvsluttet
 import no.nav.paw.bekreftelse.internehendelser.meldingMottattHendelseType
+import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning
 import no.nav.paw.config.env.appImageOrDefaultForLocal
-import no.nav.paw.config.env.namespaceOrDefaultForLocal
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.jetbrains.exposed.sql.transactions.transaction
 
@@ -65,7 +65,6 @@ class BekreftelseService(
             meterRegistry.receiveBekreftelseCounter(meldingMottattHendelseType)
 
             val kilde = serverConfig.runtimeEnvironment.appImageOrDefaultForLocal()
-            val namespace = serverConfig.runtimeEnvironment.namespaceOrDefaultForLocal()
 
             val bekreftelse = bekreftelseRepository.getByBekreftelseId(request.bekreftelseId)
             if (bekreftelse != null) {
@@ -78,8 +77,8 @@ class BekreftelseService(
                     request.vilFortsetteSomArbeidssoeker,
                     innloggetBruker.asBruker(),
                     kilde,
-                    "Mottok bekreftelse", // TODO Hva skal dette være
-                    namespace
+                    "Bekreftelse levert",
+                    Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET
                 )
 
                 logger.debug("Sletter bekreftelse fra database")

diff --git a/apps/bekreftelse-tjeneste/nais/nais-dev.yaml b/apps/bekreftelse-tjeneste/nais/nais-dev.yaml
@@ -12,7 +12,7 @@ spec:
     - name: KAFKA_STREAMS_ID_SUFFIX
       value: "v3"
     - name: KAFKA_PAW_ARBEIDSSOKER_BEKREFTELSE_TOPIC
-      value: "paw.arbeidssoker-bekreftelse-beta-v1"
+      value: "paw.arbeidssoker-bekreftelse-beta-v2"
     - name: KAFKA_PAW_ARBEIDSSOKER_BEKREFTELSE_HENDELSELOGG_TOPIC
       value: "paw.arbeidssoker-bekreftelse-hendelseslogg-beta-v2"
     - name: KAFKA_PAW_ARBEIDSSOKERPERIODER_TOPIC

diff --git a/...lse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelseStream.kt b/...lse-tjeneste/src/main/kotlin/no/nav/paw/bekreftelsetjeneste/topology/BekreftelseStream.kt
@@ -10,6 +10,7 @@ import no.nav.paw.bekreftelse.internehendelser.BaOmAaAvsluttePeriode
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelse
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseHendelseSerde
 import no.nav.paw.bekreftelse.internehendelser.BekreftelseMeldingMottatt
+import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning
 import no.nav.paw.bekreftelsetjeneste.config.ApplicationConfig
 import no.nav.paw.bekreftelsetjeneste.tilstand.*
 import no.nav.paw.config.kafka.streams.Punctuation
@@ -47,7 +48,7 @@ fun StreamsBuilder.buildBekreftelseStream(applicationConfig: ApplicationConfig)
                     return@genericProcess
                 }
 
-                if (record.value().namespace == "paw") {
+                if (record.value().bekreftelsesloesning == Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET) {
                     val (nyTilstand, hendelser) = processPawNamespace(record.value(), gjeldendeTilstand)
                     if (nyTilstand != gjeldendeTilstand) {
                         stateStore.put(gjeldendeTilstand.periode.periodeId, nyTilstand)

diff --git a/...else-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelsePunctuatorTest.kt b/...else-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelsePunctuatorTest.kt
@@ -13,6 +13,7 @@ import no.nav.paw.bekreftelse.internehendelser.BekreftelseTilgjengelig
 import no.nav.paw.bekreftelse.internehendelser.LeveringsfristUtloept
 import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeGjenstaaendeTid
 import no.nav.paw.bekreftelse.internehendelser.RegisterGracePeriodeUtloept
+import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning
 import no.nav.paw.bekreftelse.melding.v1.vo.BrukerType
 import no.nav.paw.bekreftelse.melding.v1.vo.Metadata
 import no.nav.paw.bekreftelse.melding.v1.vo.Svar
@@ -179,7 +180,7 @@ class BekreftelsePunctuatorTest : FreeSpec({
                 val currentState = stateStore.get(periode.id)
                 bekreftelseTopic.pipeInput(
                     key, no.nav.paw.bekreftelse.melding.v1.Bekreftelse(
-                        periode.id, "paw", currentState.bekreftelser.first().bekreftelseId, Svar(
+                        periode.id, Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET, currentState.bekreftelser.first().bekreftelseId, Svar(
                             Metadata(
                                 Instant.now(), no.nav.paw.bekreftelse.melding.v1.vo.Bruker(
                                     BrukerType.SLUTTBRUKER, "12345678901"
@@ -227,7 +228,7 @@ class BekreftelsePunctuatorTest : FreeSpec({
                 val currentState = stateStore.get(periode.id)
                 bekreftelseTopic.pipeInput(
                     key, no.nav.paw.bekreftelse.melding.v1.Bekreftelse(
-                        periode.id, "paw", currentState.bekreftelser.first().bekreftelseId, Svar(
+                        periode.id, Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET, currentState.bekreftelser.first().bekreftelseId, Svar(
                             Metadata(
                                 Instant.now(), no.nav.paw.bekreftelse.melding.v1.vo.Bruker(
                                     BrukerType.SLUTTBRUKER, "12345678901"

diff --git a/...reftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelseStreamTest.kt b/...reftelse-tjeneste/src/test/kotlin/no/nav/paw/bekreftelsetjeneste/BekreftelseStreamTest.kt
@@ -11,6 +11,7 @@ import no.nav.paw.arbeidssoekerregisteret.testdata.kafkaKeyContext
 import no.nav.paw.arbeidssoekerregisteret.testdata.mainavro.metadata
 import no.nav.paw.arbeidssoekerregisteret.testdata.mainavro.periode
 import no.nav.paw.bekreftelse.internehendelser.*
+import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning
 import no.nav.paw.bekreftelsetjeneste.tilstand.*
 import no.nav.paw.test.assertEvent
 import no.nav.paw.test.seconds
@@ -26,7 +27,7 @@ class BekreftelseStreamTest : FreeSpec({
         with(ApplicationTestContext(initialWallClockTime = startTime)) {
             val bekreftelseMelding = bekreftelseMelding(
                 periodeId = UUID.randomUUID(),
-                namespace = "tullball",
+                bekreftelsesloesning = Bekreftelsesloesning.DAGPENGER,
                 gjelderFra = Instant.now(),
                 gjelderTil = Instant.now(),
                 harJobbetIDennePerioden = true,
@@ -69,7 +70,7 @@ class BekreftelseStreamTest : FreeSpec({
                 val bekreftelseMelding = bekreftelseMelding(
                     id = bekreftelseId,
                     periodeId = periode.id,
-                    namespace = "paw",
+                    bekreftelsesloesning = Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET,
                     gjelderFra = startTime,
                     gjelderTil = startTime.plus(interval),
                     harJobbetIDennePerioden = true,
@@ -135,7 +136,7 @@ class BekreftelseStreamTest : FreeSpec({
                 val bekreftelseMelding = bekreftelseMelding(
                     id = bekreftelseId,
                     periodeId = periode.id,
-                    namespace = "paw",
+                    bekreftelsesloesning = Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET,
                     gjelderFra = startTime,
                     gjelderTil = fristForNesteBekreftelse(periode.startet.tidspunkt, interval, startTime),
                     harJobbetIDennePerioden = true,
@@ -200,7 +201,7 @@ class BekreftelseStreamTest : FreeSpec({
                 val bekreftelseMelding = bekreftelseMelding(
                     id = bekreftelseId,
                     periodeId = periode.id,
-                    namespace = "paw",
+                    bekreftelsesloesning = Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET,
                     gjelderFra = startTime,
                     gjelderTil = fristForNesteBekreftelse(periode.startet.tidspunkt, interval, startTime),
                     harJobbetIDennePerioden = true,

diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
@@ -2,7 +2,7 @@
 pawPdlClientVersion = "24.10.18.41-1"
 pawAaregClientVersion = "24.07.04.18-1"
 arbeidssokerregisteretVersion = "1.9348086045.48-1"
-bekreftelseSchemaVersion = "24.09.16.1-1"
+bekreftelseSchemaVersion = "24.10.21.12-1"
 arrowVersion = "1.2.4"
 arrowJacksonIntegrationVersion = "0.14.1"
 noNavCommonVersion = "3.2024.05.23_05.46-2b29fa343e8e"

diff --git a/...in/no/nav/paw/arbeidssoekerregisteret/testdata/bekreftelse/BekreftelseMeldingGenerator.kt b/...in/no/nav/paw/arbeidssoekerregisteret/testdata/bekreftelse/BekreftelseMeldingGenerator.kt
@@ -1,6 +1,7 @@
 package no.nav.paw.arbeidssoekerregisteret.testdata.bekreftelse
 
 import no.nav.paw.bekreftelse.melding.v1.Bekreftelse
+import no.nav.paw.bekreftelse.melding.v1.vo.Bekreftelsesloesning
 import no.nav.paw.bekreftelse.melding.v1.vo.Bruker
 import no.nav.paw.bekreftelse.melding.v1.vo.BrukerType
 import no.nav.paw.bekreftelse.melding.v1.vo.Svar
@@ -11,7 +12,7 @@ import java.util.*
 fun bekreftelseMelding(
     id: UUID = UUID.randomUUID(),
     periodeId: UUID = UUID.randomUUID(),
-    namespace: String = "paw",
+    bekreftelsesloesning: Bekreftelsesloesning = Bekreftelsesloesning.ARBEIDSSOEKERREGISTERET,
     gjelderFra: Instant = Instant.now(),
     gjelderTil: Instant = Instant.now(),
     harJobbetIDennePerioden: Boolean = true,
@@ -20,7 +21,7 @@ fun bekreftelseMelding(
     Bekreftelse
         .newBuilder()
         .setPeriodeId(periodeId)
-        .setNamespace(namespace)
+        .setBekreftelsesloesning(bekreftelsesloesning)
         .setId(id)
         .setSvar(
             Svar