Skip to content

Commit

Permalink
Ktlint format (#424)
Browse files Browse the repository at this point in the history
  • Loading branch information
ugur93 authored Oct 16, 2023
1 parent 204232f commit b98de48
Show file tree
Hide file tree
Showing 26 changed files with 359 additions and 353 deletions.
6 changes: 0 additions & 6 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
<bidrag-commons.version>20231013111728_2a4d649</bidrag-commons.version>
<bidrag-commons-test.version>1.20230503150725_3c2c77b</bidrag-commons-test.version>
<bidrag-transport.version>20231010134706_52d8d27</bidrag-transport.version>
<bidrag-dokument-dto.version>1.6.41</bidrag-dokument-dto.version>
<commons-codec.version>1.15</commons-codec.version>
<graphq-dgs-client.version>6.0.5</graphq-dgs-client.version>
<joark-hendelse.version>67a9be4476b63b7247cfacfaf821ab656bd2a952</joark-hendelse.version>
Expand Down Expand Up @@ -134,11 +133,6 @@
<groupId>io.micrometer</groupId>
<artifactId>micrometer-registry-prometheus</artifactId>
</dependency>
<dependency>
<groupId>no.nav.bidrag.dokument</groupId>
<artifactId>bidrag-dokument-dto</artifactId>
<version>${bidrag-dokument-dto.version}</version>
</dependency>

<dependency>
<groupId>no.nav.bidrag</groupId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import io.swagger.v3.oas.annotations.enums.SecuritySchemeType
import io.swagger.v3.oas.annotations.info.Info
import io.swagger.v3.oas.annotations.security.SecurityRequirement
import io.swagger.v3.oas.annotations.security.SecurityScheme
import no.nav.bidrag.commons.ExceptionLogger
import no.nav.bidrag.commons.security.api.EnableSecurityConfiguration
import no.nav.bidrag.commons.security.service.SecurityTokenService
import no.nav.bidrag.commons.security.service.StsTokenService
Expand All @@ -15,7 +14,6 @@ import no.nav.bidrag.commons.web.DefaultCorsFilter
import no.nav.bidrag.commons.web.HttpHeaderRestTemplate
import no.nav.bidrag.commons.web.MdcFilter
import no.nav.bidrag.commons.web.UserMdcFilter
import no.nav.bidrag.dokument.arkiv.aop.HttpStatusRestControllerAdvice
import no.nav.bidrag.dokument.arkiv.consumer.BidragOrganisasjonConsumer
import no.nav.bidrag.dokument.arkiv.consumer.DokarkivConsumer
import no.nav.bidrag.dokument.arkiv.consumer.DokarkivKnyttTilSakConsumer
Expand Down Expand Up @@ -331,30 +329,32 @@ class BidragDokumentArkivConfig {
val bidragOrganisasjonUrl: String
) {
override fun toString(): String {
return ("dokarkivUrl='"
+ dokarkivUrl
+ '\''
+ ", safUrl='"
+ safUrl
+ '\''
+ ", bidragPersonUrl='"
+ bidragPersonUrl
+ '\''
+ ", dokarkivKnyttTilSakUrl='"
+ dokarkivKnyttTilSakUrl
+ '\''
+ ", securityTokenUrl='"
+ securityTokenUrl
+ '\''
+ ", bidragOrganisasjonUrl='"
+ bidragOrganisasjonUrl
+ '\''
+ ", naisAppName='"
+ naisAppName
+ '\''
+ ", secretForServiceUser '"
+ notActualValue()
+ "'.")
return (
"dokarkivUrl='" +
dokarkivUrl +
'\'' +
", safUrl='" +
safUrl +
'\'' +
", bidragPersonUrl='" +
bidragPersonUrl +
'\'' +
", dokarkivKnyttTilSakUrl='" +
dokarkivKnyttTilSakUrl +
'\'' +
", securityTokenUrl='" +
securityTokenUrl +
'\'' +
", bidragOrganisasjonUrl='" +
bidragOrganisasjonUrl +
'\'' +
", naisAppName='" +
naisAppName +
'\'' +
", secretForServiceUser '" +
notActualValue() +
"'."
)
}

private fun notActualValue(): String {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
package no.nav.bidrag.dokument.arkiv.aop

import com.fasterxml.jackson.databind.exc.MismatchedInputException
import com.fasterxml.jackson.module.kotlin.MissingKotlinParameterException
import no.nav.bidrag.commons.util.hentForespørselValideringsfeil
import no.nav.bidrag.dokument.arkiv.model.HttpStatusException
import no.nav.bidrag.dokument.arkiv.model.JournalIkkeFunnetException
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,24 +37,28 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
@GetMapping(ROOT_JOURNAL + "/{journalpostId}/avvik")
@Operation(
security = [SecurityRequirement(name = "bearer-key")],
summary = "Henter mulige avvik for en journalpost, id på formatet '"
+ KildesystemIdenfikator.PREFIX_JOARK
+ "<journalpostId>'"
summary = "Henter mulige avvik for en journalpost, id på formatet '" +
KildesystemIdenfikator.PREFIX_JOARK +
"<journalpostId>'"
)
@ApiResponses(
value = [ApiResponse(
responseCode = "200",
description = "Tilgjengelig avvik for journalpost er hentet"
), ApiResponse(
responseCode = "404",
description = "Fant ikke journalpost som det skal hentes avvik på",
)]
value = [
ApiResponse(
responseCode = "200",
description = "Tilgjengelig avvik for journalpost er hentet"
), ApiResponse(
responseCode = "404",
description = "Fant ikke journalpost som det skal hentes avvik på"
)
]
)
fun hentAvvik(
@PathVariable journalpostId: String?,
@Parameter(name = "saksnummer", description = "journalposten tilhører sak") @RequestParam(
@Parameter(name = "saksnummer", description = "journalposten tilhører sak")
@RequestParam(
required = false
) saksnummer: String?
)
saksnummer: String?
): ResponseEntity<List<AvvikType>> {
val muligSak = Optional.ofNullable(saksnummer)
if (muligSak.isPresent) {
Expand All @@ -71,13 +75,15 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
),
HttpStatus.BAD_REQUEST
)
} else ResponseEntity.ok(
avvikService.hentAvvik(
java.lang.Long.valueOf(
kildesystemIdenfikator.hentJournalpostId()!!.toLong()
} else {
ResponseEntity.ok(
avvikService.hentAvvik(
java.lang.Long.valueOf(
kildesystemIdenfikator.hentJournalpostId()!!.toLong()
)
)
)
)
}
}

@PostMapping(
Expand All @@ -86,17 +92,19 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
)
@Operation(
security = [SecurityRequirement(name = "bearer-key")],
summary = "Behandler et avvik for en journalpost, id på formatet '"
+ KildesystemIdenfikator.PREFIX_JOARK_COMPLETE
+ "<journalpostId>'"
summary = "Behandler et avvik for en journalpost, id på formatet '" +
KildesystemIdenfikator.PREFIX_JOARK_COMPLETE +
"<journalpostId>'"
)
@Transactional
@ApiResponses(
value = [ApiResponse(
responseCode = "200",
description = "Avvik på journalpost er behandlet"
), ApiResponse(
responseCode = "400", description = """En av følgende:
value = [
ApiResponse(
responseCode = "200",
description = "Avvik på journalpost er behandlet"
), ApiResponse(
responseCode = "400",
description = """En av følgende:
- prefiks på journalpostId er ugyldig
- avvikstypen mangler i avvikshendelsen
- enhetsnummer i header (X_ENHET) mangler
Expand All @@ -105,18 +113,21 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
- BESTILL_SPLITTING: beskrivelse må være i avvikshendelsen
- OVERFOR_TIL_ANNEN_ENHET: nyttEnhetsnummer og gammeltEnhetsnummer må være i detaljer map
"""
), ApiResponse(
responseCode = "503",
description = "Oppretting av oppgave for avviket feilet"
)]
), ApiResponse(
responseCode = "503",
description = "Oppretting av oppgave for avviket feilet"
)
]
)
fun behandleAvvik(
@PathVariable journalpostId: String?,
@RequestBody avvikshendelse: Avvikshendelse,
@RequestHeader(EnhetFilter.X_ENHET_HEADER) enhet: String?
): ResponseEntity<BehandleAvvikshendelseResponse> {
LOGGER.info(
"Behandle avvik {} for journalpost {}", avvikshendelse.avvikType, journalpostId
"Behandle avvik {} for journalpost {}",
avvikshendelse.avvikType,
journalpostId
)
BidragDokumentArkiv.SECURE_LOGGER.info(
"Behandle avvik {} for journalpost {}: {}",
Expand All @@ -135,17 +146,21 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
if (muligAvvikstype == null || enhet.isNullOrBlank()) {
val message = String.format(
"BAD REQUEST: avvikshendelse: %s, mulig avvik: %s, enhet: %s",
avvikshendelse, muligAvvikstype, enhet
avvikshendelse,
muligAvvikstype,
enhet
)
LOGGER.warn(message)
return ResponseEntity(
initHttpHeadersWith(HttpHeaders.WARNING, message), HttpStatus.BAD_REQUEST
initHttpHeadersWith(HttpHeaders.WARNING, message),
HttpStatus.BAD_REQUEST
)
}
val behandleAvvikResponse = avvikService.behandleAvvik(
AvvikshendelseIntern(
avvikshendelse,
enhet, kildesystemIdenfikator.hentJournalpostId()!!.toLong()
enhet,
kildesystemIdenfikator.hentJournalpostId()!!.toLong()
)
)
return ResponseEntity.ok(behandleAvvikResponse)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,8 @@ class JournalpostController(
return journalpostService.hentJournalpostMedFnrOgTilknyttedeSaker(
java.lang.Long.valueOf(
journalpostId.toLong()
), saksnummer
),
saksnummer
)
.map { journalpost: Journalpost -> ResponseEntity.ok(journalpost.tilJournalpostResponse()) }
.orElse(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,10 +26,12 @@ class OpprettJournalpostController(private val opprettJournalpostService: Oppret
description = "Opprett journalpost i Joark"
)
@ApiResponses(
value = [ApiResponse(
responseCode = "400",
description = "Opprett journalpost kalt med ugyldig data"
)]
value = [
ApiResponse(
responseCode = "400",
description = "Opprett journalpost kalt med ugyldig data"
)
]
)
fun opprettJournalpost(@RequestBody opprettJournalpostRequest: OpprettJournalpostRequest): ResponseEntity<OpprettJournalpostResponse> {
SECURE_LOGGER.info("Oppretter journalpost {}", opprettJournalpostRequest)
Expand Down
22 changes: 14 additions & 8 deletions src/main/java/no/nav/bidrag/dokument/arkiv/service/AvvikService.kt
Original file line number Diff line number Diff line change
Expand Up @@ -47,10 +47,8 @@ import org.slf4j.LoggerFactory
import org.springframework.stereotype.Service
import java.time.LocalDate
import java.util.Base64
import java.util.Optional
import java.util.function.Consumer
import java.util.stream.Stream
import kotlin.jvm.optionals.getOrNull

@Service
class AvvikService(
Expand Down Expand Up @@ -259,17 +257,25 @@ class AvvikService(
med tittel "$nyJournalpostTittel (Kopiert fra dokument: ${journalpost.hentTittel()})"
avvikshendelseIntern.dokumenter!!.forEach(
Consumer { (dokumentreferanse, _, _, tittel, dokument, brevkode): DokumentDto ->
val dokumentByte = if (Strings.isNotEmpty(dokument)) Base64.getDecoder()
.decode(dokument) else null
val dokumentByte = if (Strings.isNotEmpty(dokument)) {
Base64.getDecoder()
.decode(dokument)
} else {
null
}
+JoarkOpprettJournalpostRequest.Dokument(
dokumentInfoId = dokumentreferanse,
brevkode = brevkode,
tittel = tittel,
dokumentvarianter = if (dokumentByte != null) listOf(
opprettDokumentVariant(
dokumentByte = dokumentByte
dokumentvarianter = if (dokumentByte != null) {
listOf(
opprettDokumentVariant(
dokumentByte = dokumentByte
)
)
) else emptyList()
} else {
emptyList()
}
)
}
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ import no.nav.bidrag.dokument.arkiv.dto.validerAdresse
import no.nav.bidrag.dokument.arkiv.dto.validerKanDistribueres
import no.nav.bidrag.dokument.arkiv.dto.validerKanDistribueresUtenAdresse
import no.nav.bidrag.dokument.arkiv.dto.validerUtgaaendeJournalpostKanDupliseres
import no.nav.bidrag.dokument.arkiv.kafka.BehandleJournalforingHendelseService
import no.nav.bidrag.dokument.arkiv.mapper.tilVarselTypeDto
import no.nav.bidrag.dokument.arkiv.model.Discriminator
import no.nav.bidrag.dokument.arkiv.model.JournalpostIkkeFunnetException
Expand Down Expand Up @@ -83,7 +82,7 @@ class DistribuerJournalpostService(
request.forsendelseStoerrelse
)
SECURE_LOGGER.info("Hentet kanal ${kanal.distribusjonskanal} for forespørsel $request")
return kanal;
return kanal
}

fun hentDistribusjonKanal(journalpost: Journalpost): BestemKanalResponse {
Expand Down Expand Up @@ -208,11 +207,14 @@ class DistribuerJournalpostService(
val distribusjonKanal = hentDistribusjonKanal(journalpost)

val adresse =
if (distribusjonKanal.distribusjonskanal == DistribusjonsKanal.PRINT) hentOgValiderAdresse(
distribuerJournalpostRequest,
journalpost
) else null

if (distribusjonKanal.distribusjonskanal == DistribusjonsKanal.PRINT) {
hentOgValiderAdresse(
distribuerJournalpostRequest,
journalpost
)
} else {
null
}

// TODO: Lagre bestillingsid når bd-arkiv er koblet mot database
val distribuerResponse =
Expand Down Expand Up @@ -326,7 +328,6 @@ class DistribuerJournalpostService(
distribuerJournalpostRequestInternal: DistribuerJournalpostRequestInternal,
journalpost: Journalpost
): DistribuerTilAdresse? {

if (distribuerJournalpostRequestInternal.hasAdresse()) {
return distribuerJournalpostRequestInternal.getAdresse()
}
Expand Down Expand Up @@ -410,7 +411,7 @@ class DistribuerJournalpostService(
if (Strings.isNullOrEmpty(batchId)) "NONE" else batchId,
"enhet", journalpost.journalforendeEnhet,
"tema", journalpost.tema,
"kanal", kanal,
"kanal", kanal
).increment()

distributionAntallDokumenter.record(journalpost.dokumenter.size.toDouble())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -118,12 +118,14 @@ class EndreJournalpostService(
endreJournalpostCommand.hentTilknyttetSaker().stream()
.filter { sak: String? -> !journalpost.hentTilknyttetSaker().contains(sak) }
.collect(Collectors.toSet())
.forEach(Consumer { saksnummer: String? ->
tilknyttTilSak(
saksnummer,
journalpost
)
})
.forEach(
Consumer { saksnummer: String? ->
tilknyttTilSak(
saksnummer,
journalpost
)
}
)
}
}

Expand Down Expand Up @@ -178,7 +180,6 @@ class EndreJournalpostService(
LOGGER.info("Henter jouranlpost $journalpostId")
return journalpostService.hentJournalpost(journalpostId)
?: throw JournalpostIkkeFunnetException("Kunne ikke finne journalpost med id: $journalpostId")

}

fun oppdaterDistribusjonsInfo(
Expand Down
Loading

0 comments on commit b98de48

Please sign in to comment.