Merge pull request #91 from navikt/bugfix/inntektsid-not-present

Kan ikke markere inntekt som brukt hvis ikke inntektsid er med i subs…

Author: geiralund

src/main/kotlin/no/nav/dagpenger/inntekt/subsumsjonbrukt/KafkaSubsumsjonBruktDataConsumer.kt

@@ -76,7 +76,11 @@ internal class KafkaSubsumsjonBruktDataConsumer(
                         val records = consumer.poll(Duration.ofMillis(100))
                         val ids = records.asSequence()
                             .map { record -> record.value() }
-                            .map { packet -> InntektId(packet.getMapValue("faktum")["inntektsId"] as String) }
+                            .filter { packet -> packet.hasField("faktum") }
+                            .map { packet -> packet.getMapValue("faktum") }
+                            .onEach { faktum -> if (faktum["inntektsId"] == null) { logger.info { "Subsumsjon do not contain inntekts id. Is it manuelt grunnlag? ${faktum["manueltGrunnlag"] != null}" } } }
+                            .filter { faktum -> faktum["inntektsId"] != null }
+                            .map { faktum -> InntektId(faktum["inntektsId"] as String) }
                             .toList()
 
                         try {

src/test/kotlin/no/nav/dagpenger/inntekt/subsumsjonbrukt/KafkaSubsumsjonBruktDataConsumerTest.kt

@@ -73,6 +73,36 @@ class KafkaSubsumsjonBruktDataConsumerTest {
         }
     }
 
+    @Test
+    fun `Cannot mark inntekt id as used if not present in faktum`() {
+        runBlocking {
+            val storeMock = mockk<InntektStore>(relaxed = false).apply {
+                every { this@apply.markerInntektBrukt(any()) } returns 1
+            }
+            val config = Configuration().run {
+                copy(kafka = kafka.copy(brokers = Kafka.instance.bootstrapServers, user = null, password = null))
+            }
+
+            val consumer = KafkaSubsumsjonBruktDataConsumer(config, storeMock).apply {
+                listen()
+            }
+
+            val bruktSubsumsjonData = mapOf("faktum" to mapOf("manueltGrunnlag" to "122212"))
+
+            val metaData = producer.send(ProducerRecord(config.subsumsjonBruktDataTopic, "test", adapter.toJson(bruktSubsumsjonData)))
+                .get(5, TimeUnit.SECONDS)
+            LOGGER.info("Producer produced $bruktSubsumsjonData with meta $metaData")
+
+            TimeUnit.MILLISECONDS.sleep(500)
+
+            verify(exactly = 0) {
+                storeMock.markerInntektBrukt(any())
+            }
+
+            consumer.status() shouldBe HealthStatus.UP
+        }
+    }
+
     @Test
     fun `Should have grace period on health status when job is no longer active`() {
         runBlocking {