Merge pull request #596 from navikt/fjerne_persongateway

R!! Bruker PdlOppslagGateway direkte i stedet for PersonGateway

src/main/java/no/nav/fo/veilarbregistrering/config/ApplicationConfig.java

@@ -5,13 +5,12 @@
 import no.nav.fo.veilarbregistrering.arbeidsforhold.adapter.ArbeidsforholdGatewayConfig;
 import no.nav.fo.veilarbregistrering.arbeidssoker.adapter.FormidlingsgruppeGatewayConfig;
 import no.nav.fo.veilarbregistrering.autorisasjon.PepConfig;
-import no.nav.fo.veilarbregistrering.bruker.adapter.PersonGatewayConfig;
 import no.nav.fo.veilarbregistrering.bruker.krr.KrrConfig;
 import no.nav.fo.veilarbregistrering.bruker.pdl.PdlOppslagConfig;
 import no.nav.fo.veilarbregistrering.db.DatabaseConfig;
-import no.nav.fo.veilarbregistrering.helsesjekk.HelsesjekkConfig;
 import no.nav.fo.veilarbregistrering.db.RepositoryConfig;
 import no.nav.fo.veilarbregistrering.enhet.adapter.EnhetGatewayConfig;
+import no.nav.fo.veilarbregistrering.helsesjekk.HelsesjekkConfig;
 import no.nav.fo.veilarbregistrering.kafka.KafkaConfig;
 import no.nav.fo.veilarbregistrering.metrics.MetricsConfig;
 import no.nav.fo.veilarbregistrering.oppfolging.adapter.OppfolgingGatewayConfig;
@@ -38,7 +37,6 @@
         CacheConfig.class,
         UnleashConfig.class,
         MetricsConfig.class,
-        PersonGatewayConfig.class,
         ArbeidsforholdGatewayConfig.class,
         OppfolgingGatewayConfig.class,
         OppgaveGatewayConfig.class,

src/main/java/no/nav/fo/veilarbregistrering/config/ServiceBeansConfig.java

@@ -13,7 +13,10 @@
 import no.nav.fo.veilarbregistrering.arbeidssoker.resources.ArbeidssokerResource;
 import no.nav.fo.veilarbregistrering.arbeidssoker.resources.InternalArbeidssokerServlet;
 import no.nav.fo.veilarbregistrering.autorisasjon.AutorisasjonService;
-import no.nav.fo.veilarbregistrering.bruker.*;
+import no.nav.fo.veilarbregistrering.bruker.KontaktinfoService;
+import no.nav.fo.veilarbregistrering.bruker.KrrGateway;
+import no.nav.fo.veilarbregistrering.bruker.PdlOppslagGateway;
+import no.nav.fo.veilarbregistrering.bruker.UserService;
 import no.nav.fo.veilarbregistrering.bruker.resources.InternalIdentServlet;
 import no.nav.fo.veilarbregistrering.bruker.resources.KontaktinfoResource;
 import no.nav.fo.veilarbregistrering.enhet.EnhetGateway;
@@ -22,21 +25,24 @@
 import no.nav.fo.veilarbregistrering.metrics.InfluxMetricsService;
 import no.nav.fo.veilarbregistrering.metrics.PrometheusMetricsService;
 import no.nav.fo.veilarbregistrering.oppfolging.OppfolgingGateway;
-import no.nav.fo.veilarbregistrering.oppgave.*;
+import no.nav.fo.veilarbregistrering.oppgave.OppgaveGateway;
+import no.nav.fo.veilarbregistrering.oppgave.OppgaveRepository;
+import no.nav.fo.veilarbregistrering.oppgave.OppgaveRouter;
+import no.nav.fo.veilarbregistrering.oppgave.OppgaveService;
 import no.nav.fo.veilarbregistrering.oppgave.resources.OppgaveResource;
 import no.nav.fo.veilarbregistrering.orgenhet.Norg2Gateway;
 import no.nav.fo.veilarbregistrering.profilering.ProfileringRepository;
 import no.nav.fo.veilarbregistrering.profilering.ProfileringService;
 import no.nav.fo.veilarbregistrering.registrering.bruker.*;
 import no.nav.fo.veilarbregistrering.registrering.bruker.resources.RegistreringResource;
