Skip to content

15 sek vent timeout #1462

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
palfi merged 1 commit into from
Nov 4, 2024
Merged

15 sek vent timeout #1462

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions ...ain/java/no/nav/foreldrepenger/autotest/aktoerer/innsender/DokumentInnsendingHjelper.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ protected Saksnummer ventTilAlleInntekstmeldingeneErMottatt(Fødselsnummer fnr,
final var saksnummerTemp = saksnummer;
var forventetAntallInnteksmeldinger = antallGamleInntekstmeldinger + antallNyeInntektsmeldinger;
Vent.til(() -> antallInntektsmeldingerMottattPåSak(saksnummerTemp) == forventetAntallInnteksmeldinger,
60, String.format("Forventet at det ble mottatt %d ny(e) inntektsmelding(er), men det ble "
String.format("Forventet at det ble mottatt %d ny(e) inntektsmelding(er), men det ble "
+ "bare mottatt %d på saksnummer %s", antallNyeInntektsmeldinger,
(antallInntektsmeldingerMottattPåSak(saksnummerTemp) - antallGamleInntekstmeldinger),
saksnummer.value()));
Expand Down Expand Up @@ -94,7 +94,7 @@ protected Saksnummer ventTilFagsakOgBehandlingErOpprettet(Fødselsnummer fnr, Lo
}
}
return null;
}, 30, "Det er hverken opprettet en ny fagsak eller oppdatert en eksistrende fagsak etter innsending. "
}, "Det er hverken opprettet en ny fagsak eller oppdatert en eksistrende fagsak etter innsending. "
+ "Noe har gått galt ved innsending av søknad/inntektsmelding på søker med fnr " + fnr.value());
}

Expand All @@ -119,7 +119,7 @@ protected Saksnummer ventTilFagsakOgBehandlingErOpprettet(Fødselsnummer fnr, Lo
return tempSaksnummer;
}
return null;
}, 30, "Ingen fagsak opprettet på sak");
}, "Ingen fagsak opprettet på sak");
}

private List<HistorikkInnslag> historikkinnslagEtterSkjæringstidspunkt(Saksnummer saksnummer, LocalDateTime skjæringstidpunktRundetNed) {
Expand Down
11 changes: 5 additions & 6 deletions src/main/java/no/nav/foreldrepenger/autotest/aktoerer/innsyn/Innsyn.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@
public class Innsyn {
private static final Logger LOG = LoggerFactory.getLogger(Innsyn.class);
private static final int PROGRESSIV_VENTETID = 3000;
private static final int TIMEOUT = 30;

private final InnsynKlient innsynKlient;
private final Fødselsnummer fnr;
Expand All @@ -42,7 +41,7 @@ private Saker hentSaker() {
return null;
}
return sak.get();
}, TIMEOUT, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID);
}, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID);
}

public SvpSak hentSvpSakMedÅpenBehandlingTilstand(Saksnummer saksnummer, BehandlingTilstand behandlingTilstand) {
Expand All @@ -56,7 +55,7 @@ private Saker hentSaker() {
return null;
}
return sak.get();
}, TIMEOUT, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID);
}, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID);
}

public EsSak hentEsSakUtenÅpenBehandling(Saksnummer saksnummer) {
Expand All @@ -70,7 +69,7 @@ private Saker hentSaker() {
return null;
}
return sak.get();
}, TIMEOUT, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
}, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
}

public SvpSak hentSvpSakUtenÅpenBehandling(Saksnummer saksnummer) {
Expand All @@ -84,7 +83,7 @@ private Saker hentSaker() {
return null;
}
return sak.get();
}, TIMEOUT, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
}, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
}

