Upgrade Spring Boot and handle SSE broken pipe

build.gradle.kts

@@ -4,7 +4,7 @@ val exposedVersion = "0.45.0"
 val h2Version = "2.3.232"
 val pamGeographyVersion = "2.9"
 val tokenValidationVersion = "1.3.0"
-val tokenSupportVersion = "4.1.7"
+val tokenSupportVersion = "5.0.11"
 val oidcSupportVersion = "0.2.18"
 val logstashVersion = "8.0"
 val pdfboxVersion = "3.0.3"
@@ -34,7 +34,7 @@ repositories {
 plugins {
     val kotlinVersion = "2.0.21"
     id("org.jetbrains.kotlin.jvm") version kotlinVersion
-    id("org.springframework.boot") version "3.2.5"
+    id("org.springframework.boot") version "3.3.5"
     id("org.jetbrains.kotlin.plugin.spring") version kotlinVersion
     kotlin("plugin.jpa") version kotlinVersion
     idea
@@ -59,6 +59,7 @@ dependencies {
 
     implementation("org.flywaydb:flyway-core")
     implementation("com.zaxxer:HikariCP")
+    implementation("org.flywaydb:flyway-database-postgresql")
     implementation("org.postgresql:postgresql")
 
     implementation("io.github.resilience4j:resilience4j-retry:$resilience4jVersion")

src/main/kotlin/no/nav/klage/config/SseBrokenPipeLogFilter.kt

@@ -0,0 +1,50 @@
+package no.nav.klage.config
+
+import ch.qos.logback.classic.Level
+import ch.qos.logback.classic.Logger
+import ch.qos.logback.classic.turbo.TurboFilter
+import ch.qos.logback.core.spi.FilterReply
+import no.nav.klage.util.getLogger
+import org.slf4j.Marker
+
+class SseBrokenPipeLogFilter : TurboFilter() {
+
+    companion object {
+        @Suppress("JAVA_CLASS_ON_COMPANION")
+        private val ourLogger = getLogger(javaClass.enclosingClass)
+    }
+
+    override fun decide(
+        marker: Marker?,
+        logger: Logger?,
+        level: Level?,
+        format: String?,
+        params: Array<out Any>?,
+        throwable: Throwable?
+    ): FilterReply {
+        if (throwable != null) {
+            if (
+                (throwable.javaClass.name == "java.io.IOException" &&
+                 throwable.message == "Broken pipe" &&
+                 logger?.name?.contains("org.apache.catalina.core.ContainerBase") == true
+                )
+                /*
+                 ||
+                (throwable.javaClass.name == "AsyncRequestNotUsableException" &&
+                 throwable.message?.contains("Broken pipe", ignoreCase = true) == true
+                )
+                 */
+            ) {
+                ourLogger.debug("Suppressing error log message when broken pipe and logger is ${logger.name}. This is probably due to lost client during async/SSE operations.")
+                return FilterReply.DENY
+            }
+        }
+
+        if (level == Level.WARN && logger?.name == "org.springframework.web.servlet.mvc.support.DefaultHandlerExceptionResolver" && format?.contains("java.io.IOException: Broken pipe") == true) {
+            ourLogger.debug("Suppressing warning log message when broken pipe and logger is ${logger.name}. This is probably due to lost client during async/SSE operations.")
+            return FilterReply.DENY
+        }
+
+        return FilterReply.NEUTRAL
+    }
+}

src/main/resources/logback-spring.xml

@@ -2,6 +2,8 @@
 <configuration>
     <include resource="org/springframework/boot/logging/logback/defaults.xml"/>
 
+    <turboFilter class="no.nav.klage.config.SseBrokenPipeLogFilter" />
+
     <springProfile name="local">
         <appender name="text" class="ch.qos.logback.core.ConsoleAppender">
             <encoder>