Skip to content

Commit 1288cd3

Browse files
chrissearlechrissearle
authored
ktlint 1.3.0 (#276)
1 parent b589ab6 commit 1288cd3

21 files changed

+435
-338
lines changed

‎apps/etterlatte-notifikasjoner/src/main/kotlin/Application.kt

+9-7
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,15 @@ package no.nav.etterlatte
22

33
import no.nav.helse.rapids_rivers.RapidApplication
44

5-
65
fun main() {
7-
val env = System.getenv().toMutableMap().apply {
8-
put("KAFKA_CONSUMER_GROUP_ID", get("NAIS_APP_NAME")!!.replace("-", ""))
9-
}
6+
val env =
7+
System.getenv().toMutableMap().apply {
8+
put("KAFKA_CONSUMER_GROUP_ID", get("NAIS_APP_NAME")!!.replace("-", ""))
9+
}
1010
val sendNotifikasjonApp = SendNotifikasjon(env)
11-
RapidApplication.create(env).also {
12-
Notifikasjon(sendNotifikasjonApp,it)
13-
}.start()
11+
RapidApplication
12+
.create(env)
13+
.also {
14+
Notifikasjon(sendNotifikasjonApp, it)
15+
}.start()
1416
}

‎apps/etterlatte-notifikasjoner/src/main/kotlin/JsonUtils.kt

+6-5
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,9 @@ import com.fasterxml.jackson.databind.SerializationFeature
66
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule
77
import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
88

9-
val mapper: ObjectMapper = jacksonObjectMapper()
10-
.enable(DeserializationFeature.READ_UNKNOWN_ENUM_VALUES_AS_NULL)
11-
.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES)
12-
.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS)
13-
.registerModule(JavaTimeModule())
9+
val mapper: ObjectMapper =
10+
jacksonObjectMapper()
11+
.enable(DeserializationFeature.READ_UNKNOWN_ENUM_VALUES_AS_NULL)
12+
.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES)
13+
.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS)
14+
.registerModule(JavaTimeModule())

‎apps/etterlatte-notifikasjoner/src/main/kotlin/Notifikasjon.kt

+31-28
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package no.nav.etterlatte
22

3-
import com.fasterxml.jackson.databind.JsonNode
43
import com.fasterxml.jackson.module.kotlin.readValue
54
import kotlinx.coroutines.runBlocking
65
import no.nav.helse.rapids_rivers.JsonMessage
@@ -10,47 +9,51 @@ import no.nav.helse.rapids_rivers.River
109
import org.slf4j.Logger
1110
import org.slf4j.LoggerFactory
1211

