Skip to content

Commit

Permalink
Merge branch 'master' into datatype-fiks
Browse files Browse the repository at this point in the history
  • Loading branch information
mbolstad committed Nov 28, 2024
2 parents c683e61 + b403109 commit cd7bb87
Show file tree
Hide file tree
Showing 47 changed files with 295 additions and 200 deletions.
10 changes: 5 additions & 5 deletions .github/workflows/build-master.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -25,14 +25,14 @@ jobs:
issues: write
steps:
- uses: actions/checkout@v4
- uses: actions/setup-java@v3
- uses: actions/setup-java@v4
with:
java-version: 21
distribution: temurin
cache: gradle

- name: Setup Gradle to generate and submit dependency graphs
uses: gradle/gradle-build-action@v2
uses: gradle/gradle-build-action@v3
with:
dependency-graph: generate-and-submit

Expand Down Expand Up @@ -64,7 +64,7 @@ jobs:
run: echo "IMAGE=${BASE_IMAGE}:${TAG}" >> $GITHUB_ENV

- name: Lukk gamle issues
uses: actions/github-script@v6
uses: actions/github-script@v7
with:
github-token: ${{ secrets.GITHUB_TOKEN }}
script: |
Expand All @@ -87,7 +87,7 @@ jobs:
- name: Opprett deployment issue
id: createdeployissue
if: success()
uses: actions/github-script@v6
uses: actions/github-script@v7
with:
github-token: ${{secrets.GITHUB_TOKEN}}
script: |
Expand All @@ -102,7 +102,7 @@ jobs:
});
- name: Deploy til preprod
uses: nais/deploy/actions/deploy@v1
uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: dev-fss
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/build-pull-request.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ jobs:

steps:
- uses: actions/checkout@v4
- uses: actions/setup-java@v3
- uses: actions/setup-java@v4
with:
java-version: 21
distribution: temurin
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/deploy-alerts.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,13 @@ jobs:
cluster: [dev-fss, prod-fss]
steps:
- uses: actions/checkout@v4
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: ${{ matrix.cluster }}
RESOURCE: nais/alerts/alert-manager.yml
VAR: cluster=${{ matrix.cluster }},slack_channel=${{ matrix.cluster == 'prod-fss' && '#k9-los-alerts' || '#k9-los-alerts-dev' }}
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: ${{ matrix.cluster }}
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/deploy-preprod.yml
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ jobs:
contents: read
steps:
- uses: actions/checkout@v4
- uses: actions/setup-java@v3
- uses: actions/setup-java@v4
with:
java-version: 21
distribution: temurin
Expand Down Expand Up @@ -43,7 +43,7 @@ jobs:
run: echo "IMAGE=${BASE_IMAGE}:${TAG}" >> $GITHUB_ENV

- name: Deploy til preprod
uses: nais/deploy/actions/deploy@v1
uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: dev-fss
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/dispatch.yml
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ jobs:
runs-on: ubuntu-latest
steps:
- name: Slash command dispatch
uses: peter-evans/slash-command-dispatch@v3.0.1
uses: peter-evans/slash-command-dispatch@v4.0.0
with:
token: ${{ secrets.LOS_TOKEN }}
commands: promote
Expand Down
20 changes: 10 additions & 10 deletions .github/workflows/kafka.yml
Original file line number Diff line number Diff line change
Expand Up @@ -13,31 +13,31 @@ jobs:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v4
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: dev-gcp
VAR: kafka-pool=nav-dev
RESOURCE: nais/kafka/produksjonsstyring-k9sak.yml
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: dev-gcp
VAR: kafka-pool=nav-dev
RESOURCE: nais/kafka/produksjonsstyring-k9punsj.yml
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: dev-gcp
VAR: kafka-pool=nav-dev
RESOURCE: nais/kafka/aapen-k9statistikk-behandling-v2.yml
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: dev-gcp
VAR: kafka-pool=nav-dev
RESOURCE: nais/kafka/aapen-k9statistikk-sak-v2.yml
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: dev-gcp
Expand All @@ -50,31 +50,31 @@ jobs:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v4
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: prod-gcp
VAR: kafka-pool=nav-prod
RESOURCE: nais/kafka/produksjonsstyring-k9sak.yml
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: prod-gcp
VAR: kafka-pool=nav-prod
RESOURCE: nais/kafka/produksjonsstyring-k9punsj.yml
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: prod-gcp
VAR: kafka-pool=nav-prod
RESOURCE: nais/kafka/oppgavemeldinger-klage-til-los.yml
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: prod-gcp
VAR: kafka-pool=nav-prod
RESOURCE: nais/kafka/aapen-k9statistikk-behandling-v2.yml
- uses: nais/deploy/actions/deploy@v1
- uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: prod-gcp
Expand Down
10 changes: 5 additions & 5 deletions .github/workflows/promote.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ jobs:

