From f163846b1a572966dbc6ee5868f0572281a4251c Mon Sep 17 00:00:00 2001
From: Jakob Havstein Eriksen <jakob.havstein.eriksen@nav.no>
Date: Thu, 14 Nov 2024 13:19:18 +0100
Subject: [PATCH] =?UTF-8?q?=E2=99=BB=EF=B8=8F=20Kan=20angi=20batchSize=20f?=
 =?UTF-8?q?or=20=C3=A5=20styre=20hvor=20mange=20navn=20som=20skal=20hentes?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ArbeidsgiverinformasjonL\303\270sningRiver.kt"   |  1 +
 .../no/nav/helse/kafka/HentArbeidsgivernavnRiver.kt  |  8 +++++---
 .../kotlin/no/nav/helse/mediator/Kommandofabrikk.kt  | 12 +++++++-----
 .../helse/mediator/meldinger/Testmeldingfabrikk.kt   |  2 +-
 4 files changed, 14 insertions(+), 9 deletions(-)

diff --git "a/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/ArbeidsgiverinformasjonL\303\270sningRiver.kt" "b/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/ArbeidsgiverinformasjonL\303\270sningRiver.kt"
index c46ef7410..bb5afc294 100644
--- "a/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/ArbeidsgiverinformasjonL\303\270sningRiver.kt"
+++ "b/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/ArbeidsgiverinformasjonL\303\270sningRiver.kt"
@@ -43,6 +43,7 @@ internal class ArbeidsgiverinformasjonLøsningRiver(
         val contextId = packet["contextId"].asUUID()
         val løsning = packet["@løsning.$behov"]
         if (packet["fødselsnummer"].isMissingOrNull()) {
+            sikkerLog.debug("Mottok svar for arbeidsgivernavn\n{}", packet.toJson())
             alternativHåndtering(løsning, contextId, hendelseId)
             return
         }
diff --git a/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/HentArbeidsgivernavnRiver.kt b/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/HentArbeidsgivernavnRiver.kt
index 14f793671..0348a1d10 100644
--- a/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/HentArbeidsgivernavnRiver.kt
+++ b/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/HentArbeidsgivernavnRiver.kt
@@ -18,6 +18,7 @@ internal class HentArbeidsgivernavnRiver(
     override fun validations() =
         River.PacketValidation {
             it.demandValue("@event_name", "innhent_arbeidsgivernavn")
+            it.requireKey("batchSize")
         }
 
     override fun onPacket(
@@ -29,12 +30,12 @@ internal class HentArbeidsgivernavnRiver(
 }
 
 internal class InnhentArbeidsgivernavn
-    private constructor(override val id: UUID, private val data: String) : Melding, CommandData {
+    private constructor(override val id: UUID, private val data: String, val batchSize: Int) : Melding, CommandData {
         fun behandle(
             kommandostarter: Kommandostarter,
             transactionalSession: TransactionalSession,
         ) {
-            kommandostarter { innhentArbeidsgivernavn(transactionalSession) }
+            kommandostarter { innhentArbeidsgivernavn(batchSize, transactionalSession) }
         }
 
         override fun toJson() = data
@@ -42,6 +43,7 @@ internal class InnhentArbeidsgivernavn
         override fun data() = data
 
         companion object {
-            fun opprettFra(packet: JsonMessage) = InnhentArbeidsgivernavn(packet.id.toUUID(), packet.toJson())
+            fun opprettFra(packet: JsonMessage) =
+                InnhentArbeidsgivernavn(packet.id.toUUID(), packet.toJson(), packet["batchSize"].intValue())
         }
     }
diff --git a/spesialist-selve/src/main/kotlin/no/nav/helse/mediator/Kommandofabrikk.kt b/spesialist-selve/src/main/kotlin/no/nav/helse/mediator/Kommandofabrikk.kt
index 7ee9d69f4..a22acd757 100644
--- a/spesialist-selve/src/main/kotlin/no/nav/helse/mediator/Kommandofabrikk.kt
+++ b/spesialist-selve/src/main/kotlin/no/nav/helse/mediator/Kommandofabrikk.kt
@@ -131,13 +131,15 @@ internal class Kommandofabrikk(
         )
     }
 
-    internal fun innhentArbeidsgivernavn(transactionalSession: TransactionalSession): OpprettEllerOppdaterInntektskilder {
-        val inntektskilderRepository = InntektskilderDao(transactionalSession)
+    internal fun innhentArbeidsgivernavn(
+        batchSize: Int,
+        session: Session,
+    ): OpprettEllerOppdaterInntektskilder {
+        val inntektskilderRepository = InntektskilderDao(session)
         val liste =
             inntektskilderRepository.finnInntektskilderSomManglerNavn().let {
-                logg.info("Fant ${it.size} arbeidsgivere det mangler navn for, innhenter for (maks) antall.")
-                val antall = 50
-                it.take(antall)
+                logg.info("Fant ${it.size} arbeidsgivere det mangler navn for, innhenter for (maks) $batchSize.")
+                it.take(batchSize)
             }
 
         return OpprettEllerOppdaterInntektskilder(
diff --git a/spesialist-selve/src/test/kotlin/no/nav/helse/mediator/meldinger/Testmeldingfabrikk.kt b/spesialist-selve/src/test/kotlin/no/nav/helse/mediator/meldinger/Testmeldingfabrikk.kt
index a48a23923..28a3f8fb4 100644
--- a/spesialist-selve/src/test/kotlin/no/nav/helse/mediator/meldinger/Testmeldingfabrikk.kt
+++ b/spesialist-selve/src/test/kotlin/no/nav/helse/mediator/meldinger/Testmeldingfabrikk.kt
@@ -732,7 +732,7 @@ internal object Testmeldingfabrikk {
     )
 
     fun lagInnhentArbeidsgivernavn(id: UUID) = nyHendelse(
-        id, "innhent_arbeidsgivernavn", emptyMap()
+        id = id, navn = "innhent_arbeidsgivernavn", hendelse = mapOf("batchSize" to 99)
     )
 
     fun lagSaksbehandlerløsning(