Skip to content

Commit 050b9be

Browse files
authored
15 sek vent timeout (#1462)
1 parent 29989c4 commit 050b9be

File tree

8 files changed

+55
-72
lines changed

8 files changed

+55
-72
lines changed

src/main/java/no/nav/foreldrepenger/autotest/aktoerer/innsender/DokumentInnsendingHjelper.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ protected Saksnummer ventTilAlleInntekstmeldingeneErMottatt(Fødselsnummer fnr,
4848
final var saksnummerTemp = saksnummer;
4949
var forventetAntallInnteksmeldinger = antallGamleInntekstmeldinger + antallNyeInntektsmeldinger;
5050
Vent.til(() -> antallInntektsmeldingerMottattPåSak(saksnummerTemp) == forventetAntallInnteksmeldinger,
51-
60, String.format("Forventet at det ble mottatt %d ny(e) inntektsmelding(er), men det ble "
51+
String.format("Forventet at det ble mottatt %d ny(e) inntektsmelding(er), men det ble "
5252
+ "bare mottatt %d på saksnummer %s", antallNyeInntektsmeldinger,
5353
(antallInntektsmeldingerMottattPåSak(saksnummerTemp) - antallGamleInntekstmeldinger),
5454
saksnummer.value()));
@@ -94,7 +94,7 @@ protected Saksnummer ventTilFagsakOgBehandlingErOpprettet(Fødselsnummer fnr, Lo
9494
}
9595
}
9696
return null;
97-
}, 30, "Det er hverken opprettet en ny fagsak eller oppdatert en eksistrende fagsak etter innsending. "
97+
}, "Det er hverken opprettet en ny fagsak eller oppdatert en eksistrende fagsak etter innsending. "
9898
+ "Noe har gått galt ved innsending av søknad/inntektsmelding på søker med fnr " + fnr.value());
9999
}
100100

@@ -119,7 +119,7 @@ protected Saksnummer ventTilFagsakOgBehandlingErOpprettet(Fødselsnummer fnr, Lo
119119
return tempSaksnummer;
120120
}
121121
return null;
122-
}, 30, "Ingen fagsak opprettet på sak");
122+
}, "Ingen fagsak opprettet på sak");
123123
}
124124

125125
private List<HistorikkInnslag> historikkinnslagEtterSkjæringstidspunkt(Saksnummer saksnummer, LocalDateTime skjæringstidpunktRundetNed) {

src/main/java/no/nav/foreldrepenger/autotest/aktoerer/innsyn/Innsyn.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
public class Innsyn {
1717
private static final Logger LOG = LoggerFactory.getLogger(Innsyn.class);
1818
private static final int PROGRESSIV_VENTETID = 3000;
19-
private static final int TIMEOUT = 30;
2019

2120
private final InnsynKlient innsynKlient;
2221
private final Fødselsnummer fnr;
@@ -42,7 +41,7 @@ private Saker hentSaker() {
4241
return null;
4342
}
4443
return sak.get();
45-
}, TIMEOUT, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID);
44+
}, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID);
4645
}
4746

4847
public SvpSak hentSvpSakMedÅpenBehandlingTilstand(Saksnummer saksnummer, BehandlingTilstand behandlingTilstand) {
@@ -56,7 +55,7 @@ private Saker hentSaker() {
5655
return null;
5756
}
5857
return sak.get();
59-
}, TIMEOUT, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID);
58+
}, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID);
6059
}
6160

6261
public EsSak hentEsSakUtenÅpenBehandling(Saksnummer saksnummer) {
@@ -70,7 +69,7 @@ private Saker hentSaker() {
7069
return null;
7170
}
7271
return sak.get();
73-
}, TIMEOUT, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
72+
}, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
7473
}
7574

7675
public SvpSak hentSvpSakUtenÅpenBehandling(Saksnummer saksnummer) {
@@ -84,7 +83,7 @@ private Saker hentSaker() {
8483
return null;
8584
}
8685
return sak.get();
87-
}, TIMEOUT, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
86+
}, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
8887
}
8988

9089
public FpSak hentFpSakUtenÅpenBehandling(Saksnummer saksnummer) {
@@ -98,6 +97,6 @@ private Saker hentSaker() {
9897
return null;
9998
}
10099
return sak.get();
101-
}, TIMEOUT, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
100+
}, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID);
102101
}
103102
}

