Skip to content

Commit

Permalink
SoftDelete hendelse sletter notifikasjon og sak fra produsent databasen
Browse files Browse the repository at this point in the history
  • Loading branch information
@anderslysne
anderslysne committed Jan 2, 2025
1 parent 9be3dc0 commit ea58883
Show file tree
Hide file tree
Showing 3 changed files with 45 additions and 82 deletions.
78 changes: 22 additions & 56 deletions app/src/main/kotlin/no/nav/arbeidsgiver/notifikasjon/produsent/ProdusentRepository.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,7 @@ interface ProdusentRepository {
SAK,
BESKJED,
OPPGAVE,
KALENDERAVTALE
}

suspend fun hentNotifikasjon(id: UUID): ProdusentModel.Notifikasjon?
Expand Down Expand Up @@ -324,8 +325,8 @@ class ProdusentRepositoryImpl(
is OppgaveUtgått -> oppdaterModellEtterOppgaveUtgått(hendelse)
is PåminnelseOpprettet -> /* Ignorer */ Unit
is BrukerKlikket -> /* Ignorer */ Unit
is SoftDelete -> oppdaterModellEtterSoftDelete(hendelse)
is HardDelete -> oppdaterModellEtterHardDelete(hendelse)
is SoftDelete -> oppdaterModellEtterDelete(aggregateId = hendelse.aggregateId, merkelapp = hendelse.merkelapp, grupperingsid = hendelse.grupperingsid)
is HardDelete -> oppdaterModellEtterDelete(aggregateId = hendelse.aggregateId, merkelapp = hendelse.merkelapp, grupperingsid = hendelse.grupperingsid)
is EksterntVarselVellykket -> oppdaterModellEtterEksterntVarselVellykket(hendelse)
is EksterntVarselFeilet -> oppdaterModellEtterEksterntVarselFeilet(hendelse)
is EksterntVarselKansellert -> oppdaterModellEtterEksterntVarselKansellert(hendelse)
Expand Down Expand Up @@ -460,7 +461,7 @@ class ProdusentRepositoryImpl(
}
}

