Test flere akaas kilder (#705)

* Test flere akaas kilder * ignorer acl meldinger på aktiviteter som er tatt over av annet team --------- Co-authored-by: johannetronstad <[email protected]>
navikt · Oct 3, 2023 · ac75e44 · ac75e44
1 parent 93227fb
commit ac75e44
Show file tree

Hide file tree

Showing 10 changed files with 111 additions and 81 deletions.
diff --git a/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/dto/KafkaAktivitetskortWrapperDTO.kt b/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/dto/KafkaAktivitetskortWrapperDTO.kt
@@ -2,6 +2,7 @@ package no.nav.veilarbaktivitet.aktivitetskort.dto
 
 import com.fasterxml.jackson.annotation.JsonProperty
 import no.nav.veilarbaktivitet.aktivitetskort.ActionType
+import no.nav.veilarbaktivitet.aktivitetskort.dto.aktivitetskort.MessageSource
 import java.util.*
 
 data class KafkaAktivitetskortWrapperDTO(
@@ -16,5 +17,23 @@ data class KafkaAktivitetskortWrapperDTO(
     actionType = ActionType.UPSERT_AKTIVITETSKORT_V1,
     messageId = messageId
 ) {
+
+    constructor(
+        payload: Aktivitetskort,
+        messageId: UUID = UUID.randomUUID(),
+        aktivitetskortType: AktivitetskortType,
+        source: MessageSource
+    ): this(
+        aktivitetskortType,
+        payload,
+        source.name,
+        messageId
+    )
+
+    constructor(
+        payload: Aktivitetskort,
+        type: AktivitetskortType = AktivitetskortType.ARENA_TILTAK,
+        source: MessageSource = MessageSource.ARENA_TILTAK_AKTIVITET_ACL
+    ): this(payload, UUID.randomUUID(), type, source)
     override fun getAktivitetskortId() = aktivitetskort.id
 }
diff --git a/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/service/AktivitetskortService.kt b/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/service/AktivitetskortService.kt
@@ -11,6 +11,7 @@ import no.nav.veilarbaktivitet.aktivitetskort.AktivitetskortMapper.toAktivitetsD
 import no.nav.veilarbaktivitet.aktivitetskort.bestilling.AktivitetskortBestilling
 import no.nav.veilarbaktivitet.aktivitetskort.bestilling.ArenaAktivitetskortBestilling
 import no.nav.veilarbaktivitet.aktivitetskort.bestilling.EksternAktivitetskortBestilling
+import no.nav.veilarbaktivitet.aktivitetskort.dto.aktivitetskort.MessageSource
 import no.nav.veilarbaktivitet.aktivitetskort.feil.AktivitetsKortFunksjonellException
 import no.nav.veilarbaktivitet.aktivitetskort.feil.ManglerOppfolgingsperiodeFeil
 import no.nav.veilarbaktivitet.aktivitetskort.feil.UlovligEndringFeil
@@ -40,6 +41,11 @@ class AktivitetskortService(
                 // Arenaaktiviteter er blitt "ekstern"-aktivitet etter de har blitt opprettet
                 val oppdatertAktivitet = when  {
                     bestilling is ArenaAktivitetskortBestilling -> {
+                        if(gammelAktivitet.eksternAktivitetData.source != MessageSource.ARENA_TILTAK_AKTIVITET_ACL.name) {
+                            log.info("Aktivitet tatt over av annet team. Ignorerer melding fra aktivitet arena acl $id")
+                            return UpsertActionResult.IGNORER
+
+                        }
                         arenaAktivitetskortService.oppdaterAktivitet(
                             bestilling,
                             gammelAktivitet)
@@ -135,7 +141,7 @@ class AktivitetskortService(
         aktivitetsMessageDAO.updateActionResult(messageId, upsertActionResult, reason)
     }
 
-    fun hentAktivitetskortByFunksjonellId(funksjonellId: UUID): Optional<AktivitetData> {
-        return aktivitetDAO.hentAktivitetByFunksjonellId(funksjonellId)
+    fun hentAktivitetskortByFunksjonellId(funksjonellId: UUID): AktivitetData {
+        return aktivitetDAO.hentAktivitetByFunksjonellId(funksjonellId).get()
     }
 }
diff --git a/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/service/UpsertActionResult.kt b/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/service/UpsertActionResult.kt
@@ -4,5 +4,6 @@ enum class UpsertActionResult {
     OPPDATER,
     OPPRETT,
     KASSER,
-    FUNKSJONELL_FEIL
+    FUNKSJONELL_FEIL,
+    IGNORER
 }
diff --git a/src/test/java/no/nav/veilarbaktivitet/brukernotifikasjon/BrukernotifikasjonTest.java b/src/test/java/no/nav/veilarbaktivitet/brukernotifikasjon/BrukernotifikasjonTest.java
@@ -17,6 +17,7 @@
 import no.nav.veilarbaktivitet.aktivitet.mappers.AktivitetDTOMapper;
 import no.nav.veilarbaktivitet.aktivitetskort.*;
 import no.nav.veilarbaktivitet.aktivitetskort.dto.AktivitetskortType;
+import no.nav.veilarbaktivitet.aktivitetskort.dto.KafkaAktivitetskortWrapperDTO;
 import no.nav.veilarbaktivitet.aktivitetskort.dto.aktivitetskort.MessageSource;
 import no.nav.veilarbaktivitet.arena.model.ArenaId;
 import no.nav.veilarbaktivitet.avtalt_med_nav.AvtaltMedNavDTO;
@@ -367,13 +368,15 @@ void skal_kunne_opprette_brukernotifications_pa_fho_pa_arena_aktiviteter_som_ER_
         var mockVeileder = MockNavService.createVeileder(mockBruker);
         var arenaId = new ArenaId("ARENATA123");
         // Opprett ekstern aktivitet
-        var aktivitetskortMelding = AktivitetskortUtil.aktivitetskortMelding(
+        var aktivitetskortMelding = new KafkaAktivitetskortWrapperDTO(
                 AktivitetskortUtil.ny(
                         UUID.randomUUID(),
                         AktivitetStatus.GJENNOMFORES,
                         ZonedDateTime.now(),
                         mockBruker
-                ), AktivitetskortType.ARENA_TILTAK, MessageSource.ARENA_TILTAK_AKTIVITET_ACL
+                ),
+                AktivitetskortType.ARENA_TILTAK,
+                MessageSource.ARENA_TILTAK_AKTIVITET_ACL
         );
         var headers = new ArenaMeldingHeaders(arenaId, "MIDL");
         aktivitetTestService.opprettEksterntArenaKort(new ArenaKort(aktivitetskortMelding, headers));

diff --git a/src/test/java/no/nav/veilarbaktivitet/kvp/KvpAvsluttetKafkaConsumerTest.java b/src/test/java/no/nav/veilarbaktivitet/kvp/KvpAvsluttetKafkaConsumerTest.java
@@ -8,6 +8,7 @@
 import no.nav.veilarbaktivitet.aktivitetskort.AktivitetskortUtil;
 import no.nav.veilarbaktivitet.aktivitetskort.MigreringService;
 import no.nav.veilarbaktivitet.aktivitetskort.dto.AktivitetskortType;
+import no.nav.veilarbaktivitet.aktivitetskort.dto.KafkaAktivitetskortWrapperDTO;
 import no.nav.veilarbaktivitet.aktivitetskort.dto.aktivitetskort.MessageSource;
 import no.nav.veilarbaktivitet.config.kafka.NavCommonKafkaConfig;
 import no.nav.veilarbaktivitet.config.kafka.kafkatemplates.KafkaJsonTemplate;
@@ -79,7 +80,7 @@ void skal_avbryte_aktiviteter_i_kvp_periode() throws ExecutionException, Interru
     void skal_ikke_avbryte_eksterne_aktiviteter_i_kvp_periode() throws ExecutionException, InterruptedException, TimeoutException {
 
         var aktivitetskort = AktivitetskortUtil.ny(UUID.randomUUID(), AktivitetStatus.PLANLAGT, ZonedDateTime.now(), mockBruker);
-        var kafkaAktivitetskortWrapperDTO = AktivitetskortUtil.aktivitetskortMelding(
+        var kafkaAktivitetskortWrapperDTO = new KafkaAktivitetskortWrapperDTO(
                 aktivitetskort, UUID.randomUUID(), AktivitetskortType.MIDLERTIDIG_LONNSTILSKUDD, MessageSource.TEAM_TILTAK);
 
         aktivitetTestService.opprettEksterntAktivitetsKort(List.of(kafkaAktivitetskortWrapperDTO));

diff --git a/...t/java/no/nav/veilarbaktivitet/veilarbportefolje/AktiviteterTilKafkaAivenServiceTest.java b/...t/java/no/nav/veilarbaktivitet/veilarbportefolje/AktiviteterTilKafkaAivenServiceTest.java
@@ -127,7 +127,7 @@ void skal_ikke_sende_arena_tiltak_til_portefolje() {
     void skal_sende_nye_lonnstilskudd_til_portefolje() {
         MockBruker mockBruker = MockNavService.createHappyBruker();
         Aktivitetskort aktivitetskort = AktivitetskortUtil.ny(UUID.randomUUID(), AktivitetStatus.PLANLAGT, ZonedDateTime.now(), mockBruker);
-        KafkaAktivitetskortWrapperDTO wrapper = AktivitetskortUtil.aktivitetskortMelding(aktivitetskort, UUID.randomUUID(), MIDLERTIDIG_LONNSTILSKUDD, MessageSource.TEAM_TILTAK);
+        KafkaAktivitetskortWrapperDTO wrapper = new KafkaAktivitetskortWrapperDTO(aktivitetskort, UUID.randomUUID(), MIDLERTIDIG_LONNSTILSKUDD, MessageSource.TEAM_TILTAK);
         aktivitetTestService.opprettEksterntAktivitetsKort(List.of(wrapper));
         cronService.sendOppTil5000AktiviterTilPortefolje();
         ConsumerRecord<String, String> portefojeRecord = getSingleRecord(portefoljeConsumer, portefoljeTopic, DEFAULT_WAIT_TIMEOUT_DURATION);
@@ -144,7 +144,7 @@ void skal_ikke_sende_tiltak_opprettet_som_historisk() {
         // Happy bruker har en gammel periode startDato nå-100 dager, sluttDato nå-50 dager
         UUID funksjonellId = UUID.randomUUID();
         Aktivitetskort aktivitetskort = AktivitetskortUtil.ny(funksjonellId, AktivitetStatus.PLANLAGT, ZonedDateTime.now().minusDays(75), mockBruker);
-        KafkaAktivitetskortWrapperDTO wrapper = AktivitetskortUtil.aktivitetskortMelding(aktivitetskort, funksjonellId, AktivitetskortType.ARENA_TILTAK, MessageSource.ARENA_TILTAK_AKTIVITET_ACL);
+        KafkaAktivitetskortWrapperDTO wrapper = new KafkaAktivitetskortWrapperDTO(aktivitetskort, funksjonellId, AktivitetskortType.ARENA_TILTAK, MessageSource.ARENA_TILTAK_AKTIVITET_ACL);
         ArenaId arenaId = new ArenaId("ARENATA123");
         String tiltakskode = "MIDLONNTIL";
         aktivitetTestService.opprettEksterntArenaKort(new ArenaKort(wrapper, new ArenaMeldingHeaders(arenaId, tiltakskode)));