From d2c4e81eadd7dc0b9d06526f951798271e96314a Mon Sep 17 00:00:00 2001 From: throndi <56258085+throndi@users.noreply.github.com> Date: Tue, 9 Jan 2024 14:09:22 +0100 Subject: [PATCH 1/2] =?UTF-8?q?Trenger=20ikke=20lenger=20=C3=A5=20sende=20?= =?UTF-8?q?over=20lister=20av=20brukere=20til=20kafka-k=C3=B8=20for=20mins?= =?UTF-8?q?ide?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ef/sak/fagsak/FagsakPersonService.kt | 6 +-- .../MinsideForvaltningsController.kt | 11 ----- .../minside/MikrofrontendEnableBrukerTask.kt | 36 +++++++++++++++ .../minside/MikrofrontendEnableBrukereTask.kt | 45 ------------------- 4 files changed, 39 insertions(+), 59 deletions(-) create mode 100644 src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt delete mode 100644 src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukereTask.kt diff --git a/src/main/kotlin/no/nav/familie/ef/sak/fagsak/FagsakPersonService.kt b/src/main/kotlin/no/nav/familie/ef/sak/fagsak/FagsakPersonService.kt index b3ba789601..195e7d0196 100644 --- a/src/main/kotlin/no/nav/familie/ef/sak/fagsak/FagsakPersonService.kt +++ b/src/main/kotlin/no/nav/familie/ef/sak/fagsak/FagsakPersonService.kt @@ -4,7 +4,7 @@ import no.nav.familie.ef.sak.fagsak.domain.FagsakPerson import no.nav.familie.ef.sak.fagsak.domain.PersonIdent import no.nav.familie.ef.sak.infrastruktur.exception.feilHvis import no.nav.familie.ef.sak.infrastruktur.exception.feilHvisIkke -import no.nav.familie.ef.sak.minside.MikrofrontendEnableBrukereTask +import no.nav.familie.ef.sak.minside.MikrofrontendEnableBrukerTask import no.nav.familie.ef.sak.repository.findByIdOrThrow import no.nav.familie.prosessering.internal.TaskService import org.springframework.stereotype.Service @@ -43,7 +43,7 @@ class FagsakPersonService(private val fagsakPersonRepository: FagsakPersonReposi fun oppdaterIdent(fagsakPerson: FagsakPerson, gjeldendePersonIdent: String): FagsakPerson { if (fagsakPerson.hentAktivIdent() != gjeldendePersonIdent) { val oppdatertFagsakPerson = fagsakPerson.medOppdatertGjeldendeIdent(gjeldendePersonIdent) - taskService.save(MikrofrontendEnableBrukereTask.opprettTask(oppdatertFagsakPerson)) + taskService.save(MikrofrontendEnableBrukerTask.opprettTask(oppdatertFagsakPerson)) return fagsakPersonRepository.update(oppdatertFagsakPerson) } else { return fagsakPerson @@ -52,7 +52,7 @@ class FagsakPersonService(private val fagsakPersonRepository: FagsakPersonReposi fun opprettFagsakPersonOgAktiverForMinSide(gjeldendePersonIdent: String): FagsakPerson { val fagsakPerson = fagsakPersonRepository.insert(FagsakPerson(identer = setOf(PersonIdent(gjeldendePersonIdent)))) - taskService.save(MikrofrontendEnableBrukereTask.opprettTask(fagsakPerson)) + taskService.save(MikrofrontendEnableBrukerTask.opprettTask(fagsakPerson)) return fagsakPerson } } diff --git a/src/main/kotlin/no/nav/familie/ef/sak/forvaltning/MinsideForvaltningsController.kt b/src/main/kotlin/no/nav/familie/ef/sak/forvaltning/MinsideForvaltningsController.kt index 90c8397dfd..20ae8583ed 100644 --- a/src/main/kotlin/no/nav/familie/ef/sak/forvaltning/MinsideForvaltningsController.kt +++ b/src/main/kotlin/no/nav/familie/ef/sak/forvaltning/MinsideForvaltningsController.kt @@ -6,7 +6,6 @@ import no.nav.familie.ef.sak.infrastruktur.exception.feilHvisIkke import no.nav.familie.ef.sak.infrastruktur.featuretoggle.FeatureToggleService import no.nav.familie.ef.sak.infrastruktur.featuretoggle.Toggle import no.nav.familie.ef.sak.infrastruktur.sikkerhet.SikkerhetContext -import no.nav.familie.ef.sak.minside.MikrofrontendEnableBrukereTask import no.nav.familie.ef.sak.minside.MinSideKafkaProducerService import no.nav.familie.prosessering.internal.TaskService import no.nav.security.token.support.core.api.ProtectedWithClaims @@ -38,16 +37,6 @@ class MinsideForvaltningsController( minSideKafkaProducerService.deaktiver(personIdent = personIdentDto.personIdent) } - @PostMapping("aktiver-alle") - fun aktiverAllePersonerForMinSide() { - feilHvisIkke(erUtviklerMedVeilderrolle()) { "Kan kun kjøres av utvikler med veilederrolle" } - fagsakPersonRepository.findAll().chunked(250) - .forEach { fagsakPersoner -> - val task = MikrofrontendEnableBrukereTask.opprettTask(fagsakPersoner) - taskService.save(task) - } - } - private fun validerPersonIdent(personIdentDto: PersonIdentDto) { if (personIdentDto.personIdent.length != 11) { error("PersonIdent må ha 11 siffer") diff --git a/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt b/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt new file mode 100644 index 0000000000..612d77de5e --- /dev/null +++ b/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt @@ -0,0 +1,36 @@ +package no.nav.familie.ef.sak.minside + +import no.nav.familie.ef.sak.fagsak.domain.FagsakPerson +import no.nav.familie.kontrakter.felles.objectMapper +import no.nav.familie.prosessering.AsyncTaskStep +import no.nav.familie.prosessering.TaskStepBeskrivelse +import no.nav.familie.prosessering.domene.Task +import org.slf4j.LoggerFactory +import org.springframework.stereotype.Service + +@Service +@TaskStepBeskrivelse( + taskStepType = MikrofrontendEnableBrukerTask.TYPE, + beskrivelse = "Sender over person til kafka-kø for minside", +) +class MikrofrontendEnableBrukerTask(val minSideKafkaProducerService: MinSideKafkaProducerService) : AsyncTaskStep { + + private val logger = LoggerFactory.getLogger(this::class.java) + + override fun doTask(task: Task) { + logger.info("Starter task for aktivering av bruker for mikrofrontend") + val personIdent = task.payload + minSideKafkaProducerService.aktiver(personIdent) + } + + companion object { + + fun opprettTask(fagsakPerson: FagsakPerson): Task { + return Task( + type = TYPE, + payload = objectMapper.writeValueAsString(listOf(fagsakPerson.hentAktivIdent())), + ) + } + const val TYPE = "mikrofrontendEnableBrukerTask" + } +} diff --git a/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukereTask.kt b/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukereTask.kt deleted file mode 100644 index e22dec0a76..0000000000 --- a/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukereTask.kt +++ /dev/null @@ -1,45 +0,0 @@ -package no.nav.familie.ef.sak.minside - -import com.fasterxml.jackson.module.kotlin.readValue -import no.nav.familie.ef.sak.fagsak.domain.FagsakPerson -import no.nav.familie.kontrakter.felles.objectMapper -import no.nav.familie.prosessering.AsyncTaskStep -import no.nav.familie.prosessering.TaskStepBeskrivelse -import no.nav.familie.prosessering.domene.Task -import org.slf4j.LoggerFactory -import org.springframework.stereotype.Service - -@Service -@TaskStepBeskrivelse( - taskStepType = MikrofrontendEnableBrukereTask.TYPE, - beskrivelse = "Sender over liste av personer til minside kafka-kø", -) -class MikrofrontendEnableBrukereTask(val minSideKafkaProducerService: MinSideKafkaProducerService) : AsyncTaskStep { - - private val logger = LoggerFactory.getLogger(this::class.java) - - override fun doTask(task: Task) { - logger.info("Starter task for aktivering av brukere for mikrofrontend") - val personIdenter = objectMapper.readValue>(task.payload) - personIdenter.forEach { personIdent -> - minSideKafkaProducerService.aktiver(personIdent) - } - } - - companion object { - - fun opprettTask(fagsakPerson: List): Task { - return Task( - type = TYPE, - payload = objectMapper.writeValueAsString(fagsakPerson.map { it.hentAktivIdent() }), - ) - } - fun opprettTask(fagsakPerson: FagsakPerson): Task { - return Task( - type = TYPE, - payload = objectMapper.writeValueAsString(listOf(fagsakPerson.hentAktivIdent())), - ) - } - const val TYPE = "mikrofrontendEnableBrukereTask" - } -} From 54d9a32c0b050fd221df9f8c9088c899895b34b0 Mon Sep 17 00:00:00 2001 From: throndi <56258085+throndi@users.noreply.github.com> Date: Tue, 9 Jan 2024 14:12:10 +0100 Subject: [PATCH 2/2] rettelse --- .../familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt b/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt index 612d77de5e..289078e9d4 100644 --- a/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt +++ b/src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukerTask.kt @@ -1,7 +1,6 @@ package no.nav.familie.ef.sak.minside import no.nav.familie.ef.sak.fagsak.domain.FagsakPerson -import no.nav.familie.kontrakter.felles.objectMapper import no.nav.familie.prosessering.AsyncTaskStep import no.nav.familie.prosessering.TaskStepBeskrivelse import no.nav.familie.prosessering.domene.Task @@ -28,7 +27,7 @@ class MikrofrontendEnableBrukerTask(val minSideKafkaProducerService: MinSideKafk fun opprettTask(fagsakPerson: FagsakPerson): Task { return Task( type = TYPE, - payload = objectMapper.writeValueAsString(listOf(fagsakPerson.hentAktivIdent())), + payload = fagsakPerson.hentAktivIdent(), ) } const val TYPE = "mikrofrontendEnableBrukerTask"