Merge pull request #1839 from navikt/dev

Prodsette fjerning av to feature toggler

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."
             )

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);
-    }
 }

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<OppfolgingsBruker> bruker;
@@ -127,9 +125,8 @@ private void flettInnNodvendigData(List<OppfolgingsBruker> 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");

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()

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;
     }

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);

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());