Slett sak løser (#365)

navikt · Dec 4, 2023 · a6b7122 · a6b7122
1 parent 991f36e
commit a6b7122
Show file tree

Hide file tree

Showing 4 changed files with 78 additions and 1 deletion.
diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/EventTypes.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/EventTypes.kt
@@ -19,6 +19,7 @@ enum class BehovType {
     DISTRIBUER_IM,
     NOTIFIKASJON_HENT_ID,
     OPPRETT_SAK,
+    SLETT_SAK,
     PERSISTER_SAK_ID,
     OPPRETT_OPPGAVE,
     PERSISTER_OPPGAVE_ID,
@@ -51,6 +52,7 @@ enum class EventName {
     SAK_OPPRETTET,
     SAK_FERDIGSTILT,
     MANUELL_OPPRETT_SAK_REQUESTED,
+    MANUELL_SLETT_SAK_REQUESTED,
 
     OPPGAVE_OPPRETT_REQUESTED,
     OPPGAVE_OPPRETTET,

diff --git a/...st/NotifikasjonTrengerInntektMeldingIT.kt → ...elding/integrasjonstest/NotifikasjonIT.kt b/...st/NotifikasjonTrengerInntektMeldingIT.kt → ...elding/integrasjonstest/NotifikasjonIT.kt
@@ -3,6 +3,7 @@ package no.nav.helsearbeidsgiver.inntektsmelding.integrasjonstest
 import io.kotest.matchers.nulls.shouldNotBeNull
 import io.kotest.matchers.shouldBe
 import io.mockk.coEvery
+import io.mockk.coVerify
 import no.nav.helsearbeidsgiver.felles.BehovType
 import no.nav.helsearbeidsgiver.felles.EventName
 import no.nav.helsearbeidsgiver.felles.Key
@@ -21,7 +22,7 @@ import org.junit.jupiter.api.TestInstance
 import java.util.UUID
 
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
-class NotifikasjonTrengerInntektMeldingIT : EndToEndTest() {
+class NotifikasjonIT : EndToEndTest() {
 
     @Test
     fun `Oppretter og lagrer sak etter at forespørselen er mottatt`() {
@@ -207,6 +208,23 @@ class NotifikasjonTrengerInntektMeldingIT : EndToEndTest() {
             }
     }
 
+    @Test
+    fun `Slett sak loeser test`() {
+        coEvery {
+            arbeidsgiverNotifikasjonKlient.hardDeleteSak(any())
+        } returns Unit
+
+        publish(
+            Key.EVENT_NAME to EventName.MANUELL_SLETT_SAK_REQUESTED.toJson(),
+            Key.BEHOV to BehovType.SLETT_SAK.toJson(),
+            Key.SAK_ID to Mock.SAK_ID.toJson()
+        )
+
+        Thread.sleep(5000)
+        coVerify(exactly = 1) { arbeidsgiverNotifikasjonKlient.hardDeleteSak(Mock.SAK_ID) }
+        messages.all().size shouldBe 1
+    }
+
     private object Mock {
         const val FNR = "fnr-123"
         const val ORGNR = "orgnr-456"

diff --git a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/App.kt b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/App.kt
@@ -48,6 +48,9 @@ fun RapidsConnection.createNotifikasjon(
 
         logger.info("Starter ${ManuellOpprettSakService::class.simpleName}...")
         ManuellOpprettSakService(this, redisStore)
+
+        logger.info("Starter ${SlettSakLoeser::class.simpleName}...")
+        SlettSakLoeser(this, arbeidsgiverNotifikasjonKlient)
     }
 
 fun buildClient(environment: Environment): ArbeidsgiverNotifikasjonKlient {

diff --git a/...n/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/SlettSakLoeser.kt b/...n/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/SlettSakLoeser.kt
@@ -0,0 +1,54 @@
+package no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon
+
+import kotlinx.coroutines.runBlocking
+import no.nav.helse.rapids_rivers.RapidsConnection
+import no.nav.helse.rapids_rivers.River
+import no.nav.helsearbeidsgiver.arbeidsgivernotifikasjon.ArbeidsgiverNotifikasjonKlient
+import no.nav.helsearbeidsgiver.arbeidsgivernotifikasjon.HardDeleteSakException
+import no.nav.helsearbeidsgiver.felles.BehovType
+import no.nav.helsearbeidsgiver.felles.Key
+import no.nav.helsearbeidsgiver.felles.rapidsrivers.Loeser
+import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Behov
+import no.nav.helsearbeidsgiver.utils.log.logger
+import no.nav.helsearbeidsgiver.utils.pipe.ifFalse
+import no.nav.helsearbeidsgiver.utils.pipe.ifTrue
+
+class SlettSakLoeser(
+    rapidsConnection: RapidsConnection,
+    private val arbeidsgiverNotifikasjonKlient: ArbeidsgiverNotifikasjonKlient
+) : Loeser(rapidsConnection) {
+
+    private val logger = logger()
+
+    override fun accept(): River.PacketValidation {
+        return River.PacketValidation {
+            it.demandValue(Key.BEHOV.str, BehovType.SLETT_SAK.name)
+            it.requireKey(Key.SAK_ID.str)
+        }
+    }
+    private fun slettSak(
+        sakId: String
+    ): Boolean {
+        return try {
+            runBlocking {
+                arbeidsgiverNotifikasjonKlient.hardDeleteSak(sakId)
+            }
+            true
+        } catch (e: HardDeleteSakException) {
+            sikkerLogger.error("Feil ved sletting av sak: $sakId", e)
+            false
+        }
+    }
+
+    override fun onBehov(behov: Behov) {
+        val sakId = behov[Key.SAK_ID].asText()
+        slettSak(sakId)
+            .ifTrue {
+                "Slettet sak: $sakId".also {
+                    logger.info(it)
+                    sikkerLogger.info(it)
+                }
+            }
+            .ifFalse { logger.error("Feil ved sletting av sak: $sakId") }
+    }
+}