Skip to content

Commit

Permalink
Bruk ktlint 1.2.1 (#606)
Browse files Browse the repository at this point in the history
* Bruk ktlint 1.2.1

* Slett duplisert fil

* Formater byggfil
  • Loading branch information
bjerga authored Dec 12, 2024
1 parent 62cdd49 commit d5ea63a
Show file tree
Hide file tree
Showing 116 changed files with 2,402 additions and 1,575 deletions.
2 changes: 1 addition & 1 deletion .editorconfig
Original file line number Diff line number Diff line change
Expand Up @@ -16,4 +16,4 @@ indent_size = 4
trim_trailing_whitespace=true
insert_final_newline = true
max_line_length = 160
disabled_rules=max-line-length
ktlint_standard_max-line-length = disabled
6 changes: 2 additions & 4 deletions .github/workflows/ktlint.yml
Original file line number Diff line number Diff line change
Expand Up @@ -4,18 +4,16 @@ on:
pull_request:
branches-ignore:
- dependabot/*
- snyk-*


jobs:
Ktlint:
runs-on: ubuntu-latest
steps:
- name: Check out repository code
uses: actions/checkout@v2
uses: actions/checkout@v4
- name: "Install ktlint"
uses: nbadal/action-ktlint-setup@v1
with:
ktlint_version: '0.42.1'
ktlint_version: '1.2.1'
- run: ktlint
shell: bash
11 changes: 7 additions & 4 deletions build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,7 @@ val bakgrunnsjobbVersion: String by project
val pdlClientVersion: String by project
val tokenProviderVersion: String by project
val oppgaveClientVersion: String by project

plugins {
kotlin("jvm")
kotlin("plugin.serialization")
Expand Down Expand Up @@ -103,15 +104,17 @@ tasks.jar {
archiveBaseName.set("app")
manifest {
attributes["Main-Class"] = mainClass
attributes["Class-Path"] = configurations.runtimeClasspath.get().joinToString(separator = " ") {
it.name
}
attributes["Class-Path"] =
configurations.runtimeClasspath.get().joinToString(separator = " ") {
it.name
}
}
doLast {
configurations.runtimeClasspath.get().forEach {
val file = layout.buildDirectory.file("libs/${it.name}").get().asFile
if (!file.exists())
if (!file.exists()) {
it.copyTo(file)
}
}
}
}
Expand Down
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ kotlin.code.style=official

# Plugin versions
kotlinVersion=1.9.21
kotlinterVersion=3.8.0
kotlinterVersion=4.3.0
versionsVersion=0.50.0

# Dependency versions
Expand Down
32 changes: 16 additions & 16 deletions src/main/kotlin/no/nav/syfo/App.kt
Original file line number Diff line number Diff line change
Expand Up @@ -91,20 +91,21 @@ class SpinnApplication(val port: Int = 8080) : KoinComponent {
}

private fun configAndStartWebserver() {
webserver = embeddedServer(
Netty,
applicationEngineEnvironment {
config = appConfig
connector {
port = this@SpinnApplication.port
}

module {
nais()
inntektsmeldingModule(config)
}
}
)
webserver =
embeddedServer(
Netty,
applicationEngineEnvironment {
config = appConfig
connector {
port = this@SpinnApplication.port
}

module {
nais()
inntektsmeldingModule(config)
}
},
)

webserver!!.start(wait = false)
}
Expand All @@ -114,7 +115,6 @@ class SpinnApplication(val port: Int = 8080) : KoinComponent {
get<FinnAlleUtgaandeOppgaverProcessor>().startAsync(true)

get<BakgrunnsjobbService>().apply {

registrer(get<FeiletUtsattOppgaveMeldingProsessor>())
registrer(get<FjernInntektsmeldingByBehandletProcessor>())
registrer(get<JoarkInntektsmeldingHendelseProsessor>())
Expand Down Expand Up @@ -153,6 +153,6 @@ fun main() {
logger.info("Fikk shutdown-signal, avslutter...")
application.shutdown()
logger.info("Avsluttet OK")
}
},
)
}
11 changes: 6 additions & 5 deletions src/main/kotlin/no/nav/syfo/Metrikker.kt
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,9 @@ class MetrikkVarsler : Bakgrunnsvarsler {
}
}

val FEILET_JOBB_COUNTER = Counter.build()
.namespace(METRICS_NS)
.name("feilet_jobb")
.help("Counts the number of permanently failed jobs")
.register()
val FEILET_JOBB_COUNTER =
Counter.build()
.namespace(METRICS_NS)
.name("feilet_jobb")
.help("Counts the number of permanently failed jobs")
.register()
8 changes: 4 additions & 4 deletions src/main/kotlin/no/nav/syfo/behandling/BehandlingException.kt
Original file line number Diff line number Diff line change
Expand Up @@ -19,10 +19,10 @@ open class HentOppgaveException(
oppgaveType: String,
cause: Exception?,
) : OppgaveException(
Feiltype.OPPGAVE_HENT,
"Feil ved oppslag til oppgave for journalpostId $journalpostId med oppgavetype $oppgaveType!",
cause,
)
Feiltype.OPPGAVE_HENT,
"Feil ved oppslag til oppgave for journalpostId $journalpostId med oppgavetype $oppgaveType!",
cause,
)

open class OpprettOppgaveException(
journalpostId: String,
Expand Down
35 changes: 21 additions & 14 deletions src/main/kotlin/no/nav/syfo/behandling/InntektsmeldingBehandler.kt
Original file line number Diff line number Diff line change
Expand Up @@ -29,19 +29,25 @@ class InntektsmeldingBehandler(
private val inntektsmeldingService: InntektsmeldingService,
private val inntektsmeldingAivenProducer: InntektsmeldingAivenProducer,
private val utsattOppgaveService: UtsattOppgaveService,
private val pdlClient: PdlClient
private val pdlClient: PdlClient,
) {
private val logger: Logger = this.logger()
private val sikkerlogger = LoggerFactory.getLogger("tjenestekall")
private val consumerLocks = Striped.lock(8)

fun behandle(arkivId: String, arkivreferanse: String): String? {
fun behandle(
arkivId: String,
arkivreferanse: String,
): String? {
logger.info("Henter inntektsmelding for $arkivreferanse")
val inntektsmelding = journalpostService.hentInntektsmelding(arkivId, arkivreferanse)
return behandleInntektsmelding(arkivreferanse, inntektsmelding)
}

private fun behandleInntektsmelding(arkivreferanse: String, inntektsmelding: Inntektsmelding): String? {
private fun behandleInntektsmelding(
arkivreferanse: String,
inntektsmelding: Inntektsmelding,
): String? {
var ret: String? = null
val consumerLock = consumerLocks.get(inntektsmelding.fnr)
try {
Expand Down Expand Up @@ -85,33 +91,34 @@ class InntektsmeldingBehandler(
gosysOppgaveId = null,
oppdatert = null,
speil = false,
utbetalingBruker = false
)
utbetalingBruker = false,
),
)
logger.info("Lagrer UtsattOppgave i databasen for ${inntektsmelding.arkivRefereranse}")

val mappedInntektsmelding = mapInntektsmeldingKontrakt(
inntektsmelding,
aktorid,
validerInntektsmelding(inntektsmelding),
arkivreferanse,
dto.uuid
)
val mappedInntektsmelding =
mapInntektsmeldingKontrakt(
inntektsmelding,
aktorid,
validerInntektsmelding(inntektsmelding),
arkivreferanse,
dto.uuid,
)

inntektsmeldingAivenProducer.leggMottattInntektsmeldingPåTopics(mappedInntektsmelding)
tellMetrikker(inntektsmelding)
logger.info(
"Inntektsmelding {} er journalført for {} refusjon {}",
inntektsmelding.journalpostId,
arkivreferanse,
inntektsmelding.refusjon.beloepPrMnd
inntektsmelding.refusjon.beloepPrMnd,
)
ret = dto.uuid
} else {
logger.info(
"Behandler ikke inntektsmelding {} da den har status: {}",
inntektsmelding.journalpostId,
inntektsmelding.journalStatus
inntektsmelding.journalStatus,
)
}
}
Expand Down
18 changes: 13 additions & 5 deletions src/main/kotlin/no/nav/syfo/client/dokarkiv/DokArkivClient.kt
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ val AUTOMATISK_JOURNALFOERING_ENHET = "9999"
class DokArkivClient(
private val url: String,
private val httpClient: HttpClient,
private val getAccessToken: () -> String
private val getAccessToken: () -> String,
) {
private val logger = this.logger()
private val sikkerlogger = sikkerLogger()
Expand All @@ -47,7 +47,7 @@ class DokArkivClient(
suspend fun ferdigstillJournalpost(
journalpostId: String,
ferdigstillRequest: FerdigstillRequest,
msgId: String
msgId: String,
): String {
try {
val httpResponse =
Expand Down Expand Up @@ -93,7 +93,7 @@ class DokArkivClient(
suspend fun oppdaterJournalpost(
journalpostId: String,
oppdaterJournalpostRequest: OppdaterJournalpostRequest,
msgId: String
msgId: String,
) = retry("oppdater_journalpost") {
try {
httpClient
Expand All @@ -113,7 +113,12 @@ class DokArkivClient(
}

else -> {
sikkerlogger.error("Fikk http status {} ved oppdatering av journalpostid {}, msgId {}", e.response.status, journalpostId, msgId)
sikkerlogger.error(
"Fikk http status {} ved oppdatering av journalpostid {}, msgId {}",
e.response.status,
journalpostId,
msgId,
)
throw RuntimeException("Fikk feilmelding ved oppdatering av journalpostid $journalpostId msgid $msgId")
}
}
Expand All @@ -123,7 +128,10 @@ class DokArkivClient(
}
}

suspend fun feilregistrerJournalpost(journalpostId: String, msgId: String) {
suspend fun feilregistrerJournalpost(
journalpostId: String,
msgId: String,
) {
try {
httpClient
.patch("$url/journalpost/$journalpostId/feilregistrer/feilregistrerSakstilknytning") {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,15 +2,16 @@ package no.nav.syfo.client.dokarkiv

fun mapFeilregistrertRequest(
fnr: String,
dokumentId: String
dokumentId: String,
): OppdaterJournalpostRequest {
return OppdaterJournalpostRequest(
bruker = Bruker(
fnr,
"FNR"
),
bruker =
Bruker(
fnr,
"FNR",
),
sak = Sak("GENERELL_SAK"),
tema = "SYK",
dokumenter = listOf(Dokument(dokumentId, "Inntektsmelding duplikat"))
dokumenter = listOf(Dokument(dokumentId, "Inntektsmelding duplikat")),
)
}
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
package no.nav.syfo.client.dokarkiv

data class FerdigstillRequest(
val journalfoerendeEnhet: String
val journalfoerendeEnhet: String,
)
24 changes: 12 additions & 12 deletions src/main/kotlin/no/nav/syfo/client/dokarkiv/OppdaterRequest.kt
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
package no.nav.syfo.client.dokarkiv

/**
* val journalpostId = inngaendeJournalpost.journalpostId
* val avsenderNr = inngaendeJournalpost.arbeidsgiverOrgnummer
Expand All @@ -16,38 +17,37 @@ data class OppdaterJournalpostRequest(
val sak: Sak? = null,
val tema: String? = null,
val tittel: String? = null,
val dokumenter: List<Dokument>? = null
val dokumenter: List<Dokument>? = null,
)

data class Dokument(
val dokumentInfoId: String,
val tittel: String? = null
val tittel: String? = null,
)

data class Bruker(
val id: String,
val idType: String
val idType: String,
)

data class AvsenderMottaker(
val id: String,
val idType: String,
val navn: String
val navn: String,
)

data class Sak(
val sakstype: String,
val arkivsaksystem: String? = null
val arkivsaksystem: String? = null,
)

fun mapOppdaterRequest(
fnr: String,
): OppdaterJournalpostRequest {
fun mapOppdaterRequest(fnr: String): OppdaterJournalpostRequest {
return OppdaterJournalpostRequest(
bruker = Bruker(
fnr,
"FNR"
),
bruker =
Bruker(
fnr,
"FNR",
),
sak = Sak("GENERELL_SAK"),
tema = "SYK",
)
Expand Down
Loading

0 comments on commit d5ea63a

Please sign in to comment.