Skip to content

Commit

Permalink
Integrasjonstest: Bruk nested data som default i meldingsfiltrering (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
bjerga authored Oct 1, 2024
1 parent 667a642 commit 97dd42a
Show file tree
Hide file tree
Showing 12 changed files with 53 additions and 53 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -102,15 +102,15 @@ class AktiveOrgnrServiceIT : EndToEndTest() {
}

aktiveOrgnrMeldinger
.filter(Key.ORG_RETTIGHETER, nestedData = true)
.filter(Key.ORG_RETTIGHETER)
.firstAsMap()
.also { melding ->
val data = melding[Key.DATA].shouldNotBeNull().toMap()
Key.ORG_RETTIGHETER.les(String.serializer().set(), data) shouldContainExactly Mock.altinnOrganisasjonSet.mapNotNull { it.orgnr }.toSet()
}

aktiveOrgnrMeldinger
.filter(Key.ARBEIDSFORHOLD, nestedData = true)
.filter(Key.ARBEIDSFORHOLD)
.firstAsMap()
.also { melding ->
val data = melding[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -126,7 +126,7 @@ class AktiveOrgnrServiceIT : EndToEndTest() {
}

aktiveOrgnrMeldinger
.filter(Key.VIRKSOMHETER, nestedData = true)
.filter(Key.VIRKSOMHETER)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand Down Expand Up @@ -183,15 +183,15 @@ class AktiveOrgnrServiceIT : EndToEndTest() {
}

aktiveOrgnrMeldinger
.filter(Key.ORG_RETTIGHETER, nestedData = true)
.filter(Key.ORG_RETTIGHETER)
.firstAsMap()
.also { melding ->
val data = melding[Key.DATA].shouldNotBeNull().toMap()
Key.ORG_RETTIGHETER.les(String.serializer().set(), data) shouldContainExactly Mock.altinnOrganisasjonSet.mapNotNull { it.orgnr }.toSet()
}

aktiveOrgnrMeldinger
.filter(Key.ARBEIDSFORHOLD, nestedData = true)
.filter(Key.ARBEIDSFORHOLD)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() {
// Forespørsel hentet
messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.FORESPOERSEL_SVAR, nestedData = true)
.filter(Key.FORESPOERSEL_SVAR)
.firstAsMap()
.verifiserTransaksjonId(Mock.transaksjonId)
.verifiserForespoerselIdFraSkjema()
Expand All @@ -104,7 +104,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() {
// Virksomhetsnavn hentet
messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.VIRKSOMHETER, nestedData = true)
.filter(Key.VIRKSOMHETER)
.firstAsMap()
.verifiserTransaksjonId(Mock.transaksjonId)
.verifiserForespoerselIdFraSkjema()
Expand All @@ -116,8 +116,8 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() {
// Inntektsmelding lagret
messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.INNTEKTSMELDING_DOKUMENT, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.INNTEKTSMELDING_DOKUMENT)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.verifiserTransaksjonId(Mock.transaksjonId)
.verifiserForespoerselIdFraSkjema()
Expand All @@ -132,7 +132,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() {
// Sykmeldt og innsender hentet
messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.PERSONER, nestedData = true)
.filter(Key.PERSONER)
.firstAsMap()
.verifiserTransaksjonId(Mock.transaksjonId)
.verifiserForespoerselIdFraSkjema()
Expand Down Expand Up @@ -221,7 +221,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() {
// Forespørsel hentet
messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.FORESPOERSEL_SVAR, nestedData = true)
.filter(Key.FORESPOERSEL_SVAR)
.firstAsMap()
.verifiserTransaksjonId(Mock.transaksjonId)
.verifiserForespoerselIdFraSkjema()
Expand All @@ -233,7 +233,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() {
// Virksomhetsnavn hentet
messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.VIRKSOMHETER, nestedData = true)
.filter(Key.VIRKSOMHETER)
.firstAsMap()
.verifiserTransaksjonId(Mock.transaksjonId)
.verifiserForespoerselIdFraSkjema()
Expand All @@ -245,7 +245,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() {
// Personnavn ikke hentet
messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.PERSONER, nestedData = true)
.filter(Key.PERSONER)
.all()
.size shouldBe 0

Expand All @@ -269,7 +269,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() {
// Sykmeldt og innsender hentet
messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.PERSONER, nestedData = true)
.filter(Key.PERSONER)
.firstAsMap()
.verifiserTransaksjonId(Mock.transaksjonId)
.verifiserForespoerselIdFraSkjema()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ class ForespoerselBesvartIT : EndToEndTest() {

messages
.filter(EventName.FORESPOERSEL_BESVART)
.filter(Key.SAK_ID, utenDataKey = true)
.filter(Key.SAK_ID, nestedData = false, utenDataKey = true)
.firstAsMap()
.also {
it shouldNotContainKey Key.BEHOV
Expand All @@ -108,7 +108,7 @@ class ForespoerselBesvartIT : EndToEndTest() {

messages
.filter(EventName.FORESPOERSEL_BESVART)
.filter(Key.OPPGAVE_ID, utenDataKey = true)
.filter(Key.OPPGAVE_ID, nestedData = false, utenDataKey = true)
.firstAsMap()
.also {
it shouldNotContainKey Key.BEHOV
Expand All @@ -126,7 +126,7 @@ class ForespoerselBesvartIT : EndToEndTest() {

messages
.filter(EventName.SAK_FERDIGSTILT)
.filter(Key.SAK_ID, utenDataKey = true)
.filter(Key.SAK_ID, nestedData = false, utenDataKey = true)
.firstAsMap()
.also {
if (forventetTransaksjonId == null) {
Expand All @@ -142,7 +142,7 @@ class ForespoerselBesvartIT : EndToEndTest() {

messages
.filter(EventName.OPPGAVE_FERDIGSTILT)
.filter(Key.OPPGAVE_ID, utenDataKey = true)
.filter(Key.OPPGAVE_ID, nestedData = false, utenDataKey = true)
.firstAsMap()
.also {
if (forventetTransaksjonId == null) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,8 +81,8 @@ class InnsendingIT : EndToEndTest() {

messages
.filter(EventName.INNTEKTSMELDING_SKJEMA_LAGRET)
.filter(Key.INNTEKTSMELDING_DOKUMENT, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.INNTEKTSMELDING_DOKUMENT)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.also {
// Ble lagret i databasen
Expand Down Expand Up @@ -152,7 +152,7 @@ class InnsendingIT : EndToEndTest() {

messages
.filter(EventName.INSENDING_STARTED)
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand Down Expand Up @@ -189,7 +189,7 @@ class InnsendingIT : EndToEndTest() {

messages
.filter(EventName.INSENDING_STARTED)
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -216,7 +216,7 @@ class InnsendingIT : EndToEndTest() {

messages
.filter(EventName.FORESPOERSEL_BESVART)
.filter(Key.SAK_ID, utenDataKey = true)
.filter(Key.SAK_ID, nestedData = false, utenDataKey = true)
.firstAsMap()
.also {
Key.FORESPOERSEL_ID.les(UuidSerializer, it) shouldBe Mock.forespoerselId
Expand All @@ -225,7 +225,7 @@ class InnsendingIT : EndToEndTest() {

messages
.filter(EventName.FORESPOERSEL_BESVART)
.filter(Key.OPPGAVE_ID, utenDataKey = true)
.filter(Key.OPPGAVE_ID, nestedData = false, utenDataKey = true)
.firstAsMap()
.also {
Key.FORESPOERSEL_ID.les(UuidSerializer, it) shouldBe Mock.forespoerselId
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ class InnsendingServiceIT : EndToEndTest() {
// Inntektsmelding lagret
messages
.filter(EventName.INSENDING_STARTED)
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.verifiserTransaksjonId(transaksjonId)
.also {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ class InntektSelvbestemtIT : EndToEndTest() {
)

messages
.filter(Key.INNTEKT, nestedData = true)
.filter(Key.INNTEKT)
.firstAsMap()
.shouldContainExactly(
mapOf(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,8 +48,8 @@ class KvitteringIT : EndToEndTest() {

messages
.filter(EventName.KVITTERING_REQUESTED)
.filter(Key.LAGRET_INNTEKTSMELDING, nestedData = true)
.filter(Key.EKSTERN_INNTEKTSMELDING, nestedData = true)
.filter(Key.LAGRET_INNTEKTSMELDING)
.filter(Key.EKSTERN_INNTEKTSMELDING)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand Down Expand Up @@ -85,8 +85,8 @@ class KvitteringIT : EndToEndTest() {

messages
.filter(EventName.KVITTERING_REQUESTED)
.filter(Key.LAGRET_INNTEKTSMELDING, nestedData = true)
.filter(Key.EKSTERN_INNTEKTSMELDING, nestedData = true)
.filter(Key.LAGRET_INNTEKTSMELDING)
.filter(Key.EKSTERN_INNTEKTSMELDING)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand Down Expand Up @@ -115,8 +115,8 @@ class KvitteringIT : EndToEndTest() {

messages
.filter(EventName.KVITTERING_REQUESTED)
.filter(Key.LAGRET_INNTEKTSMELDING, nestedData = true)
.filter(Key.EKSTERN_INNTEKTSMELDING, nestedData = true)
.filter(Key.LAGRET_INNTEKTSMELDING)
.filter(Key.EKSTERN_INNTEKTSMELDING)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Data hentet
serviceMessages
.filter(Key.VIRKSOMHETER, nestedData = true)
.filter(Key.VIRKSOMHETER)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -107,7 +107,7 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Data hentet
serviceMessages
.filter(Key.PERSONER, nestedData = true)
.filter(Key.PERSONER)
.firstAsMap()
.also { melding ->
val data = melding[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -118,7 +118,7 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Data hentet
serviceMessages
.filter(Key.ARBEIDSFORHOLD, nestedData = true)
.filter(Key.ARBEIDSFORHOLD)
.firstAsMap()
.also { melding ->
val data = melding[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -136,7 +136,7 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Lagring utført, uten duplikat
serviceMessages
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -154,7 +154,7 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Opprettelse av sak utført
serviceMessages
.filter(Key.SAK_ID, nestedData = true)
.filter(Key.SAK_ID)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand Down Expand Up @@ -215,7 +215,7 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Lagring utført, uten duplikat
serviceMessages
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -230,7 +230,7 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Opprettelse av sak _ikke_ utført
serviceMessages
.filter(Key.SAK_ID, nestedData = true)
.filter(Key.SAK_ID)
.all()
.shouldBeEmpty()

Expand Down Expand Up @@ -283,15 +283,15 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Lagring utført, med duplikat
serviceMessages
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Key.SELVBESTEMT_INNTEKTSMELDING.les(Inntektsmelding.serializer(), data).shouldBeEqualToInntektsmelding(Mock.inntektsmelding, compareType = true)
}

serviceMessages
.filter(Key.ER_DUPLIKAT_IM, nestedData = true)
.filter(Key.ER_DUPLIKAT_IM)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -306,7 +306,7 @@ class LagreSelvbestemtIT : EndToEndTest() {

// Opprettelse av sak _ikke_ utført
serviceMessages
.filter(Key.SAK_ID, nestedData = true)
.filter(Key.SAK_ID)
.all()
.shouldBeEmpty()

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ class NotifikasjonIT : EndToEndTest() {

messages
.filter(EventName.SAK_OPPRETT_REQUESTED)
.filter(Key.PERSONER, nestedData = true)
.filter(Key.PERSONER)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -76,7 +76,7 @@ class NotifikasjonIT : EndToEndTest() {

messages
.filter(EventName.SAK_OPPRETT_REQUESTED)
.filter(Key.SAK_ID)
.filter(Key.SAK_ID, nestedData = false)
.firstAsMap()
.also {
val sakId = it[Key.SAK_ID]?.fromJsonToString()
Expand Down Expand Up @@ -200,7 +200,7 @@ class NotifikasjonIT : EndToEndTest() {

messages
.filter(EventName.MANUELL_OPPRETT_SAK_REQUESTED)
.filter(Key.PERSONER, nestedData = true)
.filter(Key.PERSONER)
.firstAsMap()
.also {
val data = it[Key.DATA].shouldNotBeNull().toMap()
Expand All @@ -219,7 +219,7 @@ class NotifikasjonIT : EndToEndTest() {

messages
.filter(EventName.MANUELL_OPPRETT_SAK_REQUESTED)
.filter(Key.SAK_ID)
.filter(Key.SAK_ID, nestedData = false)
.firstAsMap()
.also {
val sakId = it[Key.SAK_ID]?.fromJsonToString()
Expand Down
Loading

0 comments on commit 97dd42a

Please sign in to comment.