Oppdaterte kafka-keys slik at den også ser på historiske identer

navikt · Oct 18, 2024 · 8b482e6 · 8b482e6
1 parent 975c7c1
commit 8b482e6
Show file tree

Hide file tree

Showing 4 changed files with 28 additions and 8 deletions.
diff --git a/apps/kafka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/Applikasjon.kt b/apps/kafka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/Applikasjon.kt
@@ -55,7 +55,11 @@ class Applikasjon(
 
     @WithSpan
     private suspend fun sjekkMotAliaser(callId: CallId, identitet: Identitetsnummer): Either<Failure, ArbeidssoekerId> {
-        return identitetsTjeneste.hentIdentiter(callId, identitet)
+        return identitetsTjeneste.hentIdentiter(
+            callId = callId,
+            identitet = identitet,
+            histrorikk = true
+        )
             .flatMap(kafkaKeys::hent)
             .flatMap { ids ->
                 ids.values

diff --git a/...ka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/pdl/PdlIdentitesTjeneste.kt b/...ka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/pdl/PdlIdentitesTjeneste.kt
@@ -14,11 +14,18 @@ private const val behandlingsnummer = "B452"
 class PdlIdentitesTjeneste(private val pdlKlient: PdlClient) {
     suspend fun hentIdentInformasjon(
         callId: CallId,
-        identitet: Identitetsnummer
+        identitet: Identitetsnummer,
+        histrorikk: Boolean = false
     ): Either<Failure, List<IdentInformasjon>> {
         return suspendeableAttempt {
             pdlKlient
-                .hentIdenter(identitet.value, callId.value, consumerId, behandlingsnummer)
+                .hentIdenter(
+                    ident = identitet.value,
+                    callId = callId.value,
+                    navConsumerId = consumerId,
+                    behandlingsnummer = behandlingsnummer,
+                    historikk = histrorikk
+                )
         }.mapToFailure { exception ->
             when (exception) {
                 is PdlException -> mapPdlException(exception)
@@ -35,9 +42,13 @@ class PdlIdentitesTjeneste(private val pdlKlient: PdlClient) {
 
     suspend fun hentIdentiter(
         callId: CallId,
-        identitet: Identitetsnummer
-    ): Either<Failure, List<String>> = hentIdentInformasjon(callId, identitet)
-        .map { liste -> liste.map { it.ident } }
+        identitet: Identitetsnummer,
+        histrorikk: Boolean = false
+    ): Either<Failure, List<String>> = hentIdentInformasjon(
+        callId = callId,
+        identitet = identitet,
+        histrorikk = histrorikk
+    ).map { liste -> liste.map { it.ident } }
 
     private fun mapPdlException(ex: PdlException): Failure {
         return if (ex.errors?.any { it.message.contains("Fant ikke person") } == true) {

diff --git a/apps/kafka-key-generator/src/test/kotlin/no/nav/paw/kafkakeygenerator/ApplikasjonsTest.kt b/apps/kafka-key-generator/src/test/kotlin/no/nav/paw/kafkakeygenerator/ApplikasjonsTest.kt
@@ -29,7 +29,10 @@ class ApplikasjonsTest : StringSpec({
         identitetsTjeneste = PdlIdentitesTjeneste(pdlKlient)
     )
     fun hentEllerOpprett(identitetsnummer: String): Either<Failure, ArbeidssoekerId> = runBlocking {
-        app.hentEllerOpprett(CallId(UUID.randomUUID().toString()), Identitetsnummer(identitetsnummer))
+        app.hentEllerOpprett(
+            callId = CallId(UUID.randomUUID().toString()),
+            identitet = Identitetsnummer(identitetsnummer)
+        )
     }
     "alle identer for person1 skal gi samme nøkkel" {
         val person1KafkaNøkler = listOf(

diff --git a/apps/kafka-key-generator/src/test/kotlin/no/nav/paw/kafkakeygenerator/testdata.kt b/apps/kafka-key-generator/src/test/kotlin/no/nav/paw/kafkakeygenerator/testdata.kt
@@ -47,7 +47,7 @@ const val person1MockSvar = """
         },
         {
           "ident": "$person1_dnummer",
-          "gruppe": "DNUMMER"
+          "gruppe": "FOLKEREGISTERIDENT"
         },
         {
           "ident": "$person1_annen_ident",
@@ -84,6 +84,8 @@ fun MockRequestHandleScope.genererResponse(it: HttpRequestData): HttpResponseDat
     val end = text.indexOf("}", start)
     val ident = text
         .substring(start, end)
+        .split(",")
+        .first()
         .replace("\"", "")
         .replace("ident:", "")
         .trim()