src/main/java/no/nav/foreldrepenger/autotest/aktoerer/saksbehandler/fpsak/Saksbehandler.java

Lines changed: 23 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ private void ventTilFagsakstatus(FagsakStatus... status) {
131131
Vent.til(() -> {
132132
refreshFagsak(valgtFagsak.saksnummer());
133133
return harFagsakstatus(status);
134-
}, 10, "Fagsak har ikke status " + Set.of(status));
134+
}, "Fagsak har ikke status " + Set.of(status));
135135
}
136136

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

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

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

307307
private void venterPåFerdigProssesseringOgOppdaterBehandling(Behandling behandling) {
308-
venterPåFerdigProssesseringOgOppdaterBehandling(behandling.uuid);
308+
venterPåFerdigProssesseringOgOppdaterBehandling(behandling.uuid, behandling.id);
309309
}
310310

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

316-
valgtBehandling = ventTilBehandlingErFerdigProsessertOgReturner(behandlingsuuid);
316+
valgtBehandling = ventTilBehandlingErFerdigProsessertOgReturner(behandlingsuuid, behandlingId);
317317

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

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

@@ -384,7 +384,7 @@ private void populateBehandling(Behandling behandling) {
384384
Vent.til(() -> {
385385
refreshBehandling();
386386
return valgtBehandling.behandlingPaaVent;
387-
}, 60, "Behandling kom aldri på vent");
387+
}, "Behandling kom aldri på vent");
388388
}
389389

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

586586
ventTilBehandlingsstatus(BehandlingStatus.AVSLUTTET);
@@ -633,29 +633,29 @@ public void ventTilAvsluttetBehandlingOgDetOpprettesTilbakekreving() {
633633
}
634634

635635
public HistorikkInnslag hentHistorikkinnslagAvType(HistorikkinnslagType type) {
636-
return hentHistorikkinnslagAvType(type, valgtBehandling.uuid);
636+
return hentHistorikkinnslagAvType(type, valgtBehandling.uuid, valgtBehandling.id);
637637
}
638638

639-
public HistorikkInnslag hentHistorikkinnslagAvType(HistorikkinnslagType type, UUID behandlingsId) {
640-
venterPåFerdigProssesseringOgOppdaterBehandling(behandlingsId);
639+
public HistorikkInnslag hentHistorikkinnslagAvType(HistorikkinnslagType type, UUID behandlingsUuid, int behandlingId) {
640+
venterPåFerdigProssesseringOgOppdaterBehandling(behandlingsUuid, behandlingId);
641641
if (List.of(HistorikkinnslagType.VEDLEGG_MOTTATT, HistorikkinnslagType.REVURD_OPPR).contains(type)) {
642-
behandlingsId = null;
642+
behandlingsUuid = null;
643643
}
644-
return hentHistorikkinnslagPåBehandling(behandlingsId).stream()
644+
return hentHistorikkinnslagPåBehandling(behandlingsUuid).stream()
645645
.filter(innslag -> type.equals(innslag.type()))
646646
.findFirst()
647647
.orElse(null);
648648
}
649649

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

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

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

697697
/* VERIFISERINGER */

src/main/java/no/nav/foreldrepenger/autotest/aktoerer/saksbehandler/fptilbake/TilbakekrevingSaksbehandler.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ public void hentSisteBehandling(Saksnummer saksnummer, BehandlingType behandling
139139
.orElseThrow();
140140
}
141141
return null; // Vi har matchede behandlinger, men ikke av forventet antall!
142-
}, 30, "Saken har ikke fått behandling av type: " + behandlingstype);
142+
}, "Saken har ikke fått behandling av type: " + behandlingstype);
143143

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

250250
public void ventTilBehandlingHarAktivtAksjonspunkt(int aksjonspunktKode) {
@@ -255,7 +255,7 @@ public void ventTilBehandlingHarAktivtAksjonspunkt(int aksjonspunktKode) {
255255
Vent.til(() -> {
256256
venterPåFerdigProssesseringOgOppdaterBehandling(valgtBehandling.uuid);
257257
return harAktivtAksjonspunkt(aksjonspunktKode);
258-
}, 60, "Aksjonspunkt" + aksjonspunktKode + "ble aldri oppnådd");
258+
}, "Aksjonspunkt" + aksjonspunktKode + "ble aldri oppnådd");
259259
}
260260

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