13-
14-
class Notifikasjon(private val sendNotifikasjon: SendNotifikasjon, rapidsConnection: RapidsConnection) :
15-
River.PacketListener {
16-
12+
class Notifikasjon(
13+
private val sendNotifikasjon: SendNotifikasjon,
14+
rapidsConnection: RapidsConnection
15+
) : River.PacketListener {
1716
private val logger: Logger = LoggerFactory.getLogger(Notifikasjon::class.java)
1817

1918
private val rapid = rapidsConnection
2019

2120
init {
22-
River(rapidsConnection).apply {
23-
validate { it.demandValue("@event_name", "soeknad_innsendt") }
24-
validate { it.requireKey("@dokarkivRetur") }
25-
validate { it.requireKey("@fnr_soeker") }
26-
validate { it.requireKey("@skjema_info") }
27-
validate { it.requireKey("@lagret_soeknad_id") }
28-
}.register(this)
21+
River(rapidsConnection)
22+
.apply {
23+
validate { it.demandValue("@event_name", "soeknad_innsendt") }
24+
validate { it.requireKey("@dokarkivRetur") }
25+
validate { it.requireKey("@fnr_soeker") }
26+
validate { it.requireKey("@skjema_info") }
27+
validate { it.requireKey("@lagret_soeknad_id") }
28+
}.register(this)
2929
}
3030

31-
override fun onPacket(packet: JsonMessage, context: MessageContext) {
31+
override fun onPacket(
32+
packet: JsonMessage,
33+
context: MessageContext
34+
) {
3235
runBlocking {
3336
val soeknad = mapper.readValue<Soeknad>(packet["@skjema_info"].toString())
3437

3538
sendNotifikasjon.sendMessage(soeknad)
3639

3740
val journalpostId = packet["@dokarkivRetur"]["journalpostId"]
38-
JsonMessage.newMessage(
39-
mapOf(
40-
"@event_name" to "notifikasjon_sendt",
41-
"@lagret_soeknad_id" to packet["@lagret_soeknad_id"],
42-
"@journalpostId" to journalpostId,
43-
"@notifikasjon" to "Notifikasjon sendt",
44-
)
45-
).apply {
46-
try {
47-
rapid.publish("SendNotifikasjon " + journalpostId.textValue(), toJson())
48-
} catch (err: Exception) {
49-
logger.error("Uhaandtert feilsituasjon. Ingen notifikasjon opprettet: ", err)
41+
JsonMessage
42+
.newMessage(
43+
mapOf(
44+
"@event_name" to "notifikasjon_sendt",
45+
"@lagret_soeknad_id" to packet["@lagret_soeknad_id"],
46+
"@journalpostId" to journalpostId,
47+
"@notifikasjon" to "Notifikasjon sendt"
48+
)
49+
).apply {
50+
try {
51+
rapid.publish("SendNotifikasjon " + journalpostId.textValue(), toJson())
52+
} catch (err: Exception) {
53+
logger.error("Uhaandtert feilsituasjon. Ingen notifikasjon opprettet: ", err)
54+
}
5055
}
51-
52-
}
5356
logger.info("Notifikasjon til bruker opprettet")
5457
}
5558
}
56-
}
59+
}

‎apps/etterlatte-notifikasjoner/src/main/kotlin/SendNotifikasjon.kt

+19-15
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package no.nav.etterlatte
22

3-
import com.fasterxml.jackson.databind.JsonNode
43
import no.nav.brukernotifikasjon.schemas.builders.BeskjedInputBuilder
54
import no.nav.brukernotifikasjon.schemas.builders.NokkelInputBuilder
65
import no.nav.brukernotifikasjon.schemas.input.BeskjedInput
@@ -37,11 +36,12 @@ class SendNotifikasjon(
3736
internal fun opprettBeskjed(type: Soeknad.Type): BeskjedInput {
3837
val now = LocalDateTime.now(ZoneOffset.UTC)
3938
val weekFromNow = now.plusDays(7)
40-
val tekst = when (type) {
41-
Soeknad.Type.GJENLEVENDEPENSJON -> "Vi har mottatt søknaden din om gjenlevendepensjon"
42-
Soeknad.Type.BARNEPENSJON -> "Vi har mottatt søknaden din om barnepensjon"
43-
Soeknad.Type.OMSTILLINGSSTOENAD -> "Vi har mottatt søknaden din om omstillingsstønad"
44-
}
39+
val tekst =
40+
when (type) {
41+
Soeknad.Type.GJENLEVENDEPENSJON -> "Vi har mottatt søknaden din om gjenlevendepensjon"
42+
Soeknad.Type.BARNEPENSJON -> "Vi har mottatt søknaden din om barnepensjon"
43+
Soeknad.Type.OMSTILLINGSSTOENAD -> "Vi har mottatt søknaden din om omstillingsstønad"
44+
}
4545

4646
return BeskjedInputBuilder()
4747
.withTidspunkt(LocalDateTime.now(ZoneOffset.UTC))
@@ -52,20 +52,24 @@ class SendNotifikasjon(
5252
.build()
5353
}
5454

55-
private fun opprettNokkel(ident: String) = NokkelInputBuilder()
56-
.withEventId(UUID.randomUUID().toString())
57-
.withGrupperingsId(grupperingsId)
58-
.withNamespace(namespace)
59-
.withAppnavn(appname)
60-
.withFodselsnummer(ident)
61-
.build()
55+
private fun opprettNokkel(ident: String) =
56+
NokkelInputBuilder()
57+
.withEventId(UUID.randomUUID().toString())
58+
.withGrupperingsId(grupperingsId)
59+
.withNamespace(namespace)
60+
.withAppnavn(appname)
61+
.withFodselsnummer(ident)
62+
.build()
6263

63-
private fun send(nokkel: NokkelInput, beskjed: BeskjedInput) = try {
64+
private fun send(
65+
nokkel: NokkelInput,
66+
beskjed: BeskjedInput
67+
) = try {
6468
producer.send(ProducerRecord(brukernotifikasjontopic, nokkel, beskjed)).get(10, TimeUnit.SECONDS)
6569
} catch (e: Exception) {
6670
logger.error(
6771
"Beskjed til $brukernotifikasjontopic (Ditt NAV) for søknad med id ${nokkel.grupperingsId} feilet.",
6872
e
6973
)
7074
}
71-
}
75+
}

‎apps/etterlatte-notifikasjoner/src/main/kotlin/Soeknad.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,4 +22,4 @@ data class Innsender(
2222
data class Foedselsnummer(
2323
@JsonProperty("svar")
2424
val value: String
25-
)
25+
)

‎apps/etterlatte-notifikasjoner/src/test/kotlin/NotifikasjonTest.kt

+74-73
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
import com.fasterxml.jackson.databind.JsonNode
21
import com.fasterxml.jackson.module.kotlin.readValue
32
import io.mockk.mockk
43
import no.nav.brukernotifikasjon.schemas.input.BeskjedInput
@@ -20,14 +19,16 @@ internal class NotifikasjonTest {
2019
private val mockKafkaProducer =
2120
MockProducer<NokkelInput, BeskjedInput>(true, mockk(relaxed = true), mockk(relaxed = true))
2221

23-
private val sendMelding = SendNotifikasjon(
24-
mapOf(
25-
"BRUKERNOTIFIKASJON_BESKJED_TOPIC" to "test_topic",
26-
"BRUKERNOTIFIKASJON_KAFKA_GROUP_ID" to "bah",
27-
"NAIS_NAMESPACE" to "etterlatte",
28-
"NAIS_NAME" to "etterlatte-notifikasjoner"
29-
), mockKafkaProducer
30-
)
22+
private val sendMelding =
23+
SendNotifikasjon(
24+
mapOf(
25+
"BRUKERNOTIFIKASJON_BESKJED_TOPIC" to "test_topic",
26+
"BRUKERNOTIFIKASJON_KAFKA_GROUP_ID" to "bah",
27+
"NAIS_NAMESPACE" to "etterlatte",
28+
"NAIS_NAME" to "etterlatte-notifikasjoner"
29+
),
30+
mockKafkaProducer
31+
)
3132

3233
@BeforeEach
3334
fun before() {
@@ -39,28 +40,28 @@ internal class NotifikasjonTest {
3940
val json = this::class.java.getResource("gjenlevendepensjon.json")!!.readText()
4041
val soeknad: Soeknad = mapper.readValue(json)
4142

42-
val inspector = TestRapid()
43-
.apply {
44-
Notifikasjon(
45-
sendMelding,
46-
this
47-
)
48-
}
49-
.apply {
50-
sendTestMessage(
51-
JsonMessage.newMessage(
52-
mapOf(
53-
"@event_name" to "soeknad_innsendt",
54-
"@dokarkivRetur" to "123456",
55-
"@fnr_soeker" to "07106123912",
56-
"@skjema_info" to mapper.readTree(json),
57-
"@lagret_soeknad_id" to "4",
58-
"@dokarkivRetur" to (mapOf("journalpostId" to "3"))
59-
)
43+
val inspector =
44+
TestRapid()
45+
.apply {
46+
Notifikasjon(
47+
sendMelding,
48+
this
49+
)
50+
}.apply {
51+
sendTestMessage(
52+
JsonMessage
53+
.newMessage(
54+
mapOf(
55+
"@event_name" to "soeknad_innsendt",
56+
"@dokarkivRetur" to "123456",
57+
"@fnr_soeker" to "07106123912",
58+
"@skjema_info" to mapper.readTree(json),
59+
"@lagret_soeknad_id" to "4",
60+
"@dokarkivRetur" to (mapOf("journalpostId" to "3"))
61+
)
62+
).toJson()
6063
)
61-
.toJson()
62-
)
63-
}.inspektør
64+
}.inspektør
6465

6566
assertEquals("notifikasjon_sendt", inspector.message(0).get("@event_name").asText())
6667
assertEquals("Notifikasjon sendt", inspector.message(0).get("@notifikasjon").asText())
@@ -83,28 +84,28 @@ internal class NotifikasjonTest {
8384
val json = this::class.java.getResource("barnepensjon.json")!!.readText()
8485
val soeknad: Soeknad = mapper.readValue(json)
8586

86-
val inspector = TestRapid()
87-
.apply {
88-
Notifikasjon(
89-
sendMelding,
90-
this
91-
)
92-
}
93-
.apply {
94-
sendTestMessage(
95-
JsonMessage.newMessage(
96-
mapOf(
97-
"@event_name" to "soeknad_innsendt",
98-
"@dokarkivRetur" to "123456",
99-
"@fnr_soeker" to "07106123912",
100-
"@skjema_info" to mapper.readTree(json),
101-
"@lagret_soeknad_id" to "4",
102-
"@dokarkivRetur" to (mapOf("journalpostId" to "5"))
103-
)
87+
val inspector =
88+
TestRapid()
89+
.apply {
90+
Notifikasjon(
91+
sendMelding,
92+
this
10493
)
105-
.toJson()
106-
)
107-
}.inspektør
94+
}.apply {
95+
sendTestMessage(
96+
JsonMessage
97+
.newMessage(
98+
mapOf(
99+
"@event_name" to "soeknad_innsendt",
100+
"@dokarkivRetur" to "123456",
101+
"@fnr_soeker" to "07106123912",
102+
"@skjema_info" to mapper.readTree(json),
103+
"@lagret_soeknad_id" to "4",
104+
"@dokarkivRetur" to (mapOf("journalpostId" to "5"))
105+
)
106+
).toJson()
107+
)
108+
}.inspektør
108109

109110
assertEquals("notifikasjon_sendt", inspector.message(0).get("@event_name").asText())
110111
assertEquals("Notifikasjon sendt", inspector.message(0).get("@notifikasjon").asText())
@@ -124,28 +125,28 @@ internal class NotifikasjonTest {
124125
val json = this::class.java.getResource("omstillingsstoenad.json")!!.readText()
125126
val soeknad: Soeknad = mapper.readValue(json)
126127

127-
val inspector = TestRapid()
128-
.apply {
129-
Notifikasjon(
130-
sendMelding,
131-
this
132-
)
133-
}
134-
.apply {
135-
sendTestMessage(
136-
JsonMessage.newMessage(
137-
mapOf(
138-
"@event_name" to "soeknad_innsendt",
139-
"@dokarkivRetur" to "123456",
140-
"@fnr_soeker" to "07106123912",
141-
"@skjema_info" to mapper.readTree(json),
142-
"@lagret_soeknad_id" to "4",
143-
"@dokarkivRetur" to (mapOf("journalpostId" to "5"))
144-
)
128+
val inspector =
129+
TestRapid()
130+
.apply {
131+
Notifikasjon(
132+
sendMelding,
133+
this
134+
)
135+
}.apply {
136+
sendTestMessage(
137+
JsonMessage
138+
.newMessage(
139+
mapOf(
140+
"@event_name" to "soeknad_innsendt",
141+
"@dokarkivRetur" to "123456",
142+
"@fnr_soeker" to "07106123912",
143+
"@skjema_info" to mapper.readTree(json),
144+
"@lagret_soeknad_id" to "4",
145+
"@dokarkivRetur" to (mapOf("journalpostId" to "5"))
146+
)
147+
).toJson()
145148
)
146-
.toJson()
147-
)
148-
}.inspektør
149+
}.inspektør
149150

150151
assertEquals("notifikasjon_sendt", inspector.message(0).get("@event_name").asText())
151152
assertEquals("Notifikasjon sendt", inspector.message(0).get("@notifikasjon").asText())
@@ -162,4 +163,4 @@ internal class NotifikasjonTest {
162163
mockKafkaProducer.history()[0].key().fodselsnummer
163164
)
164165
}
165-
}
166+
}

0 commit comments

Comments
 (0)