Merge branch 'master' into bugfix/endringsmelding-404

# Conflicts: # apps/endringsmelding-service/src/main/java/no/nav/testnav/endringsmeldingservice/consumer/TpsMessagingConsumer.java
navikt · Mar 21, 2024 · 7bb7c55 · 7bb7c55
2 parents 2c5f1ab + d48b5e0
commit 7bb7c55
Show file tree

Hide file tree

Showing 325 changed files with 6,459 additions and 1,933 deletions.
diff --git a/.github/workflows/app.ereg-batch-status-service.yml b/.github/workflows/app.ereg-batch-status-service.yml
@@ -14,7 +14,7 @@ jobs:
   workflow:
     uses: ./.github/workflows/common.workflow.backend.yml
     with:
-      cluster: "dev-fss"
+      cluster: "dev-gcp"
       working-directory: "apps/ereg-batch-status-service"
       deploy-tag: "#deploy-ereg-batch-status-service"
     permissions:

diff --git a/.github/workflows/proxy.modapp-ereg-proxy.yml b/.github/workflows/proxy.modapp-ereg-proxy.yml
@@ -0,0 +1,23 @@
+name: modapp-ereg-proxy
+
+on:
+  push:
+    paths:
+      - libs/reactive-core
+      - libs/reactive-proxy
+      - libs/reactive-security
+      - libs/security-core
+      - proxies/modapp-ereg-proxy/**
+      - .github/workflows/proxy.modapp-ereg-proxy.yml
+
+jobs:
+  workflow:
+    uses: ./.github/workflows/common.workflow.backend.yml
+    with:
+      cluster: "dev-fss"
+      working-directory: "proxies/modapp-ereg-proxy"
+      deploy-tag: "#deploy-proxy"
+    permissions:
+      contents: read
+      id-token: write
+    secrets: inherit
diff --git a/.gitignore b/.gitignore
@@ -1,6 +1,7 @@
 *.idea/
 *target/
 *.iml
+*.http
 
 # See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
 

diff --git a/apps/adresse-service/config.yml b/apps/adresse-service/config.yml
@@ -62,6 +62,8 @@ spec:
         - application: app-1
           namespace: plattformsikkerhet
           cluster: dev-gcp
+        - application: testnav-endringsmelding-service
+          cluster: dev-gcp
     outbound:
       external:
         - host: testnav-pdl-proxy.dev-fss-pub.nais.io
diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/DollyBackendApplicationStarter.java b/apps/dolly-backend/src/main/java/no/nav/dolly/DollyBackendApplicationStarter.java
@@ -10,4 +10,4 @@ public static void main(String[] args) {
 
         SpringApplication.run(DollyBackendApplicationStarter.class, args);
     }
-}
+}
diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/AaregClient.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/AaregClient.java
@@ -68,6 +68,7 @@ public Flux<ClientFuture> gjenopprett(RsDollyUtvidetBestilling bestilling, Dolly
             var initStatus = miljoer.stream()
                     .map(miljo -> String.format("%s:%s", miljo, getInfoVenter(SYSTEM)))
                     .collect(Collectors.joining(","));
+
             transactionHelperService.persister(progress, BestillingProgress::getAaregStatus,
                     BestillingProgress::setAaregStatus, initStatus);
 

diff --git a/.../dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/amelding/AmeldingConsumer.java b/.../dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/amelding/AmeldingConsumer.java
@@ -11,6 +11,7 @@
 import no.nav.testnav.libs.dto.ameldingservice.v1.VirksomhetDTO;
 import no.nav.testnav.libs.securitycore.domain.ServerProperties;
 import no.nav.testnav.libs.standalone.servletsecurity.exchange.TokenExchange;
+import org.slf4j.event.Level;
 import org.springframework.http.HttpStatus;
 import org.springframework.stereotype.Service;
 import org.springframework.web.reactive.function.client.WebClient;
@@ -30,7 +31,6 @@ public class AmeldingConsumer {
 
     private static final String JURIDISK_ENHET_IKKE_FUNNET = "Feil= Juridisk enhet for organisasjon(ene): %s ble ikke funnet i miljø";
     private static final DateTimeFormatter YEAR_MONTH = DateTimeFormatter.ofPattern("yyyy-MM");
-
     private final TokenExchange tokenService;
     private final WebClient webClient;
     private final ServerProperties serverProperties;
@@ -41,8 +41,8 @@ public AmeldingConsumer(
             Consumers consumers,
             ObjectMapper objectMapper,
             ErrorStatusDecoder errorStatusDecoder,
-            WebClient.Builder webClientBuilder
-    ) {
+            WebClient.Builder webClientBuilder) {
+
         this.tokenService = tokenService;
         serverProperties = consumers.getTestnavAmeldingService();
         this.webClient = webClientBuilder
@@ -52,7 +52,7 @@ public AmeldingConsumer(
         this.errorStatusDecoder = errorStatusDecoder;
     }
 
-    @Timed(name = "providers", tags = { "operation", "amelding_put" })
+    @Timed(name = "providers", tags = {"operation", "amelding_put"})
     public Flux<String> sendAmeldinger(List<AMeldingDTO> ameldinger, String miljoe) {
 
         return tokenService.exchange(serverProperties)
@@ -67,9 +67,13 @@ public Flux<String> sendAmeldinger(List<AMeldingDTO> ameldinger, String miljoe)
                                 log.info("Sender Amelding {} til miljø {}: {}",
                                         amelding.getKalendermaaned().format(YEAR_MONTH), miljoe, Json.pretty(amelding));
                                 return new AmeldingPutCommand(webClient, amelding, miljoe, token.getTokenValue()).call()
-                                        .doOnNext(status -> log.info("Ameldingstatus: {}", status.getStatusCode()))
                                         .map(status -> status.getStatusCode().is2xxSuccessful() ? "OK" :
-                                                errorStatusDecoder.getErrorText(HttpStatus.valueOf(status.getStatusCode().value()), status.getBody()));
+                                                errorStatusDecoder.getErrorText(HttpStatus.valueOf(status.getStatusCode().value()), status.getBody()))
+                                        .doOnNext(status ->
+                                                log.atLevel("OK".equals(status) ? Level.INFO : Level.ERROR)
+                                                        .log("Ameldingstatus: {}, miljoe: {}, kalendermåned: {}, organisasjon: {}",
+                                                                status, miljoe, amelding.getKalendermaaned(),
+                                                                amelding.getOpplysningspliktigOrganisajonsnummer()));
                             }
                         }));
     }

diff --git a/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/amelding/AmeldingService.java b/apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/amelding/AmeldingService.java
@@ -16,6 +16,7 @@
 import reactor.core.publisher.Mono;
 
 import java.util.Collection;
+import java.util.Comparator;
 import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
@@ -25,7 +26,7 @@
 @Slf4j
 public class AmeldingService {
 
-    private static final String STATUS_ELEMENT = "%s: arbforhold=1$%s";
+    private static final String STATUS_ELEMENT = "%s:Amelding$%s";
 
     private final AmeldingConsumer ameldingConsumer;
     private final MapperFacade mapperFacade;
@@ -34,7 +35,7 @@ public class AmeldingService {
     public Mono<String> sendAmelding(RsDollyUtvidetBestilling bestilling, DollyPerson dollyPerson,
                                      Set<String> miljoer) {
 
-        var orgnumre = bestilling.getAareg().get(0).getAmelding().stream()
+        var orgnumre = bestilling.getAareg().getFirst().getAmelding().stream()
                 .map(RsAmeldingRequest::getArbeidsforhold)
                 .flatMap(Collection::stream)
                 .map(RsArbeidsforholdAareg::getArbeidsgiver)
@@ -46,14 +47,15 @@ public Mono<String> sendAmelding(RsDollyUtvidetBestilling bestilling, DollyPerso
                         .filter(OrganisasjonDTO::isFunnet)
                         .collect(Collectors.toMap(OrganisasjonDTO::getOrgnummer, OrganisasjonDTO::getJuridiskEnhet))
                         .flatMapMany(organisasjon ->
-                                prepareAmeldinger(bestilling.getAareg().get(0), dollyPerson.getIdent(),
+                                prepareAmeldinger(bestilling.getAareg().getFirst(), dollyPerson.getIdent(),
                                         organisasjon, miljoe))
                         .collect(Collectors.joining(",")))
                 .flatMap(Flux::from)
                 .collect(Collectors.joining(","));
     }
 
-    private Flux<String> prepareAmeldinger(RsAareg aareg, String ident, Map<String, String> organisasjon, String miljoe) {
+    private Flux<String> prepareAmeldinger(RsAareg aareg, String ident, Map<String, String> organisasjon,
+                                           String miljoe) {
 
         var context = new MappingContext.Factory().getContext();
         context.setProperty("personIdent", ident);
@@ -62,9 +64,10 @@ private Flux<String> prepareAmeldinger(RsAareg aareg, String ident, Map<String,
 
         return Flux.fromIterable(aareg.getAmelding())
                 .map(aamelding -> mapperFacade.map(aamelding, AMeldingDTO.class, context))
+                .sort(Comparator.comparing(AMeldingDTO::getKalendermaaned))
                 .collectList()
-                .flatMapMany(reultat -> ameldingConsumer.sendAmeldinger(reultat, miljoe)
+                .flatMapMany(ameldinger -> ameldingConsumer.sendAmeldinger(ameldinger, miljoe)
                         .distinct()
-                        .map(status -> String.format(STATUS_ELEMENT, miljoe, status)));
+                        .map(status -> STATUS_ELEMENT.formatted(miljoe, status)));
     }
 }
diff --git a/...in/java/no/nav/dolly/bestilling/aareg/amelding/mapper/AmeldingRequestMappingStrategy.java b/...in/java/no/nav/dolly/bestilling/aareg/amelding/mapper/AmeldingRequestMappingStrategy.java
@@ -24,6 +24,7 @@
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.Collection;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -54,16 +55,21 @@ public void mapAtoB(RsAmeldingRequest rsAmelding,
                         amelding.setKalendermaaned(LocalDate.of(Integer.parseInt(date[0]), Integer.parseInt(date[1]), 1));
                         var opplysningsPliktig = (Map<String, String>) context.getProperty("opplysningspliktig");
 
-                        amelding.setOpplysningspliktigOrganisajonsnummer(opplysningsPliktig.get(rsAmelding.getArbeidsforhold().get(0).getArbeidsgiver().getOrgnummer()));
+                        amelding.setOpplysningspliktigOrganisajonsnummer(opplysningsPliktig.get(rsAmelding.getArbeidsforhold()
+                                .getFirst().getArbeidsgiver().getOrgnummer()));
 
                         var virksomheter = mapperFacade.mapAsList(rsAmelding.getArbeidsforhold(), Virksomhet.class, context);
-                        virksomheter.forEach(virksomhet -> {
-                            var arbForholdId = new AtomicInteger(0);
-                            virksomhet.getPersoner()
-                                    .forEach(person -> person.getArbeidsforhold()
-                                            .forEach(arbeidsforhold -> arbeidsforhold
-                                                    .setArbeidsforholdId(Integer.toString(arbForholdId.incrementAndGet()))));
-                        });
+                        var arbeidsForholdIder = new HashMap<String, AtomicInteger>();
+                        virksomheter
+                                .forEach(virksomhet -> virksomhet.getPersoner().forEach(person ->
+                                        arbeidsForholdIder.put(virksomhet.getOrganisajonsnummer()+person.getIdent(),
+                                                new AtomicInteger(0))));
+                        virksomheter.forEach(virksomhet -> virksomhet.getPersoner()
+                                .forEach(person -> person.getArbeidsforhold()
+                                        .forEach(arbeidsforhold -> arbeidsforhold
+                                                .setArbeidsforholdId(Integer.toString(
+                                                        arbeidsForholdIder.get(virksomhet.getOrganisajonsnummer()+person.getIdent())
+                                                                .incrementAndGet())))));
                         var ameldingVirksomheter = virksomheter.stream().map(virksomhet ->
                                         VirksomhetDTO.builder()
                                                 .organisajonsnummer(virksomhet.getOrganisajonsnummer())
@@ -94,12 +100,14 @@ public void mapAtoB(RsArbeidsforholdAareg rsArbeidsforholdAareg, Virksomhet virk
                                                         getDate(rsArbeidsforholdAareg.getAnsettelsesPeriode().getTom()) : null)
                                         .antallTimerPerUke(
                                                 !rsArbeidsforholdAareg.getAntallTimerForTimeloennet().isEmpty() ?
-                                                        rsArbeidsforholdAareg.getAntallTimerForTimeloennet().get(0).getAntallTimer().floatValue() :
+                                                        rsArbeidsforholdAareg.getAntallTimerForTimeloennet()
+                                                                .getFirst().getAntallTimer().floatValue() :
                                                         getAvtaltArbeidstidPerUke(rsArbeidsforholdAareg))
                                         .arbeidsforholdType((String) context.getProperty("arbeidsforholdstype"))
                                         .arbeidstidsordning(rsArbeidsforholdAareg.getArbeidsavtale().getArbeidstidsordning())
                                         .fartoey(nonNull(rsArbeidsforholdAareg.getFartoy()) && !rsArbeidsforholdAareg.getFartoy().isEmpty() ?
-                                                mapperFacade.map(rsArbeidsforholdAareg.getFartoy().get(0), FartoeyDTO.class) : null)
+                                                mapperFacade.map(rsArbeidsforholdAareg.getFartoy()
+                                                        .getFirst(), FartoeyDTO.class) : null)
                                         .inntekter(
                                                 (nonNull(rsArbeidsforholdAareg.getUtenlandsopphold()) &&
                                                         !rsArbeidsforholdAareg.getUtenlandsopphold().isEmpty()) ||

diff --git a/...dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/command/AmeldingPutCommand.java b/...dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/command/AmeldingPutCommand.java
@@ -9,11 +9,14 @@
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Mono;
+import reactor.netty.http.client.HttpClientRequest;
 import reactor.util.retry.Retry;
 
 import java.time.Duration;
 import java.util.concurrent.Callable;
 
+import static no.nav.dolly.util.RequestTimeout.REQUEST_DURATION;
+
 @RequiredArgsConstructor
 public class AmeldingPutCommand implements Callable<Mono<ResponseEntity<String>>> {
 
@@ -31,6 +34,10 @@ public Mono<ResponseEntity<String>> call() {
         return webClient.put()
                 .uri(uriBuilder -> uriBuilder.path(AMELDING_URL)
                         .build())
+                .httpRequest(httpRequest -> {
+                    HttpClientRequest reactorRequest = httpRequest.getNativeRequest();
+                    reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION));
+                })
                 .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
                 .header(UserConstant.USER_HEADER_JWT, TokenXUtil.getUserJwt())
                 .header(MILJOE, miljo)

diff --git a/...kend/src/main/java/no/nav/dolly/bestilling/pdldata/command/PdlDataOppdateringCommand.java b/...kend/src/main/java/no/nav/dolly/bestilling/pdldata/command/PdlDataOppdateringCommand.java
@@ -13,12 +13,14 @@
 import org.springframework.web.reactive.function.BodyInserters;
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Flux;
+import reactor.netty.http.client.HttpClientRequest;
 import reactor.util.retry.Retry;
 
 import java.net.http.HttpTimeoutException;
 import java.time.Duration;
 import java.util.concurrent.Callable;
 
+import static no.nav.dolly.util.RequestTimeout.REQUEST_DURATION;
 import static no.nav.dolly.util.TokenXUtil.getUserJwt;
 
 @Slf4j
@@ -37,6 +39,10 @@ public Flux<PdlResponse> call() {
         return webClient
                 .put()
                 .uri(PDL_FORVALTER_PERSONER_URL, ident)
+                .httpRequest(httpRequest -> {
+                    HttpClientRequest reactorRequest = httpRequest.getNativeRequest();
+                    reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION));
+                })
                 .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
                 .header(UserConstant.USER_HEADER_JWT, getUserJwt())
                 .contentType(MediaType.APPLICATION_JSON)

diff --git a/...ckend/src/main/java/no/nav/dolly/bestilling/pdldata/command/PdlDataOpprettingCommand.java b/...ckend/src/main/java/no/nav/dolly/bestilling/pdldata/command/PdlDataOpprettingCommand.java
@@ -13,12 +13,14 @@
 import org.springframework.web.reactive.function.BodyInserters;
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Flux;
+import reactor.netty.http.client.HttpClientRequest;
 import reactor.util.retry.Retry;
 
 import java.net.http.HttpTimeoutException;
 import java.time.Duration;
 import java.util.concurrent.Callable;
 
+import static no.nav.dolly.util.RequestTimeout.REQUEST_DURATION;
 import static no.nav.dolly.util.TokenXUtil.getUserJwt;
 
 @Slf4j
@@ -36,6 +38,10 @@ public Flux<PdlResponse> call() {
         return webClient
                 .post()
                 .uri(PDL_FORVALTER_PERSONER_URL)
+                .httpRequest(httpRequest -> {
+                    HttpClientRequest reactorRequest = httpRequest.getNativeRequest();
+                    reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION));
+                })
                 .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
                 .header(UserConstant.USER_HEADER_JWT, getUserJwt())
                 .contentType(MediaType.APPLICATION_JSON)

diff --git a/...ly-backend/src/main/java/no/nav/dolly/bestilling/pdldata/command/PdlDataOrdreCommand.java b/...ly-backend/src/main/java/no/nav/dolly/bestilling/pdldata/command/PdlDataOrdreCommand.java
@@ -10,12 +10,14 @@
 import org.springframework.http.MediaType;
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Flux;
+import reactor.netty.http.client.HttpClientRequest;
 import reactor.util.retry.Retry;
 
 import java.net.http.HttpTimeoutException;
 import java.time.Duration;
 import java.util.concurrent.Callable;
 
+import static no.nav.dolly.util.RequestTimeout.REQUEST_DURATION;
 import static no.nav.dolly.util.TokenXUtil.getUserJwt;
 
 @RequiredArgsConstructor
@@ -36,6 +38,10 @@ public Flux<PdlResponse> call() {
                 .uri(uriBuilder -> uriBuilder.path(PDL_FORVALTER_ORDRE_URL)
                         .queryParam(EXCLUDE_EKSTERNE_PERSONER, ekskluderEksternePersoner)
                         .build(ident))
+                .httpRequest(httpRequest -> {
+                    HttpClientRequest reactorRequest = httpRequest.getNativeRequest();
+                    reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION));
+                })
                 .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
                 .header(UserConstant.USER_HEADER_JWT, getUserJwt())
                 .contentType(MediaType.APPLICATION_JSON)

diff --git a/...main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreAlderspensjonCommand.java b/...main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagreAlderspensjonCommand.java
@@ -9,6 +9,7 @@
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
+import reactor.netty.http.client.HttpClientRequest;
 import reactor.util.retry.Retry;
 
 import java.time.Duration;
@@ -18,6 +19,7 @@
 import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CALL_ID;
 import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CONSUMER_ID;
 import static no.nav.dolly.util.CallIdUtil.generateCallId;
+import static no.nav.dolly.util.RequestTimeout.REQUEST_DURATION;
 import static org.springframework.http.HttpHeaders.AUTHORIZATION;
 
 @Slf4j
@@ -40,6 +42,10 @@ public Flux<PensjonforvalterResponse> call() {
                         .path(alderspensjonRequest instanceof AlderspensjonVedtakRequest ?
                                 PENSJON_AP_VEDTAK_URL : PENSJON_AP_SOKNAD_URL)
                         .build())
+                .httpRequest(httpRequest -> {
+                    HttpClientRequest reactorRequest = httpRequest.getNativeRequest();
+                    reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION));
+                })
                 .header(AUTHORIZATION, "Bearer " + token)
                 .header(HEADER_NAV_CALL_ID, generateCallId())
                 .header(HEADER_NAV_CONSUMER_ID, CONSUMER)

diff --git a/...c/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagrePoppInntektCommand.java b/...c/main/java/no/nav/dolly/bestilling/pensjonforvalter/command/LagrePoppInntektCommand.java
@@ -8,6 +8,7 @@
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
+import reactor.netty.http.client.HttpClientRequest;
 import reactor.util.retry.Retry;
 
 import java.time.Duration;
@@ -17,6 +18,7 @@
 import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CALL_ID;
 import static no.nav.dolly.domain.CommonKeysAndUtils.HEADER_NAV_CONSUMER_ID;
 import static no.nav.dolly.util.CallIdUtil.generateCallId;
+import static no.nav.dolly.util.RequestTimeout.REQUEST_DURATION;
 import static org.springframework.http.HttpHeaders.AUTHORIZATION;
 
 @Slf4j
@@ -35,6 +37,10 @@ public Flux<PensjonforvalterResponse> call() {
                 .uri(uriBuilder -> uriBuilder
                         .path(POPP_INNTEKT_URL)
                         .build())
+                .httpRequest(httpRequest -> {
+                    HttpClientRequest reactorRequest = httpRequest.getNativeRequest();
+                    reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION));
+                })
                 .header(AUTHORIZATION, "Bearer " + token)
                 .header(HEADER_NAV_CALL_ID, generateCallId())
                 .header(HEADER_NAV_CONSUMER_ID, CONSUMER)
-Original file line number
+Diff line change
@@ Expand Up / @@ -10,4 +10,4 @@ public static void main(String[] args) { @@
             SpringApplication.run(DollyBackendApplicationStarter.class, args);
         }
-    }
+    }