private suspend fun oppdaterModellEtterNesteStegSak(nesteStegSak: HendelseModel.NesteStegSak) {
private suspend fun oppdaterModellEtterNesteStegSak(nesteStegSak: NesteStegSak) {
database.transaction {
executeUpdate(
"""
Expand Down Expand Up @@ -491,21 +492,24 @@ class ProdusentRepositoryImpl(
}
}

private suspend fun oppdaterModellEtterHardDelete(hardDelete: HardDelete) {
private suspend fun oppdaterModellEtterDelete(aggregateId: UUID, merkelapp: String?, grupperingsid: String?) {
database.transaction {
registrerDelete(this, hardDelete.aggregateId)
registrerDelete(this, aggregateId)
executeQuery("""
select aggregate_type from (
select 'SAK' as aggregate_type from sak where id = ?
union
select 'BESKJED' as aggregate_type from notifikasjon where id = ?
union
select 'OPPGAVE' as aggregate_type from notifikasjon where id = ?
union
select 'KALENDERAVTALE' as aggregate_type from notifikasjon where id = ?
) as aggregate_type
""", setup = {
uuid(hardDelete.aggregateId)
uuid(hardDelete.aggregateId)
uuid(hardDelete.aggregateId)
uuid(aggregateId)
uuid(aggregateId)
uuid(aggregateId)
uuid(aggregateId)
}, transform = {
AggregateType.valueOf(getString("aggregate_type"))
}).firstOrNull()?.let {
Expand All @@ -517,18 +521,18 @@ class ProdusentRepositoryImpl(
values (?, ?, ?, ?);
"""
) {
uuid(hardDelete.aggregateId)
uuid(aggregateId)
text(it.name)
nullableText(hardDelete.merkelapp)
nullableText(hardDelete.grupperingsid)
nullableText(merkelapp)
nullableText(grupperingsid)
}
}

if (hardDelete.grupperingsid != null && hardDelete.merkelapp != null) {
if (grupperingsid != null && merkelapp != null) {
// cascade hard delete av sak med grupperingsid og merkelapp
executeUpdate("""delete from notifikasjon n where n.grupperingsid = ? and merkelapp = ?;""") {
text(hardDelete.grupperingsid)
text(hardDelete.merkelapp)
text(grupperingsid)
text(merkelapp)
}
}
executeUpdate(
Expand All @@ -537,69 +541,31 @@ class ProdusentRepositoryImpl(
where id = ?
"""
) {
uuid(hardDelete.aggregateId)
uuid(aggregateId)
}
executeUpdate(
"""
delete from sak
where id = ?
"""
) {
uuid(hardDelete.aggregateId)
uuid(aggregateId)
}
executeUpdate(
"""
delete from eksternt_varsel
where notifikasjon_id = ?
"""
) {
uuid(hardDelete.aggregateId)
uuid(aggregateId)
}
executeUpdate(
"""
delete from paaminnelse_eksternt_varsel
where notifikasjon_id = ?
"""
) {
uuid(hardDelete.aggregateId)
}
}
}

private suspend fun oppdaterModellEtterSoftDelete(softDelete: SoftDelete) {
database.transaction {
executeUpdate(
"""
UPDATE notifikasjon
SET deleted_at = ?
WHERE id = ?
"""
) {
timestamp_with_timezone(softDelete.deletedAt)
uuid(softDelete.aggregateId)
}
if (softDelete.grupperingsid !== null && softDelete.merkelapp !== null) {
executeUpdate(
"""
update notifikasjon
SET deleted_at = ?
WHERE grupperingsid = ? AND merkelapp = ?
""".trimIndent()
) {
timestamp_with_timezone(softDelete.deletedAt)
text(softDelete.grupperingsid)
text(softDelete.merkelapp)
}
}
executeUpdate(
"""
UPDATE sak
SET deleted_at = ?
WHERE id = ?
"""
) {
timestamp_with_timezone(softDelete.deletedAt)
uuid(softDelete.aggregateId)
uuid(aggregateId)
}
}
}
Expand Down
26 changes: 12 additions & 14 deletions ...test/kotlin/no/nav/arbeidsgiver/notifikasjon/produsent/api/SoftDeleteNotifikasjonTests.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ package no.nav.arbeidsgiver.notifikasjon.produsent.api

import io.kotest.core.spec.style.DescribeSpec
import io.kotest.matchers.shouldBe
import io.kotest.matchers.shouldNotBe
import io.kotest.matchers.types.instanceOf
import io.ktor.server.testing.*
import no.nav.arbeidsgiver.notifikasjon.hendelse.HendelseModel.AltinnMottaker
Expand Down Expand Up @@ -63,7 +62,7 @@ class SoftDeleteNotifikasjonTests : DescribeSpec({
describe("SoftDelete-oppførsel") {


context("Eksisterende oppgave blir markert som slettet") {
context("Eksisterende oppgave blir slettet") {
val (produsentModel, kafkaProducer, engine) = setupEngine()


Expand Down Expand Up @@ -98,17 +97,17 @@ class SoftDeleteNotifikasjonTests : DescribeSpec({
}
}

it("har slettet-status i modellen") {
val notifikasjon = produsentModel.hentNotifikasjon(uuid)!!
notifikasjon.deletedAt shouldNotBe null
it("har blitt slettet i modellen") {
val notifikasjon = produsentModel.hentNotifikasjon(uuid)
notifikasjon shouldBe null
}
it("notifikasjon2 har ikke slettet-status i modellen") {
val notifikasjon = produsentModel.hentNotifikasjon(uuid2)!!
notifikasjon.deletedAt shouldBe null
}


it("mineNotifikasjoner rapporterer som softDeleted") {
it("mineNotifikasjoner rapporterer ikke lenger notifikasjon") {
val response = engine.produsentApi(
"""
query {
Expand Down Expand Up @@ -226,10 +225,9 @@ class SoftDeleteNotifikasjonTests : DescribeSpec({
response.getTypedContent<QueryNotifikasjoner.NotifikasjonConnection>("mineNotifikasjoner")
.edges
.map { it.node }
.find { it.id == uuid }!!
.find { it.id == uuid }

slettetNotifikasjon.metadata.softDeleted shouldBe true
slettetNotifikasjon.metadata.softDeletedAt shouldNotBe null
slettetNotifikasjon shouldBe null
}
}

Expand Down Expand Up @@ -287,7 +285,7 @@ class SoftDeleteNotifikasjonTests : DescribeSpec({
val response = engine.produsentApi(
"""
mutation {
softDeleteNotifikasjonByEksternId(eksternId: "$eksternId", merkelapp: "$merkelapp") {
softDeleteNotifikasjonByEksternId_V2(eksternId: "$eksternId", merkelapp: "$merkelapp") {
__typename
... on SoftDeleteNotifikasjonVellykket {
id
Expand All @@ -302,7 +300,7 @@ class SoftDeleteNotifikasjonTests : DescribeSpec({

it("returnerer tilbake id-en") {
val vellykket =
response.getTypedContent<MutationSoftDeleteNotifikasjon.SoftDeleteNotifikasjonVellykket>("softDeleteNotifikasjonByEksternId")
response.getTypedContent<MutationSoftDeleteNotifikasjon.SoftDeleteNotifikasjonVellykket>("softDeleteNotifikasjonByEksternId_V2")
vellykket.id shouldBe uuid
}

Expand All @@ -312,9 +310,9 @@ class SoftDeleteNotifikasjonTests : DescribeSpec({
}
}

it("har fått slettet tidspunkt") {
val notifikasjon = produsentModel.hentNotifikasjon(uuid)!!
notifikasjon.deletedAt shouldNotBe null
it("har blitt slettet i modellen") {
val notifikasjon = produsentModel.hentNotifikasjon(uuid)
notifikasjon shouldBe null
}
it("oppgave 2 har ikke fått slettet tidspunkt") {
val notifikasjon = produsentModel.hentNotifikasjon(uuid2)!!
Expand Down
23 changes: 11 additions & 12 deletions app/src/test/kotlin/no/nav/arbeidsgiver/notifikasjon/produsent/api/SoftDeleteSakTests.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ package no.nav.arbeidsgiver.notifikasjon.produsent.api

import io.kotest.core.spec.style.DescribeSpec
import io.kotest.matchers.shouldBe
import io.kotest.matchers.shouldNotBe
import io.kotest.matchers.types.instanceOf
import io.ktor.server.testing.*
import no.nav.arbeidsgiver.notifikasjon.hendelse.HendelseModel
Expand Down Expand Up @@ -140,9 +139,9 @@ class SoftDeleteSakTests : DescribeSpec({
}
}

it("har slettet-status i modellen") {
val notifikasjon = produsentModel.hentSak(uuid)!!
notifikasjon.deletedAt shouldNotBe null
it("har blitt slettet i modellen") {
val notifikasjon = produsentModel.hentSak(uuid)
notifikasjon shouldBe null
}
it("notifikasjon2 har ikke slettet-status i modellen") {
val notifikasjon = produsentModel.hentSak(uuid2)!!
Expand Down Expand Up @@ -193,7 +192,7 @@ class SoftDeleteSakTests : DescribeSpec({
}

context("SoftDelete cascader fra sak til notifikasjoner"){
val (produsentModel, kafkaProducer, engine) = setupEngine()
val (produsentModel, _, engine) = setupEngine()
produsentModel.oppdaterModellEtterHendelse(sakOpprettet)
produsentModel.oppdaterModellEtterHendelse(sakOpprettet2)
produsentModel.oppdaterModellEtterHendelse(oppgaveOpprettet)
Expand Down Expand Up @@ -224,8 +223,8 @@ class SoftDeleteSakTests : DescribeSpec({
}

it ("oppgave er slettet") {
val notifikasjon = produsentModel.hentNotifikasjon(uuid3)!!
notifikasjon.deletedAt shouldNotBe null
val notifikasjon = produsentModel.hentNotifikasjon(uuid3)
notifikasjon shouldBe null
}

it ("oppgave 2 er ikke slettet") {
Expand All @@ -234,8 +233,8 @@ class SoftDeleteSakTests : DescribeSpec({
}

it ("beskjed er slettet") {
val notifikasjon = produsentModel.hentNotifikasjon(uuid5)!!
notifikasjon.deletedAt shouldNotBe null
val notifikasjon = produsentModel.hentNotifikasjon(uuid5)
notifikasjon shouldBe null
}
}
}
Expand Down Expand Up @@ -276,9 +275,9 @@ class SoftDeleteSakTests : DescribeSpec({
}
}

it("har fått slettet tidspunkt") {
val notifikasjon = produsentModel.hentSak(uuid)!!
notifikasjon.deletedAt shouldNotBe null
it("har blitt slettet i modellen") {
val notifikasjon = produsentModel.hentSak(uuid)
notifikasjon shouldBe null
}
it("oppgave 2 har ikke fått slettet tidspunkt") {
val notifikasjon = produsentModel.hentSak(uuid2)!!
Expand Down

0 comments on commit ea58883

Please sign in to comment.