timeout justeringer

Author: palfi

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

@@ -15,7 +15,8 @@
 
 public class Innsyn {
     private static final Logger LOG = LoggerFactory.getLogger(Innsyn.class);
-    private static final int PROGRESSIV_VENTETID = 3000;
+    private static final int API_PROGRESSIV_VENTETID = 3000;
+    private static final int API_TIMEOUT_SEKUNDER = 30;
 
     private final InnsynKlient innsynKlient;
     private final Fødselsnummer fnr;
@@ -41,8 +42,8 @@ private Saker hentSaker() {
                 return null;
             }
             return sak.get();
-        }, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID,
-                "åpen es behandling med tilstand " + behandlingTilstand);
+        }, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, API_PROGRESSIV_VENTETID,
+                "åpen es behandling med tilstand " + behandlingTilstand, API_TIMEOUT_SEKUNDER);
     }
 
     public SvpSak hentSvpSakMedÅpenBehandlingTilstand(Saksnummer saksnummer, BehandlingTilstand behandlingTilstand) {
@@ -56,8 +57,8 @@ private Saker hentSaker() {
                 return null;
             }
             return sak.get();
-        }, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, PROGRESSIV_VENTETID,
-                "åpen svp behandling med tilstand " + behandlingTilstand);
+        }, () -> "Finner ikke sak med tilstand " + behandlingTilstand + " for sak " + saksnummer, API_PROGRESSIV_VENTETID,
+                "åpen svp behandling med tilstand " + behandlingTilstand, API_TIMEOUT_SEKUNDER);
     }
 
     public EsSak hentEsSakUtenÅpenBehandling(Saksnummer saksnummer) {
@@ -71,8 +72,8 @@ private Saker hentSaker() {
                 return null;
             }
             return sak.get();
-        }, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID,
-                "es sak uten åpen behandling");
+        }, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, API_PROGRESSIV_VENTETID,
+                "es sak uten åpen behandling", API_TIMEOUT_SEKUNDER);
     }
 
     public SvpSak hentSvpSakUtenÅpenBehandling(Saksnummer saksnummer) {
@@ -86,8 +87,8 @@ private Saker hentSaker() {
                 return null;
             }
             return sak.get();
-        }, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID,
-                "svp sak uten åpen behandling");
+        }, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, API_PROGRESSIV_VENTETID,
+                "svp sak uten åpen behandling", API_TIMEOUT_SEKUNDER);
     }
 
     public FpSak hentFpSakUtenÅpenBehandling(Saksnummer saksnummer) {
@@ -101,7 +102,7 @@ private Saker hentSaker() {
                 return null;
             }
             return sak.get();
-        }, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, PROGRESSIV_VENTETID,
-                "fp sak uten åpen behandling");
+        }, () -> "Finner ikke sak uten åpen behandling for sak " + saksnummer, API_PROGRESSIV_VENTETID,
+                "fp sak uten åpen behandling", API_TIMEOUT_SEKUNDER);
     }
 }

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

@@ -345,7 +345,7 @@ private Behandling ventTilBehandlingErFerdigProsessertOgReturner(UUID behandling
                         .append("\n");
             }
             return "Behandling status var ikke klar men har ikke feilet\n" + prosessTaskList;
-        }, "behandling er ferdig prosessert");
+        }, 50, "behandling er ferdig prosessert", 40);
     }
 
     private List<ProsessTaskDataDto> hentProsesstaskerForBehandling(int behandlingId) {

src/main/java/no/nav/foreldrepenger/autotest/util/vent/Vent.java

@@ -29,14 +29,18 @@ public static void til(Callable<Boolean> callable, Callable<String> errorMessage
     }
 
     public static <T> T på(Callable<T> callable, Callable<String> errorMessageProducer, String loggForklaring) {
-        return på(callable, errorMessageProducer, 50, loggForklaring);
+        return på(callable, errorMessageProducer, 50, loggForklaring, TIMEOUT_SEKUNDER);
     }
 
-    public static <T> T på(Callable<T> callable, Callable<String> errorMessageProducer, int progressivVentetid, String loggForklaring) {
+    public static <T> T på(Callable<T> callable,
+                           Callable<String> errorMessageProducer,
+                           int progressivVentetid,
+                           String loggForklaring,
+                           int timeoutSekunder) {
         LOG.info("Venter på {}", loggForklaring);
         var start = LocalDateTime.now();
-        var end = start.plusSeconds(TIMEOUT_SEKUNDER);
-        var advarsel = start.plusSeconds((int) (TIMEOUT_SEKUNDER * 0.75));
+        var end = start.plusSeconds(timeoutSekunder);
+        var advarsel = start.plusSeconds((int) (timeoutSekunder * 0.75));
         var logget = false;
 
         long progressivVentetidMs = progressivVentetid;
@@ -48,11 +52,11 @@ public static void til(Callable<Boolean> callable, Callable<String> errorMessage
                 if (!logget && now.isAfter(advarsel)) {
                     logget = true;
                     var ste = getCallerCallerClassName();
-                    LOG.warn("Async venting av {} har tatt mer enn 75% av timeout på {} sekunder!", ste, TIMEOUT_SEKUNDER);
+                    LOG.warn("Async venting av {} har tatt mer enn 75% av timeout på {} sekunder!", ste, timeoutSekunder);
                 }
                 if (now.isAfter(end)) {
                     throw new IllegalStateException(
-                            "Async venting timet ut etter " + TIMEOUT_SEKUNDER + " sekunder fordi: " + errorMessageProducer.call());
+                            "Async venting timet ut etter " + timeoutSekunder + " sekunder fordi: " + errorMessageProducer.call());
                 }
                 sleep(progressivVentetidMs);
                 progressivVentetidMs = Math.min(750, 2 * progressivVentetidMs);