-import no.nav.fo.veilarbregistrering.registrering.manuell.ManuellRegistreringRepository;
-import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerProfilertProducer;
-import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerRegistrertProducer;
-import no.nav.fo.veilarbregistrering.registrering.publisering.PubliseringAvEventsService;
 import no.nav.fo.veilarbregistrering.registrering.formidling.RegistreringTilstandRepository;
 import no.nav.fo.veilarbregistrering.registrering.formidling.RegistreringTilstandService;
 import no.nav.fo.veilarbregistrering.registrering.formidling.resources.InternalRegistreringStatusServlet;
 import no.nav.fo.veilarbregistrering.registrering.formidling.resources.InternalRegistreringStatusoversiktServlet;
+import no.nav.fo.veilarbregistrering.registrering.manuell.ManuellRegistreringRepository;
+import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerProfilertProducer;
+import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerRegistrertProducer;
+import no.nav.fo.veilarbregistrering.registrering.publisering.PubliseringAvEventsService;
 import no.nav.fo.veilarbregistrering.sykemelding.SykemeldingGateway;
 import no.nav.fo.veilarbregistrering.sykemelding.SykemeldingService;
 import no.nav.fo.veilarbregistrering.sykemelding.resources.SykemeldingResource;
@@ -92,12 +98,12 @@ BrukerTilstandService brukerTilstandService(
     StartRegistreringStatusService startRegistreringStatusService(
             ArbeidsforholdGateway arbeidsforholdGateway,
             BrukerTilstandService brukerTilstandService,
-            PersonGateway personGateway,
+            PdlOppslagGateway pdlOppslagGateway,
             InfluxMetricsService influxMetricsService) {
         return new StartRegistreringStatusService(
                 arbeidsforholdGateway,
                 brukerTilstandService,
-                personGateway,
+                pdlOppslagGateway,
                 influxMetricsService);
     }
 
@@ -217,14 +223,12 @@ OppgaveRouter oppgaveRouter(
             ArbeidsforholdGateway arbeidsforholdGateway,
             EnhetGateway enhetGateway,
             Norg2Gateway norg2Gateway,
-            PersonGateway personGateway,
             PdlOppslagGateway pdlOppslagGateway,
             InfluxMetricsService influxMetricsService) {
         return new OppgaveRouter(
                 arbeidsforholdGateway,
                 enhetGateway,
                 norg2Gateway,
-                personGateway,
                 pdlOppslagGateway,
                 influxMetricsService);
     }

src/main/java/no/nav/fo/veilarbregistrering/oppgave/OppgaveRouter.java

@@ -37,21 +37,18 @@ public class OppgaveRouter {
     private final ArbeidsforholdGateway arbeidsforholdGateway;
     private final EnhetGateway enhetGateway;
     private final Norg2Gateway norg2Gateway;
-    private final PersonGateway personGateway;
     private final PdlOppslagGateway pdlOppslagGateway;
     private final InfluxMetricsService influxMetricsService;
 
     public OppgaveRouter(
             ArbeidsforholdGateway arbeidsforholdGateway,
             EnhetGateway enhetGateway,
             Norg2Gateway norg2Gateway,
-            PersonGateway personGateway,
             PdlOppslagGateway pdlOppslagGateway,
             InfluxMetricsService influxMetricsService) {
         this.arbeidsforholdGateway = arbeidsforholdGateway;
         this.enhetGateway = enhetGateway;
         this.norg2Gateway = norg2Gateway;
-        this.personGateway = personGateway;
         this.pdlOppslagGateway = pdlOppslagGateway;
         this.influxMetricsService = influxMetricsService;
     }
@@ -64,7 +61,7 @@ public Optional<Enhetnr> hentEnhetsnummerFor(Bruker bruker) {
 
         Optional<GeografiskTilknytning> geografiskTilknytning;
         try {
-            geografiskTilknytning = personGateway.hentGeografiskTilknytning(bruker);
+            geografiskTilknytning = pdlOppslagGateway.hentGeografiskTilknytning(bruker.getAktorId());
         } catch (RuntimeException e) {
             LOG.warn("Henting av geografisk tilknytning feilet", e);
             influxMetricsService.reportTags(OPPGAVE_ROUTING_EVENT, GeografiskTilknytning_Feilet);

src/main/java/no/nav/fo/veilarbregistrering/registrering/bruker/StartRegistreringStatusService.java

@@ -3,7 +3,7 @@
 import no.nav.fo.veilarbregistrering.arbeidsforhold.ArbeidsforholdGateway;
 import no.nav.fo.veilarbregistrering.bruker.Bruker;
 import no.nav.fo.veilarbregistrering.bruker.GeografiskTilknytning;
-import no.nav.fo.veilarbregistrering.bruker.PersonGateway;
+import no.nav.fo.veilarbregistrering.bruker.PdlOppslagGateway;
 import no.nav.fo.veilarbregistrering.metrics.Events;
 import no.nav.fo.veilarbregistrering.metrics.InfluxMetricsService;
 import no.nav.fo.veilarbregistrering.registrering.bruker.resources.StartRegistreringStatusDto;
@@ -23,17 +23,17 @@ public class StartRegistreringStatusService {
 
     private final ArbeidsforholdGateway arbeidsforholdGateway;
     private final BrukerTilstandService brukerTilstandService;
-    private final PersonGateway personGateway;
+    private final PdlOppslagGateway pdlOppslagGateway;
     private final InfluxMetricsService influxMetricsService;
 
     public StartRegistreringStatusService(
             ArbeidsforholdGateway arbeidsforholdGateway,
             BrukerTilstandService brukerTilstandService,
-            PersonGateway personGateway,
+            PdlOppslagGateway pdlOppslagGateway,
             InfluxMetricsService influxMetricsService) {
         this.arbeidsforholdGateway = arbeidsforholdGateway;
         this.brukerTilstandService = brukerTilstandService;
-        this.personGateway = personGateway;
+        this.pdlOppslagGateway = pdlOppslagGateway;
         this.influxMetricsService = influxMetricsService;
     }
 
@@ -70,7 +70,7 @@ private Optional<GeografiskTilknytning> hentGeografiskTilknytning(Bruker bruker)
         Optional<GeografiskTilknytning> geografiskTilknytning = Optional.empty();
         try {
             long t1 = System.currentTimeMillis();
-            geografiskTilknytning = personGateway.hentGeografiskTilknytning(bruker);
+            geografiskTilknytning = pdlOppslagGateway.hentGeografiskTilknytning(bruker.getAktorId());
             LOG.info("Henting av geografisk tilknytning tok {} ms.", System.currentTimeMillis() - t1);
 
         } catch (RuntimeException e) {

src/test/java/no/nav/fo/veilarbregistrering/oppgave/OppgaveRouterTest.kt

@@ -61,18 +61,17 @@ class OppgaveRouterTest {
 
     @Test
     fun `geografisk tilknytning med by med bydel skal gi intern brukerstotte`() {
-        val personGateway = PersonGateway { Optional.of(GeografiskTilknytning.of("0301")) }
-
-        val oppgaveRouter = oppgaveRouter(personGateway = personGateway)
+        val pdlOppslagGateway = StubPdlOppslagGateway(geografiskTilknytning = GeografiskTilknytning.of("0301"))
+        val oppgaveRouter = oppgaveRouter(pdlOppslagGateway = pdlOppslagGateway)
         val enhetsnr = oppgaveRouter.hentEnhetsnummerFor(BRUKER)
         assertThat(enhetsnr).hasValue(Enhetnr.internBrukerstotte())
     }
 
     @Test
     fun `geografisk tilknytning med unntak av landkode skal gi empty enhetsnummer`() {
-        val personGateway = PersonGateway { Optional.of(GeografiskTilknytning.of("030106")) }
+        val pdlOppslagGateway = StubPdlOppslagGateway(geografiskTilknytning = GeografiskTilknytning.of("030106"))
 
-        val oppgaveRouter = oppgaveRouter(personGateway = personGateway)
+        val oppgaveRouter = oppgaveRouter(pdlOppslagGateway = pdlOppslagGateway)
         val enhetsnr = oppgaveRouter.hentEnhetsnummerFor(BRUKER)
         assertThat(enhetsnr).isEmpty
     }
@@ -83,9 +82,9 @@ class OppgaveRouterTest {
                 Kommunenummer.of("1241"),
                 Periode.of(LocalDate.of(2020, 1, 1), null))
         val enhetGateway = EnhetGateway { Organisasjonsdetaljer.of(listOf(forretningsadresse), emptyList()) }
-        val personGateway = PersonGateway { Optional.of(GeografiskTilknytning.of("DNK")) }
+        val pdlOppslagGateway = StubPdlOppslagGateway(geografiskTilknytning = GeografiskTilknytning.of("DNK"))
 
-        val oppgaveRouter = oppgaveRouter(enhetGateway = enhetGateway, personGateway = personGateway)
+        val oppgaveRouter = oppgaveRouter(enhetGateway = enhetGateway, pdlOppslagGateway = pdlOppslagGateway)
         val enhetsnr = oppgaveRouter.hentEnhetsnummerFor(BRUKER)
         assertThat(enhetsnr).hasValue(Enhetnr.of("232"))
     }
@@ -96,9 +95,9 @@ class OppgaveRouterTest {
                 Kommunenummer.of(KommuneMedBydel.STAVANGER),
                 Periode.of(LocalDate.of(2020, 1, 1), null))
         val enhetGateway = EnhetGateway { Organisasjonsdetaljer.of(listOf(forretningsadresse), emptyList()) }
-        val personGateway = PersonGateway { Optional.of(GeografiskTilknytning.of("DNK")) }
+        val pdlOppslagGateway = StubPdlOppslagGateway(geografiskTilknytning = GeografiskTilknytning.of("DNK"))
 
-        val oppgaveRouter = oppgaveRouter(enhetGateway = enhetGateway, personGateway = personGateway)
+        val oppgaveRouter = oppgaveRouter(enhetGateway = enhetGateway, pdlOppslagGateway = pdlOppslagGateway)
         val enhetsnr = oppgaveRouter.hentEnhetsnummerFor(BRUKER)
         assertThat(enhetsnr).hasValue(Enhetnr.internBrukerstotte())
     }
@@ -122,10 +121,10 @@ class OppgaveRouterTest {
     }
 
     private fun hentEnhetsnummerForBrukerMedAdressebeskyttelse(adressebeskyttelseGradering: AdressebeskyttelseGradering): Optional<Enhetnr> {
-        val personGateway = PersonGateway { Optional.of(GeografiskTilknytning.of("0301")) }
         val person = Person.of(null, null, adressebeskyttelseGradering)
-        val pdlOppslagGateway = StubPdlOppslagGateway(users = mapOf(BRUKER.aktorId to person))
-        val oppgaveRouter = oppgaveRouter(personGateway = personGateway, pdlOppslagGateway = pdlOppslagGateway)
+        val pdlOppslagGateway = StubPdlOppslagGateway(geografiskTilknytning = GeografiskTilknytning.of("0301"),
+                                                      users = mapOf(BRUKER.aktorId to person))
+        val oppgaveRouter = oppgaveRouter(pdlOppslagGateway = pdlOppslagGateway)
 
         return oppgaveRouter.hentEnhetsnummerFor(BRUKER)
     }
@@ -134,11 +133,10 @@ class OppgaveRouterTest {
             arbeidsforholdGateway: ArbeidsforholdGateway = StubArbeidsforholdGateway(),
             enhetGateway: EnhetGateway = EnhetGateway { null },
             norg2Gateway: Norg2Gateway = StubNorg2Gateway(),
-            personGateway: PersonGateway = StubPersonGateway(),
             pdlOppslagGateway: PdlOppslagGateway = StubPdlOppslagGateway(),
             influxMetricsService: InfluxMetricsService = mockk(relaxed = true)
     ) =
-            OppgaveRouter(arbeidsforholdGateway, enhetGateway, norg2Gateway, personGateway, pdlOppslagGateway, influxMetricsService)
+            OppgaveRouter(arbeidsforholdGateway, enhetGateway, norg2Gateway, pdlOppslagGateway, influxMetricsService)
 
     private class StubNorg2Gateway : Norg2Gateway {
         override fun hentEnhetFor(kommunenummer: Kommunenummer): Optional<Enhetnr> {
@@ -158,11 +156,7 @@ class OppgaveRouterTest {
             FlereArbeidsforholdTestdataBuilder.flereArbeidsforholdTilfeldigSortert()!!
     }
 
-    private class StubPersonGateway : PersonGateway {
-        override fun hentGeografiskTilknytning(bruker: Bruker): Optional<GeografiskTilknytning>? = Optional.empty<GeografiskTilknytning>()
-    }
-
-    private class StubPdlOppslagGateway(private val users: Map<AktorId, Person> = emptyMap()) : PdlOppslagGateway {
+    private class StubPdlOppslagGateway(private val geografiskTilknytning: GeografiskTilknytning? = null ,private val users: Map<AktorId, Person> = emptyMap()) : PdlOppslagGateway {
         override fun hentPerson(aktorId: AktorId?) = Optional.ofNullable(users[aktorId])
 
         override fun hentIdenter(fnr: Foedselsnummer?): Identer {
@@ -173,7 +167,7 @@ class OppgaveRouterTest {
             TODO("Not yet implemented")
         }
 
-        override fun hentGeografiskTilknytning(aktorId: AktorId?) = TODO("Not yet implemented")
+        override fun hentGeografiskTilknytning(aktorId: AktorId?) = Optional.ofNullable(geografiskTilknytning)
 
     }