diff --git a/src/main/java/no/nav/pto/veilarbportefolje/arbeidssoeker/v2/ArbeidssoekerService.kt b/src/main/java/no/nav/pto/veilarbportefolje/arbeidssoeker/v2/ArbeidssoekerService.kt index bba4037bde..3fd5903185 100644 --- a/src/main/java/no/nav/pto/veilarbportefolje/arbeidssoeker/v2/ArbeidssoekerService.kt +++ b/src/main/java/no/nav/pto/veilarbportefolje/arbeidssoeker/v2/ArbeidssoekerService.kt @@ -1,10 +1,8 @@ package no.nav.pto.veilarbportefolje.arbeidssoeker.v2 -import io.getunleash.DefaultUnleash import no.nav.common.types.identer.AktorId import no.nav.common.types.identer.Fnr import no.nav.paw.arbeidssokerregisteret.api.v1.Periode -import no.nav.pto.veilarbportefolje.config.FeatureToggle import no.nav.pto.veilarbportefolje.kafka.KafkaCommonNonKeyedConsumerService import no.nav.pto.veilarbportefolje.opensearch.OpensearchIndexerV2 import no.nav.pto.veilarbportefolje.persononinfo.PdlIdentRepository @@ -50,17 +48,13 @@ class ArbeidssoekerService( private val opplysningerOmArbeidssoekerRepository: OpplysningerOmArbeidssoekerRepository, private val sisteArbeidssoekerPeriodeRepository: SisteArbeidssoekerPeriodeRepository, private val profileringRepository: ProfileringRepository, - private val defaultUnleash: DefaultUnleash, private val arbeidssoekerDataRepository: ArbeidssoekerDataRepository, private val opensearchIndexerV2: OpensearchIndexerV2 ) { @Transactional fun behandleKafkaMeldingLogikk(kafkaMelding: Periode) { - if (!FeatureToggle.brukNyttArbeidssoekerregisterKafka(defaultUnleash)) { - secureLog.info("Bryter for å lytte på kafkameldinger fra nytt arbeidssøkerregister er skrudd av. Ignorerer melding.") - return - } + val periodeId = kafkaMelding.id val identitetsnummer = kafkaMelding.identitetsnummer @@ -115,10 +109,7 @@ class ArbeidssoekerService( @Transactional fun behandleKafkaMeldingLogikk(opplysninger: OpplysningerOmArbeidssoekerKafkaMelding) { - if (!FeatureToggle.brukNyttArbeidssoekerregisterKafka(defaultUnleash)) { - secureLog.info("Bryter for å lytte på kafkameldinger fra nytt arbeidssøkerregister er skrudd av. Ignorerer melding.") - return - } + val arbeidssoekerPeriodeId = opplysninger.periodeId val opplysningerOmArbeidssoekerId = opplysninger.id @@ -135,7 +126,7 @@ class ArbeidssoekerService( val fnr = sisteArbeidssoekerPeriode.fnr if (!pdlIdentRepository.erBrukerUnderOppfolging(fnr)) { secureLog.info( - "Bruker med fnr ${fnr} er ikke under oppfølging, men har arbeidssøkerpeiode lagret. " + + "Bruker med fnr $fnr er ikke under oppfølging, men har arbeidssøkerpeiode lagret. " + "Dette betyr at arbeidssøkerdata ikke har blitt slettet riktig når bruker gikk ut av oppfølging. " + "Ignorer melding, data må slettes manuelt og slettelogikk ved utgang av oppfølging bør kontrollsjekkes for feil." ) @@ -164,10 +155,7 @@ class ArbeidssoekerService( @Transactional fun behandleKafkaMeldingLogikk(kafkaMelding: ProfileringKafkaMelding) { - if (!FeatureToggle.brukNyttArbeidssoekerregisterKafka(defaultUnleash)) { - secureLog.info("Bryter for å lytte på kafkameldinger fra nytt arbeidssøkerregister er skrudd av. Ignorerer melding.") - return - } + secureLog.info("Behandler endring på profilering for bruker med arbeidssoekerPeriodeId: ${kafkaMelding.periodeId}") val sisteArbeidssoekerPeriode = @@ -181,7 +169,7 @@ class ArbeidssoekerService( val fnr = sisteArbeidssoekerPeriode.fnr if (!pdlIdentRepository.erBrukerUnderOppfolging(fnr)) { secureLog.info( - "Bruker med fnr ${fnr} er ikke under oppfølging, men har arbeidssøkerpeiode lagret. " + + "Bruker med fnr $fnr er ikke under oppfølging, men har arbeidssøkerpeiode lagret. " + "Dette betyr at arbeidssøkerdata ikke har blitt slettet riktig når bruker gikk ut av oppfølging. " + "Ignorer melding, data må slettes manuelt og slettelogikk ved utgang av oppfølging bør kontrollsjekkes for feil." ) diff --git a/src/main/java/no/nav/pto/veilarbportefolje/config/FeatureToggle.java b/src/main/java/no/nav/pto/veilarbportefolje/config/FeatureToggle.java index 1b8d475531..7385cf7518 100644 --- a/src/main/java/no/nav/pto/veilarbportefolje/config/FeatureToggle.java +++ b/src/main/java/no/nav/pto/veilarbportefolje/config/FeatureToggle.java @@ -13,11 +13,7 @@ private FeatureToggle() { public static final String KAFKA_AIVEN_CONSUMERS_STOP = "veilarbportefolje.kafka_aiven_consumers_stop"; public static final String KAFKA_SISTE_14A_STOP = "veilarbportefolje.kafka_siste_14a_stop"; public static final String BRUK_FILTER_FOR_BRUKERINNSYN_TILGANGER = "veilarbportefolje.bruk_filter_for_brukerinnsyn_tilganger"; - public static final String STOPP_OPENSEARCH_INDEKSERING = "veilarbportefolje.stopp_opensearch_indeksering"; - public static final String BRUK_NYTT_ARBEIDSSOEKERREGISTER = "veilarbportefolje.bruk_nytt_arbeidssoekerregister"; - public static final String BRUK_NYTT_ARBEIDSSOEKERREGISTER_KAFKA = "veilarbportefolje.bruk_nytt_arbeidssoekerregister_kafka"; - public static final String STOPP_KONSUMERING_FRA_PORTEFOLJE_HENDELSESFILTER_TOPIC = "veilarbportefolje.stopp_konsumering_fra_portefolje_hendelsesfilter_topic"; public static boolean brukAvAliasIndeksering(DefaultUnleash defaultUnleash) { @@ -32,12 +28,4 @@ public static boolean brukFilterForBrukerinnsynTilganger(DefaultUnleash defaultU public static boolean stoppOpensearchIndeksering(DefaultUnleash defaultUnleash) { return defaultUnleash.isEnabled(FeatureToggle.STOPP_OPENSEARCH_INDEKSERING); } - - public static boolean brukNyttArbeidssoekerregister(DefaultUnleash defaultUnleash) { - return defaultUnleash.isEnabled(FeatureToggle.BRUK_NYTT_ARBEIDSSOEKERREGISTER); - } - - public static boolean brukNyttArbeidssoekerregisterKafka(DefaultUnleash defaultUnleash) { - return defaultUnleash.isEnabled(FeatureToggle.BRUK_NYTT_ARBEIDSSOEKERREGISTER_KAFKA); - } } diff --git a/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java b/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java index f127b73dee..f55baebe59 100644 --- a/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java +++ b/src/main/java/no/nav/pto/veilarbportefolje/opensearch/OpensearchIndexer.java @@ -1,11 +1,10 @@ package no.nav.pto.veilarbportefolje.opensearch; -import io.getunleash.DefaultUnleash; import lombok.RequiredArgsConstructor; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import no.nav.common.types.identer.AktorId; -import no.nav.pto.veilarbportefolje.config.FeatureToggle; + import no.nav.pto.veilarbportefolje.opensearch.domene.OppfolgingsBruker; import no.nav.pto.veilarbportefolje.postgres.BrukerRepositoryV2; import no.nav.pto.veilarbportefolje.postgres.PostgresOpensearchMapper; @@ -38,7 +37,6 @@ public class OpensearchIndexer { private final IndexName alias; private final PostgresOpensearchMapper postgresOpensearchMapper; private final OpensearchIndexerV2 opensearchIndexerV2; - private final DefaultUnleash defaultUnleash; public void indekser(AktorId aktoerId) { Optional bruker; @@ -127,9 +125,8 @@ private void flettInnNodvendigData(List brukere) { postgresOpensearchMapper.flettInnTiltakshendelser(brukere); postgresOpensearchMapper.flettInnSiste14aVedtak(brukere); postgresOpensearchMapper.flettInnEldsteUtgattVarsel(brukere); - if (FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)) { - postgresOpensearchMapper.flettInnOpplysningerOmArbeidssoekerData(brukere); - } + + postgresOpensearchMapper.flettInnOpplysningerOmArbeidssoekerData(brukere); if (brukere.isEmpty()) { log.warn("Skriver ikke til index da alle brukere i batchen er ugyldige"); diff --git a/src/test/java/no/nav/pto/veilarbportefolje/arbeidssoeker/v2/ArbeidssoekerServiceTest.kt b/src/test/java/no/nav/pto/veilarbportefolje/arbeidssoeker/v2/ArbeidssoekerServiceTest.kt index d8b8eb61f6..5749dbe57e 100644 --- a/src/test/java/no/nav/pto/veilarbportefolje/arbeidssoeker/v2/ArbeidssoekerServiceTest.kt +++ b/src/test/java/no/nav/pto/veilarbportefolje/arbeidssoeker/v2/ArbeidssoekerServiceTest.kt @@ -11,7 +11,6 @@ import no.nav.paw.arbeidssokerregisteret.api.v1.ProfilertTil import no.nav.paw.arbeidssokerregisteret.api.v2.Annet import no.nav.paw.arbeidssokerregisteret.api.v4.Utdanning import no.nav.pto.veilarbportefolje.config.ApplicationConfigTest -import no.nav.pto.veilarbportefolje.config.FeatureToggle import no.nav.pto.veilarbportefolje.database.PostgresTable.SISTE_ARBEIDSSOEKER_PERIODE import no.nav.pto.veilarbportefolje.oppfolging.OppfolgingPeriodeService import no.nav.pto.veilarbportefolje.oppfolgingsbruker.OppfolgingsbrukerDTO @@ -141,7 +140,6 @@ class ArbeidssoekerServiceTest( @Test fun meldinger_om_periode_og_opplysninger_om_arbeidssoeker_skal_ignoreres_dersom_bruker_ikke_er_under_oppfolging() { - `when`(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true) val periodeId = UUID.fromString("ea0ad984-8b99-4fff-afd6-07737ab19d16") val opplysningerOmArbeidssoekerId = UUID.fromString("913161a3-dde9-4448-abf8-2a01a043f8cd") val fnr = Fnr.of("17858998980") @@ -262,7 +260,6 @@ class ArbeidssoekerServiceTest( */ // Arrange - `when`(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true) val gammelPeriodeId = UUID.fromString("ea0ad984-8b99-4fff-afd6-07737ab19d16") val nyPeriodeId = UUID.randomUUID() val gammelOpplysningerOmArbeidssoekerId = UUID.fromString("913161a3-dde9-4448-abf8-2a01a043f8cd") @@ -330,7 +327,6 @@ class ArbeidssoekerServiceTest( @Test fun ved_kafkamelding_om_nye_opplysninger_om_arbeidssoeker_paa_ny_arbeidssoekerperiode_ignoreres_meldingen_dersom_vi_ikke_har_data_paa_periodeId() { // Arrange - `when`(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true) val periodeIdVedOppfolgingStartet = UUID.fromString("ea0ad984-8b99-4fff-afd6-07737ab19d16") val nyPeriodeId = UUID.randomUUID() val opplysningerOmArbeidssoekerIdVedOppfolgingStartet = UUID.fromString("913161a3-dde9-4448-abf8-2a01a043f8cd") @@ -388,7 +384,6 @@ class ArbeidssoekerServiceTest( @Test fun ved_kafkamelding_om_nye_opplysninger_om_arbeidssoeker_paa_eksisterende_arbeidssoekerperiode_slettes_gammle_opplysninger_om_arbiedssoeker_og_ny_lagres() { // Arrange - `when`(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true) val periodeIdVedOppfolgingStartet = UUID.fromString("ea0ad984-8b99-4fff-afd6-07737ab19d16") val opplysningerOmArbeidssoekerIdVedOppfolgingStartet = UUID.fromString("913161a3-dde9-4448-abf8-2a01a043f8cd") val nyOpplysningerOmArbeidssoekerId = UUID.randomUUID() @@ -452,7 +447,6 @@ class ArbeidssoekerServiceTest( @Test fun ved_kafkamelding_om_ny_profilering_for_arbeidssoeker_paa_eksisterende_arbeidssoekerperiode_slettes_gammel_profilering_om_arbiedssoeker_og_ny_lagres() { // Arrange - `when`(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true) val periodeIdVedOppfolgingStartet = UUID.fromString("ea0ad984-8b99-4fff-afd6-07737ab19d16") val nyOpplysningerOmArbeidssoekerId = UUID.randomUUID() val fnr = Fnr.of("17858998980") @@ -499,7 +493,6 @@ class ArbeidssoekerServiceTest( @Test fun ved_kafkamelding_om_ny_profilering_for_arbeidssoeker_paa_ny_arbeidssoekerperiode_ignoreres_dersom_vi_ikke_har_priodeId() { // Arrange - `when`(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true) val periodeIdVedOppfolgingStartet = UUID.fromString("ea0ad984-8b99-4fff-afd6-07737ab19d16") val periodeIdVedEndring = UUID.fromString("ea0ad984-8b99-4fff-afd6-07737ab20a45") val nyOpplysningerOmArbeidssoekerId = UUID.randomUUID() diff --git a/src/test/java/no/nav/pto/veilarbportefolje/config/ApplicationConfigTest.java b/src/test/java/no/nav/pto/veilarbportefolje/config/ApplicationConfigTest.java index a78281aaad..281c0118a0 100644 --- a/src/test/java/no/nav/pto/veilarbportefolje/config/ApplicationConfigTest.java +++ b/src/test/java/no/nav/pto/veilarbportefolje/config/ApplicationConfigTest.java @@ -95,7 +95,6 @@ import java.util.UUID; import static no.nav.common.utils.IdUtils.generateId; -import static no.nav.pto.veilarbportefolje.config.FeatureToggle.BRUK_NYTT_ARBEIDSSOEKERREGISTER; import static no.nav.pto.veilarbportefolje.domene.Kjonn.K; import static no.nav.pto.veilarbportefolje.opensearch.OpensearchUtils.createClient; import static no.nav.pto.veilarbportefolje.util.TestDataUtils.*; @@ -231,7 +230,6 @@ public AktorClient aktorClient() { public DefaultUnleash defaultUnleash() { final DefaultUnleash mock = mock(DefaultUnleash.class); when(mock.isEnabled(anyString())).thenReturn(true); - when(mock.isEnabled(BRUK_NYTT_ARBEIDSSOEKERREGISTER)).thenReturn(false); return mock; } diff --git a/src/test/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingStartetOgAvsluttetServiceTest.java b/src/test/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingStartetOgAvsluttetServiceTest.java index eb8b5707b4..817d1e24fd 100644 --- a/src/test/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingStartetOgAvsluttetServiceTest.java +++ b/src/test/java/no/nav/pto/veilarbportefolje/oppfolging/OppfolgingStartetOgAvsluttetServiceTest.java @@ -7,7 +7,6 @@ import no.nav.common.types.identer.Fnr; import no.nav.pto.veilarbportefolje.arbeidssoeker.v2.*; import no.nav.pto.veilarbportefolje.config.ApplicationConfigTest; -import no.nav.pto.veilarbportefolje.config.FeatureToggle; import no.nav.pto.veilarbportefolje.domene.AktorClient; import no.nav.pto.veilarbportefolje.domene.BrukerOppdatertInformasjon; import no.nav.pto.veilarbportefolje.oppfolgingsbruker.*; @@ -89,9 +88,6 @@ class OppfolgingStartetOgAvsluttetServiceTest extends EndToEndTest { @Autowired private ArbeidssoekerService arbeidssoekerService; - @Autowired - private SisteArbeidssoekerPeriodeRepository sisteArbeidssoekerPeriodeRepository; - @MockBean private PdlPortefoljeClient pdlPortefoljeClient; @@ -237,7 +233,6 @@ public void cleanup() { @Test void når_oppfolging_startes_skal_arbeidssoekerdata_hentes_lagres() throws JsonProcessingException { UUID periodeId = UUID.fromString("ea0ad984-8b99-4fff-afd6-07737ab19d16"); - when(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true); mockPdlIdenterRespons(aktorId, fnr); mockPdlPersonRespons(fnr); mockPdlPersonBarnRespons(fnr); @@ -338,7 +333,6 @@ public void cleanup() { @Test void når_oppfølging_avsluttes_skal_arbeidssøkerdata_slettes() throws JsonProcessingException { - when(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true); when(aktorClient.hentFnr(aktorId)).thenReturn(fnr); when(aktorClient.hentAktorId(fnr)).thenReturn(aktorId); mockHentArbeidssoekerPerioderResponse(fnr); diff --git a/src/test/java/no/nav/pto/veilarbportefolje/util/EndToEndTest.java b/src/test/java/no/nav/pto/veilarbportefolje/util/EndToEndTest.java index 8769c7cd9f..7c5c48252d 100644 --- a/src/test/java/no/nav/pto/veilarbportefolje/util/EndToEndTest.java +++ b/src/test/java/no/nav/pto/veilarbportefolje/util/EndToEndTest.java @@ -5,13 +5,11 @@ import no.nav.common.types.identer.AktorId; import no.nav.common.types.identer.Fnr; import no.nav.pto.veilarbportefolje.config.ApplicationConfigTest; -import no.nav.pto.veilarbportefolje.config.FeatureToggle; import no.nav.pto.veilarbportefolje.domene.value.NavKontor; import no.nav.pto.veilarbportefolje.domene.value.VeilederId; import no.nav.pto.veilarbportefolje.opensearch.IndexName; import no.nav.pto.veilarbportefolje.opensearch.OpensearchAdminService; import no.nav.pto.veilarbportefolje.opensearch.OpensearchIndexer; -import no.nav.pto.veilarbportefolje.opensearch.OpensearchIndexerV2; import no.nav.pto.veilarbportefolje.opensearch.domene.OppfolgingsBruker; import no.nav.pto.veilarbportefolje.oppfolging.OppfolgingRepositoryV2; import no.nav.pto.veilarbportefolje.persononinfo.PdlIdentRepository; @@ -29,7 +27,6 @@ import java.util.TimeZone; import java.util.concurrent.TimeUnit; -import static org.mockito.Mockito.when; @SpringBootTest(classes = ApplicationConfigTest.class) @DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS) @@ -44,9 +41,6 @@ public abstract class EndToEndTest { @Autowired protected OpensearchIndexer opensearchIndexer; - @Autowired - protected OpensearchIndexerV2 opensearchIndexerV2; - @Autowired protected PdlIdentRepository pdlIdentRepository; @@ -67,7 +61,6 @@ void setUp() { try { TimeZone.setDefault(TimeZone.getTimeZone(Optional.ofNullable(System.getenv("TZ")).orElse("Europe/Oslo"))); opensearchAdminService.opprettNyIndeks(indexName.getValue()); - when(FeatureToggle.brukNyttArbeidssoekerregister(defaultUnleash)).thenReturn(true); } catch (Exception e) { opensearchAdminService.slettIndex(indexName.getValue()); opensearchAdminService.opprettNyIndeks(indexName.getValue());