remove service that updates statuses

navikt · Jul 24, 2023 · 43b8b6c · 43b8b6c
1 parent 80dcb3b
commit 43b8b6c
Show file tree

Hide file tree

Showing 8 changed files with 2 additions and 363 deletions.
diff --git a/src/main/kotlin/no/nav/syfo/Bootstrap.kt b/src/main/kotlin/no/nav/syfo/Bootstrap.kt
@@ -21,11 +21,8 @@ import no.nav.syfo.clients.HttpClients
 import no.nav.syfo.clients.KafkaConsumers
 import no.nav.syfo.clients.KafkaProducers
 import no.nav.syfo.db.Database
-import no.nav.syfo.elector.LeaderElector
-import no.nav.syfo.elector.LeadershipHandling
 import no.nav.syfo.oppgave.kafka.OppgaveHendelseConsumer
 import no.nav.syfo.oppgave.service.OppgaveService
-import no.nav.syfo.oppgave.service.UpdateStatusService
 import no.nav.syfo.persistering.MottattSykmeldingService
 import no.nav.syfo.service.ManuellOppgaveService
 import no.nav.syfo.util.TrackableException
@@ -109,15 +106,8 @@ fun main() {
     createListener(applicationState) {
         oppgaveHendelseConsumer.start()
     }
-    val leaderElectorService = LeadershipHandling(
-        updateService = UpdateStatusService(
-            database = database,
-            oppgaveClient = httpClients.oppgaveClient,
-        ),
-        LeaderElector(httpClient = httpClients.httpClient, env.electorPath),
-    )
-    leaderElectorService.start()
-    ApplicationServer(applicationEngine, applicationState, leaderElectorService).start()
+
+    ApplicationServer(applicationEngine, applicationState).start()
 }
 
 @DelicateCoroutinesApi

diff --git a/src/main/kotlin/no/nav/syfo/application/ApplicationServer.kt b/src/main/kotlin/no/nav/syfo/application/ApplicationServer.kt
@@ -1,20 +1,17 @@
 package no.nav.syfo.application
 
 import io.ktor.server.engine.ApplicationEngine
-import no.nav.syfo.elector.LeadershipHandling
 import java.util.concurrent.TimeUnit
 
 class ApplicationServer(
     private val applicationServer: ApplicationEngine,
     private val applicationState: ApplicationState,
-    private val leaderElectorService: LeadershipHandling,
 ) {
 
     init {
         Runtime.getRuntime().addShutdownHook(
             Thread {
                 this.applicationState.ready = false
-                leaderElectorService.stop()
                 this.applicationServer.stop(TimeUnit.SECONDS.toMillis(10), TimeUnit.SECONDS.toMillis(10))
             },
         )

diff --git a/src/main/kotlin/no/nav/syfo/elector/LeaderElector.kt b/src/main/kotlin/no/nav/syfo/elector/LeaderElector.kt
diff --git a/src/main/kotlin/no/nav/syfo/elector/LeadershipHandling.kt b/src/main/kotlin/no/nav/syfo/elector/LeadershipHandling.kt
diff --git a/src/main/kotlin/no/nav/syfo/oppgave/service/UpdateStatusService.kt b/src/main/kotlin/no/nav/syfo/oppgave/service/UpdateStatusService.kt
diff --git a/src/test/kotlin/no/nav/syfo/elector/LeadershipHandlingTest.kt b/src/test/kotlin/no/nav/syfo/elector/LeadershipHandlingTest.kt
diff --git a/src/test/kotlin/no/nav/syfo/oppgave/service/UpdateStatusServiceDbTest.kt b/src/test/kotlin/no/nav/syfo/oppgave/service/UpdateStatusServiceDbTest.kt