Skip to content

Commit

Permalink
Fjern sending av gammelt IM-format til Spinn
Browse files Browse the repository at this point in the history
  • Loading branch information
bjerga committed Dec 18, 2024
1 parent 56a2f4e commit f6d4791
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 30 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ package no.nav.helsearbeidsgiver.inntektsmelding.distribusjon
import kotlinx.serialization.Serializable
import kotlinx.serialization.builtins.serializer
import kotlinx.serialization.json.JsonElement
import no.nav.helsearbeidsgiver.domene.inntektsmelding.Utils.convert
import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.Inntektsmelding
import no.nav.helsearbeidsgiver.felles.EventName
import no.nav.helsearbeidsgiver.felles.Key
Expand All @@ -26,7 +25,6 @@ import org.apache.kafka.clients.producer.KafkaProducer
import org.apache.kafka.clients.producer.ProducerRecord
import java.time.LocalDate
import java.util.UUID
import no.nav.helsearbeidsgiver.domene.inntektsmelding.deprecated.Inntektsmelding as InntektsmeldingGammel

const val TOPIC_HELSEARBEIDSGIVER_INNTEKTSMELDING_EKSTERN = "helsearbeidsgiver.inntektsmelding"

Expand Down Expand Up @@ -85,7 +83,7 @@ class DistribusjonRiver(
): Map<Key, JsonElement> {
val fail =
Fail(
feilmelding = "Klarte ikke distribuere IM med journalpost-ID: '$journalpostId'.",
feilmelding = "Klarte ikke distribuere IM med journalpost-ID '$journalpostId'.",
kontekstId = transaksjonId,
utloesendeMelding = json,
)
Expand All @@ -112,26 +110,11 @@ class DistribusjonRiver(
bestemmendeFravaersdag: LocalDate?,
journalpostId: String,
) {
val inntektsmeldingGammeltFormat =
inntektsmelding
.convert()
.let {
if (bestemmendeFravaersdag != null) {
it.copy(bestemmendeFraværsdag = bestemmendeFravaersdag)
} else {
it
}
}

val erSelvbestemt = inntektsmelding.type is Inntektsmelding.Type.Selvbestemt

val journalfoertInntektsmelding =
JournalfoertInntektsmelding(
journalpostId = journalpostId,
inntektsmeldingV1 = inntektsmelding,
bestemmendeFravaersdag = bestemmendeFravaersdag,
inntektsmelding = inntektsmeldingGammeltFormat,
selvbestemt = erSelvbestemt,
)

val record =
Expand All @@ -144,13 +127,11 @@ class DistribusjonRiver(
}
}

// Midlertidig klasse som inneholder både gammelt og nytt format
// Midlertidig klasse som inneholder bestemmende fraværsdag
@Serializable
data class JournalfoertInntektsmelding(
val journalpostId: String,
val inntektsmeldingV1: Inntektsmelding,
@Serializable(LocalDateSerializer::class)
val bestemmendeFravaersdag: LocalDate?,
val inntektsmelding: InntektsmeldingGammel,
val selvbestemt: Boolean, // for å skille på selvbestemt og vanlig i spinosaurus, før V1 tas i bruk overalt
)
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ import io.mockk.mockk
import io.mockk.verify
import io.mockk.verifySequence
import kotlinx.serialization.json.JsonElement
import no.nav.helsearbeidsgiver.domene.inntektsmelding.Utils.convert
import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.Inntektsmelding
import no.nav.helsearbeidsgiver.felles.BehovType
import no.nav.helsearbeidsgiver.felles.EventName
Expand Down Expand Up @@ -72,8 +71,6 @@ class DistribusjonRiverTest :
journalpostId = innkommendeMelding.journalpostId,
inntektsmeldingV1 = innkommendeMelding.inntektsmelding,
bestemmendeFravaersdag = innkommendeMelding.bestemmendeFravaersdag,
inntektsmelding = innkommendeMelding.inntektsmelding.convert().copy(bestemmendeFraværsdag = Mock.bestemmendeFravaersdag),
selvbestemt = false,
).toJsonStr(JournalfoertInntektsmelding.serializer()),
)

Expand Down Expand Up @@ -119,8 +116,6 @@ class DistribusjonRiverTest :
journalpostId = innkommendeMelding.journalpostId,
inntektsmeldingV1 = selvbestemtInntektsmelding,
bestemmendeFravaersdag = null,
inntektsmelding = selvbestemtInntektsmelding.convert(),
selvbestemt = true,
).toJsonStr(JournalfoertInntektsmelding.serializer()),
)

Expand All @@ -138,7 +133,7 @@ class DistribusjonRiverTest :

val forventetFail =
Fail(
feilmelding = "Klarte ikke distribuere IM med journalpost-ID: '${innkommendeMelding.journalpostId}'.",
feilmelding = "Klarte ikke distribuere IM med journalpost-ID '${innkommendeMelding.journalpostId}'.",
kontekstId = innkommendeMelding.transaksjonId,
utloesendeMelding = innkommendeJsonMap,
)
Expand Down Expand Up @@ -180,16 +175,14 @@ class DistribusjonRiverTest :
})

private object Mock {
val bestemmendeFravaersdag = 20.oktober

val fail = mockFail("I'm afraid I can't let you do that.", EventName.INNTEKTSMELDING_JOURNALPOST_ID_LAGRET)

fun innkommendeMelding(): Melding =
Melding(
eventName = EventName.INNTEKTSMELDING_JOURNALPOST_ID_LAGRET,
transaksjonId = UUID.randomUUID(),
inntektsmelding = mockInntektsmeldingV1(),
bestemmendeFravaersdag = bestemmendeFravaersdag,
bestemmendeFravaersdag = 20.oktober,
journalpostId = randomDigitString(13),
)

Expand Down

0 comments on commit f6d4791

Please sign in to comment.