Skip to content

Commit

Permalink
IS-2601: Cleanup api
Browse files Browse the repository at this point in the history
  • Loading branch information
andersrognstad committed Sep 3, 2024
1 parent dc48aea commit 34d183d
Show file tree
Hide file tree
Showing 7 changed files with 7 additions and 89 deletions.
Original file line number Diff line number Diff line change
@@ -1,15 +1,11 @@
package no.nav.syfo.personstatus

import no.nav.syfo.personstatus.infrastructure.database.DatabaseInterface
import no.nav.syfo.personstatus.db.hentBrukereTilknyttetVeileder
import no.nav.syfo.personstatus.db.lagreVeilederForBruker
import no.nav.syfo.personstatus.domain.VeilederBrukerKnytning

class PersonTildelingService(private val database: DatabaseInterface) {

fun hentBrukertilknytningerPaVeileder(veilederIdent: String) =
database.hentBrukereTilknyttetVeileder(veilederIdent).map { VeilederBrukerKnytning(it.veilederIdent, it.fnr, it.enhet) }

fun lagreKnytningMellomVeilederOgBruker(veilederBrukerKnytninger: List<VeilederBrukerKnytning>) =
veilederBrukerKnytninger.map { database.lagreVeilederForBruker(it) }
}
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,7 @@ import no.nav.syfo.util.getCallId
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import kotlin.collections.filter
import kotlin.collections.isNotEmpty
import kotlin.collections.map
import kotlin.takeIf
import kotlin.text.isNotEmpty

private val log: Logger = LoggerFactory.getLogger("no.nav.syfo")

