VKT(Backend): KOSKI client

Opetushallitus · Jun 5, 2024 · 4802f65 · 4802f65
1 parent b3c566a
commit 4802f65
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 3 deletions.
diff --git a/backend/vkt/src/main/java/fi/oph/vkt/api/PublicController.java b/backend/vkt/src/main/java/fi/oph/vkt/api/PublicController.java
@@ -153,7 +153,7 @@ public PublicExamEventDTO getExamEventInfo(@PathVariable final long examEventId)
    */
   @GetMapping(path = "/education")
   public KoskiResponseDTO getEducation() {
-    return koskiService.findEducations();
+    return koskiService.findEducations("1.2.246.562.24.97984579806");
   }
 
   /**

diff --git a/backend/vkt/src/main/java/fi/oph/vkt/service/koski/KoskiService.java b/backend/vkt/src/main/java/fi/oph/vkt/service/koski/KoskiService.java
@@ -2,6 +2,7 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import fi.oph.vkt.service.koski.dto.KoskiResponseDTO;
+import fi.oph.vkt.service.koski.dto.RequestBody;
 import lombok.RequiredArgsConstructor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -19,14 +20,16 @@ public class KoskiService {
 
   private final WebClient koskiClient;
 
-  public KoskiResponseDTO findEducations() {
+  public KoskiResponseDTO findEducations(final String oid) {
     final ObjectMapper objectMapper = new ObjectMapper();
+    final RequestBody body = new RequestBody(oid);
 
     try {
+      final String bodyJson = objectMapper.writeValueAsString(body);
       final String response = koskiClient
         .post()
         .uri("/oid")
-        .bodyValue("{ \"oid\": \"1.2.246.562.24.97984579806\" }")
+        .bodyValue(bodyJson)
         .exchangeToMono(clientResponse -> {
           if (clientResponse.statusCode().isError()) {
             return clientResponse.createException().flatMap(Mono::error);

diff --git a/backend/vkt/src/main/java/fi/oph/vkt/service/koski/dto/RequestBody.java b/backend/vkt/src/main/java/fi/oph/vkt/service/koski/dto/RequestBody.java
@@ -0,0 +1,8 @@
+package fi.oph.vkt.service.koski.dto;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.Builder;
+import lombok.NonNull;
+
+@Builder
+public record RequestBody(@NonNull @NotNull String oid) {}