Skip to content

Commit

Permalink
splitt prosjekt opp i pakkenavn som matcher funksjon
Browse files Browse the repository at this point in the history
  • Loading branch information
sondrele committed Nov 12, 2024
1 parent 6bc21f3 commit 9f90902
Show file tree
Hide file tree
Showing 177 changed files with 900 additions and 773 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@ import io.ktor.client.statement.*
import io.ktor.http.*
import kotlinx.serialization.SerialName
import kotlinx.serialization.Serializable
import no.nav.mulighetsrommet.altinn.models.AltinnRessurs
import no.nav.mulighetsrommet.altinn.models.BedriftRettigheter
import no.nav.mulighetsrommet.altinn.model.AltinnRessurs
import no.nav.mulighetsrommet.altinn.model.BedriftRettigheter
import no.nav.mulighetsrommet.domain.dto.NorskIdent
import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer
import no.nav.mulighetsrommet.ktor.clients.httpJsonClient
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
package no.nav.mulighetsrommet.altinn

import no.nav.mulighetsrommet.altinn.models.BedriftRettigheter
import no.nav.mulighetsrommet.altinn.db.AltinnRettigheterRepository
import no.nav.mulighetsrommet.altinn.db.BedriftRettigheterDbo
import no.nav.mulighetsrommet.altinn.db.PersonBedriftRettigheterDbo
import no.nav.mulighetsrommet.altinn.model.BedriftRettigheter
import no.nav.mulighetsrommet.domain.dto.NorskIdent
import java.time.Duration
import java.time.LocalDateTime
Expand All @@ -23,7 +26,7 @@ class AltinnRettigheterService(
private suspend fun syncRettigheter(norskIdent: NorskIdent): List<BedriftRettigheter> {
val rettigheter = altinnClient.hentRettigheter(norskIdent)
altinnRettigheterRepository.upsertRettighet(
PersonBedriftRettigheter(
PersonBedriftRettigheterDbo(
norskIdent = norskIdent,
bedriftRettigheter = rettigheter,
expiry = LocalDateTime.now().plusSeconds(rolleExpiryDuration.seconds),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,20 +1,18 @@
package no.nav.mulighetsrommet.altinn
package no.nav.mulighetsrommet.altinn.db

import kotliquery.Session
import kotliquery.queryOf
import no.nav.mulighetsrommet.altinn.models.AltinnRessurs
import no.nav.mulighetsrommet.altinn.models.BedriftRettigheter
import no.nav.mulighetsrommet.altinn.model.AltinnRessurs
import no.nav.mulighetsrommet.database.Database
import no.nav.mulighetsrommet.domain.dto.NorskIdent
import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer
import org.intellij.lang.annotations.Language
import java.time.LocalDateTime

class AltinnRettigheterRepository(private val db: Database) {
fun upsertRettighet(personBedriftRettigheter: PersonBedriftRettigheter) =
fun upsertRettighet(personBedriftRettigheter: PersonBedriftRettigheterDbo) =
db.transaction { tx -> upsertRettighet(personBedriftRettigheter, tx) }

private fun upsertRettighet(personBedriftRettigheter: PersonBedriftRettigheter, tx: Session) {
private fun upsertRettighet(personBedriftRettigheter: PersonBedriftRettigheterDbo, tx: Session) {
@Language("PostgreSQL")
val upsertRolle = """
insert into altinn_person_rettighet (
Expand Down Expand Up @@ -94,19 +92,3 @@ class AltinnRettigheterRepository(private val db: Database) {
}
}
}

data class PersonBedriftRettigheter(
val norskIdent: NorskIdent,
val bedriftRettigheter: List<BedriftRettigheter>,
val expiry: LocalDateTime,
)

data class BedriftRettigheterDbo(
val organisasjonsnummer: Organisasjonsnummer,
val rettigheter: List<RettighetDbo>,
)

data class RettighetDbo(
val rettighet: AltinnRessurs,
val expiry: LocalDateTime,
)
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
package no.nav.mulighetsrommet.altinn.db

import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer

data class BedriftRettigheterDbo(
val organisasjonsnummer: Organisasjonsnummer,
val rettigheter: List<RettighetDbo>,
)
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
package no.nav.mulighetsrommet.altinn.db

import no.nav.mulighetsrommet.altinn.model.BedriftRettigheter
import no.nav.mulighetsrommet.domain.dto.NorskIdent
import java.time.LocalDateTime

data class PersonBedriftRettigheterDbo(
val norskIdent: NorskIdent,
val bedriftRettigheter: List<BedriftRettigheter>,
val expiry: LocalDateTime,
)
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
package no.nav.mulighetsrommet.altinn.db

import no.nav.mulighetsrommet.altinn.model.AltinnRessurs
import java.time.LocalDateTime

data class RettighetDbo(
val rettighet: AltinnRessurs,
val expiry: LocalDateTime,
)
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.mulighetsrommet.altinn.models
package no.nav.mulighetsrommet.altinn.model

enum class AltinnRessurs(val ressursId: String) {
TILTAK_ARRANGOR_REFUSJON("tiltak-arrangor-refusjon"),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.mulighetsrommet.altinn.models
package no.nav.mulighetsrommet.altinn.model

import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,16 +3,23 @@ package no.nav.mulighetsrommet.api
import io.ktor.client.engine.*
import io.ktor.client.engine.cio.*
import no.nav.mulighetsrommet.altinn.AltinnClient
import no.nav.mulighetsrommet.api.avtale.task.NotifySluttdatoForAvtalerNarmerSeg
import no.nav.mulighetsrommet.api.clients.brreg.BrregClient
import no.nav.mulighetsrommet.api.clients.sanity.SanityClient
import no.nav.mulighetsrommet.api.domain.dbo.NavAnsattRolle
import no.nav.mulighetsrommet.api.tasks.*
import no.nav.mulighetsrommet.api.gjennomforing.kafka.ArenaMigreringTiltaksgjennomforingerV1KafkaProducer
import no.nav.mulighetsrommet.api.gjennomforing.kafka.SisteTiltaksgjennomforingerV1KafkaProducer
import no.nav.mulighetsrommet.api.gjennomforing.task.NotifySluttdatoForGjennomforingerNarmerSeg
import no.nav.mulighetsrommet.api.gjennomforing.task.UpdateApentForInnsok
import no.nav.mulighetsrommet.api.navansatt.db.NavAnsattRolle
import no.nav.mulighetsrommet.api.navansatt.task.SynchronizeNavAnsatte
import no.nav.mulighetsrommet.api.navenhet.task.SynchronizeNorgEnheter
import no.nav.mulighetsrommet.api.refusjon.task.GenerateRefusjonskrav
import no.nav.mulighetsrommet.api.tasks.GenerateValidationReport
import no.nav.mulighetsrommet.api.tasks.NotifyFailedKafkaEvents
import no.nav.mulighetsrommet.api.tiltakstype.kafka.SisteTiltakstyperV2KafkaProducer
import no.nav.mulighetsrommet.database.DatabaseConfig
import no.nav.mulighetsrommet.database.FlywayMigrationManager
import no.nav.mulighetsrommet.kafka.KafkaTopicConsumer
import no.nav.mulighetsrommet.kafka.producers.ArenaMigreringTiltaksgjennomforingerV1KafkaProducer
import no.nav.mulighetsrommet.kafka.producers.SisteTiltaksgjennomforingerV1KafkaProducer
import no.nav.mulighetsrommet.kafka.producers.SisteTiltakstyperV2KafkaProducer
import no.nav.mulighetsrommet.ktor.ServerConfig
import no.nav.mulighetsrommet.unleash.UnleashService
import no.nav.mulighetsrommet.utdanning.client.UtdanningClient
Expand Down
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
package no.nav.mulighetsrommet.api.repositories
package no.nav.mulighetsrommet.api.amo

import kotlinx.serialization.encodeToString
import kotlinx.serialization.json.Json
import kotliquery.Session
import kotliquery.queryOf
import no.nav.mulighetsrommet.api.domain.dbo.AvtaleDbo
import no.nav.mulighetsrommet.api.domain.dbo.TiltaksgjennomforingDbo
import no.nav.mulighetsrommet.api.avtale.db.AvtaleDbo
import no.nav.mulighetsrommet.api.gjennomforing.db.TiltaksgjennomforingDbo
import no.nav.mulighetsrommet.domain.dto.*
import org.intellij.lang.annotations.Language
import java.util.*
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.mulighetsrommet.api.clients.arenaadapter
package no.nav.mulighetsrommet.api.arenaadapter

import io.ktor.client.call.*
import io.ktor.client.engine.*
Expand All @@ -15,13 +15,13 @@ import no.nav.mulighetsrommet.tokenprovider.TokenProvider
import org.slf4j.LoggerFactory
import java.util.*

private val log = LoggerFactory.getLogger(ArenaAdapterClient::class.java)

class ArenaAdapterClient(
private val baseUrl: String,
private val tokenProvider: TokenProvider,
clientEngine: HttpClientEngine,
) {
private val log = LoggerFactory.getLogger(javaClass)

val client = httpJsonClient(clientEngine).config {
install(HttpCache)
}
Expand All @@ -37,6 +37,7 @@ class ArenaAdapterClient(
log.info("Tiltaksgjennomføring finnes ikke: $arenaId")
null
}

else -> throw ResponseException(response, "Unexpected response from arena-adapter")
}
}
Expand All @@ -52,6 +53,7 @@ class ArenaAdapterClient(
log.info("Tiltaksgjennomføring finnes ikke: $id")
null
}

else -> throw ResponseException(response, "Unexpected response from arena-adapter")
}
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,12 +1,11 @@
package no.nav.mulighetsrommet.api.routes.v1
package no.nav.mulighetsrommet.api.arenaadapter

import io.ktor.http.*
import io.ktor.server.application.*
import io.ktor.server.request.*
import io.ktor.server.response.*
import io.ktor.server.routing.*
import io.ktor.server.util.*
import no.nav.mulighetsrommet.api.services.ArenaAdapterService
import no.nav.mulighetsrommet.domain.dbo.ArenaAvtaleDbo
import no.nav.mulighetsrommet.domain.dbo.ArenaTiltaksgjennomforingDbo
import no.nav.mulighetsrommet.domain.dto.UpsertTiltaksgjennomforingResponse
Expand Down
Original file line number Diff line number Diff line change
@@ -1,23 +1,27 @@
package no.nav.mulighetsrommet.api.services
package no.nav.mulighetsrommet.api.arenaadapter

import kotlinx.serialization.json.Json
import kotlinx.serialization.json.encodeToJsonElement
import kotliquery.TransactionalSession
import no.nav.mulighetsrommet.api.arrangor.ArrangorService
import no.nav.mulighetsrommet.api.avtale.db.AvtaleRepository
import no.nav.mulighetsrommet.api.avtale.model.AvtaleDto
import no.nav.mulighetsrommet.api.clients.brreg.BrregError
import no.nav.mulighetsrommet.api.domain.dto.AvtaleDto
import no.nav.mulighetsrommet.api.domain.dto.TiltaksgjennomforingDto
import no.nav.mulighetsrommet.api.domain.dto.TiltakstypeDto
import no.nav.mulighetsrommet.api.repositories.AvtaleRepository
import no.nav.mulighetsrommet.api.repositories.TiltaksgjennomforingRepository
import no.nav.mulighetsrommet.api.repositories.TiltakstypeRepository
import no.nav.mulighetsrommet.api.gjennomforing.db.TiltaksgjennomforingRepository
import no.nav.mulighetsrommet.api.gjennomforing.kafka.SisteTiltaksgjennomforingerV1KafkaProducer
import no.nav.mulighetsrommet.api.gjennomforing.model.TiltaksgjennomforingDto
import no.nav.mulighetsrommet.api.services.DocumentClass
import no.nav.mulighetsrommet.api.services.EndringshistorikkService
import no.nav.mulighetsrommet.api.services.TILTAKSADMINISTRASJON_SYSTEM_BRUKER
import no.nav.mulighetsrommet.api.services.cms.SanityService
import no.nav.mulighetsrommet.api.tiltakstype.db.TiltakstypeRepository
import no.nav.mulighetsrommet.api.tiltakstype.model.TiltakstypeDto
import no.nav.mulighetsrommet.database.Database
import no.nav.mulighetsrommet.domain.Tiltakskoder
import no.nav.mulighetsrommet.domain.constants.ArenaMigrering.TiltaksgjennomforingSluttDatoCutoffDate
import no.nav.mulighetsrommet.domain.dbo.ArenaAvtaleDbo
import no.nav.mulighetsrommet.domain.dbo.ArenaTiltaksgjennomforingDbo
import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer
import no.nav.mulighetsrommet.kafka.producers.SisteTiltaksgjennomforingerV1KafkaProducer
import org.slf4j.LoggerFactory
import java.util.*

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.mulighetsrommet.api.routes.v1
package no.nav.mulighetsrommet.api.arrangor

import arrow.core.Either
import io.ktor.http.*
Expand All @@ -9,12 +9,11 @@ import io.ktor.server.routing.*
import io.ktor.server.util.*
import io.ktor.util.pipeline.*
import kotlinx.serialization.Serializable
import no.nav.mulighetsrommet.api.domain.dto.ArrangorKontaktperson
import no.nav.mulighetsrommet.api.domain.dto.ArrangorTil
import no.nav.mulighetsrommet.api.arrangor.db.ArrangorRepository
import no.nav.mulighetsrommet.api.arrangor.model.ArrangorKontaktperson
import no.nav.mulighetsrommet.api.arrangor.model.ArrangorTil
import no.nav.mulighetsrommet.api.parameters.getPaginationParams
import no.nav.mulighetsrommet.api.repositories.ArrangorRepository
import no.nav.mulighetsrommet.api.responses.*
import no.nav.mulighetsrommet.api.services.ArrangorService
import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer
import no.nav.mulighetsrommet.domain.serializers.UUIDSerializer
import org.koin.ktor.ext.inject
Expand Down
Original file line number Diff line number Diff line change
@@ -1,15 +1,15 @@
package no.nav.mulighetsrommet.api.services
package no.nav.mulighetsrommet.api.arrangor

import arrow.core.Either
import arrow.core.flatMap
import arrow.core.right
import kotlinx.serialization.Serializable
import no.nav.mulighetsrommet.api.arrangor.db.ArrangorRepository
import no.nav.mulighetsrommet.api.arrangor.db.DokumentKoblingForKontaktperson
import no.nav.mulighetsrommet.api.arrangor.model.ArrangorDto
import no.nav.mulighetsrommet.api.arrangor.model.ArrangorKontaktperson
import no.nav.mulighetsrommet.api.clients.brreg.BrregClient
import no.nav.mulighetsrommet.api.clients.brreg.BrregError
import no.nav.mulighetsrommet.api.domain.dto.ArrangorDto
import no.nav.mulighetsrommet.api.domain.dto.ArrangorKontaktperson
import no.nav.mulighetsrommet.api.repositories.ArrangorRepository
import no.nav.mulighetsrommet.api.repositories.DokumentKoblingForKontaktperson
import no.nav.mulighetsrommet.api.responses.BadRequest
import no.nav.mulighetsrommet.api.responses.StatusResponse
import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer
Expand Down
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
package no.nav.mulighetsrommet.api.routes.v1
package no.nav.mulighetsrommet.api.arrangor

import io.ktor.server.application.*
import io.ktor.server.plugins.*
import io.ktor.server.routing.*
import io.ktor.server.util.*
import no.nav.mulighetsrommet.api.arrangor.db.ArrangorRepository
import no.nav.mulighetsrommet.api.arrangor.model.ArrangorDto
import no.nav.mulighetsrommet.api.arrangor.model.BrregVirksomhetDto
import no.nav.mulighetsrommet.api.clients.brreg.BrregClient
import no.nav.mulighetsrommet.api.clients.brreg.BrregError
import no.nav.mulighetsrommet.api.domain.dto.ArrangorDto
import no.nav.mulighetsrommet.api.domain.dto.BrregVirksomhetDto
import no.nav.mulighetsrommet.api.repositories.ArrangorRepository
import no.nav.mulighetsrommet.api.responses.BadRequest
import no.nav.mulighetsrommet.api.responses.NotFound
import no.nav.mulighetsrommet.api.responses.ServerError
Expand Down
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
package no.nav.mulighetsrommet.api.repositories
package no.nav.mulighetsrommet.api.arrangor.db

import kotlinx.serialization.Serializable
import kotliquery.Row
import kotliquery.queryOf
import no.nav.mulighetsrommet.api.domain.dto.ArrangorDto
import no.nav.mulighetsrommet.api.domain.dto.ArrangorKontaktperson
import no.nav.mulighetsrommet.api.domain.dto.ArrangorTil
import no.nav.mulighetsrommet.api.domain.dto.BrregVirksomhetDto
import no.nav.mulighetsrommet.api.arrangor.model.ArrangorDto
import no.nav.mulighetsrommet.api.arrangor.model.ArrangorKontaktperson
import no.nav.mulighetsrommet.api.arrangor.model.ArrangorTil
import no.nav.mulighetsrommet.api.arrangor.model.BrregVirksomhetDto
import no.nav.mulighetsrommet.database.Database
import no.nav.mulighetsrommet.database.utils.PaginatedResult
import no.nav.mulighetsrommet.database.utils.Pagination
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.mulighetsrommet.kafka.consumers.amt
package no.nav.mulighetsrommet.api.arrangor.kafka

import kotlinx.serialization.Serializable
import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer
Expand Down
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
package no.nav.mulighetsrommet.kafka.consumers.amt
package no.nav.mulighetsrommet.api.arrangor.kafka

import kotlinx.serialization.json.JsonElement
import kotlinx.serialization.json.decodeFromJsonElement
import no.nav.common.kafka.consumer.util.deserializer.Deserializers.stringDeserializer
import no.nav.mulighetsrommet.api.arrangor.db.ArrangorRepository
import no.nav.mulighetsrommet.api.clients.brreg.BrregClient
import no.nav.mulighetsrommet.api.repositories.ArrangorRepository
import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer
import no.nav.mulighetsrommet.kafka.KafkaTopicConsumer
import no.nav.mulighetsrommet.kafka.serialization.JsonElementDeserializer
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package no.nav.mulighetsrommet.api.domain.dto
package no.nav.mulighetsrommet.api.arrangor.model

import kotlinx.serialization.Serializable
import no.nav.mulighetsrommet.domain.dto.Organisasjonsnummer
Expand All @@ -25,23 +25,3 @@ data class ArrangorDto(
@Serializable(with = LocalDateSerializer::class)
val slettetDato: LocalDate? = null,
)

@Serializable
data class ArrangorKontaktperson(
@Serializable(with = UUIDSerializer::class)
val id: UUID,
@Serializable(with = UUIDSerializer::class)
val arrangorId: UUID,
val navn: String,
val beskrivelse: String?,
val telefon: String?,
val epost: String,
val ansvarligFor: List<AnsvarligFor>? = emptyList(),
) {
@Serializable
enum class AnsvarligFor {
AVTALE,
TILTAKSGJENNOMFORING,
OKONOMI,
}
}
Loading

0 comments on commit 9f90902

Please sign in to comment.