Fix hentFullmakt mono to flux (#3955)

Author: krharum

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/fullmakt/FullmaktConsumer.java

@@ -59,10 +59,10 @@ public Flux<FullmaktPostResponse> createFullmaktData(List<RsFullmakt> fullmakter
     }
 
     @Timed(name = "providers", tags = { "operation", "fullmakt_getData" })
-    public Mono<FullmaktPostResponse.Fullmakt> getFullmaktData(String ident) {
+    public Flux<FullmaktPostResponse.Fullmakt> getFullmaktData(String ident) {
 
         return tokenService.exchange(serverProperties)
-                .flatMap(token -> new GetFullmaktDataCommand(webClient, ident,
+                .flatMapMany(token -> new GetFullmaktDataCommand(webClient, ident,
                         token.getTokenValue()).call());
     }
 

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/fullmakt/command/GetFullmaktDataCommand.java

@@ -8,6 +8,7 @@
 import no.nav.testnav.libs.reactivecore.web.WebClientHeader;
 import org.springframework.web.reactive.function.client.WebClient;
 import org.springframework.web.reactive.function.client.WebClientResponseException;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 import java.util.concurrent.Callable;
@@ -18,15 +19,15 @@
 
 @RequiredArgsConstructor
 @Slf4j
-public class GetFullmaktDataCommand implements Callable<Mono<FullmaktPostResponse.Fullmakt>> {
+public class GetFullmaktDataCommand implements Callable<Flux<FullmaktPostResponse.Fullmakt>> {
 
     private static final String HENT_FULLMAKT_URL = "/api/fullmaktsgiver";
 
     private final WebClient webClient;
     private final String ident;
     private final String token;
 
-    public Mono<FullmaktPostResponse.Fullmakt> call() {
+    public Flux<FullmaktPostResponse.Fullmakt> call() {
         return webClient
                 .get()
                 .uri(uriBuilder -> uriBuilder
@@ -37,15 +38,14 @@ public Mono<FullmaktPostResponse.Fullmakt> call() {
                 .header("fnr", ident)
                 .headers(WebClientHeader.bearer(token))
                 .retrieve()
-                .bodyToMono(FullmaktPostResponse.Fullmakt.class)
+                .bodyToFlux(FullmaktPostResponse.Fullmakt.class)
                 .doOnError(WebClientError.logTo(log))
                 .onErrorResume(throwable -> {
                     var description = WebClientError.describe(throwable);
                     return Mono.just(FullmaktPostResponse.Fullmakt.builder()
                             .status(description.getStatus().getReasonPhrase())
                             .build());
                 })
-
                 .onErrorResume(WebClientResponseException.NotFound.class::isInstance, throwable -> Mono.empty());
     }
 }