retry i LoadTests

navikt · Sep 16, 2024 · 61970df · 61970df
1 parent 2ec3328
commit 61970df
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 18 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
@@ -6,6 +6,7 @@ import no.nav.soknad.arkivering.innsending.*
 import no.nav.soknad.arkivering.kafka.KafkaListener
 import no.nav.soknad.arkivering.soknadsmottaker.model.Soknad
 import no.nav.soknad.arkivering.utils.createSoknad
+import no.nav.soknad.arkivering.utils.retry
 import no.nav.soknad.arkivering.utils.skjemaliste
 import no.nav.soknad.arkivering.utils.vedleggsliste
 import no.nav.soknad.arkivering.verification.AssertionHelper
@@ -82,14 +83,16 @@ 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 = innsendingApi.opprettEttersending(
-				skjemanr = soknadDef.skjemanr,
-				tema = soknadDef.tema,
-				tittel = soknadDef.tittel,
-				vedleggListe = vedleggsliste
-					.take(antallVedlegg)
-					.map { Vedlegg(it.vedleggKode, it.vedleggTittel) }
-			)
+			val soknad = retry(3) {
+				innsendingApi.opprettEttersending(
+					skjemanr = soknadDef.skjemanr,
+					tema = soknadDef.tema,
+					tittel = soknadDef.tittel,
+					vedleggListe = vedleggsliste
+						.take(antallVedlegg)
+						.map { Vedlegg(it.vedleggKode, it.vedleggTittel) }
+				)
+			}
 
 			soknad.vedleggsliste()
 				.verifyHasSize(antallVedlegg)
@@ -102,7 +105,7 @@ class LoadTests(config: Config, private val kafkaListener: KafkaListener, val us
 							}
 							logger.debug("Laster opp fil nr. ${it + 1} for søknad ${soknad.innsendingsId} (etter delay på ${fileUploadDelay/1000.0} sekunder)")
 							val start = System.currentTimeMillis()
-							vedleggsliste.lastOppFil(it, file)
+							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")
 						}
 				}
@@ -124,7 +127,7 @@ class LoadTests(config: Config, private val kafkaListener: KafkaListener, val us
 
 	private suspend fun sendInnSoknad(innsendingsId: String) {
 		return withContext(Dispatchers.IO) {
-			innsendingApi.sendInn(innsendingsId)
+			retry(3) { innsendingApi.sendInn(innsendingsId) }
 		}
 	}
 

diff --git a/...m-tests/system-tests/src/main/kotlin/no/nav/soknad/arkivering/innsending/InnsendingApi.kt b/...m-tests/system-tests/src/main/kotlin/no/nav/soknad/arkivering/innsending/InnsendingApi.kt
@@ -7,7 +7,6 @@ import no.nav.soknad.arkivering.innsending.api.*
 import no.nav.soknad.arkivering.innsending.model.*
 import no.nav.soknad.arkivering.innsending.infrastructure.Serializer.jacksonObjectMapper
 import no.nav.soknad.arkivering.tokensupport.createOkHttpAuthorizationClient
-import no.nav.soknad.arkivering.utils.retry
 import okhttp3.OkHttpClient
 import org.slf4j.LoggerFactory
 
@@ -51,19 +50,19 @@ class InnsendingApi(config: Config, useOauth: Boolean? = false) {
 				)
 			}
 		)
-		val soknad = retry(3) { ettersending.opprettEttersending(dto) }
+		val soknad = ettersending.opprettEttersending(dto)
 		logger.info("Opprettet ettersending: $soknad")
 		return SoknadTestdata(soknad, sendInnFil)
 	}
 
-	fun sendInn(soknad: SoknadTestdata) {
+	fun sendInn(soknad: SoknadTestdata) = runCatching {
 		logger.info("Sender inn søknad: ${soknad.innsendingsId}")
-		retry(3) { sendInnSoknad.sendInnSoknad(soknad.innsendingsId) }
+		sendInnSoknad.sendInnSoknad(soknad.innsendingsId)
 	}
 
-	fun sendInn(innsendingsId: String) {
+	fun sendInn(innsendingsId: String) = runCatching {
 		logger.info("Sender inn søknad: ${innsendingsId}")
-		retry(3) { sendInnSoknad.sendInnSoknad(innsendingsId) }
+		sendInnSoknad.sendInnSoknad(innsendingsId)
 	}
 
 	fun getArkiveringsstatus(innsendingsId: String): ArkiveringsStatusDto {

diff --git a/...-tests/system-tests/src/main/kotlin/no/nav/soknad/arkivering/innsending/SoknadTestdata.kt b/...-tests/system-tests/src/main/kotlin/no/nav/soknad/arkivering/innsending/SoknadTestdata.kt
@@ -2,7 +2,6 @@ package no.nav.soknad.arkivering.innsending
 
 import no.nav.soknad.arkivering.innsending.api.SendinnFilApi
 import no.nav.soknad.arkivering.innsending.model.DokumentSoknadDto
-import no.nav.soknad.arkivering.utils.retry
 import java.io.File
 
 class SoknadTestdata(
@@ -39,7 +38,7 @@ class VedleggslisteTestdata(
 	}
 
 	fun lastOppFil(index: Int, file: File): VedleggslisteTestdata {
-		retry(3) { sendinnFilApi.lagreFil(innsendingsId, vedleggIdListe[index].id, file) }
+		sendinnFilApi.lagreFil(innsendingsId, vedleggIdListe[index].id, file)
 		return this
 	}