V6TalentTransformer.kt

import com.fasterxml.jackson.databind.JsonNode
import com.fasterxml.jackson.databind.ObjectMapper
import com.fasterxml.jackson.databind.node.ArrayNode
import com.fasterxml.jackson.databind.node.ObjectNode
import mu.KLogging
import org.springframework.stereotype.Service
import org.springframework.web.reactive.function.client.WebClient
import org.springframework.web.reactive.function.client.bodyToMono
import org.springframework.web.server.ServerWebExchange
import reactor.core.publisher.Mono

@Service
class V6TalentTransformer(
  val objectMapper: ObjectMapper,
  val webClient: WebClient
) : VersionTransformer {

    override fun sourceVersionNumber(): ApiVersion = ApiVersion.V6

    override fun accept(exchange: ServerWebExchange): Boolean = exchange.request.uri.path.startsWith("/api/talent") 

    override fun transformRequestObjectNodeReactive(requestBody: ObjectNode): Mono<ObjectNode> {
        return webClient
          .get()
          .uri("lb://microservicename/api/workspace/${requestBody.get(WORKSPACE_ID).asText()}")
          .retrieve()
          .bodyToMono<ObjectNode>()
          .map { workspace ->
              requestBody.set<JsonNode>(FEDERATION_ID, objectMapper.valueToTree(workspace.get(FEDERATION_ID).asText()))
              requestBody
          }
    }

    companion object : KLogging() {
        const val WORKSPACE_ID = "workspaceId"
        const val FEDERATION_ID = "federationId"
    }

}