From 16045cab6f57ca9003ee1ec11ad40b373ba337ff Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Vetle=20Bu=20Solg=C3=A5rd?= Date: Wed, 8 Jan 2025 09:25:10 +0100 Subject: [PATCH] IS: Move aktivitetskrav folder into personstatus folder structure (#503) --- .../domain/Aktivitetskrav.kt | 15 -------------- .../kafka/AktivitetskravVurderingRecord.kt | 16 --------------- .../infrastructure/kafka/KafkaModule.kt | 2 +- .../AktivitetskravVurderingConsumer.kt | 20 ++++++++++++++++++- .../KafkaAktivitetskravVurderingTask.kt | 7 +++++-- .../AktivitetskravVurderingConsumerSpek.kt | 5 ++++- .../KafkaAktivitetskravVurderingGenerator.kt | 6 +++--- 7 files changed, 32 insertions(+), 39 deletions(-) delete mode 100644 src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/domain/Aktivitetskrav.kt delete mode 100644 src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingRecord.kt rename src/main/kotlin/no/nav/syfo/{aktivitetskravvurdering/kafka => personstatus/infrastructure/kafka/aktivitetskrav}/AktivitetskravVurderingConsumer.kt (77%) rename src/main/kotlin/no/nav/syfo/{aktivitetskravvurdering/kafka => personstatus/infrastructure/kafka/aktivitetskrav}/KafkaAktivitetskravVurderingTask.kt (91%) diff --git a/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/domain/Aktivitetskrav.kt b/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/domain/Aktivitetskrav.kt deleted file mode 100644 index 8941121e..00000000 --- a/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/domain/Aktivitetskrav.kt +++ /dev/null @@ -1,15 +0,0 @@ -package no.nav.syfo.aktivitetskravvurdering.domain - -enum class AktivitetskravStatus { - NY, - NY_VURDERING, - AVVENT, - UNNTAK, - OPPFYLT, - FORHANDSVARSEL, - AUTOMATISK_OPPFYLT, - STANS, - IKKE_OPPFYLT, - IKKE_AKTUELL, - LUKKET, -} diff --git a/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingRecord.kt b/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingRecord.kt deleted file mode 100644 index 79e41c2b..00000000 --- a/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingRecord.kt +++ /dev/null @@ -1,16 +0,0 @@ -package no.nav.syfo.aktivitetskravvurdering.kafka - -import java.time.LocalDate -import java.time.OffsetDateTime - -data class AktivitetskravVurderingRecord( - val uuid: String, - val personIdent: String, - val createdAt: OffsetDateTime, - val status: String, - val isFinal: Boolean, - val stoppunktAt: LocalDate, - val beskrivelse: String?, - val sistVurdert: OffsetDateTime?, - val frist: LocalDate?, -) diff --git a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt index 42bb1153..c87633ed 100644 --- a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt +++ b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt @@ -1,6 +1,6 @@ package no.nav.syfo.personstatus.infrastructure.kafka -import no.nav.syfo.aktivitetskravvurdering.kafka.launchKafkaTaskAktivitetskravVurdering +import no.nav.syfo.personstatus.infrastructure.kafka.aktivitetskrav.launchKafkaTaskAktivitetskravVurdering import no.nav.syfo.ApplicationState import no.nav.syfo.Environment import no.nav.syfo.personstatus.infrastructure.clients.azuread.AzureAdClient diff --git a/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingConsumer.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/aktivitetskrav/AktivitetskravVurderingConsumer.kt similarity index 77% rename from src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingConsumer.kt rename to src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/aktivitetskrav/AktivitetskravVurderingConsumer.kt index 29f1f581..2704cb47 100644 --- a/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingConsumer.kt +++ b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/aktivitetskrav/AktivitetskravVurderingConsumer.kt @@ -1,4 +1,4 @@ -package no.nav.syfo.aktivitetskravvurdering.kafka +package no.nav.syfo.personstatus.infrastructure.kafka.aktivitetskrav import no.nav.syfo.personstatus.application.PersonoversiktStatusService import no.nav.syfo.personstatus.domain.PersonIdent @@ -7,6 +7,12 @@ import org.apache.kafka.clients.consumer.ConsumerRecords import org.apache.kafka.clients.consumer.KafkaConsumer import org.slf4j.LoggerFactory import java.time.Duration +import java.time.LocalDate +import java.time.OffsetDateTime +import kotlin.collections.forEach +import kotlin.collections.isNotEmpty +import kotlin.collections.partition +import kotlin.jvm.java class AktivitetskravVurderingConsumer( private val personoversiktStatusService: PersonoversiktStatusService, @@ -42,3 +48,15 @@ class AktivitetskravVurderingConsumer( private val log = LoggerFactory.getLogger(AktivitetskravVurderingRecord::class.java) } } + +data class AktivitetskravVurderingRecord( + val uuid: String, + val personIdent: String, + val createdAt: OffsetDateTime, + val status: String, + val isFinal: Boolean, + val stoppunktAt: LocalDate, + val beskrivelse: String?, + val sistVurdert: OffsetDateTime?, + val frist: LocalDate?, +) diff --git a/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/KafkaAktivitetskravVurderingTask.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/aktivitetskrav/KafkaAktivitetskravVurderingTask.kt similarity index 91% rename from src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/KafkaAktivitetskravVurderingTask.kt rename to src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/aktivitetskrav/KafkaAktivitetskravVurderingTask.kt index 0f8faaba..624a1949 100644 --- a/src/main/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/KafkaAktivitetskravVurderingTask.kt +++ b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/aktivitetskrav/KafkaAktivitetskravVurderingTask.kt @@ -1,4 +1,4 @@ -package no.nav.syfo.aktivitetskravvurdering.kafka +package no.nav.syfo.personstatus.infrastructure.kafka.aktivitetskrav import no.nav.syfo.ApplicationState import no.nav.syfo.personstatus.application.PersonoversiktStatusService @@ -8,7 +8,10 @@ import no.nav.syfo.personstatus.infrastructure.kafka.launchKafkaTask import no.nav.syfo.util.configuredJacksonMapper import org.apache.kafka.clients.consumer.ConsumerConfig import org.apache.kafka.common.serialization.Deserializer -import java.util.* +import java.util.Properties +import kotlin.apply +import kotlin.collections.set +import kotlin.jvm.java const val AKTIVITETSKRAV_VURDERING_TOPIC = "teamsykefravr.aktivitetskrav-vurdering" diff --git a/src/test/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingConsumerSpek.kt b/src/test/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingConsumerSpek.kt index 37d027d8..e6a35327 100644 --- a/src/test/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingConsumerSpek.kt +++ b/src/test/kotlin/no/nav/syfo/aktivitetskravvurdering/kafka/AktivitetskravVurderingConsumerSpek.kt @@ -2,10 +2,13 @@ package no.nav.syfo.aktivitetskravvurdering.kafka import io.mockk.* import kotlinx.coroutines.runBlocking -import no.nav.syfo.aktivitetskravvurdering.domain.AktivitetskravStatus +import no.nav.syfo.personstatus.application.aktivitetskrav.AktivitetskravStatus import no.nav.syfo.personstatus.domain.PersonOversiktStatus import no.nav.syfo.personstatus.infrastructure.database.queries.getPersonOversiktStatusList import no.nav.syfo.personstatus.infrastructure.database.queries.createPersonOversiktStatus +import no.nav.syfo.personstatus.infrastructure.kafka.aktivitetskrav.AKTIVITETSKRAV_VURDERING_TOPIC +import no.nav.syfo.personstatus.infrastructure.kafka.aktivitetskrav.AktivitetskravVurderingConsumer +import no.nav.syfo.personstatus.infrastructure.kafka.aktivitetskrav.AktivitetskravVurderingRecord import no.nav.syfo.personstatus.infrastructure.kafka.mockPollConsumerRecords import no.nav.syfo.testutil.* import no.nav.syfo.testutil.generator.* diff --git a/src/test/kotlin/no/nav/syfo/testutil/generator/KafkaAktivitetskravVurderingGenerator.kt b/src/test/kotlin/no/nav/syfo/testutil/generator/KafkaAktivitetskravVurderingGenerator.kt index a4cf9da2..f147f09f 100644 --- a/src/test/kotlin/no/nav/syfo/testutil/generator/KafkaAktivitetskravVurderingGenerator.kt +++ b/src/test/kotlin/no/nav/syfo/testutil/generator/KafkaAktivitetskravVurderingGenerator.kt @@ -1,8 +1,8 @@ package no.nav.syfo.testutil.generator -import no.nav.syfo.aktivitetskravvurdering.domain.AktivitetskravStatus -import no.nav.syfo.aktivitetskravvurdering.kafka.AKTIVITETSKRAV_VURDERING_TOPIC -import no.nav.syfo.aktivitetskravvurdering.kafka.AktivitetskravVurderingRecord +import no.nav.syfo.personstatus.application.aktivitetskrav.AktivitetskravStatus +import no.nav.syfo.personstatus.infrastructure.kafka.aktivitetskrav.AKTIVITETSKRAV_VURDERING_TOPIC +import no.nav.syfo.personstatus.infrastructure.kafka.aktivitetskrav.AktivitetskravVurderingRecord import no.nav.syfo.testutil.UserConstants import org.apache.kafka.clients.consumer.ConsumerRecord import org.apache.kafka.common.TopicPartition