Merge branch 'master' of github.com:navikt/tiltak-refusjon-api into f…

…eat/vtao-tiltakstype
navikt · Jul 5, 2024 · ce4b8da · ce4b8da
2 parents 0faef4f + ef92171
commit ce4b8da
Show file tree

Hide file tree

Showing 5 changed files with 26 additions and 20 deletions.
diff --git a/.nais/nais.yml b/.nais/nais.yml
@@ -24,10 +24,10 @@ spec:
       memory: {{memory-requests}}
   liveness:
     path: /internal/actuator/health
-    initialDelay: 20
+    initialDelay: 40
   readiness:
     path: /internal/actuator/health
-    initialDelay: 20
+    initialDelay: 40
   accessPolicy:
     inbound:
       rules:

diff --git a/src/main/kotlin/no/nav/arbeidsgiver/tiltakrefusjon/autorisering/SystemBrukere.kt b/src/main/kotlin/no/nav/arbeidsgiver/tiltakrefusjon/autorisering/SystemBrukere.kt
@@ -2,13 +2,6 @@ package no.nav.arbeidsgiver.tiltakrefusjon.autorisering
 
 import no.nav.arbeidsgiver.tiltakrefusjon.refusjon.BrukerRolle
 
-val KAFKA_BRUKER = object : InnloggetBruker {
-    override val identifikator: String
-        get() = "kafka"
-    override val rolle: BrukerRolle
-        get() = BrukerRolle.SYSTEM
-}
-
 val ADMIN_BRUKER = object : InnloggetBruker {
     override val identifikator: String
         get() = "admin"
@@ -21,4 +14,4 @@ val SYSTEM_BRUKER = object : InnloggetBruker {
         get() = "system"
     override val rolle: BrukerRolle
         get() = BrukerRolle.SYSTEM
-}
+}
diff --git a/src/main/kotlin/no/nav/arbeidsgiver/tiltakrefusjon/hendelseslogg/HendelsesloggDTO.kt b/src/main/kotlin/no/nav/arbeidsgiver/tiltakrefusjon/hendelseslogg/HendelsesloggDTO.kt
@@ -15,16 +15,27 @@ data class HendelsesloggDTO(
     constructor(hendelseslogg: Hendelseslogg) : this(
         refusjonId = hendelseslogg.refusjonId,
         korreksjonId = hendelseslogg.korreksjonId,
-        utførtAv = if (hendelseslogg.utførtRolle == BrukerRolle.ARBEIDSGIVER) {
-            hendelseslogg.utførtRolle.name
-        } else if (erGyldigFnr(hendelseslogg.utførtAv)) {
-            // rolle mangler på eldre events
-            ""
-        } else {
-            hendelseslogg.utførtAv
-        },
+        utførtAv = utførtAv(hendelseslogg),
         event = hendelseslogg.event,
         metadata = hendelseslogg.metadata,
         tidspunkt = hendelseslogg.tidspunkt,
     )
 }
+
+private val RollerSomSkalAnonymiseres = setOf(
+    BrukerRolle.ARBEIDSGIVER,
+    BrukerRolle.SYSTEM
+)
+
+private fun hendelseSkalAnonymiseres(hendelseslogg: Hendelseslogg) =
+    RollerSomSkalAnonymiseres.contains(hendelseslogg.utførtRolle)
+
+private fun utførtAv(hendelseslogg: Hendelseslogg) =
+    if (hendelseSkalAnonymiseres(hendelseslogg)) {
+        hendelseslogg.utførtRolle!!.name
+    } else if (erGyldigFnr(hendelseslogg.utførtAv)) {
+        // rolle mangler på eldre events
+        ""
+    } else {
+        hendelseslogg.utførtAv
+    }
diff --git a/src/main/kotlin/no/nav/arbeidsgiver/tiltakrefusjon/refusjon/Refusjon.kt b/src/main/kotlin/no/nav/arbeidsgiver/tiltakrefusjon/refusjon/Refusjon.kt
@@ -12,7 +12,6 @@ import no.nav.arbeidsgiver.tiltakrefusjon.FeilkodeException
 import no.nav.arbeidsgiver.tiltakrefusjon.audit.FnrOgBedrift
 import no.nav.arbeidsgiver.tiltakrefusjon.audit.RefusjonMedFnrOgBedrift
 import no.nav.arbeidsgiver.tiltakrefusjon.autorisering.InnloggetBruker
-import no.nav.arbeidsgiver.tiltakrefusjon.autorisering.KAFKA_BRUKER
 import no.nav.arbeidsgiver.tiltakrefusjon.autorisering.SYSTEM_BRUKER
 import no.nav.arbeidsgiver.tiltakrefusjon.refusjon.events.FristForlenget
 import no.nav.arbeidsgiver.tiltakrefusjon.refusjon.events.GodkjentAvArbeidsgiver
@@ -258,7 +257,7 @@ class Refusjon(
         refusjonsgrunnlag.tilskuddsgrunnlag.tilskuddTom = tilskuddTom
         refusjonsgrunnlag.tilskuddsgrunnlag.tilskuddsbeløp = tilskuddsbeløp
         oppdaterStatus()
-        registerEvent(RefusjonForkortet(this, KAFKA_BRUKER))
+        registerEvent(RefusjonForkortet(this, SYSTEM_BRUKER))
     }
 
     fun korreksjongrunnerInnholdSjekk(korreksjonsgrunner: Set<Korreksjonsgrunn>): Int {

diff --git a/src/main/resources/db/migration/V53__endre_navn_kafka.sql b/src/main/resources/db/migration/V53__endre_navn_kafka.sql
@@ -0,0 +1,3 @@
+-- Opprydding i systembrukernavn (admin-bruker endres ikke, men frontend endres til at kun rolle vises for systembrukere)
+UPDATE hendelseslogg SET utført_av = 'system' where utført_av in ('kafka', 'Kafka') and utført_rolle = 'SYSTEM';
+UPDATE hendelseslogg SET utført_av = 'system', utført_rolle = 'SYSTEM' where utført_av = 'Kafka' and utført_rolle is null;