bump sosialhjelp-common

build.gradle.kts

@@ -9,7 +9,7 @@ object Versions {
     const val kotlin = "1.4.21"
     const val coroutines = "1.4.2"
     const val springBoot = "2.4.3"
-    const val sosialhjelpCommon = "1.1c8e196"
+    const val sosialhjelpCommon = "1.8f11108"
     const val logback = "1.2.3"
     const val logstash = "6.5"
     const val filformat = "1.2021.03.02-10.58-415c44e55124"
@@ -82,6 +82,7 @@ dependencies {
 //    Coroutines
     implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:${Versions.coroutines}")
     implementation("org.jetbrains.kotlinx:kotlinx-coroutines-slf4j:${Versions.coroutines}")
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactor:${Versions.coroutines}")
 
 //    Spring
     implementation("org.springframework.boot:spring-boot-starter-web:${Versions.springBoot}")

src/main/kotlin/no/nav/sosialhjelp/innsyn/client/fiks/KommuneInfoClientConfig.kt

@@ -7,26 +7,29 @@ import no.nav.sosialhjelp.innsyn.config.ClientProperties
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 import org.springframework.context.annotation.Profile
-import org.springframework.web.client.RestTemplate
+import org.springframework.web.reactive.function.client.WebClient
 
 @Profile("!mock")
 @Configuration
-class KommuneInfoClientConfig {
+class KommuneInfoClientConfig(
+    private val proxiedWebClient: WebClient,
+    private val clientProperties: ClientProperties
+) {
 
     @Bean
-    fun kommuneInfoClient(restTemplate: RestTemplate, clientProperties: ClientProperties): KommuneInfoClient {
+    fun kommuneInfoClient(): KommuneInfoClient {
         return KommuneInfoClientImpl(
-                restTemplate,
-                toFiksProperties(clientProperties)
+            proxiedWebClient,
+            fiksProperties()
         )
     }
 
-    private fun toFiksProperties(clientProperties: ClientProperties): FiksProperties {
+    private fun fiksProperties(): FiksProperties {
         return FiksProperties(
-                clientProperties.fiksDigisosEndpointUrl + FiksPaths.PATH_KOMMUNEINFO,
-                clientProperties.fiksDigisosEndpointUrl + FiksPaths.PATH_ALLE_KOMMUNEINFO,
-                clientProperties.fiksIntegrasjonId,
-                clientProperties.fiksIntegrasjonpassord
+            clientProperties.fiksDigisosEndpointUrl + FiksPaths.PATH_KOMMUNEINFO,
+            clientProperties.fiksDigisosEndpointUrl + FiksPaths.PATH_ALLE_KOMMUNEINFO,
+            clientProperties.fiksIntegrasjonId,
+            clientProperties.fiksIntegrasjonpassord
         )
     }
 

src/main/kotlin/no/nav/sosialhjelp/innsyn/client/idporten/IdPortenClientConfig.kt

@@ -7,36 +7,37 @@ import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 import org.springframework.context.annotation.Profile
-import org.springframework.web.client.RestTemplate
+import org.springframework.web.reactive.function.client.WebClient
 
 @Profile("!mock")
 @Configuration
 class IdPortenClientConfig(
-        @Value("\${no.nav.sosialhjelp.idporten.token_url}") private val tokenUrl: String,
-        @Value("\${no.nav.sosialhjelp.idporten.client_id}") private val clientId: String,
-        @Value("\${no.nav.sosialhjelp.idporten.scope}") private val scope: String,
-        @Value("\${no.nav.sosialhjelp.idporten.config_url}") private val configUrl: String,
-        @Value("\${no.nav.sosialhjelp.idporten.truststore_type}") private val truststoreType: String,
-        @Value("\${no.nav.sosialhjelp.idporten.truststore_filepath}") private val truststoreFilepath: String
+    private val proxiedWebClient: WebClient,
+    @Value("\${no.nav.sosialhjelp.idporten.token_url}") private val tokenUrl: String,
+    @Value("\${no.nav.sosialhjelp.idporten.client_id}") private val clientId: String,
+    @Value("\${no.nav.sosialhjelp.idporten.scope}") private val scope: String,
+    @Value("\${no.nav.sosialhjelp.idporten.config_url}") private val configUrl: String,
+    @Value("\${no.nav.sosialhjelp.idporten.truststore_type}") private val truststoreType: String,
+    @Value("\${no.nav.sosialhjelp.idporten.truststore_filepath}") private val truststoreFilepath: String,
 ) {
 
     @Bean
-    fun idPortenClient(restTemplate: RestTemplate): IdPortenClient {
+    fun idPortenClient(): IdPortenClient {
         return IdPortenClient(
-                restTemplate = restTemplate,
-                idPortenProperties = idPortenProperties()
+            webClient = proxiedWebClient,
+            idPortenProperties = idPortenProperties()
         )
     }
 
     fun idPortenProperties(): IdPortenProperties {
         return IdPortenProperties(
-                tokenUrl = tokenUrl,
-                clientId = clientId,
-                scope = scope,
-                configUrl = configUrl,
-                truststoreType = truststoreType,
-                truststoreFilepath = truststoreFilepath,
-                virksomhetSertifikatPath = getenv("VIRKSERT_STI", "/var/run/secrets/nais.io/virksomhetssertifikat")
+            tokenUrl = tokenUrl,
+            clientId = clientId,
+            scope = scope,
+            configUrl = configUrl,
+            truststoreType = truststoreType,
+            truststoreFilepath = truststoreFilepath,
+            virksomhetSertifikatPath = getenv("VIRKSERT_STI", "/var/run/secrets/nais.io/virksomhetssertifikat")
         )
     }
 }

src/main/kotlin/no/nav/sosialhjelp/innsyn/client/norg/NorgClientImpl.kt

@@ -9,6 +9,7 @@ import no.nav.sosialhjelp.innsyn.utils.IntegrationUtils.forwardHeaders
 import no.nav.sosialhjelp.innsyn.utils.logger
 import no.nav.sosialhjelp.innsyn.utils.mdc.MDCUtils
 import no.nav.sosialhjelp.innsyn.utils.objectMapper
+import no.nav.sosialhjelp.innsyn.utils.withStatusCode
 import org.springframework.context.annotation.Profile
 import org.springframework.http.HttpHeaders
 import org.springframework.http.HttpStatus
@@ -69,6 +70,7 @@ class NorgClientImpl(
                     }
             }
             .bodyToMono<String>()
+
             .block()
     }
 

src/main/kotlin/no/nav/sosialhjelp/innsyn/config/ProxiedWebClientConfig.kt

@@ -0,0 +1,41 @@
+package no.nav.sosialhjelp.innsyn.config
+
+import no.nav.sosialhjelp.innsyn.utils.getReactorClientHttpConnector
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Profile
+import org.springframework.http.client.reactive.ReactorClientHttpConnector
+import org.springframework.web.reactive.function.client.WebClient
+import reactor.netty.http.client.HttpClient
+
+@Profile("!(mock|mock-alt|local)")
+@Configuration
+class ProxiedWebClientConfig(
+    private val webClientBuilder: WebClient.Builder
+) {
+
+    @Value("\${HTTPS_PROXY}")
+    private lateinit var proxyUrl: String
+
+    @Bean
+    fun proxiedWebClient(): WebClient =
+        webClientBuilder
+            .clientConnector(getReactorClientHttpConnector(proxyUrl))
+            .build()
+
+}
+
+@Profile("mock|mock-alt|local")
+@Configuration
+class MockProxiedWebClientConfig(
+    private val webClientBuilder: WebClient.Builder
+) {
+
+    @Bean
+    fun proxiedWebClient(): WebClient =
+        webClientBuilder
+            .clientConnector(ReactorClientHttpConnector(HttpClient.newConnection()))
+            .build()
+
+}

src/main/kotlin/no/nav/sosialhjelp/innsyn/config/WebClientConfig.kt

@@ -0,0 +1,18 @@
+package no.nav.sosialhjelp.innsyn.config
+
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.http.client.reactive.ReactorClientHttpConnector
+import org.springframework.web.reactive.function.client.WebClient
+import reactor.netty.http.client.HttpClient
+
+@Configuration
+class WebClientConfig(
+    private val webClientBuilder: WebClient.Builder,
+) {
+    @Bean
+    fun webClient(): WebClient =
+        webClientBuilder
+            .clientConnector(ReactorClientHttpConnector(HttpClient.newConnection()))
+            .build()
+}

src/main/kotlin/no/nav/sosialhjelp/innsyn/health/checks/StsCheck.kt

@@ -8,7 +8,7 @@ import no.nav.sosialhjelp.selftest.Importance
 import org.springframework.context.annotation.Profile
 import org.springframework.stereotype.Component
 
-@Profile("!mock")
+@Profile("!(mock | local)")
 @Component
 class StsCheck(
         clientProperties: ClientProperties,

src/main/kotlin/no/nav/sosialhjelp/innsyn/utils/HttpClientUtil.kt

@@ -0,0 +1,17 @@
+package no.nav.sosialhjelp.innsyn.utils
+
+import org.springframework.http.client.reactive.ReactorClientHttpConnector
+import reactor.netty.http.client.HttpClient
+import reactor.netty.transport.ProxyProvider
+import java.net.URL
+
+fun getReactorClientHttpConnector(proxyUrl: String): ReactorClientHttpConnector {
+    val uri = URL(proxyUrl)
+
+    val httpClient: HttpClient = HttpClient.create()
+        .proxy { proxy ->
+            proxy.type(ProxyProvider.Proxy.HTTP).host(uri.host).port(uri.port)
+        }
+
+    return ReactorClientHttpConnector(httpClient)
+}

src/main/kotlin/no/nav/sosialhjelp/innsyn/utils/Utils.kt

@@ -14,7 +14,9 @@ import org.slf4j.Logger
 import org.slf4j.LoggerFactory
 import org.slf4j.MDC
 import org.springframework.core.ParameterizedTypeReference
+import org.springframework.http.HttpStatus
 import org.springframework.web.client.HttpStatusCodeException
+import org.springframework.web.reactive.function.client.WebClientResponseException
 import java.io.IOException
 import java.sql.Timestamp
 import java.time.Instant
@@ -138,6 +140,9 @@ val ErrorMessage.feilmeldingUtenFnr: String?
         return this.message?.feilmeldingUtenFnr
     }
 
+fun withStatusCode(t: Throwable): HttpStatus? =
+    (t as? WebClientResponseException)?.statusCode
+
 fun runAsyncWithMDC(runnable: Runnable, executor: ExecutorService): CompletableFuture<Void> {
     val previous: Map<String, String> = MDC.getCopyOfContextMap()
     return CompletableFuture.runAsync(Runnable {

src/test/kotlin/no/nav/sosialhjelp/innsyn/ApplicationContextTest.kt

@@ -2,10 +2,12 @@ package no.nav.sosialhjelp.innsyn
 
 import com.ninjasquad.springmockk.MockkBean
 import no.nav.sosialhjelp.idporten.client.IdPortenClient
+import no.nav.sosialhjelp.innsyn.config.ProxiedWebClientConfig
 import org.junit.jupiter.api.Test
 import org.springframework.boot.test.context.SpringBootTest
 import org.springframework.test.context.ActiveProfiles
 import org.springframework.web.client.RestTemplate
+import org.springframework.web.reactive.function.client.WebClient
 
 @SpringBootTest(classes = [TestApplication::class], webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
 @ActiveProfiles(profiles = ["no-redis"])
@@ -14,6 +16,12 @@ class ApplicationContextTest {
     @MockkBean
     private lateinit var idPortenClient: IdPortenClient
 
+    @MockkBean(name = "proxiedWebClient")
+    private lateinit var proxiedWebClient: WebClient
+
+    @MockkBean
+    private lateinit var proxiedWebClientConfig: ProxiedWebClientConfig
+
     @MockkBean(name = "stsRestTemplate")
     private lateinit var stsRestTemplate: RestTemplate