Fjern mulighet for import av virksomheter fra brreg i Fia

dette håndteres nå av brreg-oppdaterer

src/main/kotlin/no/nav/lydia/App.kt

@@ -21,10 +21,24 @@ import io.ktor.server.request.*
 import io.ktor.server.response.*
 import io.ktor.server.routing.*
 import no.nav.lydia.NaisEnvironment.Companion.Environment.LOKAL
-import no.nav.lydia.appstatus.*
+import no.nav.lydia.appstatus.DatabaseHelsesjekk
+import no.nav.lydia.appstatus.HelseMonitor
+import no.nav.lydia.appstatus.Metrics
+import no.nav.lydia.appstatus.featureToggle
+import no.nav.lydia.appstatus.healthChecks
+import no.nav.lydia.appstatus.metrics
 import no.nav.lydia.exceptions.UautorisertException
 import no.nav.lydia.ia.debug.debug
-import no.nav.lydia.ia.eksport.*
+import no.nav.lydia.ia.eksport.IASakEksporterer
+import no.nav.lydia.ia.eksport.IASakLeveranseEksportør
+import no.nav.lydia.ia.eksport.IASakLeveranseProdusent
+import no.nav.lydia.ia.eksport.IASakProdusent
+import no.nav.lydia.ia.eksport.IASakStatistikkEksporterer
+import no.nav.lydia.ia.eksport.IASakStatistikkProdusent
+import no.nav.lydia.ia.eksport.IASakStatusEksportør
+import no.nav.lydia.ia.eksport.IASakStatusProdusent
+import no.nav.lydia.ia.eksport.KafkaProdusent
+import no.nav.lydia.ia.eksport.iaSakEksporterer
 import no.nav.lydia.ia.sak.IASakLeveranseObserver
 import no.nav.lydia.ia.sak.IASakService
 import no.nav.lydia.ia.sak.api.IA_SAK_RADGIVER_PATH
@@ -34,25 +48,27 @@ import no.nav.lydia.ia.sak.db.IASakRepository
 import no.nav.lydia.ia.sak.db.IASakshendelseRepository
 import no.nav.lydia.ia.årsak.db.ÅrsakRepository
 import no.nav.lydia.ia.årsak.ÅrsakService
+import no.nav.lydia.integrasjoner.azure.AzureService
 import no.nav.lydia.integrasjoner.azure.AzureTokenFetcher
-import no.nav.lydia.integrasjoner.brreg.BrregDownloader
-import no.nav.lydia.integrasjoner.brreg.virksomhetsImport
+import no.nav.lydia.integrasjoner.azure.navEnhet
+import no.nav.lydia.integrasjoner.brreg.BrregAlleVirksomheterConsumer
+import no.nav.lydia.integrasjoner.brreg.BrregOppdateringConsumer
 import no.nav.lydia.integrasjoner.ssb.NæringsDownloader
 import no.nav.lydia.integrasjoner.ssb.NæringsRepository
 import no.nav.lydia.integrasjoner.ssb.næringsImport
 import no.nav.lydia.statusoverikt.StatusoversiktRepository
 import no.nav.lydia.statusoverikt.StatusoversiktService
 import no.nav.lydia.statusoverikt.api.statusoversikt
-import no.nav.lydia.sykefraversstatistikk.*
+import no.nav.lydia.sykefraversstatistikk.SistePubliseringRepository
+import no.nav.lydia.sykefraversstatistikk.SistePubliseringService
+import no.nav.lydia.sykefraversstatistikk.SykefraversstatistikkRepository
+import no.nav.lydia.sykefraversstatistikk.SykefraværsstatistikkService
+import no.nav.lydia.sykefraversstatistikk.VirksomhetsinformasjonRepository
 import no.nav.lydia.sykefraversstatistikk.api.SYKEFRAVERSSTATISTIKK_PATH
 import no.nav.lydia.sykefraversstatistikk.api.geografi.GeografiService
 import no.nav.lydia.sykefraversstatistikk.api.sykefraversstatistikk
