From 5f990965d586457077ac6553d45ece4cfa7057ee Mon Sep 17 00:00:00 2001
From: Andreas Jonsson <andreas.jonsson@nav.no>
Date: Mon, 15 Jan 2024 22:17:59 +0100
Subject: [PATCH] Removed unused client.

---
 .../DokumenterUnderArbeidController.kt        |  2 --
 .../clients/events/KafkaEventClient.kt        | 28 -------------------
 .../DokumentUnderArbeidControllerTest.kt      |  4 ---
 3 files changed, 34 deletions(-)
 delete mode 100644 src/main/kotlin/no/nav/klage/oppgave/clients/events/KafkaEventClient.kt

diff --git a/src/main/kotlin/no/nav/klage/dokument/api/controller/DokumenterUnderArbeidController.kt b/src/main/kotlin/no/nav/klage/dokument/api/controller/DokumenterUnderArbeidController.kt
index 370251b23..a0d4e0bbe 100644
--- a/src/main/kotlin/no/nav/klage/dokument/api/controller/DokumenterUnderArbeidController.kt
+++ b/src/main/kotlin/no/nav/klage/dokument/api/controller/DokumenterUnderArbeidController.kt
@@ -8,7 +8,6 @@ import no.nav.klage.dokument.api.view.*
 import no.nav.klage.dokument.service.DokumentUnderArbeidService
 import no.nav.klage.kodeverk.DokumentType
 import no.nav.klage.oppgave.api.view.DokumentUnderArbeidMetadata
-import no.nav.klage.oppgave.clients.events.KafkaEventClient
 import no.nav.klage.oppgave.config.SecurityConfiguration
 import no.nav.klage.oppgave.service.InnloggetSaksbehandlerService
 import no.nav.klage.oppgave.util.getLogger
@@ -26,7 +25,6 @@ class DokumentUnderArbeidController(
     private val innloggetSaksbehandlerService: InnloggetSaksbehandlerService,
     private val dokumentMapper: DokumentMapper,
     private val dokumentInputMapper: DokumentInputMapper,
-    private val kafkaEventClient: KafkaEventClient,
 ) {
 
     companion object {
diff --git a/src/main/kotlin/no/nav/klage/oppgave/clients/events/KafkaEventClient.kt b/src/main/kotlin/no/nav/klage/oppgave/clients/events/KafkaEventClient.kt
deleted file mode 100644
index 68ad5f044..000000000
--- a/src/main/kotlin/no/nav/klage/oppgave/clients/events/KafkaEventClient.kt
+++ /dev/null
@@ -1,28 +0,0 @@
-package no.nav.klage.oppgave.clients.events
-
-import jakarta.annotation.PostConstruct
-import org.springframework.beans.factory.annotation.Qualifier
-import org.springframework.http.codec.ServerSentEvent
-import org.springframework.stereotype.Service
-import reactor.core.publisher.ConnectableFlux
-import reactor.kafka.receiver.KafkaReceiver
-
-@Service
-class KafkaEventClient(
-    @Qualifier("kafkaEventReceiver") private val kafkaReceiver: KafkaReceiver<String, String>
-) {
-
-    private lateinit var eventPublisher: ConnectableFlux<ServerSentEvent<String>>
-
-    @PostConstruct
-    fun init() {
-        eventPublisher = kafkaReceiver.receive()
-            .map { consumerRecord -> ServerSentEvent.builder(consumerRecord.value()).build() }
-            .publish()
-
-        // subscribes to the KafkaReceiver -> starts consumption (without observers attached)
-        eventPublisher.connect()
-    }
-
-    fun getEventPublisher() = eventPublisher
-}
\ No newline at end of file
diff --git a/src/test/kotlin/no/nav/klage/dokument/api/controller/DokumentUnderArbeidControllerTest.kt b/src/test/kotlin/no/nav/klage/dokument/api/controller/DokumentUnderArbeidControllerTest.kt
index fa20ee7da..f265b3426 100644
--- a/src/test/kotlin/no/nav/klage/dokument/api/controller/DokumentUnderArbeidControllerTest.kt
+++ b/src/test/kotlin/no/nav/klage/dokument/api/controller/DokumentUnderArbeidControllerTest.kt
@@ -7,7 +7,6 @@ import no.nav.klage.dokument.api.mapper.DokumentMapper
 import no.nav.klage.dokument.clients.kabalsmarteditorapi.KabalSmartEditorApiClient
 import no.nav.klage.dokument.repositories.DokumentUnderArbeidRepository
 import no.nav.klage.dokument.service.DokumentUnderArbeidService
-import no.nav.klage.oppgave.clients.events.KafkaEventClient
 import no.nav.klage.oppgave.clients.saf.graphql.SafGraphQlClient
 import no.nav.klage.oppgave.service.BehandlingService
 import no.nav.klage.oppgave.service.InnloggetSaksbehandlerService
@@ -33,9 +32,6 @@ internal class DokumentUnderArbeidControllerTest {
     @MockkBean
     private lateinit var kabalSmartEditorApiClient: KabalSmartEditorApiClient
 
-    @MockkBean
-    private lateinit var kafkaEventClient: KafkaEventClient
-
     @MockkBean
     private lateinit var dokumentUnderArbeidService: DokumentUnderArbeidService