public FpSak hentFpSakUtenÅpenBehandling(Saksnummer saksnummer) {
Expand All @@ -98,6 +97,6 @@ private Saker hentSaker() {
return null;
}
return sak.get();
}, TIMEOUT, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
}, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
}
}
46 changes: 23 additions & 23 deletions src/main/java/no/nav/foreldrepenger/autotest/aktoerer/saksbehandler/fpsak/Saksbehandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ private void ventTilFagsakstatus(FagsakStatus... status) {
Vent.til(() -> {
refreshFagsak(valgtFagsak.saksnummer());
return harFagsakstatus(status);
}, 10, "Fagsak har ikke status " + Set.of(status));
}, "Fagsak har ikke status " + Set.of(status));
}

private boolean harFagsakstatus(FagsakStatus... status) {
Expand Down Expand Up @@ -233,7 +233,7 @@ public boolean harRevurderingBehandling() {
.orElseThrow();
}
return null; // Vi har matchede behandlinger, men ikke av forventet antall!
}, 30, "Saken har ikke fått behandling av type: " + behandlingstype);
}, "Saken har ikke fått behandling av type: " + behandlingstype);

// 2) Hvis vi venter på en REVURDERING og behandling er køet, men ikke gjennopptatt venter vi til AP 7011 er utført.
if (BehandlingType.REVURDERING.equals(behandlingstype) && erBehandlingKøetOgIkkeGjenopptatt(behandling.uuid)) {
Expand All @@ -243,7 +243,7 @@ public boolean harRevurderingBehandling() {
.orElseThrow()
.getStatus()
.equals("UTFO")
, 30, "Køet behandling er ikke gjenopptatt av fpsak!");
, "Køet behandling er ikke gjenopptatt av fpsak!");
}

