From fe17b1a9d7f5d88e8154b220889e2ced6c9b377b Mon Sep 17 00:00:00 2001
From: Tore Langedal Endestad <tore.langedal.endestad@nav.no>
Date: Fri, 6 Dec 2024 13:57:52 +0100
Subject: [PATCH] Logge antall oppgaver i kanal (#2777)

* Logge antall oppgaver i kanal

* Logge antall oppgaver i kanal
---
 .../no/nav/k9/los/eventhandler/K\303\270Oppdatert.kt"     | 2 ++
 src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9.kt   | 8 ++++++--
 src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3.kt | 3 ++-
 .../nav/k9/los/jobber/K9sakBehandlingsoppfriskingJobb.kt  | 2 ++
 4 files changed, 12 insertions(+), 3 deletions(-)

diff --git "a/src/main/kotlin/no/nav/k9/los/eventhandler/K\303\270Oppdatert.kt" "b/src/main/kotlin/no/nav/k9/los/eventhandler/K\303\270Oppdatert.kt"
index b6ae7fc03..7464f1637 100644
--- "a/src/main/kotlin/no/nav/k9/los/eventhandler/K\303\270Oppdatert.kt"
+++ "b/src/main/kotlin/no/nav/k9/los/eventhandler/K\303\270Oppdatert.kt"
@@ -5,6 +5,7 @@ import io.opentelemetry.instrumentation.annotations.WithSpan
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.channels.ReceiveChannel
+import kotlinx.coroutines.channels.toList
 import kotlinx.coroutines.launch
 import no.nav.k9.kodeverk.Fagsystem
 import no.nav.k9.los.domene.lager.oppgave.Oppgave
@@ -100,6 +101,7 @@ private suspend fun oppdaterKø(
         for (uuid in behandlingerUuiderTilRefresh) {
             refreshOppgaveChannel.send(uuid)
         }
+        log.info("Antall oppgaver i refreshOppgaveChannel er nå ${refreshOppgaveChannel.toList().size}")
         log.info("Ferdig")
     }
 }
diff --git a/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9.kt b/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9.kt
index 9935dc797..cc7f29260 100644
--- a/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9.kt
+++ b/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9.kt
@@ -33,13 +33,17 @@ class RefreshK9(
                 if (oppgaveId == null) {
                     try {
                         ChannelMetrikker.timeSuspended("refresh_k9sak") {
+                            log.info("Behandler ${oppgaveListe.size} oppgaver")
                             oppfrisk(oppgaveListe)
                             oppgaveListe.clear()
                         }
                     } catch (e: Exception) {
-                        log.error("Feilet ved refresh av oppgaver i k9-sak: " + oppgaveListe.joinToString(", "), e)
+                        log.error("Feilet ved refresh av ${oppgaveListe.size} oppgaver i k9-sak", e)
+                        for (uuid in oppgaveListe) {
+                            log.warn("Feilet ved refresh av $uuid i k9-sak");
+                        }
                     } catch (t : Throwable) {
-                        log.error("Feilet hardt (Throwable) ved refresh av oppgaver (v1) mot k9-sak, avslutter tråden", t)
+                        log.error("Feilet hardt (Throwable) ved refresh av ${oppgaveListe.size} oppgaver (v1) mot k9-sak, avslutter tråden", t)
                         throw t;
                     }
                     oppgaveListe.add(channel.receive())
diff --git a/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3.kt b/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3.kt
index fe4dbd910..903235f39 100644
--- a/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3.kt
+++ b/src/main/kotlin/no/nav/k9/los/eventhandler/RefreshK9v3.kt
@@ -20,7 +20,8 @@ class RefreshK9v3(
                 if (hendelse == null) {
                     try {
                         val refreshUtført = ChannelMetrikker.timeSuspended("refresh_k9sak_v3") {
-                             refreshK9v3Tjeneste.refreshK9(hendelser)
+                            log.info("Behandler ${hendelser.size} oppgaver")
+                            refreshK9v3Tjeneste.refreshK9(hendelser)
                         }
                         hendelser.clear()
                         if (refreshUtført == RefreshK9v3Tjeneste.RefreshUtført.ALLE_KØER){
diff --git a/src/main/kotlin/no/nav/k9/los/jobber/K9sakBehandlingsoppfriskingJobb.kt b/src/main/kotlin/no/nav/k9/los/jobber/K9sakBehandlingsoppfriskingJobb.kt
index fb6312efe..3b82acf67 100644
--- a/src/main/kotlin/no/nav/k9/los/jobber/K9sakBehandlingsoppfriskingJobb.kt
+++ b/src/main/kotlin/no/nav/k9/los/jobber/K9sakBehandlingsoppfriskingJobb.kt
@@ -1,6 +1,7 @@
 package no.nav.k9.los.jobber
 
 import kotlinx.coroutines.channels.Channel
+import kotlinx.coroutines.channels.toList
 import kotlinx.coroutines.runBlocking
 import no.nav.k9.los.Configuration
 import no.nav.k9.los.KoinProfile
@@ -118,6 +119,7 @@ class K9sakBehandlingsoppfriskingJobb(
             for (uuid in behandlingerTilRefresh) {
                 refreshOppgaveChannel.send(uuid)
             }
+            log.info("Antall oppgaver i refreshOppgaveChannel er nå ${refreshOppgaveChannel.toList().size}")
         }
     }