Lagt til tidligere arbeidssøkerId i kafka_key_audit tabell

navikt · Nov 27, 2024 · 343656a · 343656a
1 parent 4cc72bd
commit 343656a
Show file tree

Hide file tree

Showing 6 changed files with 96 additions and 70 deletions.
diff --git a/...ey-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/database/KafkaKeysAuditTable.kt b/...ey-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/database/KafkaKeysAuditTable.kt
@@ -6,6 +6,7 @@ import org.jetbrains.exposed.sql.javatime.timestamp
 
 object KafkaKeysAuditTable : LongIdTable("kafka_keys_audit") {
     val identitetsnummer = varchar("identitetsnummer", 255).references(IdentitetTabell.identitetsnummer)
+    val tidligereKafkaKey = long("tidligere_kafka_key")
     val status = enumerationByName<IdentitetStatus>("status", 50)
     val detaljer = varchar("detaljer", 255)
     val tidspunkt = timestamp("tidspunkt")

diff --git a/...rator/src/main/kotlin/no/nav/paw/kafkakeygenerator/repository/KafkaKeysAuditRepository.kt b/...rator/src/main/kotlin/no/nav/paw/kafkakeygenerator/repository/KafkaKeysAuditRepository.kt
@@ -1,6 +1,7 @@
 package no.nav.paw.kafkakeygenerator.repository
 
 import no.nav.paw.kafkakeygenerator.database.KafkaKeysAuditTable
+import no.nav.paw.kafkakeygenerator.vo.ArbeidssoekerId
 import no.nav.paw.kafkakeygenerator.vo.Audit
 import no.nav.paw.kafkakeygenerator.vo.Identitetsnummer
 import org.jetbrains.exposed.sql.Database
@@ -19,6 +20,7 @@ class KafkaKeysAuditRepository(
             .map {
                 Audit(
                     identitetsnummer = Identitetsnummer(it[KafkaKeysAuditTable.identitetsnummer]),
+                    tidligereArbeidssoekerId = ArbeidssoekerId(it[KafkaKeysAuditTable.tidligereKafkaKey]),
                     identitetStatus = it[KafkaKeysAuditTable.status],
                     detaljer = it[KafkaKeysAuditTable.detaljer],
                     tidspunkt = it[KafkaKeysAuditTable.tidspunkt]
@@ -29,6 +31,7 @@ class KafkaKeysAuditRepository(
     fun insert(audit: Audit): Int = transaction(database) {
         KafkaKeysAuditTable.insert {
             it[identitetsnummer] = audit.identitetsnummer.value
+            it[tidligereKafkaKey] = audit.tidligereArbeidssoekerId.value
             it[status] = audit.identitetStatus
             it[detaljer] = audit.detaljer
             it[tidspunkt] = audit.tidspunkt

diff --git a/...ey-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/service/KafkaConsumerService.kt b/...ey-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/service/KafkaConsumerService.kt
@@ -121,17 +121,23 @@ class KafkaConsumerService(
         if (eksisterendeArbeidssoekerId == tilArbeidssoekerId) {
             logger.info("Identitetsnummer er allerede linket til korrekt ArbeidsøkerId")
             meterRegistry.countKafkaVerified()
-            val audit = Audit(identitetsnummer, IdentitetStatus.VERIFISERT, "Ingen endringer")
+            val audit = Audit(
+                identitetsnummer = identitetsnummer,
+                tidligereArbeidssoekerId = fraArbeidssoekerId,
+                identitetStatus = IdentitetStatus.VERIFISERT,
+                detaljer = "Ingen endringer"
+            )
             kafkaKeysAuditRepository.insert(audit)
         } else {
             logger.info("Identitetsnummer oppdateres med annen ArbeidsøkerId")
             meterRegistry.countKafkaUpdated()
             val count = identitetRepository.update(identitetsnummer, tilArbeidssoekerId)
             if (count != 0) {
                 val audit = Audit(
-                    identitetsnummer,
-                    IdentitetStatus.OPPDATERT,
-                    "Bytte av arbeidsøkerId fra ${fraArbeidssoekerId.value} til ${tilArbeidssoekerId.value}"
+                    identitetsnummer = identitetsnummer,
+                    tidligereArbeidssoekerId = fraArbeidssoekerId,
+                    identitetStatus = IdentitetStatus.OPPDATERT,
+                    detaljer = "Bytte av arbeidsøkerId fra ${fraArbeidssoekerId.value} til ${tilArbeidssoekerId.value}"
                 )
                 kafkaKeysAuditRepository.insert(audit)
             } else {
@@ -151,6 +157,7 @@ class KafkaConsumerService(
         if (count != 0) {
             val audit = Audit(
                 identitetsnummer = identitetsnummer,
+                tidligereArbeidssoekerId = tilArbeidssoekerId,
                 identitetStatus = IdentitetStatus.OPPRETTET,
                 detaljer = "Opprettet ident for arbeidsøkerId ${tilArbeidssoekerId.value}"
             )

diff --git a/apps/kafka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/vo/Audit.kt b/apps/kafka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/vo/Audit.kt
@@ -4,6 +4,7 @@ import java.time.Instant
 
 data class Audit(
     val identitetsnummer: Identitetsnummer,
+    val tidligereArbeidssoekerId: ArbeidssoekerId,
     val identitetStatus: IdentitetStatus,
     val detaljer: String,
     val tidspunkt: Instant = Instant.now()

diff --git a/apps/kafka-key-generator/src/main/resources/db/migration/V4__endre_kafka_keys_audit.sql b/apps/kafka-key-generator/src/main/resources/db/migration/V4__endre_kafka_keys_audit.sql
@@ -0,0 +1,2 @@
+ALTER TABLE kafka_keys_audit
+ADD tidligere_kafka_key BIGINT NOT NULL DEFAULT -1;
diff --git a/docker/mocks/config/mock-oauth2-server/config.json b/docker/mocks/config/mock-oauth2-server/config.json
@@ -1,73 +1,85 @@
 {
-  "interactiveLogin": true,
-  "httpServer": "NettyWrapper",
-  "tokenCallbacks": [
-    {
-      "issuerId": "idporten",
-      "tokenExpiry": 3600,
-      "requestMappings": [
+    "interactiveLogin": true,
+    "httpServer": "NettyWrapper",
+    "tokenCallbacks": [
         {
-          "requestParam": "client_id",
-          "match": "paw-arbeidssoekerregisteret-api-bekreftelse",
-          "claims": {
-            "sub": "admin@paw-arbeidssoekerregisteret-api-bekreftelse",
-            "aud": [
-              "paw-arbeidssoekerregisteret-api-bekreftelse"
-            ],
-            "pid": "17830348441",
-            "acr": "idporten-loa-high"
-          }
-        }
-      ]
-    },
-    {
-      "issuerId": "tokenx",
-      "tokenExpiry": 3600,
-      "requestMappings": [
-        {
-          "requestParam": "client_id",
-          "match": "paw-arbeidssoekerregisteret-api-bekreftelse",
-          "claims": {
-            "sub": "admin@paw-arbeidssoekerregisteret-api-bekreftelse",
-            "aud": [
-              "paw-arbeidssoekerregisteret-api-bekreftelse"
-            ],
-            "pid": "01017012345",
-            "acr": "idporten-loa-high"
-          }
-        }
-      ]
-    },
-    {
-      "issuerId": "azure",
-      "tokenExpiry": 3600,
-      "requestMappings": [
+            "issuerId": "idporten",
+            "tokenExpiry": 3600,
+            "requestMappings": [
+                {
+                    "requestParam": "client_id",
+                    "match": "paw-arbeidssoekerregisteret-api-bekreftelse",
+                    "claims": {
+                        "sub": "admin@paw-arbeidssoekerregisteret-api-bekreftelse",
+                        "aud": [
+                            "paw-arbeidssoekerregisteret-api-bekreftelse"
+                        ],
+                        "pid": "17830348441",
+                        "acr": "idporten-loa-high"
+                    }
+                }
+            ]
+        },
         {
-          "requestParam": "client_id",
-          "match": "paw-kafka-key-generator",
-          "claims": {
-            "sub": "admin@paw-kafka-key-generator",
-            "aud": [
-              "paw-kafka-key-generator"
-            ],
-            "pid": "01017012345",
-            "acr": "idporten-loa-high"
-          }
+            "issuerId": "tokenx",
+            "tokenExpiry": 3600,
+            "requestMappings": [
+                {
+                    "requestParam": "client_id",
+                    "match": "paw-kafka-key-generator",
+                    "claims": {
+                        "sub": "admin@paw-kafka-key-generator",
+                        "aud": [
+                            "paw-kafka-key-generator"
+                        ],
+                        "pid": "01017012345",
+                        "acr": "idporten-loa-high"
+                    }
+                },
+                {
+                    "requestParam": "client_id",
+                    "match": "paw-arbeidssoekerregisteret-api-bekreftelse",
+                    "claims": {
+                        "sub": "admin@paw-arbeidssoekerregisteret-api-bekreftelse",
+                        "aud": [
+                            "paw-arbeidssoekerregisteret-api-bekreftelse"
+                        ],
+                        "pid": "01017012345",
+                        "acr": "idporten-loa-high"
+                    }
+                }
+            ]
         },
         {
-          "requestParam": "client_id",
-          "match": "paw-arbeidssoekerregisteret-api-bekreftelse",
-          "claims": {
-            "sub": "admin@paw-arbeidssoekerregisteret-api-bekreftelse",
-            "aud": [
-              "paw-arbeidssoekerregisteret-api-bekreftelse"
-            ],
-            "oid": "84a9421a-610d-4258-ac2c-bae144216f14",
-            "name": "Nav Navesen",
-            "NAVident": "NAV12345"
-          }
+            "issuerId": "azure",
+            "tokenExpiry": 3600,
+            "requestMappings": [
+                {
+                    "requestParam": "client_id",
+                    "match": "paw-kafka-key-generator",
+                    "claims": {
+                        "sub": "admin@paw-kafka-key-generator",
+                        "aud": [
+                            "paw-kafka-key-generator"
+                        ],
+                        "pid": "01017012345",
+                        "acr": "idporten-loa-high"
+                    }
+                },
+                {
+                    "requestParam": "client_id",
+                    "match": "paw-arbeidssoekerregisteret-api-bekreftelse",
+                    "claims": {
+                        "sub": "admin@paw-arbeidssoekerregisteret-api-bekreftelse",
+                        "aud": [
+                            "paw-arbeidssoekerregisteret-api-bekreftelse"
+                        ],
+                        "oid": "84a9421a-610d-4258-ac2c-bae144216f14",
+                        "name": "Nav Navesen",
+                        "NAVident": "NAV12345"
+                    }
+                }
+            ]
         }
-      ]
-    }
-  ]
+    ]
 }
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		ALTER TABLE kafka_keys_audit
		ADD tidligere_kafka_key BIGINT NOT NULL DEFAULT -1;