La til hendelser for id håndtering

apps/hendelseprosessor/src/main/kotlin/no/nav/paw/arbeidssokerregisteret/app/funksjoner/GenererTilstander.kt

@@ -17,6 +17,8 @@ fun genererNyInternTilstandOgNyeApiTilstander(
             is OpplysningerOmArbeidssoekerMottatt -> opplysningerOmArbeidssoekerMottatt(hendelse)
             is Avvist -> avvist(hendelse)
             is AvvistStoppAvPeriode -> ingenEndringEllerUtgaaendeMeldinger()
+            is IdentitetsnummerOpphoert -> ingenEndringEllerUtgaaendeMeldinger()
+            is IdentitetsnummerSammenslaatt -> ingenEndringEllerUtgaaendeMeldinger()
         }
     }
 }

apps/kafka-key-maintenance/build.gradle.kts

@@ -86,6 +86,9 @@ jib {
     to.image = "${image ?: project.name}:${project.version}"
     container {
         jvmFlags = listOf("-XX:ActiveProcessorCount=4", "-XX:+UseZGC", "-XX:+ZGenerational")
+        environment = mapOf(
+            "IMAGE_WITH_VERSION" to "${image ?: project.name}:${project.version}"
+        )
     }
 }
 

apps/kafka-key-maintenance/src/main/kotlin/no/nav/paw/kafkakeymaintenance/ApplicationMetadata.kt

@@ -0,0 +1,27 @@
+package no.nav.paw.kafkakeymaintenance
+
+import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.Bruker
+import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.BrukerType
+import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.Metadata
+import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.TidspunktFraKilde
+import java.time.Instant
+
+private val systemId = System.getenv("IMAGE_WITH_VERSION")?: "UNSPECIFIED"
+
+fun metadata(
+    kilde: String,
+    tidspunkt: Instant = Instant.now(),
+    tidspunktFraKilde: TidspunktFraKilde
+): Metadata {
+
+    return Metadata(
+        tidspunkt = tidspunkt,
+        utfoertAv = Bruker(
+            type = BrukerType.SYSTEM,
+            id = systemId
+        ),
+        kilde = kilde,
+        aarsak = "Id oppdatering",
+        tidspunktFraKilde = tidspunktFraKilde
+    )
+}

apps/kafka-key-maintenance/src/main/kotlin/no/nav/paw/kafkakeymaintenance/PdlConsumer.kt

@@ -1,6 +1,10 @@
 package no.nav.paw.kafkakeymaintenance
 
 import kotlinx.coroutines.runBlocking
+import no.nav.paw.arbeidssokerregisteret.intern.v1.Hendelse
+import no.nav.paw.arbeidssokerregisteret.intern.v1.IdentitetsnummerOpphoert
+import no.nav.paw.arbeidssokerregisteret.intern.v1.IdentitetsnummerSammenslaatt
+import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.Metadata
 import no.nav.paw.kafkakeygenerator.client.KafkaKeysClient
 import no.nav.paw.kafkakeygenerator.client.LokaleAlias
 import no.nav.paw.kafkakeymaintenance.functions.genererIdOppdatering
@@ -10,13 +14,13 @@ import no.nav.paw.kafkakeymaintenance.functions.hentPerioder
 import no.nav.paw.kafkakeymaintenance.kafka.Topic
 import no.nav.paw.kafkakeymaintenance.kafka.TransactionContext
 import no.nav.paw.kafkakeymaintenance.kafka.updateHwm
-import no.nav.paw.kafkakeymaintenance.vo.IdOppdatering
-import no.nav.paw.kafkakeymaintenance.vo.avviksMelding
+import no.nav.paw.kafkakeymaintenance.vo.*
 import no.nav.person.pdl.aktor.v2.Aktor
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.jetbrains.exposed.sql.Transaction
 import org.jetbrains.exposed.sql.transactions.transaction
 import java.time.Instant
+import java.util.*
 
 const val ANTALL_PARTISJONER = 6
 
@@ -48,3 +52,45 @@ fun process(
             null
         }
     }
