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 index e95f5bd..6aed446 100644 --- 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) { + private fun prosesserTilStopp(kontekst: Steg.Kontekst, stegene: List) { 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 index 2e46972..8631c39 100644 --- 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 index 3659a32..6cbc6b4 100644 --- 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 index 89517fa..35cdbb1 100644 --- 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 index 3a71d3f..c5e2530 100644 --- 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 index 6d7106b..f2f4e38 100644 --- 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,16 +4,15 @@ 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) @@ -21,11 +20,11 @@ class HentInnholdSteg( 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\303\270rBrevSteg.kt" "b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/Journalf\303\270rBrevSteg.kt" index d97a0d5..d9b3a4b 100644 --- "a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/Journalf\303\270rBrevSteg.kt" +++ "b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/Journalf\303\270rBrevSteg.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 index 0d7c676..92282b1 100644 --- 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 index fae280a..524d5c1 100644 --- 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 deleted file mode 100644 index 9b151be..0000000 --- a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StegResultat.kt +++ /dev/null @@ -1,5 +0,0 @@ -package no.nav.aap.brev.prosessering.steg - -enum class StegResultat { - FULLFØRT, STOPP -} diff --git "a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StegUtf\303\270rer.kt" "b/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StegUtf\303\270rer.kt" deleted file mode 100644 index fbd7f9f..0000000 --- "a/app/src/main/kotlin/no/nav/aap/brev/prosessering/steg/StegUtf\303\270rer.kt" +++ /dev/null @@ -1,10 +0,0 @@ -package no.nav.aap.brev.prosessering.steg - -import no.nav.aap.brev.domene.BrevbestillingReferanse - -sealed interface StegUtfører { - - data class Kontekst(val referanse: BrevbestillingReferanse) - - fun utfør(kontekst: Kontekst): StegResultat -}