- name: Henter informasjon fra issuet
id: issue_comment
uses: actions/github-script@v6
uses: actions/github-script@v7
with:
script: |
github.rest.issues.get( {
Expand All @@ -43,15 +43,15 @@ jobs:
ref: ${{ steps.issue_comment.outputs.sha }}

- name: Promoter til cluster og namespace
uses: nais/deploy/actions/deploy@v1
uses: nais/deploy/actions/deploy@v2
env:
APIKEY: ${{ secrets.DEPLOY_KEY }}
CLUSTER: ${{ env.CLUSTER }}
RESOURCE: nais/${{ env.CLUSTER }}.yml

- name: Oppdater kommentar med deployment status ved feil
if: failure()
uses: actions/github-script@v6
uses: actions/github-script@v7
with:
script: |
const issue = { owner: context.issue.owner,
Expand All @@ -65,7 +65,7 @@ jobs:
- name: Oppdater kommentar med deployment status
if: success()
uses: actions/github-script@v6
uses: actions/github-script@v7
with:
script: |
const issue = { owner: context.issue.owner,
Expand All @@ -81,7 +81,7 @@ jobs:
echo "COMMIT_SHA=$(git rev-parse ${{ env.TAG }})" >> $GITHUB_ENV
- name: Tagg prodsatt commit
if: success() && env.CLUSTER == 'prod-fss'
uses: actions/github-script@v6
uses: actions/github-script@v7
with:
github-token: ${{secrets.GITHUB_TOKEN}}
script: |
Expand Down
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ Oppgavestyrere definerer kriterier som ligger til grunn for køer som fordeler o

# Bygge og kjøre lokalt

1. Start k9-verdikjede. Er avhengig av vtp, postgresql og nav-auth-mock.
1. Start k9-verdikjede. Er avhengig av vtp, postgresql og azure-mock.



Expand Down
1 change: 0 additions & 1 deletion force_merge_fil.txt

This file was deleted.

6 changes: 2 additions & 4 deletions nais/dev-fss.yml
Original file line number Diff line number Diff line change
Expand Up @@ -60,8 +60,6 @@ spec:
accessPolicy:
inbound:
rules:
- application: k9-los-oidc-auth-proxy
namespace: k9saksbehandling
- application: k9-los-web
namespace: k9saksbehandling
cluster: dev-gcp
Expand All @@ -71,14 +69,14 @@ spec:
- https://k9-los-api.dev-fss-pub.nais.io
env:
- name: OPPGAVE_BASE_URI
value: https://oppgave.nais.preprod.local
value: https://oppgave.dev.intern.nav.no
- name: DB_URL
value: jdbc:postgresql://b27dbvl028.preprod.local:5432/k9-los
- name: DB_VAULT_MOUNTPATH
value: postgresql/preprod-fss/

- name: PDL_URL
value: https://pdl-api.nais.preprod.local/graphql
value: https://pdl-api.intern.dev.nav.no/graphql

# Nav applikasjoner
- name: APP_K9SAK_URL
Expand Down
2 changes: 0 additions & 2 deletions nais/prod-fss.yml
Original file line number Diff line number Diff line change
Expand Up @@ -61,8 +61,6 @@ spec:
accessPolicy:
inbound:
rules:
- application: k9-los-oidc-auth-proxy
namespace: k9saksbehandling
- application: k9-los-web
namespace: k9saksbehandling
cluster: prod-gcp
Expand Down
6 changes: 2 additions & 4 deletions src/main/kotlin/no/nav/k9/los/K9Los.kt
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ fun Application.k9Los() {
val k9TilbakeTilLosAdapterTjeneste = koin.get<K9TilbakeTilLosAdapterTjeneste>()
k9TilbakeTilLosAdapterTjeneste.setup()

if (LocalDateTime.now().isBefore(LocalDateTime.of(2024, 11, 6, 10, 0))) {
if (LocalDateTime.now().isBefore(LocalDateTime.of(2024, 11, 22, 18, 0))) {
if (1 == 0) { //HAXX for å ikke kjøre jobb, men indikere at koden er i bruk og dermed ikke slettes
//koin.get<ReservasjonKonverteringJobb>().kjørReservasjonskonvertering() //TODO slette
//koin.get<K9SakTilLosLukkeFeiloppgaverTjeneste>().kjørFeiloppgaverVask() //TODO slette
Expand All @@ -122,9 +122,7 @@ fun Application.k9Los() {
koin.get<K9KlageTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
koin.get<K9TilbakeTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
}
if (configuration.koinProfile == KoinProfile.PREPROD) {
koin.get<K9TilbakeTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
}
koin.get<K9PunsjTilLosHistorikkvaskTjeneste>().kjørHistorikkvask()
}

install(Authentication) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ class K9TilbakeEventHandler(
OpentelemetrySpanUtil.span("k9TilbakeTilLosAdapterTjeneste.oppdaterOppgaveForBehandlingUuid") { k9TilbakeTilLosAdapterTjeneste.oppdaterOppgaveForBehandlingUuid(event.eksternId!!) }

runBlocking {
for (oppgavekø in oppgaveKøRepository.hentKøIdIkkeTaHensyn()) {
for (oppgavekø in oppgaveKøRepository.hentKøIdInkluderKode6()) {
oppgaveKøRepository.leggTilOppgaverTilKø(oppgavekø, listOf(oppgave), reservasjonRepository)
}
statistikkChannel.send(true)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ class K9punsjEventHandler constructor(
}

runBlocking {
for (oppgavekø in oppgaveKøRepository.hentKøIdIkkeTaHensyn()) {
for (oppgavekø in oppgaveKøRepository.hentKøIdInkluderKode6()) {
oppgaveKøRepository.leggTilOppgaverTilKø(oppgavekø, listOf(oppgave), reservasjonRepository)
}
statistikkChannel.send(true)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ class K9sakEventHandler constructor(
}
modell.reportMetrics(reservasjonRepository)
runBlocking {
for (oppgavekø in oppgaveKøRepository.hentKøIdIkkeTaHensyn()) {
for (oppgavekø in oppgaveKøRepository.hentKøIdInkluderKode6()) {
if (reservasjonFjernet){
oppgaveKøRepository.leggTilOppgaverTilKø(oppgavekø, listOf(oppgave), erOppgavenReservertSjekk = {false}) //reservasjon nettopp fjernet, trenger ikke sjekke mot repository
} else {
Expand Down
4 changes: 2 additions & 2 deletions src/main/kotlin/no/nav/k9/los/domene/modell/K9SakModell.kt
Original file line number Diff line number Diff line change
Expand Up @@ -273,7 +273,7 @@ data class K9SakModell(
val oppgave = oppgave()
val reservasjon = reservasjonRepository.hentOptional(oppgave.eksternId)
val beslutter = if (oppgave.tilBeslutter && reservasjon != null) {
val saksbehandler = saksbehandlerRepository.finnSaksbehandlerMedIdentIkkeTaHensyn(reservasjon.reservertAv)
val saksbehandler = saksbehandlerRepository.finnSaksbehandlerMedIdentInkluderKode6(reservasjon.reservertAv)
saksbehandler?.brukerIdent
} else {
""
Expand All @@ -283,7 +283,7 @@ data class K9SakModell(
if (reservasjon != null) {
val hentMedHistorikk = reservasjonRepository.hentMedHistorikk(oppgave.eksternId)
val reservertav = hentMedHistorikk.map { it.reservertAv }.first()
saksbehandlerRepository.finnSaksbehandlerMedIdentIkkeTaHensyn(reservertav)?.enhet?.substringBefore(" ")
saksbehandlerRepository.finnSaksbehandlerMedIdentInkluderKode6(reservertav)?.enhet?.substringBefore(" ")
} else {
"SRV"
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -245,7 +245,7 @@ data class K9TilbakeModell(
val oppgave = oppgave(sisteEvent())
val reservasjon = reservasjonRepository.hentOptional(oppgave.eksternId)
val beslutter = if (oppgave.tilBeslutter && reservasjon != null) {
val saksbehandler = saksbehandlerRepository.finnSaksbehandlerMedIdentIkkeTaHensyn(reservasjon.reservertAv)
val saksbehandler = saksbehandlerRepository.finnSaksbehandlerMedIdentInkluderKode6(reservasjon.reservertAv)
saksbehandler?.brukerIdent
} else {
""
Expand All @@ -255,7 +255,7 @@ data class K9TilbakeModell(
if (reservasjonRepository.finnes(oppgave.eksternId)) {
val hentMedHistorikk = reservasjonRepository.hentMedHistorikk(oppgave.eksternId)
val reservertav = hentMedHistorikk.map { it.reservertAv }.first()
saksbehandlerRepository.finnSaksbehandlerMedIdentIkkeTaHensyn(reservertav)?.enhet?.substringBefore(" ")
saksbehandlerRepository.finnSaksbehandlerMedIdentInkluderKode6(reservertav)?.enhet?.substringBefore(" ")
} else {
"SRV"
}
Expand Down
2 changes: 1 addition & 1 deletion src/main/kotlin/no/nav/k9/los/domene/modell/Kodeverk.kt
Original file line number Diff line number Diff line change
Expand Up @@ -193,7 +193,7 @@ enum class BehandlingType(override val kode: String, override val navn: String,
@JvmStatic
fun fraKode(o: Any): BehandlingType {
val kode = TempAvledeKode.getVerdi(o)
return values().find { it.kode == kode } ?: throw IllegalStateException("Kjenner ikke igjen koden=$kode")
return entries.find { it.kode == kode } ?: throw IllegalStateException("Kjenner ikke igjen koden=$kode")
}
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ import org.slf4j.Logger
import org.slf4j.LoggerFactory
import java.time.LocalDate
import java.util.*
import java.util.concurrent.atomic.LongAdder
import javax.sql.DataSource

class OppgaveKøRepository(
Expand All @@ -29,7 +28,7 @@ class OppgaveKøRepository(
private val pepClient: IPepClient
) {
private val log: Logger = LoggerFactory.getLogger(OppgaveKøRepository::class.java)
suspend fun hent(): List<OppgaveKø> {
suspend fun hentAlle(): List<OppgaveKø> {
val skjermet = pepClient.harTilgangTilKode6()
val json: List<String> = using(sessionOf(dataSource)) {
it.run(
Expand All @@ -45,7 +44,7 @@ class OppgaveKøRepository(
return json.map { s -> LosObjectMapper.instance.readValue(s, OppgaveKø::class.java) }.toList()
}

fun hentIkkeTaHensyn(): List<OppgaveKø> {
fun hentAlleInkluderKode6(): List<OppgaveKø> {
val json: List<String> = using(sessionOf(dataSource)) {
it.run(
queryOf(
Expand All @@ -60,7 +59,7 @@ class OppgaveKøRepository(
return json.map { s -> LosObjectMapper.instance.readValue(s, OppgaveKø::class.java) }.toList()
}

fun hentKøIdIkkeTaHensyn(): List<UUID> {
fun hentKøIdInkluderKode6(): List<UUID> {
val uuidListe: List<UUID> = using(sessionOf(dataSource)) {
it.run(
queryOf(
Expand Down Expand Up @@ -208,7 +207,7 @@ class OppgaveKøRepository(
}
}

suspend fun lagreIkkeTaHensyn(
suspend fun lagreInkluderKode6(
uuid: UUID,
f: (OppgaveKø?) -> OppgaveKø
) {
Expand Down
Loading

0 comments on commit cd7bb87

Please sign in to comment.