Logg throwable hvis retry. Ignorer at innsending feiler etter retry.

navikt · Sep 16, 2024 · 3afd96f · 3afd96f
1 parent a9b1a54
commit 3afd96f
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 7 deletions.
diff --git a/system-tests/system-tests/src/main/kotlin/no/nav/soknad/arkivering/LoadTests.kt b/system-tests/system-tests/src/main/kotlin/no/nav/soknad/arkivering/LoadTests.kt
@@ -83,7 +83,7 @@ class LoadTests(config: Config, private val kafkaListener: KafkaListener, val us
 				logger.debug("Venter ${soknadDelay / 1000.0} sekunder før søknad opprettes..")
 				delay(soknadDelay)
 			}
-			val soknad = retry(3) {
+			val soknad = retry(3, logThrowable = logThrowableAsWarning("Feil ved opprettelse av søknad: $soknadDef")) {
 				innsendingApi.opprettEttersending(
 					skjemanr = soknadDef.skjemanr,
 					tema = soknadDef.tema,
@@ -103,10 +103,10 @@ class LoadTests(config: Config, private val kafkaListener: KafkaListener, val us
 							if (doDelay) {
 								delay(fileUploadDelay)
 							}
-							logger.debug("Laster opp fil nr. ${it + 1} for søknad ${soknad.innsendingsId} (etter delay på ${fileUploadDelay/1000.0} sekunder)")
+							logger.debug("${soknad.innsendingsId}: Laster opp fil nr. ${it + 1} for søknad (etter delay på ${fileUploadDelay/1000.0} sekunder)")
 							val start = System.currentTimeMillis()
-							retry(3) { vedleggsliste.lastOppFil(it, file) }
-							logger.info("Fullførte opplasting av fil nr. ${it + 1} for søknad ${soknad.innsendingsId} på ${(System.currentTimeMillis() - start)/1000.0} sekunder")
+							retry(3, logThrowable = logThrowableAsWarning("${soknad.innsendingsId}: Feil ved opplastning av fil")) { vedleggsliste.lastOppFil(it, file) }
+							logger.info("${soknad.innsendingsId}: Fullførte opplasting av fil nr. ${it + 1} for søknad på ${(System.currentTimeMillis() - start)/1000.0} sekunder")
 						}
 				}
 
@@ -125,14 +125,18 @@ class LoadTests(config: Config, private val kafkaListener: KafkaListener, val us
 			.map { opprettEttersending(antallVedlegg, file) }
 	}
 
+	private fun logThrowableAsWarning(message: String): (Throwable) -> Unit {
+		return { t -> logger.warn("$message - ${t.message}", t) }
+	}
+
 	private suspend fun sendInnSoknad(innsendingsId: String) {
 		return withContext(Dispatchers.IO) {
-			retry(3) { innsendingApi.sendInn(innsendingsId) }
+			retry(3, logThrowable = logThrowableAsWarning("$innsendingsId: Feil ved innsending")) { innsendingApi.sendInn(innsendingsId) }
 		}
 	}
 
 	private fun sendInnSoknader(innsendingsIds: List<String>) = runBlocking {
-		innsendingsIds.map { async { sendInnSoknad(it) }}.awaitAll()
+		innsendingsIds.map { async { runCatching { sendInnSoknad(it) } }}.awaitAll()
 	}
 
 	@Suppress("FunctionName")

diff --git a/system-tests/system-tests/src/main/kotlin/no/nav/soknad/arkivering/utils/Retry.kt b/system-tests/system-tests/src/main/kotlin/no/nav/soknad/arkivering/utils/Retry.kt
@@ -2,12 +2,14 @@ package no.nav.soknad.arkivering.utils
 
 fun <R> retry(
 	maxAttempts: Int,
+	logThrowable: (t: Throwable) -> Unit = {},
 	action: () -> R
 ): R {
 	require(maxAttempts > 0) { "maxAttempts must be greater than 0" }
 	return runCatching(action).getOrElse {
+		logThrowable(it)
 		val leftAttempts = maxAttempts.dec()
 		if (leftAttempts == 0) throw it
-		retry(leftAttempts, action)
+		retry(leftAttempts, logThrowable, action)
 	}
 }