Refaktorer, samler typer relatert til Steg

navikt · Oct 4, 2024 · da1be17 · da1be17
1 parent 64a54cd
commit da1be17
Show file tree

Hide file tree

Showing 11 changed files with 45 additions and 58 deletions.
diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/ProsesserStegService.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/ProsesserStegService.kt
@@ -11,8 +11,6 @@ import no.nav.aap.brev.prosessering.steg.HentInnholdSteg
 import no.nav.aap.brev.prosessering.steg.JournalførBrevSteg
 import no.nav.aap.brev.prosessering.steg.StarterSteg
 import no.nav.aap.brev.prosessering.steg.Steg
-import no.nav.aap.brev.prosessering.steg.StegResultat
-import no.nav.aap.brev.prosessering.steg.StegUtfører
 import no.nav.aap.komponenter.dbconnect.DBConnection
 import org.slf4j.LoggerFactory
 
@@ -36,17 +34,17 @@ class ProsesserStegService(
 
         val bestilling = brevbestillingRepository.hent(referanse)
 
-        prosesserTilStop(
-            kontekst = StegUtfører.Kontekst(referanse),
+        prosesserTilStopp(
+            kontekst = Steg.Kontekst(referanse),
             stegene = flyt.fraStatus(bestilling.prosesseringStatus),
         )
     }
 
-    private fun prosesserTilStop(kontekst: StegUtfører.Kontekst, stegene: List<Steg>) {
+    private fun prosesserTilStopp(kontekst: Steg.Kontekst, stegene: List<Steg>) {
         stegene.forEach { steg ->
             val stegResultat = steg.konstruer(connection).utfør(kontekst)
 
-            if (stegResultat == StegResultat.STOPP) {
+            if (stegResultat == Steg.Resultat.STOPP) {
                 return
             }
 
@@ -55,7 +53,6 @@ class ProsesserStegService(
             connection.markerSavepoint()
         }
     }
-
 }
 
 class ProsesseringFlyt private constructor(

diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/DistribuerJournalpostSteg.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/DistribuerJournalpostSteg.kt
@@ -1,18 +1,17 @@
 package no.nav.aap.brev.prosessering.steg
 
-import no.nav.aap.brev.prosessering.steg.StegUtfører.Kontekst
 import no.nav.aap.komponenter.dbconnect.DBConnection
 import org.slf4j.LoggerFactory
 
-class DistribuerJournalpostSteg() : StegUtfører {
+class DistribuerJournalpostSteg() : Steg.Utfører {
     private val log = LoggerFactory.getLogger(DistribuerJournalpostSteg::class.java)
-    override fun utfør(kontekst: Kontekst): StegResultat {
+    override fun utfør(kontekst: Steg.Kontekst): Steg.Resultat {
         log.info("DistribuerJournalpostSteg")
-        return StegResultat.FULLFØRT
+        return Steg.Resultat.FULLFØRT
     }
 
     companion object : Steg {
-        override fun konstruer(connection: DBConnection): StegUtfører {
+        override fun konstruer(connection: DBConnection): Steg.Utfører {
             return DistribuerJournalpostSteg()
         }
     }

diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/FerdigSteg.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/FerdigSteg.kt
@@ -1,18 +1,17 @@
 package no.nav.aap.brev.prosessering.steg
 
-import no.nav.aap.brev.prosessering.steg.StegUtfører.Kontekst
 import no.nav.aap.komponenter.dbconnect.DBConnection
 import org.slf4j.LoggerFactory
 
-class FerdigSteg() : StegUtfører {
+class FerdigSteg() : Steg.Utfører {
     private val log = LoggerFactory.getLogger(FerdigSteg::class.java)
-    override fun utfør(kontekst: Kontekst): StegResultat {
+    override fun utfør(kontekst: Steg.Kontekst): Steg.Resultat {
         log.info("Prosessering er ferdig.")
-        return StegResultat.FULLFØRT
+        return Steg.Resultat.FULLFØRT
     }
 
     companion object : Steg {
-        override fun konstruer(connection: DBConnection): StegUtfører {
+        override fun konstruer(connection: DBConnection): Steg.Utfører {
             return FerdigSteg()
         }
     }

diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/FerdigstillBrevSteg.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/FerdigstillBrevSteg.kt
@@ -1,18 +1,17 @@
 package no.nav.aap.brev.prosessering.steg
 
-import no.nav.aap.brev.prosessering.steg.StegUtfører.Kontekst
 import no.nav.aap.komponenter.dbconnect.DBConnection
 import org.slf4j.LoggerFactory
 
-class FerdigstillBrevSteg() : StegUtfører {
+class FerdigstillBrevSteg() : Steg.Utfører {
     private val log = LoggerFactory.getLogger(FerdigstillBrevSteg::class.java)
-    override fun utfør(kontekst: Kontekst): StegResultat {
+    override fun utfør(kontekst: Steg.Kontekst): Steg.Resultat {
         log.info("FerdigstillBrevSteg")
-        return StegResultat.FULLFØRT
+        return Steg.Resultat.FULLFØRT
     }
 
     companion object : Steg {
-        override fun konstruer(connection: DBConnection): StegUtfører {
+        override fun konstruer(connection: DBConnection): Steg.Utfører {
             return FerdigstillBrevSteg()
         }
     }

diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/HentFaktagrunnlagSteg.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/HentFaktagrunnlagSteg.kt
@@ -1,18 +1,17 @@
 package no.nav.aap.brev.prosessering.steg
 
-import no.nav.aap.brev.prosessering.steg.StegUtfører.Kontekst
 import no.nav.aap.komponenter.dbconnect.DBConnection
 import org.slf4j.LoggerFactory
 
-class HentFaktagrunnlagSteg() : StegUtfører {
+class HentFaktagrunnlagSteg() : Steg.Utfører {
     private val log = LoggerFactory.getLogger(HentFaktagrunnlagSteg::class.java)
-    override fun utfør(kontekst: Kontekst): StegResultat {
+    override fun utfør(kontekst: Steg.Kontekst): Steg.Resultat {
         log.info("HentFaktagrunnlagSteg")
-        return StegResultat.FULLFØRT
+        return Steg.Resultat.FULLFØRT
     }
 
     companion object : Steg {
-        override fun konstruer(connection: DBConnection): StegUtfører {
+        override fun konstruer(connection: DBConnection): Steg.Utfører {
             return HentFaktagrunnlagSteg()
         }
     }

diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/HentInnholdSteg.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/HentInnholdSteg.kt
@@ -4,28 +4,27 @@ import no.nav.aap.brev.BrevbestillingRepository
 import no.nav.aap.brev.BrevbestillingRepositoryImpl
 import no.nav.aap.brev.innhold.BrevinnholdGateway
 import no.nav.aap.brev.innhold.SanityBrevinnholdGateway
-import no.nav.aap.brev.prosessering.steg.StegUtfører.Kontekst
 import no.nav.aap.komponenter.dbconnect.DBConnection
 import org.slf4j.LoggerFactory
 
 class HentInnholdSteg(
     private val brevinnholdGateway: BrevinnholdGateway,
     private val brevbestillingRepository: BrevbestillingRepository
-) : StegUtfører {
+) : Steg.Utfører {
     private val log = LoggerFactory.getLogger(HentInnholdSteg::class.java)
-    override fun utfør(kontekst: Kontekst): StegResultat {
+    override fun utfør(kontekst: Steg.Kontekst): Steg.Resultat {
         log.info("Henter brevinnhold for bestillingsreferanse=${kontekst.referanse}")
 
         val bestilling = brevbestillingRepository.hent(kontekst.referanse)
         val brev = brevinnholdGateway.hentBrevmal(bestilling.brevtype, bestilling.språk)
 
         brevbestillingRepository.oppdaterBrev(bestilling.referanse, brev)
 
-        return StegResultat.FULLFØRT
+        return Steg.Resultat.FULLFØRT
     }
 
     companion object : Steg {
-        override fun konstruer(connection: DBConnection): StegUtfører {
+        override fun konstruer(connection: DBConnection): Steg.Utfører {
             return HentInnholdSteg(
                 brevinnholdGateway = SanityBrevinnholdGateway(),
                 brevbestillingRepository = BrevbestillingRepositoryImpl(connection),

diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/JournalførBrevSteg.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/JournalførBrevSteg.kt
@@ -1,18 +1,17 @@
 package no.nav.aap.brev.prosessering.steg
 
-import no.nav.aap.brev.prosessering.steg.StegUtfører.Kontekst
 import no.nav.aap.komponenter.dbconnect.DBConnection
 import org.slf4j.LoggerFactory
 
-class JournalførBrevSteg() : StegUtfører {
+class JournalførBrevSteg() : Steg.Utfører {
     private val log = LoggerFactory.getLogger(JournalførBrevSteg::class.java)
-    override fun utfør(kontekst: Kontekst): StegResultat {
+    override fun utfør(kontekst: Steg.Kontekst): Steg.Resultat {
         log.info("JournalførBrevSteg")
-        return StegResultat.FULLFØRT
+        return Steg.Resultat.FULLFØRT
     }
 
     companion object : Steg {
-        override fun konstruer(connection: DBConnection): StegUtfører {
+        override fun konstruer(connection: DBConnection): Steg.Utfører {
             return JournalførBrevSteg()
         }
     }

diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StarterSteg.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StarterSteg.kt
@@ -1,18 +1,17 @@
 package no.nav.aap.brev.prosessering.steg
 
-import no.nav.aap.brev.prosessering.steg.StegUtfører.Kontekst
 import no.nav.aap.komponenter.dbconnect.DBConnection
 import org.slf4j.LoggerFactory
 
-class StarterSteg() : StegUtfører {
+class StarterSteg() : Steg.Utfører {
     private val log = LoggerFactory.getLogger(StarterSteg::class.java)
-    override fun utfør(kontekst: Kontekst): StegResultat {
+    override fun utfør(kontekst: Steg.Kontekst): Steg.Resultat {
         log.info("Prosessering har startet.")
-        return StegResultat.FULLFØRT
+        return Steg.Resultat.FULLFØRT
     }
 
     companion object : Steg {
-        override fun konstruer(connection: DBConnection): StegUtfører {
+        override fun konstruer(connection: DBConnection): Steg.Utfører {
             return StarterSteg()
         }
     }

diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/Steg.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/Steg.kt
@@ -1,7 +1,19 @@
 package no.nav.aap.brev.prosessering.steg
 
+import no.nav.aap.brev.domene.BrevbestillingReferanse
 import no.nav.aap.komponenter.dbconnect.DBConnection
 
 sealed interface Steg {
-    fun konstruer(connection: DBConnection): StegUtfører
+
+    fun konstruer(connection: DBConnection): Utfører
+
+    sealed interface Utfører {
+        fun utfør(kontekst: Kontekst): Resultat
+    }
+
+    data class Kontekst(val referanse: BrevbestillingReferanse)
+
+    enum class Resultat {
+        FULLFØRT, STOPP
+    }
 }
diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StegResultat.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StegResultat.kt
diff --git a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StegUtfører.kt b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StegUtfører.kt