Merge branch 'master' into feature/bytte-endepukter-til-kodeverk-service

Author: krharum

.github/workflows/app.kodeverk-service.yml

@@ -0,0 +1,22 @@
+name: kodeverk-service
+
+on:
+  push:
+    paths:
+      - libs/security-core
+      - libs/reactive-core
+      - libs/reactive-security
+      - libs/data-transfer-objects
+      - apps/kodeverk-service/**
+      - .github/workflows/app.kodeverk-service.yml
+
+jobs:
+  workflow:
+    uses: ./.github/workflows/common.workflow.backend.yml
+    with:
+      working-directory: "apps/kodeverk-service"
+      deploy-tag: "#deploy-kodeverk-service"
+    permissions:
+      contents: read
+      id-token: write
+    secrets: inherit

.github/workflows/app.team-dolly-lokal-app.yml

@@ -0,0 +1,21 @@
+name: team-dolly-lokal-app
+
+on:
+  push:
+    paths:
+      - .nais/team-dolly-lokal-app.yml
+      - .github/workflows/app.team-dolly-lokal-app.yml
+
+jobs:
+  deploy:
+    name: Deploy team-dolly-lokal-app
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      id-token: write
+    steps:
+      - uses: actions/checkout@v4
+      - uses: nais/deploy/actions/deploy@v2
+        env:
+          CLUSTER: dev-gcp
+          RESOURCE: .nais/team-dolly-lokal-app.yml

.github/workflows/build.yml

@@ -1,4 +1,4 @@
-name: Tests
+name: Integration Tests
 on:
   push:
     branches:

.github/workflows/tests.yml .github/workflows/integration-tests.yml

@@ -0,0 +1,18 @@
+apiVersion: nais.io/v1
+kind: AzureAdApplication
+metadata:
+  labels:
+    team: dolly
+  name: team-dolly-lokal-app
+  namespace: dolly
+spec:
+  allowAllUsers: true
+  logoutUrl: https://localhost:8080/oauth2/logout
+  preAuthorizedApplications:
+    - application: testnav-oversikt-frontend
+      cluster: dev-gcp
+      namespace: dolly
+  replyUrls:
+    - url: http://localhost:8080/login/oauth2/code/aad
+  secretName: azuread-team-dolly-lokal-app
+  tenant: nav.no

.nais/team-dolly-lokal-app.yml

@@ -44,5 +44,6 @@ TESTCONTAINERS_RYUK_DISABLED=true
 For å kjøre lokalt med elastic search:
 
 ```
-docker run -p 9200:9200 -p 9600:9600 -e "discovery.type=single-node" -e "plugins.security.disabled=true" --name opensearch-node -d opensearchproject/opensearch:latest
-```
+docker run -p 9200:9200 -p 9600:9600 -e "discovery.type=single-node" -e "plugins.security.disabled=true" -e "OPENSEARCH_INITIAL_ADMIN_PASSWORD=YLAgOm}rz#o6#Aq" --name opensearch -d opensearchproject/opensearch:latest
+```
+Legg merke til passord `YLAgOm}rz#o6#Aq` (tilfeldig [generert](https://www.strongpasswordgenerator.org/), men må være "sterkt" ellers vil ikke OpenSearch starte). 

apps/dolly-backend/README.md

@@ -85,52 +85,59 @@ private ClientFuture futurePersist(BestillingProgress progress, String status) {
         };
     }
 
-    private Flux<String> postInntektsmelding(boolean isSendMelding,
-                                             InntektsmeldingRequest inntektsmeldingRequest, Long bestillingid) {
-
+    private Flux<String> postInntektsmelding(
+            boolean isSendMelding,
+            InntektsmeldingRequest inntektsmeldingRequest,
+            Long bestillingid
+    ) {
+        final var miljoe = inntektsmeldingRequest.getMiljoe();
         if (isSendMelding) {
-            return inntektsmeldingConsumer.postInntektsmelding(inntektsmeldingRequest)
+            return inntektsmeldingConsumer
+                    .postInntektsmelding(inntektsmeldingRequest)
                     .map(response -> {
                         if (isBlank(response.getError())) {
-
-                            transaksjonMappingService.saveAll(
-                                    response.getDokumenter().stream()
-                                            .map(dokument -> {
-                                                var gjeldendeInntektRequest = InntektsmeldingRequest.builder()
-                                                        .arbeidstakerFnr(inntektsmeldingRequest.getArbeidstakerFnr())
-                                                        .inntekter(singletonList(
-                                                                inntektsmeldingRequest.getInntekter().get(response.getDokumenter().indexOf(dokument))))
-                                                        .joarkMetadata(inntektsmeldingRequest.getJoarkMetadata())
-                                                        .miljoe(inntektsmeldingRequest.getMiljoe())
-                                                        .build();
-
-                                                return TransaksjonMapping.builder()
-                                                        .ident(inntektsmeldingRequest.getArbeidstakerFnr())
-                                                        .bestillingId(bestillingid)
-                                                        .transaksjonId(toJson(TransaksjonMappingDTO.builder()
-                                                                .request(gjeldendeInntektRequest)
-                                                                .dokument(dokument)
-                                                                .build()))
-                                                        .datoEndret(LocalDateTime.now())
-                                                        .miljoe(inntektsmeldingRequest.getMiljoe())
-                                                        .system(INNTKMELD.name())
-                                                        .build();
-                                            })
-                                            .toList());
-
-                            return inntektsmeldingRequest.getMiljoe() + ":OK";
+                            var entries = response
+                                    .getDokumenter()
+                                    .stream()
+                                    .map(dokument -> {
+                                        var gjeldendeInntektRequest = InntektsmeldingRequest
+                                                .builder()
+                                                .arbeidstakerFnr(inntektsmeldingRequest.getArbeidstakerFnr())
+                                                .inntekter(singletonList(inntektsmeldingRequest.getInntekter().get(response.getDokumenter().indexOf(dokument))))
+                                                .joarkMetadata(inntektsmeldingRequest.getJoarkMetadata())
+                                                .miljoe(miljoe)
+                                                .build();
+                                        var json = toJson(TransaksjonMappingDTO
+                                                .builder()
+                                                .request(gjeldendeInntektRequest)
+                                                .dokument(dokument)
+                                                .build());
+                                        return TransaksjonMapping
+                                                .builder()
+                                                .ident(inntektsmeldingRequest.getArbeidstakerFnr())
+                                                .bestillingId(bestillingid)
+                                                .transaksjonId(json)
+                                                .datoEndret(LocalDateTime.now())
+                                                .miljoe(miljoe)
+                                                .system(INNTKMELD.name())
+                                                .build();
+                                    })
+                                    .toList();
+                            transaksjonMappingService.saveAll(entries);
+
+                            return miljoe + ":OK";
 
                         } else {
                             log.error("Feilet å legge inn person: {} til Inntektsmelding miljø: {} feilmelding {}",
-                                    inntektsmeldingRequest.getArbeidstakerFnr(), inntektsmeldingRequest.getMiljoe(), response.getError());
+                                    inntektsmeldingRequest.getArbeidstakerFnr(), miljoe, response.getError());
 
-                            return String.format(STATUS_FMT, inntektsmeldingRequest.getMiljoe(),
+                            return String.format(STATUS_FMT, miljoe,
                                     errorStatusDecoder.getErrorText(response.getStatus(), response.getError()));
 
                         }
                     });
         } else {
-            return Flux.just(inntektsmeldingRequest.getMiljoe() + ":OK");
+            return Flux.just(miljoe + ":OK");
         }
     }