Fjern unødvendig lagring av sak-ID for selvbestemt (#751)

config/notifikasjon/dev-gcp.yml

@@ -8,8 +8,6 @@ database:
 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"

config/notifikasjon/prod-gcp.yml

@@ -8,8 +8,6 @@ database:
 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"

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")

integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/utils/ContainerTest.kt

@@ -18,7 +18,6 @@ abstract class ContainerTest {
     val redisContainer = RedisContainer(DockerImageName.parse("redis:7"))
     val postgresContainerOne = postgresContainer()
     val postgresContainerTwo = postgresContainer()
-    val postgresContainerThree = postgresContainer()
 
     @BeforeAll
     fun startContainers() {
@@ -43,7 +42,6 @@ abstract class ContainerTest {
         println("Starter Postgres...")
         postgresContainerOne.start()
         postgresContainerTwo.start()
-        postgresContainerThree.start()
 
         println("Containerne er klare!")
     }
@@ -54,7 +52,6 @@ abstract class ContainerTest {
         kafkaContainer.stop()
         postgresContainerOne.stop()
         postgresContainerTwo.stop()
-        postgresContainerThree.stop()
         redisContainer.stop()
         println("Containere er stoppet!")
     }

integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/utils/EndToEndTest.kt

@@ -60,7 +60,6 @@ import no.nav.helsearbeidsgiver.inntektsmelding.joark.createJournalfoerImRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.PaaminnelseToggle
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.createNotifikasjonRivers
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.createNotifikasjonService
-import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.db.SelvbestemtRepo
 import no.nav.helsearbeidsgiver.inntektsmelding.pdl.createPdlRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.selvbestemthentimservice.createHentSelvbestemtImService
 import no.nav.helsearbeidsgiver.inntektsmelding.selvbestemtlagreimservice.createLagreSelvbestemtImService
@@ -138,31 +137,14 @@ abstract class EndToEndTest : ContainerTest() {
         }
     }
 
-    // Vent på im-notifikasjon database
-    private val notifikasjonDatabase by lazy {
-        println("Database jdbcUrl for im-notifikasjon: ${postgresContainerTwo.jdbcUrl}")
-
-        return@lazy withRetries(
-            feilmelding = "Klarte ikke sette opp notifikasjonDatabase.",
-        ) {
-            postgresContainerTwo
-                .toHikariConfig()
-                .let(::Database)
-                .also {
-                    val migrationLocation = Path("../notifikasjon/src/main/resources/db/migration").absolutePathString()
-                    it.migrate(migrationLocation)
-                }.createTruncateFunction()
-        }
-    }
-
     // Vent på feilbehandlerdatabase
     private val bakgrunnsjobbDatabase by lazy {
-        println("Database jdbcUrl for im-feil-behandler: ${postgresContainerThree.jdbcUrl}")
+        println("Database jdbcUrl for im-feil-behandler: ${postgresContainerTwo.jdbcUrl}")
 
         return@lazy withRetries(
             feilmelding = "Klarte ikke sette opp feilbehandlerdatabase.",
         ) {
-            postgresContainerThree
+            postgresContainerTwo
                 .toHikariConfig()
                 .let(::Database)
                 .also {
@@ -189,8 +171,6 @@ abstract class EndToEndTest : ContainerTest() {
     val selvbestemtImRepo by lazy { SelvbestemtImRepo(inntektsmeldingDatabase.db) }
     private val forespoerselRepository by lazy { ForespoerselRepository(inntektsmeldingDatabase.db) }
 
-    private val selvbestemtRepo by lazy { SelvbestemtRepo(notifikasjonDatabase.db) }
-
     val bakgrunnsjobbRepository by lazy { PostgresBakgrunnsjobbRepository(bakgrunnsjobbDatabase.dataSource) }
 
     val altinnClient = mockk<AltinnClient>()
@@ -261,12 +241,7 @@ abstract class EndToEndTest : ContainerTest() {
             createHentInntektRiver(inntektClient)
             createJournalfoerImRiver(dokarkivClient)
             createMarkerForespoerselBesvart(priProducer)
-            createNotifikasjonRivers(
-                NOTIFIKASJON_LINK,
-                paaminnelseToggle,
-                selvbestemtRepo,
-                agNotifikasjonKlient,
-            )
+            createNotifikasjonRivers(NOTIFIKASJON_LINK, paaminnelseToggle, agNotifikasjonKlient)
             createPdlRiver(pdlKlient)
             createFeilLytter(bakgrunnsjobbRepository)
         }
@@ -276,7 +251,7 @@ abstract class EndToEndTest : ContainerTest() {
     fun afterAllEndToEnd() {
         redisConnection.close()
         inntektsmeldingDatabase.dataSource.close()
-        notifikasjonDatabase.dataSource.close()
+        bakgrunnsjobbDatabase.dataSource.close()
         println("Stopped.")
     }
 
@@ -387,7 +362,7 @@ abstract class EndToEndTest : ContainerTest() {
         transaction(inntektsmeldingDatabase.db) {
             exec("SELECT truncate_tables()")
         }
-        transaction(notifikasjonDatabase.db) {
+        transaction(bakgrunnsjobbDatabase.db) {
             exec("SELECT truncate_tables()")
         }
     }

notifikasjon/build.gradle.kts

@@ -1,9 +1,5 @@
 val arbeidsgiverNotifikasjonKlientVersion: String by project
 
 dependencies {
-    implementation(project(":felles-db-exposed"))
-
     implementation("no.nav.helsearbeidsgiver:arbeidsgiver-notifikasjon-klient:$arbeidsgiverNotifikasjonKlientVersion")
-
-    testImplementation(testFixtures(project(":felles-db-exposed")))
 }

notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/App.kt

@@ -3,10 +3,7 @@ package no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
 import no.nav.helse.rapids_rivers.RapidApplication
 import no.nav.helsearbeidsgiver.arbeidsgivernotifikasjon.ArbeidsgiverNotifikasjonKlient
-import no.nav.helsearbeidsgiver.felles.db.exposed.Database
-import no.nav.helsearbeidsgiver.felles.rapidsrivers.registerShutdownLifecycle
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.service.ServiceRiverStateless
-import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.db.SelvbestemtRepo
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.river.FerdigstillForespoerselSakOgOppgaveRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.river.FjernPaaminnelseRiver
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.river.OpprettForespoerselSakOgOppgaveRiver
@@ -18,26 +15,11 @@ import no.nav.helsearbeidsgiver.utils.log.logger
 private val logger = "im-notifikasjon".logger()
 
 fun main() {
-    val database = Database("NAIS_DATABASE_IM_NOTIFIKASJON_NOTIFIKASJON")
-
-    logger.info("Migrering starter...")
-    database.migrate()
-    logger.info("Migrering ferdig.")
-
-    val selvbestemtRepo = SelvbestemtRepo(database.db)
-
     RapidApplication
         .create(System.getenv())
         .createNotifikasjonService()
-        .createNotifikasjonRivers(
-            linkUrl = Env.linkUrl,
-            paaminnelseToggle = Env.paaminnelseToggle,
-            selvbestemtRepo = selvbestemtRepo,
-            agNotifikasjonKlient = buildClient(),
-        ).registerShutdownLifecycle {
-            logger.info("Stoppsignal mottatt, lukker databasetilkobling.")
-            database.dataSource.close()
-        }.start()
+        .createNotifikasjonRivers(Env.linkUrl, Env.paaminnelseToggle, buildClient())
+        .start()
 }
 
 fun RapidsConnection.createNotifikasjonService(): RapidsConnection =
@@ -51,7 +33,6 @@ fun RapidsConnection.createNotifikasjonService(): RapidsConnection =
 fun RapidsConnection.createNotifikasjonRivers(
     linkUrl: String,
     paaminnelseToggle: PaaminnelseToggle,
-    selvbestemtRepo: SelvbestemtRepo,
     agNotifikasjonKlient: ArbeidsgiverNotifikasjonKlient,
 ): RapidsConnection =
     also {
@@ -63,7 +44,7 @@ fun RapidsConnection.createNotifikasjonRivers(
         ).connect(this)
 
         logger.info("Starter ${OpprettSelvbestemtSakRiver::class.simpleName}...")
-        OpprettSelvbestemtSakRiver(linkUrl, selvbestemtRepo, agNotifikasjonKlient).connect(this)
+        OpprettSelvbestemtSakRiver(linkUrl, agNotifikasjonKlient).connect(this)
 
         logger.info("Starter ${FerdigstillForespoerselSakOgOppgaveRiver::class.simpleName}...")
         FerdigstillForespoerselSakOgOppgaveRiver(linkUrl, agNotifikasjonKlient).connect(this)

notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettSelvbestemtSakRiver.kt

@@ -16,7 +16,6 @@ import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail
 import no.nav.helsearbeidsgiver.felles.rapidsrivers.river.ObjectRiver
 import no.nav.helsearbeidsgiver.felles.utils.Log
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.NotifikasjonTekst
-import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.db.SelvbestemtRepo
 import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.opprettSak
 import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer
 import no.nav.helsearbeidsgiver.utils.json.toJson
@@ -34,7 +33,6 @@ data class OpprettSelvbestemtSakMelding(
 
 class OpprettSelvbestemtSakRiver(
     private val linkUrl: String,
-    private val selvbestemtRepo: SelvbestemtRepo,
     private val agNotifikasjonKlient: ArbeidsgiverNotifikasjonKlient,
 ) : ObjectRiver<OpprettSelvbestemtSakMelding>() {
     private val logger = logger()
@@ -66,8 +64,6 @@ class OpprettSelvbestemtSakRiver(
                 initiellStatus = SaksStatus.FERDIG,
             )
 
-        selvbestemtRepo.lagreSakId(inntektsmelding.type.id, sakId)
-
         return mapOf(
             Key.EVENT_NAME to eventName.toJson(),
             Key.UUID to transaksjonId.toJson(),