Simplify cbor-formatter response parsing. Error responses are returne…

…d with 200/OK. (#30)
eu-digital-identity-wallet · Nov 20, 2023 · 520dfe3 · 520dfe3
1 parent ddcc2a6
commit 520dfe3
Showing 1 changed file with 5 additions and 12 deletions.
diff --git a/...ain/kotlin/eu/europa/ec/eudi/pidissuer/adapter/out/pid/EncodePidInCborWithMicroService.kt b/...ain/kotlin/eu/europa/ec/eudi/pidissuer/adapter/out/pid/EncodePidInCborWithMicroService.kt
@@ -29,7 +29,6 @@ import org.springframework.http.codec.json.KotlinSerializationJsonDecoder
 import org.springframework.http.codec.json.KotlinSerializationJsonEncoder
 import org.springframework.web.reactive.function.client.WebClient
 import org.springframework.web.reactive.function.client.awaitBody
-import org.springframework.web.reactive.function.client.awaitExchange
 import java.io.StringWriter
 import kotlin.io.encoding.Base64
 import kotlin.io.encoding.ExperimentalEncodingApi
@@ -61,20 +60,14 @@ class EncodePidInCborWithMicroService(private val creatorUrl: HttpsUrl) : Encode
     ): String = coroutineScope {
         log.info("Requesting PID in mso_mdoc for ${pid.familyName} ...")
         val request = createMsoMdocReq(pid, pidMetaData, holderKey)
-        val response = webClient
-            .post()
+        webClient.post()
             .accept(MediaType.APPLICATION_JSON)
             .contentType(MediaType.APPLICATION_JSON)
             .bodyValue(request)
-            .awaitExchange { response ->
-                val statusCode = response.statusCode()
-                when {
-                    statusCode.is2xxSuccessful -> response.awaitBody<CreateMsoMdocResponse>()
-                    statusCode.is4xxClientError -> response.awaitBody<CreateMsoMdocResponse>()
-                    else -> error("Unexpected error statusCode = $statusCode")
-                }
-            }
-        response.fold().getOrThrow()
+            .retrieve()
+            .awaitBody<CreateMsoMdocResponse>()
+            .fold()
+            .getOrThrow()
     }
 }