La til initiell støtte for ny variant av feilretting

Author: nilsmsa

apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/tilstand/KonverterTilApiHendelse.kt

@@ -58,7 +58,9 @@ fun TidspunktFraKilde.api(): ApiTidspunktFraKilde =
         tidspunkt,
         when (avviksType) {
             AvviksType.FORSINKELSE -> ApiAvviksType.FORSINKELSE
-            AvviksType.RETTING -> ApiAvviksType.RETTING
+            AvviksType.RETTING -> ApiAvviksType.SLETTET // RETTING er erstattet av SLETTET(periode som aldri skulle vært lagt inn)
+            AvviksType.SLETTET -> ApiAvviksType.SLETTET
+            AvviksType.TIDSPUNKT_KORRIGERT -> no.nav.paw.arbeidssokerregisteret.api.v1.AvviksType.TIDSPUNKT_KORRIGERT
         }
     )
 

apps/hendelseprosessor/src/test/kotlin/no/nav/paw/arbeidssokerregisteret/app/ApplikasjonsTest.kt

@@ -18,6 +18,7 @@ import no.nav.paw.arbeidssokerregisteret.intern.v1.OpplysningerOmArbeidssoekerMo
 import no.nav.paw.arbeidssokerregisteret.intern.v1.Startet
 import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.*
 import no.nav.paw.test.assertEvent
+import no.nav.paw.test.days
 import org.apache.kafka.common.serialization.Serdes
 import org.apache.kafka.streams.TopologyTestDriver
 import java.time.Duration
@@ -76,7 +77,7 @@ class ApplikasjonsTest : FreeSpec({
                 aarsak = "tester",
                 tidspunktFraKilde = TidspunktFraKilde(
                     Instant.parse("2024-03-07T15:41:01Z"),
-                    AvviksType.RETTING
+                    AvviksType.FORSINKELSE
                 )
             )
         )
@@ -126,6 +127,40 @@ class ApplikasjonsTest : FreeSpec({
             opplysningerOmArbeidssoekerTopic.isEmpty shouldBe true
         }
 
+        "Når vi mottar en 'startet' med korrigert tidspunkt for en akrive periode skal vi oppdatere perioden".config(
+            enabled = false // Funsjonalitet er ikke implementert
+        ) {
+            val duplikatStart = Startet(
+                hendelseId = UUID.randomUUID(),
+                id = 1L,
+                identitetsnummer = identitetnummer,
+                metadata = Metadata(
+                    tidspunkt = Instant.now(),
+                    utfoertAv = Bruker(type = BrukerType.VEILEDER, id = "en_som_fikser_ting"),
+                    kilde = "unit-test2",
+                    aarsak = "tekniske feil i systemet",
+                    tidspunktFraKilde = TidspunktFraKilde(
+                        startet.metadata.tidspunkt - 10.days,
+                        AvviksType.TIDSPUNKT_KORRIGERT
+                    )
+                )
+            )
+            eventlogTopic.pipeInput(key, duplikatStart)
+            periodeTopic.isEmpty shouldBe false
+            val periodeKv = periodeTopic.readKeyValue()
+            val periode = periodeKv.value
+            periode.startet.tidspunkt shouldBe startet.metadata.tidspunkt
+            periode.startet.tidspunktFraKilde?.avviksType shouldBe AvviksType.TIDSPUNKT_KORRIGERT
+            periode.startet.tidspunktFraKilde?.tidspunkt shouldBe duplikatStart.metadata.tidspunktFraKilde?.tidspunkt
+            periode.id shouldBe startet.hendelseId
+            periode.identitetsnummer shouldBe startet.identitetsnummer
+            periode.startet.utfoertAv.type shouldBe BrukerType.VEILEDER
+            periode.startet.utfoertAv.id shouldBe "en_som_fikser_ting"
+            periode.startet.aarsak shouldBe "tekniske feil i systemet"
+            periode.startet.kilde shouldBe "unit-test2"
+            periodeTopic.isEmpty shouldBe true
+        }
+
         "Når vi mottar en ny situsjon for en person med en aktiv periode skal vi sende ut en ny situasjon" {
             val situsjonMottat = opplysningerMottatt(1L, identitetnummer, Instant.now())
             eventlogTopic.pipeInput(key, situsjonMottat)

apps/hendelseprosessor/src/test/kotlin/no/nav/paw/arbeidssokerregisteret/app/TestUtils.kt

@@ -74,6 +74,8 @@ fun verifiserApiMetadataMotInternMetadata(
     when (forventedeMetadataVerdier.tidspunktFraKilde?.avviksType) {
         FORSINKELSE -> mottattApiMetadata.tidspunktFraKilde?.avviksType shouldBe AvviksType.FORSINKELSE
         RETTING -> mottattApiMetadata.tidspunktFraKilde?.avviksType shouldBe AvviksType.RETTING
+        SLETTET -> mottattApiMetadata.tidspunktFraKilde?.avviksType shouldBe AvviksType.SLETTET
+        TIDSPUNKT_KORRIGERT -> mottattApiMetadata.tidspunktFraKilde?.avviksType shouldBe AvviksType.TIDSPUNKT_KORRIGERT
         null -> mottattApiMetadata.tidspunktFraKilde shouldBe null
     }
 }

domain/interne-hendelser/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/intern/v1/vo/AvviksType.kt

@@ -2,5 +2,8 @@ package no.nav.paw.arbeidssokerregisteret.intern.v1.vo
 
 enum class AvviksType {
     FORSINKELSE,
-    RETTING
+    @Deprecated("Erstattet av 'SLETTET'", replaceWith = ReplaceWith("SLETTET"))
+    RETTING,
+    SLETTET,
+    TIDSPUNKT_KORRIGERT
 }