♻️ Kan angi batchSize for å styre hvor mange navn som skal hentes

navikt · Nov 14, 2024 · f163846 · f163846
1 parent 6991232
commit f163846
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 9 deletions.
diff --git a/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/ArbeidsgiverinformasjonLøsningRiver.kt b/spesialist-selve/src/main/kotlin/no/nav/helse/kafka/ArbeidsgiverinformasjonLøsningRiver.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
@@ -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,19 +30,20 @@ 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
 
         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
@@ -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
@@ -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(