Legg til soft delete aggregater i deleted aggregates. lett refaktorer…

…ing for å tilpasse dette
navikt · Dec 18, 2024 · 5be6a67 · 5be6a67
1 parent 983b2b8
commit 5be6a67
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 19 deletions.
diff --git a/app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/bruker/BrukerRepository.kt b/app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/bruker/BrukerRepository.kt
@@ -706,14 +706,7 @@ class BrukerRepositoryImpl(
             is OppgaveUtført -> oppdaterModellEtterOppgaveUtført(hendelse, metadata)
             is OppgaveUtgått -> oppdaterModellEtterOppgaveUtgått(hendelse)
             is SoftDelete -> oppdaterModellEtterDelete(hendelse.aggregateId, hendelse.grupperingsid, hendelse.merkelapp)
-            is HardDelete -> oppdaterModellEtterDelete(
-                hendelse.aggregateId,
-                hendelse.grupperingsid,
-                hendelse.merkelapp
-            ) { tx ->
-                registrerHardDelete(tx, hendelse)
-            }
-
+            is HardDelete -> oppdaterModellEtterDelete(hendelse.aggregateId,hendelse.grupperingsid,hendelse.merkelapp)
             is EksterntVarselFeilet -> Unit
             is EksterntVarselVellykket -> Unit
             is EksterntVarselKansellert -> Unit
@@ -834,8 +827,7 @@ class BrukerRepositoryImpl(
     private suspend fun oppdaterModellEtterDelete(
         aggregateId: UUID,
         grupperingsid: String?,
-        merkelapp: String?,
-        callback: (tx: Transaction) -> Unit = {}
+        merkelapp: String?
     ) {
         database.transaction({
             throw RuntimeException("Delete", it)
@@ -859,7 +851,7 @@ class BrukerRepositoryImpl(
                 uuid(aggregateId)
             }
 
-            callback(this)
+            registrerDelete(this, aggregateId)
         }
     }
 

diff --git a/app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/dataprodukt/DataproduktModel.kt b/app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/dataprodukt/DataproduktModel.kt
@@ -425,7 +425,7 @@ class DataproduktModel(
                     ) {
                         uuid(hendelse.aggregateId)
                     }
-                    registrerHardDelete(this, hendelse)
+                    registrerDelete(this, hendelse.aggregateId)
                 }
             }
 

diff --git a/app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/hendelse/HardDeletedRepository.kt b/app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/hendelse/HardDeletedRepository.kt
@@ -40,16 +40,12 @@ open class HardDeletedRepository(private val database: Database) {
 
     }
 
-    fun registrerHardDelete(tx: Transaction, hendelse: HendelseModel.Hendelse) {
-        if (hendelse !is HendelseModel.HardDelete) {
-            return
-        }
-
+    fun registrerDelete(tx: Transaction, aggregateId: UUID) {
         tx.executeUpdate("""
             insert into hard_deleted_aggregates(aggregate_id) values (?)
             on conflict do nothing
         """) {
-            uuid(hendelse.aggregateId)
+            uuid(aggregateId)
         }
     }
 }
diff --git a/app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/produsent/ProdusentRepository.kt b/app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/produsent/ProdusentRepository.kt
@@ -493,7 +493,7 @@ class ProdusentRepositoryImpl(
 
     private suspend fun oppdaterModellEtterHardDelete(hardDelete: HardDelete) {
         database.transaction {
-            registrerHardDelete(this, hardDelete)
+            registrerDelete(this, hardDelete.aggregateId)
             executeQuery("""
                 select aggregate_type from (
                     select 'SAK' as aggregate_type from sak where id = ?
-Original file line number
+Diff line change
@@ Expand Up / @@ -425,7 +425,7 @@ class DataproduktModel( @@
                         ) {
                             uuid(hendelse.aggregateId)
                         }
-                        registrerHardDelete(this, hendelse)
+                        registrerDelete(this, hendelse.aggregateId)
                     }
                 }
@@ Expand Down @@