IS-2646: Bedre feilhåndtering mot EREG (#545)

Author: geir-waagboe

.gitignore

@@ -6,6 +6,7 @@
 out/
 build/
 .gradle/
+.kotlin/
 
 # Generated sources
 src/generated

src/main/kotlin/no/nav/syfo/client/dokarkiv/DokarkivClient.kt

@@ -37,6 +37,9 @@ class DokarkivClient(
                 }
                 val journalpostResponse = response.body<JournalpostResponse>()
                 COUNT_CALL_DOKARKIV_JOURNALPOST_SUCCESS.increment()
+                if (journalpostResponse.journalpostferdigstilt == null || !journalpostResponse.journalpostferdigstilt) {
+                    log.error("Journalpost med id ${journalpostResponse.journalpostId} ble ikke ferdigstilt (status er ${journalpostResponse.journalstatus})")
+                }
                 journalpostResponse
             } catch (e: ClientRequestException) {
                 if (e.response.status == HttpStatusCode.Conflict) {

src/main/kotlin/no/nav/syfo/client/ereg/EregClient.kt

@@ -19,19 +19,19 @@ class EregClient(
     suspend fun organisasjonVirksomhetsnavn(
         virksomhetsnummer: Virksomhetsnummer,
     ): EregVirksomhetsnavn? {
-        try {
+        return try {
             val url = "$eregOrganisasjonUrl/${virksomhetsnummer.value}"
             val response = httpClient.get(url) {
                 accept(ContentType.Application.Json)
             }.body<EregOrganisasjonResponse>()
             COUNT_CALL_EREG_ORGANISASJON_SUCCESS.increment()
-            return response.toEregVirksomhetsnavn()
+            response.toEregVirksomhetsnavn()
         } catch (e: ResponseException) {
             if (e.isOrganisasjonNotFound(virksomhetsnummer)) {
                 log.warn("No Organisasjon was found in Ereg: returning empty Virksomhetsnavn, message=${e.message}")
                 COUNT_CALL_EREG_ORGANISASJON_NOT_FOUND.increment()
-                return EregVirksomhetsnavn(
-                    virksomhetsnavn = "",
+                EregVirksomhetsnavn(
+                    virksomhetsnavn = "Ukjent",
                 )
             } else {
                 log.error(
@@ -40,9 +40,9 @@ class EregClient(
                     StructuredArguments.keyValue("message", e.message),
                 )
                 COUNT_CALL_EREG_ORGANISASJON_FAIL.increment()
+                throw RuntimeException(e)
             }
         }
-        return null
     }
 
     private fun ResponseException.isOrganisasjonNotFound(

src/main/kotlin/no/nav/syfo/cronjob/journalforing/DialogmoteVarselJournalforingCronjob.kt

@@ -69,7 +69,7 @@ class DialogmoteVarselJournalforingCronjob(
                     journalforingResult.updated++
                 } ?: throw RuntimeException("Failed to Journalfor ArbeidstakerVarsel: response missing JournalpostId")
             } catch (e: Exception) {
-                log.error("Exception caught while attempting Journalforing of ArbeidstakerVarsel", e)
+                log.error("Exception caught while attempting Journalforing of ArbeidstakerVarsel, will try again later", e)
                 journalforingResult.failed++
             }
         }

src/test/kotlin/no/nav/syfo/cronjob/journalforing/DialogmoteVarselJournalforingCronjobSpek.kt

@@ -510,6 +510,37 @@ class DialogmoteVarselJournalforingCronjobSpek : Spek({
                         result.updated shouldBeEqualTo 0
                     }
                 }
+                it("should fail to update journalpost if call to ereg fails") {
+                    val newDialogmoteDTO = generateNewDialogmoteDTO(
+                        personIdent = UserConstants.ARBEIDSTAKER_FNR,
+                        virksomhetsnummer = UserConstants.VIRKSOMHETSNUMMER_EREG_FAILS.value,
+                    )
+
+                    with(
+                        handleRequest(HttpMethod.Post, urlMote) {
+                            addHeader(HttpHeaders.Authorization, bearerHeader(validToken))
+                            addHeader(HttpHeaders.ContentType, ContentType.Application.Json.toString())
+                            setBody(objectMapper.writeValueAsString(newDialogmoteDTO))
+                        }
+                    ) {
+                        response.status() shouldBeEqualTo HttpStatusCode.OK
+                    }
+
+                    runBlocking {
+                        val result = DialogmoteCronjobResult()
+                        dialogmoteVarselJournalforingCronjob.dialogmoteArbeidstakerVarselJournalforingJob(result)
+
+                        result.failed shouldBeEqualTo 0
+                        result.updated shouldBeEqualTo 1
+                    }
+                    runBlocking {
+                        val result = DialogmoteCronjobResult()
+                        dialogmoteVarselJournalforingCronjob.dialogmoteArbeidsgiverVarselJournalforingJob(result)
+
+                        result.failed shouldBeEqualTo 1
+                        result.updated shouldBeEqualTo 0
+                    }
+                }
                 it("Check that correct title is generated") {
                     val moteTidspunkt = LocalDateTime.of(2022, Month.JUNE, 20, 0, 0, 0)
                     val referatUtenEndring = createReferat(

src/test/kotlin/no/nav/syfo/testhelper/UserConstants.kt

@@ -41,6 +41,7 @@ object UserConstants {
     val NARMESTELEDER_FNR_2 = PersonIdent("98765432102")
     val VIRKSOMHETSNUMMER_NO_NARMESTELEDER = Virksomhetsnummer("981111117")
     val VIRKSOMHETSNUMMER_HAS_NARMESTELEDER = Virksomhetsnummer("934567897")
+    val VIRKSOMHETSNUMMER_EREG_FAILS = Virksomhetsnummer("934567889")
     val OTHER_VIRKSOMHETSNUMMER_HAS_NARMESTELEDER = Virksomhetsnummer("922222223")
 
     val JOURNALPOST_ID_MOTTAKER_GONE = 129

src/test/kotlin/no/nav/syfo/testhelper/mock/EregMock.kt

@@ -1,5 +1,6 @@
 package no.nav.syfo.testhelper.mock
 
+import io.ktor.http.*
 import io.ktor.server.application.*
 import io.ktor.server.engine.*
 import io.ktor.server.netty.*
@@ -9,6 +10,7 @@ import no.nav.syfo.application.api.authentication.installContentNegotiation
 import no.nav.syfo.client.ereg.EregClient.Companion.EREG_PATH
 import no.nav.syfo.client.ereg.EregOrganisasjonNavn
 import no.nav.syfo.client.ereg.EregOrganisasjonResponse
+import no.nav.syfo.testhelper.UserConstants.VIRKSOMHETSNUMMER_EREG_FAILS
 import no.nav.syfo.testhelper.UserConstants.VIRKSOMHETSNUMMER_HAS_NARMESTELEDER
 import no.nav.syfo.testhelper.getRandomPort
 
@@ -26,6 +28,9 @@ class EregMock {
             get("$EREG_PATH/${VIRKSOMHETSNUMMER_HAS_NARMESTELEDER.value}") {
                 call.respond(EregOrganisasjonResponse(EregOrganisasjonNavn("Butikken", "")))
             }
+            get("$EREG_PATH/${VIRKSOMHETSNUMMER_EREG_FAILS.value}") {
+                call.respond(HttpStatusCode.InternalServerError)
+            }
         }
     }
 }