Expand All @@ -37,24 +34,6 @@ fun Route.registerPersonTildelingApiV2(
personoversiktStatusService: PersonoversiktStatusService,
) {
route(personTildelingApiV2Path) {
get("/veileder/{veileder}") {
try {
val veileder: String = call.parameters["veileder"]?.takeIf { it.isNotEmpty() }
?: throw java.lang.IllegalArgumentException("Veileder mangler")

val tilknytninger: List<VeilederBrukerKnytning> =
personTildelingService.hentBrukertilknytningerPaVeileder(veileder)

when {
tilknytninger.isNotEmpty() -> call.respond(tilknytninger)
else -> call.respond(HttpStatusCode.NoContent)
}
} catch (e: IllegalArgumentException) {
log.warn("Kan ikke hente tilknytninger: {}, {}", e.message, callIdArgument(getCallId()))
call.respond(HttpStatusCode.BadRequest, e.message ?: "Kan ikke hente tilknytninger")
}
}

post("/registrer") {
val callId = getCallId()
val token = getBearerHeader()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,20 +66,6 @@ fun DatabaseInterface.hentUbehandledePersonerTilknyttetEnhet(enhet: String): Lis
}
}

fun DatabaseInterface.hentBrukereTilknyttetVeileder(veileder: String): List<VeilederBrukerKnytning> {
val query = """
SELECT *
FROM PERSON_OVERSIKT_STATUS
WHERE tildelt_veileder = ?
"""
return connection.use { connection ->
connection.prepareStatement(query).use {
it.setString(1, veileder)
it.executeQuery().toList { toVeilederBrukerKnytning() }
}
}
}

fun ResultSet.toPPersonOversiktStatus(): PPersonOversiktStatus =
PPersonOversiktStatus(
id = getInt("id"),
Expand Down Expand Up @@ -121,10 +107,3 @@ fun ResultSet.toPPersonOversiktStatus(): PPersonOversiktStatus =
isAktivAktivitetskravvurdering = getBoolean("is_aktiv_aktivitetskrav_vurdering"),
isAktivManglendeMedvirkningVurdering = getBoolean("is_aktiv_manglende_medvirkning_vurdering"),
)

fun ResultSet.toVeilederBrukerKnytning(): VeilederBrukerKnytning =
VeilederBrukerKnytning(
veilederIdent = getString("tildelt_veileder"),
fnr = getString("fnr"),
enhet = getString("tildelt_enhet") ?: ""
)
Original file line number Diff line number Diff line change
Expand Up @@ -3,5 +3,4 @@ package no.nav.syfo.personstatus.domain
data class VeilederBrukerKnytning(
val veilederIdent: String,
val fnr: String,
val enhet: String
)
Original file line number Diff line number Diff line change
Expand Up @@ -176,7 +176,6 @@ object PersonBehandlendeEnhetCronjobSpek : Spek({
val veilederBrukerKnytning = VeilederBrukerKnytning(
veilederIdent = UserConstants.VEILEDER_ID,
fnr = oversikthendelse.personident,
enhet = firstEnhet,
)
database.lagreVeilederForBruker(
veilederBrukerKnytning = veilederBrukerKnytning,
Expand Down Expand Up @@ -349,7 +348,6 @@ object PersonBehandlendeEnhetCronjobSpek : Spek({
val veilederBrukerKnytning = VeilederBrukerKnytning(
veilederIdent = UserConstants.VEILEDER_ID,
fnr = oversikthendelse.personident,
enhet = behandlendeEnhetDTO().enhetId,
)
database.lagreVeilederForBruker(
veilederBrukerKnytning = veilederBrukerKnytning,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -184,7 +184,7 @@ object PersonoversiktStatusApiV2Spek : Spek({
enhet = NAV_ENHET,
)

val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR, NAV_ENHET)
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR)
database.lagreVeilederForBruker(tilknytning)

with(
Expand Down Expand Up @@ -217,7 +217,7 @@ object PersonoversiktStatusApiV2Spek : Spek({
enhet = NAV_ENHET,
)

val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR, NAV_ENHET)
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR)
database.lagreVeilederForBruker(tilknytning)

with(
Expand Down Expand Up @@ -381,7 +381,7 @@ object PersonoversiktStatusApiV2Spek : Spek({
enhet = NAV_ENHET,
)

val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR, NAV_ENHET)
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR)
database.lagreVeilederForBruker(tilknytning)

with(
Expand Down Expand Up @@ -436,7 +436,7 @@ object PersonoversiktStatusApiV2Spek : Spek({
enhet = NAV_ENHET,
)

val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR, NAV_ENHET)
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR)
database.lagreVeilederForBruker(tilknytning)

with(
Expand Down Expand Up @@ -671,7 +671,7 @@ object PersonoversiktStatusApiV2Spek : Spek({
personoppgavehendelser = listOf(oversikthendelseDialogmotesvarMottatt)
)

val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, personIdent.value, NAV_ENHET)
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, personIdent.value)
database.lagreVeilederForBruker(tilknytning)
database.setTildeltEnhet(
ident = personIdent,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,39 +48,6 @@ object PersontildelingApiV2Spek : Spek({
navIdent = VEILEDER_ID,
)

describe("Hent veiledertilknytninger") {
val url = "$baseUrl/veileder/$VEILEDER_ID"

it("skal returnere status NoContent om veileder ikke har tilknytninger") {
with(
handleRequest(HttpMethod.Get, url) {
addHeader(HttpHeaders.Authorization, bearerHeader(validToken))
}
) {
response.status() shouldBeEqualTo HttpStatusCode.NoContent
}
}

it("skal hente veileder sine tilknytninger ") {
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR, NAV_ENHET)

database.lagreVeilederForBruker(tilknytning)

with(
handleRequest(HttpMethod.Get, url) {
addHeader(HttpHeaders.Authorization, bearerHeader(validToken))
}
) {
response.status() shouldBeEqualTo HttpStatusCode.OK
val returnertVerdi =
objectMapper.readValue<List<VeilederBrukerKnytning>>(response.content!!)[0]
returnertVerdi.veilederIdent shouldBeEqualTo tilknytning.veilederIdent
returnertVerdi.fnr shouldBeEqualTo tilknytning.fnr
returnertVerdi.enhet shouldBeEqualTo ""
}
}
}

describe("skal lagre veiledertilknytninger") {
val url = "$baseUrl/registrer"

Expand All @@ -100,7 +67,7 @@ object PersontildelingApiV2Spek : Spek({

describe("/personer") {
it("returns person with correct values") {
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR, NAV_ENHET)
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR)
database.lagreVeilederForBruker(tilknytning)

val url = "$personTildelingApiV2Path/personer/single"
Expand All @@ -117,7 +84,7 @@ object PersontildelingApiV2Spek : Spek({
}
}
it("returns 404 when person does not exist") {
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR, NAV_ENHET)
val tilknytning = VeilederBrukerKnytning(VEILEDER_ID, ARBEIDSTAKER_FNR)
database.lagreVeilederForBruker(tilknytning)

val url = "$personTildelingApiV2Path/personer/single"
Expand Down

0 comments on commit 34d183d

Please sign in to comment.