Refactor getTestgruppeByBrukerId to improve user handling and logging for different user types #deploy-test-dolly-backend #deploy-dolly-backend

Author: krharum

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

@@ -17,7 +17,6 @@
 import no.nav.dolly.exceptions.ConstraintViolationException;
 import no.nav.dolly.exceptions.DollyFunctionalException;
 import no.nav.dolly.exceptions.NotFoundException;
-import no.nav.dolly.repository.BrukerRepository;
 import no.nav.dolly.repository.TestgruppeRepository;
 import no.nav.dolly.repository.TransaksjonMappingRepository;
 import no.nav.testnav.libs.servletsecurity.action.GetUserInfo;
@@ -35,8 +34,6 @@
 import java.util.List;
 
 import static java.lang.String.format;
-import static java.util.Collections.emptyList;
-import static java.util.Objects.nonNull;
 import static no.nav.dolly.domain.jpa.Bruker.Brukertype.BANKID;
 import static no.nav.dolly.util.CurrentAuthentication.getUserId;
 import static org.apache.commons.lang3.BooleanUtils.isTrue;
@@ -207,18 +204,33 @@ public Testgruppe oppdaterTestgruppe(Long gruppeId, RsOpprettEndreTestgruppe end
 
     public RsTestgruppePage getTestgruppeByBrukerId(Integer pageNo, Integer pageSize, String brukerId) {
 
-        var bruker = isBlank(brukerId) ? null : brukerService.fetchBruker(brukerId);
-        var paginertGruppe = isBlank(brukerId)
-                ? testgruppeRepository.findAllByOrderByIdDesc(PageRequest.of(pageNo, pageSize))
-                : fetchTestgrupperByBrukerId(pageNo, pageSize, brukerId);
+        var bruker = brukerService.fetchOrCreateBruker(brukerId);
+        log.info("Henter testgrupper for bruker: {}, brukertype: {}", bruker.getBrukerId(), bruker.getBrukertype());
+
+        Page<Testgruppe> paginertGruppe;
+
+        if (bruker.getBrukertype() == BANKID) {
+            paginertGruppe = brukerServiceConsumer.getKollegaerIOrganisasjon(bruker.getBrukerId())
+                    .doOnNext(brukere -> log.info("BrukerServiceConsumer hentet {} kollegaer for bruker: {}",
+                            String.join(",", brukere), bruker.getBrukerId()))
+                    .map(brukere -> testgruppeRepository.findAllByOpprettetAv_BrukerIdIn(brukere,
+                            PageRequest.of(pageNo, pageSize, Sort.by("id").descending())))
+                    .block();
+
+        } else if (isBlank(brukerId)) {
+            paginertGruppe = testgruppeRepository.findAllByOrderByIdDesc(PageRequest.of(pageNo, pageSize));
+
+        } else {
+            paginertGruppe = fetchTestgrupperByBrukerId(pageNo, pageSize, brukerId);
+        }
 
         return RsTestgruppePage.builder()
                 .pageNo(paginertGruppe.getNumber())
                 .antallPages(paginertGruppe.getTotalPages())
                 .pageSize(paginertGruppe.getSize())
                 .antallElementer(paginertGruppe.getTotalElements())
                 .contents(mapperFacade.mapAsList(paginertGruppe.getContent(), RsTestgruppe.class))
-                .favoritter(nonNull(bruker) ? mapperFacade.mapAsList(bruker.getFavoritter(), RsTestgruppe.class) : emptyList())
+                .favoritter(mapperFacade.mapAsList(bruker.getFavoritter(), RsTestgruppe.class))
                 .build();
     }