+
+fun genererHendelser(metadata: Metadata, idOppdatering: IdOppdatering): List<Hendelse> {
+    return when (idOppdatering) {
+        is AutomatiskIdOppdatering -> genererHendelse(metadata, idOppdatering)
+        is ManuellIdOppdatering -> TODO()
+    }
+}
+
+fun genererHendelse(metadata: Metadata, idOppdatering: AutomatiskIdOppdatering): List<Hendelse> {
+    val identitetsnummerOpphoert = idOppdatering
+        .frieIdentiteter
+        .groupBy { it.arbeidsoekerId }
+        .map { (arbeidsoekerId, alias) ->
+            val identiteter = alias.map { it.identitetsnummer }
+            IdentitetsnummerOpphoert(
+                id = arbeidsoekerId,
+                hendelseId = UUID.randomUUID(),
+                identitetsnummer = identiteter.first(),
+                metadata = metadata,
+                alleIdentitetsnummer = identiteter
+            )
+        }
+    val identitetsnummerSammenslaatt = idOppdatering.oppdatertData?.let { genererHendelse(metadata, it) } ?: emptyList()
+    TODO()
+}
+
+fun genererHendelse(metadata: Metadata, idMap: IdMap): List<IdentitetsnummerSammenslaatt> =
+   idMap.identiteter
+       .filter { it.arbeidsoekerId != idMap.arbeidsoekerId }
+       .groupBy { it.arbeidsoekerId }
+       .map { (arbeidsoekerId, alias) ->
+           val identiteter = alias.map { it.identitetsnummer }
+           IdentitetsnummerSammenslaatt(
+               id = arbeidsoekerId,
+               hendelseId = UUID.randomUUID(),
+               identitetsnummer = identiteter.first(),
+               metadata = metadata,
+               alleIdentitetsnummer = identiteter,
+               flyttetTilArbeidssoekerId = idMap.arbeidsoekerId
+           )
+       }
+

apps/kafka-key-maintenance/src/main/kotlin/no/nav/paw/kafkakeymaintenance/vo/IdOppdatering.kt

@@ -3,7 +3,7 @@ package no.nav.paw.kafkakeymaintenance.vo
 import no.nav.paw.kafkakeygenerator.client.Alias
 import no.nav.paw.kafkakeymaintenance.perioder.PeriodeRad
 
-interface IdOppdatering {}
+sealed interface IdOppdatering {}
 data class ManuellIdOppdatering(
     val gjeldeneIdentitetsnummer: String?,
     val pdlIdentitetsnummer: List<String>,

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

@@ -7,6 +7,8 @@ const val avsluttetHendelseType = "intern.v1.avsluttet"
 const val avvistHendelseType = "intern.v1.avvist"
 const val avvistStoppAvPeriodeHendelseType = "intent.v1.avvist_stopp_av_periode"
 const val opplysningerOmArbeidssoekerHendelseType = "intern.v1.opplysninger_om_arbeidssoeker"
+const val identitetsnummerOpphoertHendelseType = "intern.v1.identitetsnummer_opphoert"
+const val identitetsnummerSammenslaattHendelseType = "intern.v1.identitetsnummer_sammenslaatt"
 
 sealed interface Hendelse : HarIdentitetsnummer, HarMetadata {
     val id: Long

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

@@ -78,5 +78,7 @@ fun eventTypeToClass(type: String?): KClass<out Hendelse> =
         avvistHendelseType -> Avvist::class
         avvistStoppAvPeriodeHendelseType -> AvvistStoppAvPeriode::class
         opplysningerOmArbeidssoekerHendelseType -> OpplysningerOmArbeidssoekerMottatt::class
+        identitetsnummerOpphoertHendelseType -> IdentitetsnummerOpphoert::class
+        identitetsnummerSammenslaattHendelseType -> IdentitetsnummerSammenslaatt::class
         else -> throw IllegalArgumentException("Ukjent hendelse type: '$type'")
     }

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

@@ -0,0 +1,14 @@
+package no.nav.paw.arbeidssokerregisteret.intern.v1
+
+import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.Metadata
+import java.util.*
+
+data class IdentitetsnummerOpphoert(
+    override val id: Long,
+    override val hendelseId: UUID,
+    override val identitetsnummer: String,
+    override val metadata: Metadata,
+    val alleIdentitetsnummer: List<String>
+): Hendelse {
+    override val hendelseType: String = identitetsnummerOpphoertHendelseType
+}

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

@@ -0,0 +1,15 @@
+package no.nav.paw.arbeidssokerregisteret.intern.v1
+
+import no.nav.paw.arbeidssokerregisteret.intern.v1.vo.Metadata
+import java.util.*
+
+data class IdentitetsnummerSammenslaatt(
+    override val id: Long,
+    override val hendelseId: UUID,
+    override val identitetsnummer: String,
+    override val metadata: Metadata,
+    val alleIdentitetsnummer: List<String>,
+    val flyttetTilArbeidssoekerId: Long
+): Hendelse {
+    override val hendelseType: String = identitetsnummerSammenslaattHendelseType
+}