Merge branch 'main' into dev/feillytter-kun-events

navikt · Nov 7, 2024 · a9359aa · a9359aa
2 parents eb21d34 + 3b83891
commit a9359aa
Show file tree

Hide file tree

Showing 26 changed files with 102 additions and 485 deletions.
diff --git a/config/nais.yml b/config/nais.yml
@@ -58,6 +58,9 @@ spec:
   gcp:
     sqlInstances:
       - type: POSTGRES_14
+        {{#if database.cascadingDelete}}
+        cascadingDelete: {{ database.cascadingDelete }}
+        {{/if}}
         tier: {{ database.tier }}
         databases:
           - name: {{ database.name }}
@@ -73,9 +76,10 @@ spec:
   {{/if}}
   {{#if envFrom}}
   envFrom:
-  {{# each envFrom as |item| }}
+    {{# each envFrom as |item| }}
     - {{ item.type }}: {{ item.name }}
-  {{/each}}{{/if}}
+    {{/each}}
+  {{/if}}
   env:
     - name: KAFKA_CONSUMER_GROUP_ID
       value: helsearbeidsgiver-im-{{app}}-v1

diff --git a/config/notifikasjon/dev-gcp.yml b/config/notifikasjon/dev-gcp.yml
@@ -5,11 +5,10 @@ database:
   name: notifikasjon
   tier: db-custom-1-3840
   logicalDecoding: true
+  cascadingDelete: true
 envFrom:
   - type: secret
     name: google-sql-im-notifikasjon
-secureLogs:
-  enabled: true
 env:
   - name: ARBEIDSGIVER_NOTIFIKASJON_API_URL
     value: "http://notifikasjon-produsent-api.fager/api/graphql"

diff --git a/config/notifikasjon/prod-gcp.yml b/config/notifikasjon/prod-gcp.yml
@@ -5,11 +5,10 @@ database:
   name: notifikasjon
   tier: db-custom-1-3840
   logicalDecoding: true
+  cascadingDelete: true
 envFrom:
   - type: secret
     name: google-sql-im-notifikasjon
-secureLogs:
-  enabled: true
 env:
   - name: ARBEIDSGIVER_NOTIFIKASJON_API_URL
     value: "http://notifikasjon-produsent-api.fager/api/graphql"

diff --git a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/App.kt b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/App.kt
@@ -7,7 +7,6 @@ import no.nav.helsearbeidsgiver.felles.rapidsrivers.registerShutdownLifecycle
 import no.nav.helsearbeidsgiver.inntektsmelding.db.river.HentLagretImRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.db.river.HentSelvbestemtImRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.db.river.LagreEksternImRiver
-import no.nav.helsearbeidsgiver.inntektsmelding.db.river.LagreForespoerselRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.db.river.LagreImRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.db.river.LagreImSkjemaRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.db.river.LagreJournalpostIdRiver
@@ -25,11 +24,10 @@ fun main() {
 
     val imRepo = InntektsmeldingRepository(database.db)
     val selvbestemtImRepo = SelvbestemtImRepo(database.db)
-    val forespoerselRepo = ForespoerselRepository(database.db)
 
     return RapidApplication
         .create(System.getenv())
-        .createDbRivers(imRepo, selvbestemtImRepo, forespoerselRepo)
+        .createDbRivers(imRepo, selvbestemtImRepo)
         .registerShutdownLifecycle {
             logger.info("Stoppsignal mottatt, lukker databasetilkobling.")
             database.dataSource.close()
@@ -39,12 +37,8 @@ fun main() {
 fun RapidsConnection.createDbRivers(
     imRepo: InntektsmeldingRepository,
     selvbestemtImRepo: SelvbestemtImRepo,
-    forespoerselRepo: ForespoerselRepository,
 ): RapidsConnection =
     also {
-        logger.info("Starter ${LagreForespoerselRiver::class.simpleName}...")
-        LagreForespoerselRiver(forespoerselRepo).connect(this)
-
         logger.info("Starter ${HentLagretImRiver::class.simpleName}...")
         HentLagretImRiver(imRepo).connect(this)
 

diff --git a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/ForespoerselRepository.kt b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/ForespoerselRepository.kt
diff --git a/...c/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/LagreForespoerselRiver.kt b/...c/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/river/LagreForespoerselRiver.kt
diff --git a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/tabell/ForespoerselEntitet.kt b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/tabell/ForespoerselEntitet.kt
diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/EventTypes.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/EventTypes.kt
@@ -22,9 +22,6 @@ enum class BehovType {
     LAGRE_IM,
     LAGRE_SELVBESTEMT_IM,
     OPPRETT_SELVBESTEMT_SAK,
-
-    // Asynkrone endringer
-    LAGRE_FORESPOERSEL, // TODO slett etter databasen er flyttet
 }
 
 @Serializable

diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/metrics/Metrics.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/metrics/Metrics.kt
@@ -22,8 +22,6 @@ object Metrics {
 
     val dbSelvbestemtIm = databaseMetric("inntektsmelding", "selvbestemt_inntektsmelding")
 
-    val dbSelvbestemtSak = databaseMetric("notifikasjon", "selvbestemt_sak")
-
     val aaregRequest = requestMetric("Aareg")
 
     val altinnRequest = requestMetric("Altinn")

diff --git a/.../no/nav/helsearbeidsgiver/inntektsmelding/forespoerselmottatt/ForespoerselMottattRiver.kt b/.../no/nav/helsearbeidsgiver/inntektsmelding/forespoerselmottatt/ForespoerselMottattRiver.kt
@@ -18,18 +18,14 @@ import no.nav.helsearbeidsgiver.utils.json.toJson
 import no.nav.helsearbeidsgiver.utils.json.toPretty
 import no.nav.helsearbeidsgiver.utils.log.logger
 import no.nav.helsearbeidsgiver.utils.log.sikkerLogger
-import no.nav.helsearbeidsgiver.utils.wrapper.Fnr
-import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr
 import java.util.UUID
 
 data class Melding(
     val notisType: Pri.NotisType,
     val transaksjonId: UUID,
     val forespoerselId: UUID,
-    val orgnr: Orgnr,
-    val fnr: Fnr,
-    val skalHaPaaminnelse: Boolean,
     val forespoerselFraBro: ForespoerselFraBro,
+    val skalHaPaaminnelse: Boolean,
 )
 
 /** Tar imot notifikasjon om at det er kommet en forespørsel om arbeidsgiveropplysninger. */
@@ -42,10 +38,8 @@ class ForespoerselMottattRiver : PriObjectRiver<Melding>() {
             notisType = Pri.Key.NOTIS.krev(Pri.NotisType.FORESPØRSEL_MOTTATT, Pri.NotisType.serializer(), json),
             transaksjonId = UUID.randomUUID(),
             forespoerselId = Pri.Key.FORESPOERSEL_ID.les(UuidSerializer, json),
-            orgnr = Pri.Key.ORGNR.les(Orgnr.serializer(), json),
-            fnr = Pri.Key.FNR.les(Fnr.serializer(), json),
-            skalHaPaaminnelse = Pri.Key.SKAL_HA_PAAMINNELSE.les(Boolean.serializer(), json),
             forespoerselFraBro = Pri.Key.FORESPOERSEL.les(ForespoerselFraBro.serializer(), json),
+            skalHaPaaminnelse = Pri.Key.SKAL_HA_PAAMINNELSE.les(Boolean.serializer(), json),
         )
 
     override fun Melding.haandter(json: Map<Pri.Key, JsonElement>): Map<Key, JsonElement> {
@@ -58,12 +52,8 @@ class ForespoerselMottattRiver : PriObjectRiver<Melding>() {
             Key.DATA to
                 mapOf(
                     Key.FORESPOERSEL_ID to forespoerselId.toJson(),
-                    // TODO kan fjernes etter overgangsfase
-                    Key.ORGNRUNDERENHET to orgnr.toJson(),
-                    // TODO kan fjernes etter overgangsfase
-                    Key.FNR to fnr.toJson(),
-                    Key.SKAL_HA_PAAMINNELSE to skalHaPaaminnelse.toJson(Boolean.serializer()),
                     Key.FORESPOERSEL to forespoerselFraBro.toForespoersel().toJson(Forespoersel.serializer()),
+                    Key.SKAL_HA_PAAMINNELSE to skalHaPaaminnelse.toJson(Boolean.serializer()),
                 ).toJson(),
         )
     }

diff --git a/...nav/helsearbeidsgiver/inntektsmelding/forespoerselmottatt/ForespoerselMottattRiverTest.kt b/...nav/helsearbeidsgiver/inntektsmelding/forespoerselmottatt/ForespoerselMottattRiverTest.kt
@@ -54,10 +54,8 @@ class ForespoerselMottattRiverTest :
                     Key.DATA to
                         mapOf(
                             Key.FORESPOERSEL_ID to innkommendeMelding.forespoerselId.toJson(),
-                            Key.ORGNRUNDERENHET to innkommendeMelding.orgnr.toJson(),
-                            Key.FNR to innkommendeMelding.fnr.toJson(),
-                            Key.SKAL_HA_PAAMINNELSE to innkommendeMelding.skalHaPaaminnelse.toJson(Boolean.serializer()),
                             Key.FORESPOERSEL to innkommendeMelding.forespoerselFraBro.toForespoersel().toJson(Forespoersel.serializer()),
+                            Key.SKAL_HA_PAAMINNELSE to innkommendeMelding.skalHaPaaminnelse.toJson(Boolean.serializer()),
                         ).toJson(),
                 )
         }
@@ -68,24 +66,20 @@ private fun mockInnkommendeMelding(): Melding =
         notisType = Pri.NotisType.FORESPØRSEL_MOTTATT,
         transaksjonId = UUID.randomUUID(),
         forespoerselId = UUID.randomUUID(),
-        orgnr = Orgnr.genererGyldig(),
-        fnr = Fnr.genererGyldig(),
-        skalHaPaaminnelse = true,
         forespoerselFraBro = Mock.forespoerselFraBro,
+        skalHaPaaminnelse = true,
     )
 
 private fun Melding.toMap(): Map<Pri.Key, JsonElement> =
     mapOf(
         Pri.Key.NOTIS to notisType.toJson(Pri.NotisType.serializer()),
         Pri.Key.FORESPOERSEL_ID to forespoerselId.toJson(),
-        Pri.Key.ORGNR to orgnr.toJson(),
-        Pri.Key.FNR to fnr.toJson(),
-        Pri.Key.SKAL_HA_PAAMINNELSE to skalHaPaaminnelse.toJson(Boolean.serializer()),
         Pri.Key.FORESPOERSEL to forespoerselFraBro.toJson(ForespoerselFraBro.serializer()),
+        Pri.Key.SKAL_HA_PAAMINNELSE to skalHaPaaminnelse.toJson(Boolean.serializer()),
     )
 
 object Mock {
-    val orgnr = Orgnr.genererGyldig()
+    private val orgnr = Orgnr.genererGyldig()
     val forespoerselFraBro =
         ForespoerselFraBro(
             orgnr = orgnr,