-import no.nav.lydia.sykefraversstatistikk.import.BrregOppdateringConsumer
-import no.nav.lydia.sykefraversstatistikk.import.StatistikkPerKategoriConsumer
-import no.nav.lydia.integrasjoner.azure.AzureService
-import no.nav.lydia.integrasjoner.azure.navEnhet
-import no.nav.lydia.sykefraversstatistikk.import.BrregAlleVirksomheterConsumer
 import no.nav.lydia.sykefraversstatistikk.import.StatistikkMetadataVirksomhetConsumer
+import no.nav.lydia.sykefraversstatistikk.import.StatistikkPerKategoriConsumer
 import no.nav.lydia.virksomhet.VirksomhetRepository
 import no.nav.lydia.virksomhet.VirksomhetService
 import no.nav.lydia.virksomhet.api.VIRKSOMHET_PATH
@@ -267,12 +283,6 @@ fun Application.lydiaRestApi(
                 iaSakStatusProdusent = iaSakStatusProdusent,
             ),
         )
-        virksomhetsImport(
-            BrregDownloader(
-                url = naisEnvironment.integrasjoner.brregUnderEnhetUrl,
-                virksomhetRepository = virksomhetRepository
-            )
-        )
         næringsImport(
             næringsDownloader = NæringsDownloader(
                 url = naisEnvironment.integrasjoner.ssbNæringsUrl,

src/main/kotlin/no/nav/lydia/sykefraversstatistikk/import/BrregAlleVirksomheterConsumer.kt → src/main/kotlin/no/nav/lydia/integrasjoner/brreg/BrregAlleVirksomheterConsumer.kt

@@ -1,11 +1,15 @@
-package no.nav.lydia.sykefraversstatistikk.import
+package no.nav.lydia.integrasjoner.brreg
 
-import kotlinx.coroutines.*
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.Job
+import kotlinx.coroutines.cancelAndJoin
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
 import kotlinx.serialization.json.Json
 import no.nav.lydia.Kafka
 import no.nav.lydia.exceptions.UgyldigAdresseException
-import no.nav.lydia.integrasjoner.brreg.BrregVirksomhetDto
-import no.nav.lydia.integrasjoner.brreg.tilVirksomhet
 import no.nav.lydia.virksomhet.VirksomhetRepository
 import no.nav.lydia.virksomhet.domene.VirksomhetStatus
 import org.apache.kafka.clients.consumer.KafkaConsumer
@@ -37,9 +41,9 @@ object BrregAlleVirksomheterConsumer : CoroutineScope {
         val consumerGroupNavn = Kafka.brregConsumerGroupId
 
         logger.info("Creating kafka consumer job for $topicNavn i group $consumerGroupNavn")
-        this.job = Job()
-        this.kafka = kafka
-        this.virksomhetRepository = repository
+        job = Job()
+        BrregAlleVirksomheterConsumer.kafka = kafka
+        virksomhetRepository = repository
         kafkaConsumer = KafkaConsumer(
             BrregAlleVirksomheterConsumer.kafka.consumerProperties(consumerGroupId = Kafka.brregConsumerGroupId),
             StringDeserializer(),

src/main/kotlin/no/nav/lydia/sykefraversstatistikk/import/BrregOppdateringConsumer.kt → src/main/kotlin/no/nav/lydia/integrasjoner/brreg/BrregOppdateringConsumer.kt

@@ -1,13 +1,17 @@
-package no.nav.lydia.sykefraversstatistikk.import
+package no.nav.lydia.integrasjoner.brreg
 
-import kotlinx.coroutines.*
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.Job
+import kotlinx.coroutines.cancelAndJoin
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
 import kotlinx.datetime.Instant
 import kotlinx.serialization.Serializable
 import kotlinx.serialization.json.Json
 import no.nav.lydia.Kafka
 import no.nav.lydia.exceptions.UgyldigAdresseException
-import no.nav.lydia.integrasjoner.brreg.BrregVirksomhetDto
-import no.nav.lydia.integrasjoner.brreg.tilVirksomhet
 import no.nav.lydia.virksomhet.VirksomhetRepository
 import no.nav.lydia.virksomhet.domene.VirksomhetStatus
 import org.apache.kafka.clients.consumer.KafkaConsumer
@@ -36,9 +40,9 @@ object BrregOppdateringConsumer : CoroutineScope {
 
     fun create(kafka: Kafka, repository: VirksomhetRepository) {
         logger.info("Creating kafka consumer job for ${kafka.brregOppdateringTopic}")
-        this.job = Job()
-        this.kafka = kafka
-        this.repository = repository
+        job = Job()
+        BrregOppdateringConsumer.kafka = kafka
+        BrregOppdateringConsumer.repository = repository
         kafkaConsumer = KafkaConsumer(
             BrregOppdateringConsumer.kafka.consumerProperties(consumerGroupId = Kafka.brregConsumerGroupId),
             StringDeserializer(),

src/test/kotlin/no/nav/lydia/helper/KafkaContainerHelper.kt

@@ -11,10 +11,10 @@ import kotlinx.datetime.Clock.System.now
 import kotlinx.serialization.encodeToString
 import kotlinx.serialization.json.Json
 import no.nav.lydia.Kafka
+import no.nav.lydia.integrasjoner.brreg.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Ny
+import no.nav.lydia.integrasjoner.brreg.BrregOppdateringConsumer.OppdateringVirksomhet
 import no.nav.lydia.integrasjoner.brreg.BrregVirksomhetDto
 import no.nav.lydia.integrasjoner.brreg.NæringsundergruppeBrreg
-import no.nav.lydia.sykefraversstatistikk.import.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Ny
-import no.nav.lydia.sykefraversstatistikk.import.BrregOppdateringConsumer.OppdateringVirksomhet
 import no.nav.lydia.sykefraversstatistikk.import.KeySykefraversstatistikkMetadataVirksomhet
 import no.nav.lydia.sykefraversstatistikk.import.KeySykefraversstatistikkPerKategori
 import no.nav.lydia.sykefraversstatistikk.import.SykefraversstatistikkMetadataVirksomhetImportDto

src/test/kotlin/no/nav/lydia/helper/PiaBrregOppdateringContainerHelper.kt

@@ -5,22 +5,21 @@ import com.github.tomakehurst.wiremock.client.WireMock.matching
 import io.ktor.http.*
 import kotlinx.datetime.Clock
 import no.nav.lydia.integrasjoner.brreg.Beliggenhetsadresse
+import no.nav.lydia.integrasjoner.brreg.BrregOppdateringConsumer.BrregVirksomhetEndringstype
+import no.nav.lydia.integrasjoner.brreg.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Endring
+import no.nav.lydia.integrasjoner.brreg.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Fjernet
+import no.nav.lydia.integrasjoner.brreg.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Ny
+import no.nav.lydia.integrasjoner.brreg.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Sletting
 import no.nav.lydia.sykefraversstatistikk.api.Periode
-import no.nav.lydia.sykefraversstatistikk.import.BrregOppdateringConsumer.BrregVirksomhetEndringstype
-import no.nav.lydia.sykefraversstatistikk.import.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Endring
-import no.nav.lydia.sykefraversstatistikk.import.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Fjernet
-import no.nav.lydia.sykefraversstatistikk.import.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Ny
-import no.nav.lydia.sykefraversstatistikk.import.BrregOppdateringConsumer.BrregVirksomhetEndringstype.Sletting
 import org.slf4j.Logger
 import org.slf4j.LoggerFactory
 import org.testcontainers.containers.GenericContainer
 import org.testcontainers.containers.Network
 import org.testcontainers.containers.output.Slf4jLogConsumer
 import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy
 import org.testcontainers.images.builder.ImageFromDockerfile
-import java.util.TimeZone
+import java.util.*
 
-const val brregOppdateringTopic = "pia.brreg-oppdatering"
 const val brregOppdaterteUnderenheterMockPath = "/brregmock/api/oppdateringer/underenheter"
 const val brregUnderenheterMockPath = "/brregmock/api/underenheter"