Refactor BrukerServiceConsumer and BrukerServiceGetTilgangCommand to …

…return Mono<TilgangDTO> for improved data handling and add TilgangDTO class for user access management #deploy-test-dolly-backend #deploy-dolly-backend

apps/dolly-backend/src/main/java/no/nav/dolly/consumer/brukerservice/BrukerServiceConsumer.java

@@ -3,15 +3,13 @@
 import lombok.extern.slf4j.Slf4j;
 import no.nav.dolly.config.Consumers;
 import no.nav.dolly.consumer.brukerservice.command.BrukerServiceGetTilgangCommand;
+import no.nav.dolly.consumer.brukerservice.dto.TilgangDTO;
 import no.nav.testnav.libs.securitycore.domain.ServerProperties;
 import no.nav.testnav.libs.standalone.servletsecurity.exchange.TokenExchange;
 import org.springframework.stereotype.Service;
 import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
-import java.util.List;
-
 @Service
 @Slf4j
 public class BrukerServiceConsumer {
@@ -32,7 +30,7 @@ public BrukerServiceConsumer(
                 .build();
     }
 
-    public Mono<List<String>> getKollegaerIOrganisasjon(String brukerId) {
+    public Mono<TilgangDTO> getKollegaerIOrganisasjon(String brukerId) {
 
         return tokenService.exchange(serverProperties)
                 .flatMap(token ->

apps/dolly-backend/src/main/java/no/nav/dolly/consumer/brukerservice/command/BrukerServiceGetTilgangCommand.java

@@ -1,10 +1,10 @@
 package no.nav.dolly.consumer.brukerservice.command;
 
 import lombok.RequiredArgsConstructor;
+import no.nav.dolly.consumer.brukerservice.dto.TilgangDTO;
 import no.nav.testnav.libs.reactivecore.utils.WebClientFilter;
 import org.springframework.http.HttpHeaders;
 import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.util.retry.Retry;
 
@@ -13,7 +13,7 @@
 import java.util.concurrent.Callable;
 
 @RequiredArgsConstructor
-public class BrukerServiceGetTilgangCommand implements Callable<Mono<List<String>>> {
+public class BrukerServiceGetTilgangCommand implements Callable<Mono<TilgangDTO>> {
 
     private static final String TILGANG_URL = "/api/v1/tilgang";
 
@@ -22,18 +22,19 @@ public class BrukerServiceGetTilgangCommand implements Callable<Mono<List<String
     private final String token;
 
     @Override
-    public Mono<List<String>> call() {
+    public Mono<TilgangDTO> call() {
 
         return webClient.get()
                 .uri(uriBuilder -> uriBuilder.path(TILGANG_URL)
                         .queryParam("brukerId", brukerId)
                         .build())
                 .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
                 .retrieve()
-                .bodyToMono(String[].class)
-                .map(List::of)
+                .bodyToMono(TilgangDTO.class)
                 .doOnError(WebClientFilter::logErrorMessage)
-                .onErrorResume(error -> Mono.just(List.of(brukerId)))
+                .onErrorResume(error -> Mono.just(TilgangDTO.builder()
+                        .brukere(List.of(brukerId))
+                        .build()))
                 .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
                         .filter(WebClientFilter::is5xxException));
     }

apps/dolly-backend/src/main/java/no/nav/dolly/consumer/brukerservice/dto/TilgangDTO.java

@@ -0,0 +1,28 @@
+package no.nav.dolly.consumer.brukerservice.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static java.util.Objects.isNull;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class TilgangDTO {
+
+    private List<String> brukere;
+
+    public List<String> getBrukere() {
+
+        if (isNull(brukere)) {
+            brukere = new ArrayList<>();
+        }
+        return brukere;
+    }
+}

apps/dolly-backend/src/main/java/no/nav/dolly/service/TestgruppeService.java

@@ -5,6 +5,7 @@
 import ma.glasnost.orika.MapperFacade;
 import no.nav.dolly.bestilling.pdldata.PdlDataConsumer;
 import no.nav.dolly.consumer.brukerservice.BrukerServiceConsumer;
+import no.nav.dolly.consumer.brukerservice.dto.TilgangDTO;
 import no.nav.dolly.domain.dto.TestidentDTO;
 import no.nav.dolly.domain.jpa.Bruker;
 import no.nav.dolly.domain.jpa.Testgruppe;
@@ -71,7 +72,7 @@ public Testgruppe opprettTestgruppe(RsOpprettEndreTestgruppe rsTestgruppe) {
     @Transactional(readOnly = true)
     public RsTestgruppeMedBestillingId fetchPaginertTestgruppeById(Long gruppeId, Integer pageNo, Integer pageSize, String sortColumn, String sortRetning) {
 
-        sjekkTilgang(gruppeId, pageNo, pageSize);
+        sjekkTilgang(gruppeId);
 
         var testgruppeUtenIdenter = testgruppeRepository.findByIdOrderById(gruppeId)
                 .orElseThrow(() -> new NotFoundException(format("Gruppe med id %s ble ikke funnet.", gruppeId)));
@@ -101,11 +102,12 @@ public RsTestgruppeMedBestillingId fetchPaginertTestgruppeById(Long gruppeId, In
         return rsTestgruppe;
     }
 
-    private void sjekkTilgang(Long gruppeId, Integer pageNo, Integer pageSize) {
+    private void sjekkTilgang(Long gruppeId) {
 
         var bruker = brukerService.fetchOrCreateBruker();
         if (bruker.getBrukertype() == BANKID) {
             brukerServiceConsumer.getKollegaerIOrganisasjon(bruker.getBrukerId())
+                    .map(TilgangDTO::getBrukere)
                     .map(testgruppeRepository::findAllByOpprettetAv_BrukerIdIn)
                     .filter(page -> page.stream().anyMatch(gruppe -> gruppe.equals(gruppeId)))
                     .switchIfEmpty(Mono.error(new NotFoundException(format("Gruppe med id %s ble ikke funnet.", gruppeId))))
@@ -123,6 +125,7 @@ public Mono<Page<Testgruppe>> getAllTestgrupper(Integer pageNo, Integer pageSize
         var bruker = brukerService.fetchOrCreateBruker();
         if (bruker.getBrukertype() == BANKID) {
             return brukerServiceConsumer.getKollegaerIOrganisasjon(bruker.getBrukerId())
+                    .map(TilgangDTO::getBrukere)
                     .map(brukere -> testgruppeRepository.findAllByOpprettetAv_BrukerIdIn(brukere,
                             PageRequest.of(pageNo, pageSize, Sort.by("id").descending())));
         } else {
@@ -204,6 +207,7 @@ public RsTestgruppePage getTestgruppeByBrukerId(Integer pageNo, Integer pageSize
 
         if (bruker.getBrukertype() == BANKID) {
             paginertGruppe = brukerServiceConsumer.getKollegaerIOrganisasjon(bruker.getBrukerId())
+                    .map(TilgangDTO::getBrukere)
                     .map(brukere -> testgruppeRepository.findAllByOpprettetAv_BrukerIdIn(brukere,
                             PageRequest.of(pageNo, pageSize, Sort.by("id").descending())))
                     .block();