Skip to content

Commit

Permalink
Rename service and producer brukertifikasjon -> minsideVarsler
Browse files Browse the repository at this point in the history
  • Loading branch information
tu55eladd committed Oct 21, 2024
1 parent 6c3a93e commit 79c14b8
Show file tree
Hide file tree
Showing 16 changed files with 45 additions and 43 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetTransaksjonsType;
import no.nav.veilarbaktivitet.aktivitet.dto.AktivitetDTO;
import no.nav.veilarbaktivitet.aktivitet.mappers.AktivitetDTOMapper;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.brukernotifikasjon.VarselType;
import no.nav.veilarbaktivitet.brukernotifikasjon.opprettVarsel.AktivitetVarsel;
import no.nav.veilarbaktivitet.person.Innsender;
Expand All @@ -31,7 +31,7 @@ public class AvtaltMedNavService {
private final AktivitetDAO aktivitetDAO;
private final ForhaandsorienteringDAO fhoDAO;
private final MeterRegistry meterRegistry;
private final BrukernotifikasjonService brukernotifikasjonService;
private final MinsideVarselService brukernotifikasjonService;

public static final String AVTALT_MED_NAV_COUNTER = "aktivitet.avtalt.med.nav";
public static final String AKTIVITET_TYPE_LABEL = "AktivitetType";
Expand All @@ -44,7 +44,7 @@ public AvtaltMedNavService(MetricService metricService,
AktivitetDAO aktivitetDAO,
ForhaandsorienteringDAO fhoDAO,
MeterRegistry meterRegistry,
BrukernotifikasjonService brukernotifikasjonService) {
MinsideVarselService brukernotifikasjonService) {

this.metricService = metricService;
this.aktivitetDAO = aktivitetDAO;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import jakarta.annotation.PreDestroy;
import lombok.RequiredArgsConstructor;
import net.javacrumbs.shedlock.spring.annotation.SchedulerLock;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.util.ExcludeFromCoverageGenerated;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
Expand All @@ -17,7 +17,7 @@
@EnableScheduling
@RequiredArgsConstructor
public class SendBrukernotifikasjonCron {
private final BrukernotifikasjonService brukernotifikasjonService;
private final MinsideVarselService brukernotifikasjonService;
private final VarselDAO varselDao;
private final VarselMetrikk varselMetrikk;
private final ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import net.javacrumbs.shedlock.spring.annotation.SchedulerLock;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.brukernotifikasjon.VarselType;
import no.nav.veilarbaktivitet.brukernotifikasjon.opprettVarsel.AktivitetVarsel;
import no.nav.veilarbaktivitet.util.ExcludeFromCoverageGenerated;
Expand All @@ -24,7 +24,7 @@
@RequiredArgsConstructor
public class MoteSMSService {
private final MoteSmsDAO moteSmsDAO;
private final BrukernotifikasjonService brukernotifikasjonService;
private final MinsideVarselService brukernotifikasjonService;
private final ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);

@Scheduled(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetData;
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetStatus;
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetTransaksjonsType;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.brukernotifikasjon.VarselType;
import no.nav.veilarbaktivitet.person.Innsender;
import no.nav.veilarbaktivitet.person.Person;
Expand Down Expand Up @@ -36,7 +36,7 @@ public class DelingAvCvService {
private final IAuthService authService;
private final AktivitetService aktivitetService;
private final StillingFraNavProducerClient stillingFraNavProducerClient;
private final BrukernotifikasjonService brukernotifikasjonService;
private final MinsideVarselService brukernotifikasjonService;
private final StillingFraNavMetrikker metrikker;

public boolean aktivitetAlleredeOpprettetForBestillingsId(String bestillingsId) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetStatus;
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetTransaksjonsType;
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetTypeData;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.brukernotifikasjon.VarselType;
import no.nav.veilarbaktivitet.brukernotifikasjon.opprettVarsel.AktivitetVarsel;
import no.nav.veilarbaktivitet.kvp.KvpService;
Expand Down Expand Up @@ -41,7 +41,7 @@ public class OpprettForesporselOmDelingAvCv {
private final DelingAvCvService delingAvCvService;
private final KvpService kvpService;
private final SistePeriodeService sistePeriodeService;
private final BrukernotifikasjonService brukernotifikasjonService;
private final MinsideVarselService brukernotifikasjonService;
private final StillingFraNavProducerClient producerClient;
private final StillingFraNavMetrikker metrikker;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetData;
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetStatus;
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetTransaksjonsType;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.brukernotifikasjon.VarselType;
import no.nav.veilarbaktivitet.brukernotifikasjon.opprettVarsel.AktivitetVarsel;
import no.nav.veilarbaktivitet.person.Person;
Expand All @@ -24,7 +24,7 @@ public class RekrutteringsbistandStatusoppdateringService {
public static final String IKKE_FATT_JOBBEN_TEKST = "NAV har gjort en oppdatering på denne stillingen";
private final AktivitetDAO aktivitetDAO;
private final StillingFraNavMetrikker stillingFraNavMetrikker;
private final BrukernotifikasjonService brukernotifikasjonService;
private final MinsideVarselService brukernotifikasjonService;

private void maybeBestillBrukernotifikasjon(AktivitetData aktivitetData, VarselType varselType) {
if (brukernotifikasjonService.finnesBrukernotifikasjonMedVarselTypeForAktivitet(aktivitetData.getId(), varselType)) {
Expand Down
4 changes: 2 additions & 2 deletions src/main/kotlin/no/nav/veilarbaktivitet/arena/ArenaService.kt
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ import no.nav.veilarbaktivitet.avtalt_med_nav.AvtaltMedNavService
import no.nav.veilarbaktivitet.avtalt_med_nav.Forhaandsorientering
import no.nav.veilarbaktivitet.avtalt_med_nav.ForhaandsorienteringDAO
import no.nav.veilarbaktivitet.avtalt_med_nav.ForhaandsorienteringDTO
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService
import no.nav.veilarbaktivitet.brukernotifikasjon.VarselType
import no.nav.veilarbaktivitet.brukernotifikasjon.opprettVarsel.ArenaAktivitetVarsel
import no.nav.veilarbaktivitet.oppfolging.periode.OppfolgingsperiodeDAO
Expand All @@ -32,7 +32,7 @@ import java.util.*
open class ArenaService(
private val fhoDAO: ForhaandsorienteringDAO,
private val meterRegistry: MeterRegistry,
private val brukernotifikasjonArenaAktivitetService: BrukernotifikasjonService,
private val brukernotifikasjonArenaAktivitetService: MinsideVarselService,
private val veilarbarenaClient: VeilarbarenaClient,
private val idMappingDAO: IdMappingDAO,
private val personService: PersonService,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ import org.springframework.stereotype.Service
import java.time.ZonedDateTime

@Service
class BrukernotifikasjonProducer(
class MinsideVarselProducer(
@Value("\${topic.ut.brukernotifikasjon.brukervarsel}")
private var brukervarselTopic: String,
@Value("\${app.env.appname}")
Expand All @@ -23,7 +23,7 @@ class BrukernotifikasjonProducer(
private val producer: KafkaStringTemplate
) {

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

private fun toBrukerVarsel(skalSendes: SkalSendes, varselType: Varseltype): String {
return VarselActionBuilder.opprett {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@ import org.springframework.transaction.annotation.Transactional
import java.util.*

@Service
open class BrukernotifikasjonService(
val brukernotifikasjonProducer: BrukernotifikasjonProducer,
open class MinsideVarselService(
val minsideVarselProducer: MinsideVarselProducer,
val varselDAO: VarselDAO,
val aktivitetDao: AktivitetDAO,
val manuellStatusClient: ManuellStatusV2Client,
Expand All @@ -29,7 +29,7 @@ open class BrukernotifikasjonService(
val aktivitetsplanBasepath: String,
var sistePeriodeService: SistePeriodeService
) {
private val log = LoggerFactory.getLogger(BrukernotifikasjonService::class.java)
private val log = LoggerFactory.getLogger(MinsideVarselService::class.java)
private val secureLogs: Logger = LoggerFactory.getLogger("SecureLog")

open fun hentVarselSomSkalSendes(maxAntall: Int): List<SkalSendes> = varselDAO.hentVarselSomSkalSendes(maxAntall)
Expand All @@ -52,9 +52,9 @@ open class BrukernotifikasjonService(
}

private fun sendVarsel(skalSendes: SkalSendes) {
val offset: Long = brukernotifikasjonProducer.send(skalSendes)
val offset: Long = minsideVarselProducer.send(skalSendes)
log.debug(
"Brukernotifikasjon {} med type {} publisert med offset {}",
"Minside varsel {} med type {} publisert med offset {}",
skalSendes.varselId.toString(),
skalSendes.varselType.brukernotifikasjonType.name,
offset
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package no.nav.veilarbaktivitet.oppfolging.periode

import no.nav.veilarbaktivitet.aktivitet.AktivitetService
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService
import no.nav.veilarbaktivitet.oppfolging.client.MålDTO
import no.nav.veilarbaktivitet.oppfolging.client.OppfolgingClient
import no.nav.veilarbaktivitet.oppfolging.client.OppfolgingPeriodeMinimalDTO
Expand All @@ -17,7 +17,7 @@ import java.util.*
@Service
class OppfolgingsperiodeService(
private val aktivitetService: AktivitetService,
private val brukernotifikasjonService: BrukernotifikasjonService,
private val minsideVarselService: MinsideVarselService,
private val sistePeriodeDAO: SistePeriodeDAO,
private val oppfolgingsperiodeDAO: OppfolgingsperiodeDAO,
private val oppfolgingClient: OppfolgingClient
Expand All @@ -29,7 +29,7 @@ class OppfolgingsperiodeService(
}

fun avsluttOppfolgingsperiode(oppfolgingsperiode: UUID, sluttDato: ZonedDateTime) {
brukernotifikasjonService.setDoneGrupperingsID(oppfolgingsperiode)
minsideVarselService.setDoneGrupperingsID(oppfolgingsperiode)
aktivitetService.settAktiviteterTilHistoriske(oppfolgingsperiode, sluttDato)
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@
import no.nav.veilarbaktivitet.avtalt_med_nav.ForhaandsorienteringDAO;
import no.nav.veilarbaktivitet.avtalt_med_nav.ForhaandsorienteringDTO;
import no.nav.veilarbaktivitet.avtalt_med_nav.Type;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonProducer;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselProducer;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.brukernotifikasjon.varsel.VarselDAO;
import no.nav.veilarbaktivitet.config.database.Database;
import no.nav.veilarbaktivitet.db.DbTestUtils;
Expand Down Expand Up @@ -61,9 +61,9 @@ class ArenaControllerTest {

private final JdbcTemplate jdbc = new JdbcTemplate(LocalDatabaseSingleton.INSTANCE.getPostgres());
private final Database db = new Database(jdbc);
private final BrukernotifikasjonProducer brukernotifikasjonProducer = mock(BrukernotifikasjonProducer.class);
private final MinsideVarselProducer minsideVarselProducer = mock(MinsideVarselProducer.class);
private final VarselDAO varselDAO = mock(VarselDAO.class);
private final BrukernotifikasjonService brukernotifikasjonArenaAktivitetService = new BrukernotifikasjonService(brukernotifikasjonProducer,
private final MinsideVarselService brukernotifikasjonArenaAktivitetService = new MinsideVarselService(minsideVarselProducer,
varselDAO, aktivitetDAO, manuellStatusClient, personService, aktivitetsplanBasepath, sistePeriodeService);
private final ForhaandsorienteringDAO fhoDao = new ForhaandsorienteringDAO(db.getNamedJdbcTemplate());
private final IdMappingDAO idMappingDAO = new IdMappingDAO(new NamedParameterJdbcTemplate(jdbc));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import no.nav.veilarbaktivitet.avtalt_med_nav.Forhaandsorientering;
import no.nav.veilarbaktivitet.avtalt_med_nav.ForhaandsorienteringDAO;
import no.nav.veilarbaktivitet.avtalt_med_nav.Type;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.oppfolging.periode.OppfolgingsperiodeDAO;
import no.nav.veilarbaktivitet.person.PersonService;
import org.junit.jupiter.api.Test;
Expand All @@ -18,7 +18,7 @@
import java.util.Date;
import java.util.List;

import static org.junit.jupiter.api.Assertions.*;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.mockito.Mockito.mock;

class ArenaServiceTest {
Expand All @@ -28,7 +28,7 @@ class ArenaServiceTest {
var arenaService = new ArenaService(
mock(ForhaandsorienteringDAO.class),
mock(MeterRegistry.class),
mock(BrukernotifikasjonService.class),
mock(MinsideVarselService.class),
mock(VeilarbarenaClient.class),
mock(IdMappingDAO.class),
mock(PersonService.class),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
import no.nav.veilarbaktivitet.aktivitet.domain.AktivitetTypeData;
import no.nav.veilarbaktivitet.aktivitet.dto.AktivitetDTO;
import no.nav.veilarbaktivitet.aktivitet.mappers.AktivitetDTOMapper;
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService;
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService;
import no.nav.veilarbaktivitet.db.DbTestUtils;
import no.nav.veilarbaktivitet.person.Innsender;
import no.nav.veilarbaktivitet.person.Person;
Expand Down Expand Up @@ -59,7 +59,7 @@ class ForhaandsorienteringDTOControllerTest {
private IAuthService authService;

@Mock
private BrukernotifikasjonService brukernotifikasjonService;
private MinsideVarselService brukernotifikasjonService;

private final MeterRegistry meterRegistry = new SimpleMeterRegistry();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@

class BrukernotifikasjonTest extends SpringBootTestBase {
@Autowired
BrukernotifikasjonService brukernotifikasjonService;
MinsideVarselService brukernotifikasjonService;

@Autowired
AvsluttBrukernotifikasjonCron avsluttBrukernotifikasjonCron;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package no.nav.veilarbaktivitet.aktivitetskort.service

import no.nav.veilarbaktivitet.aktivitet.AktivitetService
import no.nav.veilarbaktivitet.brukernotifikasjon.BrukernotifikasjonService
import no.nav.veilarbaktivitet.brukernotifikasjon.MinsideVarselService
import no.nav.veilarbaktivitet.oppfolging.client.OppfolgingClient
import no.nav.veilarbaktivitet.oppfolging.periode.*
import no.nav.veilarbaktivitet.person.Person
Expand All @@ -16,7 +16,7 @@ import java.util.*
class OppfolgingsperiodeServiceTest {
private lateinit var oppfolgingClient: OppfolgingClient
private lateinit var aktivitetService: AktivitetService
private lateinit var brukernotifikasjonService: BrukernotifikasjonService
private lateinit var minsideVarselService: MinsideVarselService
private lateinit var sistePeriodeDAO: SistePeriodeDAO
private lateinit var oppfolgingsperiodeDAO: OppfolgingsperiodeDAO

Expand All @@ -32,10 +32,10 @@ class OppfolgingsperiodeServiceTest {
fun setup() {
oppfolgingClient = Mockito.mock(OppfolgingClient::class.java)
aktivitetService = Mockito.mock(AktivitetService::class.java)
brukernotifikasjonService = Mockito.mock(BrukernotifikasjonService::class.java)
minsideVarselService = Mockito.mock(MinsideVarselService::class.java)
sistePeriodeDAO = Mockito.mock(SistePeriodeDAO::class.java)
oppfolgingsperiodeDAO = Mockito.mock(OppfolgingsperiodeDAO::class.java)
oppfolgingsperiodeService = OppfolgingsperiodeService(aktivitetService, brukernotifikasjonService, sistePeriodeDAO, oppfolgingsperiodeDAO, oppfolgingClient)
oppfolgingsperiodeService = OppfolgingsperiodeService(aktivitetService, minsideVarselService, sistePeriodeDAO, oppfolgingsperiodeDAO, oppfolgingClient)
}

@Test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,16 @@ import no.nav.veilarbaktivitet.brukernotifikasjon.kvittering.VarselKvitteringSta
import no.nav.veilarbaktivitet.brukernotifikasjon.opprettVarsel.AktivitetVarsel
import no.nav.veilarbaktivitet.brukernotifikasjon.varsel.SendBrukernotifikasjonCron
import no.nav.veilarbaktivitet.brukernotifikasjon.varsel.VarselDAO
import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.*
import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.EksternVarselHendelseDTO
import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.EksternVarselKanal
import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.EksternVarselStatus
import no.nav.veilarbaktivitet.brukernotifikasjon.varselStatusHendelse.VarselEventTypeDto
import no.nav.veilarbaktivitet.db.DbTestUtils
import no.nav.veilarbaktivitet.mock_nav_modell.MockBruker
import no.nav.veilarbaktivitet.mock_nav_modell.NavMockService
import no.nav.veilarbaktivitet.testutils.AktivitetDataTestBuilder
import no.nav.veilarbaktivitet.util.KafkaTestService
import org.apache.kafka.clients.consumer.Consumer
import org.apache.kafka.clients.consumer.ConsumerRecord
import org.junit.jupiter.api.AfterEach
import org.junit.jupiter.api.Assertions
import org.junit.jupiter.api.BeforeEach
Expand All @@ -34,7 +36,7 @@ import java.util.*

internal class BrukerVarselHendelseTest(
@Autowired
val brukernotifikasjonService: BrukernotifikasjonService,
val minsideVarselService: MinsideVarselService,
@Autowired
val avsluttBrukernotifikasjonCron: AvsluttBrukernotifikasjonCron,
@Autowired
Expand Down Expand Up @@ -191,7 +193,7 @@ internal class BrukerVarselHendelseTest(
// }

private fun opprettOppgave(mockBruker: MockBruker, aktivitetDTO: AktivitetDTO): OpprettVarselDto {
brukernotifikasjonService.opprettVarselPaaAktivitet(
minsideVarselService.opprettVarselPaaAktivitet(
AktivitetVarsel(
aktivitetDTO.id.toLong(),
aktivitetDTO.versjon.toLong(),
Expand Down

0 comments on commit 79c14b8

Please sign in to comment.