300300
ventTilBehandlingsstatus(BehandlingStatus.AVSLUTTET);
@@ -311,7 +311,7 @@ public void ventTilAvsluttetBehandling() {
311311
* gjenopptatt, vil den bare returnere behandlingen før prosesseringene er ferdig. Må legge inn noe spesiallokikk for håndtering av dette.
312312
*/
313313
private Behandling ventTilBehandlingErFerdigProsessertOgReturner(UUID behandlinguuid) {
314-
return Vent.(() -> behandlingerKlient.hentBehandlingHvisTilgjenglig(behandlinguuid), 90, () -> {
314+
return Vent.(() -> behandlingerKlient.hentBehandlingHvisTilgjenglig(behandlinguuid), () -> {
315315
var prosessTasker = hentProsesstaskerForBehandling(behandlinguuid);
316316
var prosessTaskList = new StringBuilder();
317317
for (ProsessTaskDataDto prosessTaskListItemDto : prosessTasker) {
@@ -335,6 +335,6 @@ private List<ProsessTaskDataDto> hentProsesstaskerForBehandling(UUID behandlings
335335
var prosessTaskOpprettInputDto = new ProsessTaskOpprettInputDto();
336336
prosessTaskOpprettInputDto.setTaskType("batch.automatisk.saksbehandling");
337337
prosesstaskKlient.create(prosessTaskOpprettInputDto);
338-
Vent.til(() -> hentAksjonspunkt(autopunkt) == null, 10, "Kravgrunnlag skal være sendt og plukket opp av batch!");
338+
Vent.til(() -> hentAksjonspunkt(autopunkt) == null, "Kravgrunnlag skal være sendt og plukket opp av batch!");
339339
}
340340
}

src/main/java/no/nav/foreldrepenger/autotest/klienter/fpsak/behandlinger/BehandlingFpsakKlient.java

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.Behandling;
3131
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.KlageInfo;
3232
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.Soknad;
33-
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.Vilkar;
3433
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.arbeidInntektsmelding.ArbeidOgInntektsmeldingDto;
3534
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.arbeidInntektsmelding.ManglendeOpplysningerVurderingDto;
3635
import no.nav.foreldrepenger.autotest.klienter.fpsak.behandlinger.dto.behandling.arbeidInntektsmelding.ManueltArbeidsforholdDto;
@@ -214,21 +213,6 @@ public Feriepengegrunnlag behandlingFeriepengegrunnlag(UUID behandlingUuid) {
214213
return send(request.build(), Feriepengegrunnlag.class);
215214
}
216215

217-
218-
public List<Vilkar> behandlingVilkår(UUID behandlingUuid) {
219-
var request = requestMedInnloggetSaksbehandler(this.saksbehandlerRolle, API_NAME)
220-
.uri(fromUri(FPSAK_BASE)
221-
.path(BEHANDLING_VILKAAR_URL)
222-
.queryParam(UUID_NAME, behandlingUuid)
223-
.build())
224-
.GET();
225-
return Optional.ofNullable(send(request.build(), new TypeReference<List<Vilkar>>() {}))
226-
.orElse(List.of());
227-
}
228-
229-
230-
231-
232216
public void overstyr(OverstyrAksjonspunkter aksjonspunkter) {
233217
var request = requestMedInnloggetSaksbehandler(this.saksbehandlerRolle, API_NAME)
234218
.uri(fromUri(FPSAK_BASE)

src/main/java/no/nav/foreldrepenger/autotest/klienter/fpsak/behandlinger/BehandlingKlientFelles.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ public void postBehandlingAksjonspunkt(BekreftedeAksjonspunkter aksjonspunkter)
162162
var requestTilStatusEndepunkt = requestMedInnloggetSaksbehandler(this.saksbehandlerRolle, this.apiName)
163163
.uri(URI.create(hentRedirectUriFraLocationHeader(response)))
164164
.GET();
165-
return Vent.(() -> getBehandlingHvisTilgjenglig(requestTilStatusEndepunkt), 30,
165+
return Vent.(() -> getBehandlingHvisTilgjenglig(requestTilStatusEndepunkt),
166166
"Behandling ikke tilgjenglig etter X sekund");
167167
}
168168
throw new RuntimeException("Uventet tilstand. Skal ikke være mulig!");

0 commit comments

Comments
 (0)