// 3) Venter til enten behandling avsluttet eller det har oppstått et aksjonspunkt
Expand Down Expand Up @@ -282,7 +282,7 @@ private boolean harBehandling(BehandlingType behandlingstype, BehandlingÅrsakTy
*/
public void ventTilBehandlingsstatus(BehandlingStatus forventetStatus) {
debugBehandlingsstatus(forventetStatus, valgtBehandling.uuid);
venterPåFerdigProssesseringOgOppdaterBehandling(valgtBehandling.uuid);
venterPåFerdigProssesseringOgOppdaterBehandling(valgtBehandling.uuid, valgtBehandling.id);
var behandlingsstatus = getBehandlingsstatus();
if (forventetStatus.equals(behandlingsstatus)) {
return;
Expand All @@ -305,15 +305,15 @@ public BehandlingStatus getBehandlingsstatus() {
}

private void venterPåFerdigProssesseringOgOppdaterBehandling(Behandling behandling) {
venterPåFerdigProssesseringOgOppdaterBehandling(behandling.uuid);
venterPåFerdigProssesseringOgOppdaterBehandling(behandling.uuid, behandling.id);
}

private void venterPåFerdigProssesseringOgOppdaterBehandling(UUID behandlingsuuid) {
private void venterPåFerdigProssesseringOgOppdaterBehandling(UUID behandlingsuuid, int behandlingId) {
// Sjekker om behandlingen prosesserer. Siden vi vil vente på at den er ferdig for å få den siste
// behandling.versjon. Og å hindre at tester henter data fra behandlingen som kan endre seg ettersom
// behandlingen ikke har stoppet opp

valgtBehandling = ventTilBehandlingErFerdigProsessertOgReturner(behandlingsuuid);
valgtBehandling = ventTilBehandlingErFerdigProsessertOgReturner(behandlingsuuid, behandlingId);

// TODO: fiks dette!
oppdaterLazyFelterForBehandling();
Expand All @@ -332,9 +332,9 @@ private void oppdaterLazyFelterForBehandling() {
* Status endepunktet i fpsak fungerer med unntak når saken er satt på vent. Hvis vi sjekke status før behandlingen er
* gjenopptatt, vil den bare returnere behandlingen før prosesseringene er ferdig. Må legge inn noe spesiallokikk for håndtering av dette.
*/
private Behandling ventTilBehandlingErFerdigProsessertOgReturner(UUID behandlinguuid) {
return Vent.på(() -> behandlingerKlient.hentBehandlingHvisTilgjenglig(behandlinguuid), 90, () -> {
var prosessTasker = hentProsesstaskerForBehandling(behandlinguuid);
private Behandling ventTilBehandlingErFerdigProsessertOgReturner(UUID behandlinguuid, int behandlingId) {
return Vent.på(() -> behandlingerKlient.hentBehandlingHvisTilgjenglig(behandlinguuid), () -> {
var prosessTasker = hentProsesstaskerForBehandling(behandlingId);
var prosessTaskList = new StringBuilder();
for (ProsessTaskDataDto prosessTaskListItemDto : prosessTasker) {
prosessTaskList.append(prosessTaskListItemDto.getTaskType())
Expand All @@ -346,9 +346,9 @@ private Behandling ventTilBehandlingErFerdigProsessertOgReturner(UUID behandling
});
}

private List<ProsessTaskDataDto> hentProsesstaskerForBehandling(UUID behandlingsuuid) {
private List<ProsessTaskDataDto> hentProsesstaskerForBehandling(int behandlingId) {
return prosesstaskKlient.alleProsesstaskPåBehandling().stream()
.filter(p -> Objects.equals(behandlingsuuid.toString(), p.getTaskParametre().getProperty("behandlingId")))
.filter(p -> Objects.equals(String.valueOf(behandlingId), p.getTaskParametre().getProperty("behandlingId")))
.toList();
}

Expand Down Expand Up @@ -384,7 +384,7 @@ private void populateBehandling(Behandling behandling) {
Vent.til(() -> {
refreshBehandling();
return valgtBehandling.behandlingPaaVent;
}, 60, "Behandling kom aldri på vent");
}, "Behandling kom aldri på vent");
}

@Step("Setter behandling på vent")
Expand Down Expand Up @@ -579,8 +579,8 @@ public void ventTilAvsluttetBehandling() {
* Venter da til den er gjenopprettet, for så og vente på potensiell prosessering.
*/
if (hentHistorikkinnslagPåBehandling().stream().anyMatch(h -> h.type().equals(HistorikkinnslagType.BEH_VENT))) {
Vent.til(() -> hentHistorikkinnslagPåBehandling().stream().anyMatch(h -> GJENOPPTATT.contains(h.type()))
,10, "Behandlingen er på vent og er ikke blitt gjenopptatt!");
Vent.til(() -> hentHistorikkinnslagPåBehandling().stream().anyMatch(h -> GJENOPPTATT.contains(h.type())),
"Behandlingen er på vent og er ikke blitt gjenopptatt!");
}

ventTilBehandlingsstatus(BehandlingStatus.AVSLUTTET);
Expand Down Expand Up @@ -633,29 +633,29 @@ public void ventTilAvsluttetBehandlingOgDetOpprettesTilbakekreving() {
}

public HistorikkInnslag hentHistorikkinnslagAvType(HistorikkinnslagType type) {
return hentHistorikkinnslagAvType(type, valgtBehandling.uuid);
return hentHistorikkinnslagAvType(type, valgtBehandling.uuid, valgtBehandling.id);
}

public HistorikkInnslag hentHistorikkinnslagAvType(HistorikkinnslagType type, UUID behandlingsId) {
venterPåFerdigProssesseringOgOppdaterBehandling(behandlingsId);
public HistorikkInnslag hentHistorikkinnslagAvType(HistorikkinnslagType type, UUID behandlingsUuid, int behandlingId) {
venterPåFerdigProssesseringOgOppdaterBehandling(behandlingsUuid, behandlingId);
if (List.of(HistorikkinnslagType.VEDLEGG_MOTTATT, HistorikkinnslagType.REVURD_OPPR).contains(type)) {
behandlingsId = null;
behandlingsUuid = null;
}
return hentHistorikkinnslagPåBehandling(behandlingsId).stream()
return hentHistorikkinnslagPåBehandling(behandlingsUuid).stream()
.filter(innslag -> type.equals(innslag.type()))
.findFirst()
.orElse(null);
}

public void ventTilHistorikkinnslag(HistorikkinnslagType type) {
Vent.til(() -> harHistorikkinnslagPåBehandling(type),
45, () -> "Saken hadde ikke historikkinslag " + type + "\nHistorikkInnslag:"
() -> "Saken hadde ikke historikkinslag " + type + "\nHistorikkInnslag:"
+ String.join("\t\n", String.valueOf(hentHistorikkinnslagPåBehandling())));
}

public void ventTilHistorikkinnslag(Set<HistorikkinnslagType> typer) {
Vent.til(() -> harHistorikkinnslagPåBehandling(typer),
45, () -> "Saken hadde ikke historikkinslag " + typer + "\nHistorikkInnslag:"
() -> "Saken hadde ikke historikkinslag " + typer + "\nHistorikkInnslag:"
+ String.join("\t\n", String.valueOf(hentHistorikkinnslagPåBehandling())));
}

Expand Down Expand Up @@ -691,7 +691,7 @@ public void ventTilRisikoKlassefiseringsstatus(RisikoklasseType forventetRisikok
Vent.til(() -> {
var response = risikovurderingKlient.getRisikovurdering(valgtBehandling.uuid);
return response.risikoklasse().equals(forventetRisikoklasse);
}, 45, "Har ikke riktig risikoklassifiseringsstatus");
}, "Har ikke riktig risikoklassifiseringsstatus");
}

/* VERIFISERINGER */
Expand Down
14 changes: 7 additions & 7 deletions ...foreldrepenger/autotest/aktoerer/saksbehandler/fptilbake/TilbakekrevingSaksbehandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ public void hentSisteBehandling(Saksnummer saksnummer, BehandlingType behandling
.orElseThrow();
}
return null; // Vi har matchede behandlinger, men ikke av forventet antall!
}, 30, "Saken har ikke fått behandling av type: " + behandlingstype);
}, "Saken har ikke fått behandling av type: " + behandlingstype);

// 3) Venter til enten behandling avsluttet eller det har oppstått et aksjonspunkt
venterPåFerdigProssesseringOgOppdaterBehandling(behandling.uuid);
Expand Down Expand Up @@ -244,7 +244,7 @@ public void behandleAksjonspunkt(AksjonspunktBekreftelse aksjonspunktBekreftelse
Vent.til(() -> {
refreshBehandling();
return valgtBehandling.behandlingPaaVent;
}, 60, "Behandling kom aldri på vent");
}, "Behandling kom aldri på vent");
}

public void ventTilBehandlingHarAktivtAksjonspunkt(int aksjonspunktKode) {
Expand All @@ -255,7 +255,7 @@ public void ventTilBehandlingHarAktivtAksjonspunkt(int aksjonspunktKode) {
Vent.til(() -> {
venterPåFerdigProssesseringOgOppdaterBehandling(valgtBehandling.uuid);
return harAktivtAksjonspunkt(aksjonspunktKode);
}, 60, "Aksjonspunkt" + aksjonspunktKode + "ble aldri oppnådd");
}, "Aksjonspunkt" + aksjonspunktKode + "ble aldri oppnådd");
}

public void ventTilBehandlingsstatus(BehandlingStatus forventetStatus) {
Expand Down Expand Up @@ -293,8 +293,8 @@ public void ventTilAvsluttetBehandling() {
* Venter da til den er gjenopprettet, for så og vente på potensiell prosessering.
*/
if (hentHistorikkinnslagPåBehandling().stream().anyMatch(h -> h.type().equals(HistorikkinnslagType.BEH_VENT))) {
Vent.til(() -> hentHistorikkinnslagPåBehandling().stream().anyMatch(h -> GJENOPPTATT.contains(h.type()))
,10, "Behandlingen er på vent og er ikke blitt gjenopptatt!");
Vent.til(() -> hentHistorikkinnslagPåBehandling().stream().anyMatch(h -> GJENOPPTATT.contains(h.type())),
"Behandlingen er på vent og er ikke blitt gjenopptatt!");
}

ventTilBehandlingsstatus(BehandlingStatus.AVSLUTTET);
Expand All @@ -311,7 +311,7 @@ public void ventTilAvsluttetBehandling() {
* gjenopptatt, vil den bare returnere behandlingen før prosesseringene er ferdig. Må legge inn noe spesiallokikk for håndtering av dette.
*/
private Behandling ventTilBehandlingErFerdigProsessertOgReturner(UUID behandlinguuid) {
return Vent.på(() -> behandlingerKlient.hentBehandlingHvisTilgjenglig(behandlinguuid), 90, () -> {
return Vent.på(() -> behandlingerKlient.hentBehandlingHvisTilgjenglig(behandlinguuid), () -> {
var prosessTasker = hentProsesstaskerForBehandling(behandlinguuid);
var prosessTaskList = new StringBuilder();
for (ProsessTaskDataDto prosessTaskListItemDto : prosessTasker) {
Expand All @@ -335,6 +335,6 @@ private List<ProsessTaskDataDto> hentProsesstaskerForBehandling(UUID behandlings
var prosessTaskOpprettInputDto = new ProsessTaskOpprettInputDto();
prosessTaskOpprettInputDto.setTaskType("batch.automatisk.saksbehandling");
prosesstaskKlient.create(prosessTaskOpprettInputDto);
Vent.til(() -> hentAksjonspunkt(autopunkt) == null, 10, "Kravgrunnlag skal være sendt og plukket opp av batch!");
Vent.til(() -> hentAksjonspunkt(autopunkt) == null, "Kravgrunnlag skal være sendt og plukket opp av batch!");
}
}
16 changes: 0 additions & 16 deletions ...ava/no/nav/foreldrepenger/autotest/klienter/fpsak/behandlinger/BehandlingFpsakKlient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.Behandling;
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.KlageInfo;
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.Soknad;
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.Vilkar;
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.arbeidInntektsmelding.ArbeidOgInntektsmeldingDto;
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.arbeidInntektsmelding.ManglendeOpplysningerVurderingDto;
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.arbeidInntektsmelding.ManueltArbeidsforholdDto;
Expand Down Expand Up @@ -214,21 +213,6 @@ public Feriepengegrunnlag behandlingFeriepengegrunnlag(UUID behandlingUuid) {
return send(request.build(), Feriepengegrunnlag.class);
}


public List<Vilkar> behandlingVilkår(UUID behandlingUuid) {
var request = requestMedInnloggetSaksbehandler(this.saksbehandlerRolle, API_NAME)
.uri(fromUri(FPSAK_BASE)
.path(BEHANDLING_VILKAAR_URL)
.queryParam(UUID_NAME, behandlingUuid)
.build())
.GET();
return Optional.ofNullable(send(request.build(), new TypeReference<List<Vilkar>>() {}))
.orElse(List.of());
}




public void overstyr(OverstyrAksjonspunkter aksjonspunkter) {
var request = requestMedInnloggetSaksbehandler(this.saksbehandlerRolle, API_NAME)
.uri(fromUri(FPSAK_BASE)
Expand Down
2 changes: 1 addition & 1 deletion ...va/no/nav/foreldrepenger/autotest/klienter/fpsak/behandlinger/BehandlingKlientFelles.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,7 @@ public void postBehandlingAksjonspunkt(BekreftedeAksjonspunkter aksjonspunkter)
var requestTilStatusEndepunkt = requestMedInnloggetSaksbehandler(this.saksbehandlerRolle, this.apiName)
.uri(URI.create(hentRedirectUriFraLocationHeader(response)))
.GET();
return Vent.på(() -> getBehandlingHvisTilgjenglig(requestTilStatusEndepunkt), 30,
return Vent.på(() -> getBehandlingHvisTilgjenglig(requestTilStatusEndepunkt),
"Behandling ikke tilgjenglig etter X sekund");
}
throw new RuntimeException("Uventet tilstand. Skal ikke være mulig!");
Expand Down
Loading