From 013beeea5643cf88b23a0a3244044d4eee3aae40 Mon Sep 17 00:00:00 2001
From: bjkim <bjkim@cuuva.com>
Date: Tue, 23 Sep 2025 22:20:37 +0900
Subject: [PATCH] =?UTF-8?q?[UPDATE]=20ExperimentsController=EC=97=90=20Kub?=
 =?UTF-8?q?eflow=20Run=20=EB=AA=A9=EB=A1=9D=20=EC=A1=B0=ED=9A=8C=20API=20?=
 =?UTF-8?q?=EC=B6=94=EA=B0=80=20=EB=B0=8F=20=EC=9A=94=EC=B2=AD=20=ED=8C=8C?=
 =?UTF-8?q?=EB=9D=BC=EB=AF=B8=ED=84=B0=20=EC=B2=98=EB=A6=AC=20=EB=A1=9C?=
 =?UTF-8?q?=EC=A7=81=20=EA=B5=AC=ED=98=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controllers/ExperimentsController.java    | 56 +++++++++++++++++++
 1 file changed, 56 insertions(+)

diff --git a/src/main/java/kr/re/etri/autoflow/controllers/ExperimentsController.java b/src/main/java/kr/re/etri/autoflow/controllers/ExperimentsController.java
index cd3e4f5..b793802 100644
--- a/src/main/java/kr/re/etri/autoflow/controllers/ExperimentsController.java
+++ b/src/main/java/kr/re/etri/autoflow/controllers/ExperimentsController.java
@@ -2,6 +2,8 @@ package kr.re.etri.autoflow.controllers;
 
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.responses.ApiResponses;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.transaction.Transactional;
 import kr.re.etri.autoflow.entity.ExperimentsEntity;
@@ -18,6 +20,8 @@ import org.springframework.web.bind.annotation.*;
 import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.publisher.Mono;
 
+import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
 import java.time.Instant;
 import java.time.OffsetDateTime;
 import java.time.ZoneId;
@@ -205,6 +209,58 @@ public class ExperimentsController {
                 .doOnError(e -> log.error("Experiment 등록 실패", e));
     }
 
+    @Operation(summary = "Kubeflow Run 목록 조회", description = "Kubeflow API를 호출하여 Run 목록을 조회합니다.")
+    @ApiResponses({
+            @ApiResponse(responseCode = "200", description = "Run 목록 조회 성공"),
+            @ApiResponse(responseCode = "400", description = "잘못된 요청"),
+            @ApiResponse(responseCode = "500", description = "서버 내부 오류")
+    })
+    @GetMapping("/api/kubeflow/runs")
+    public Mono<ResponseEntity<Map>> listRuns(
+            @Parameter(description = "페이지 토큰 (다음 페이지 조회 시 사용)", example = "")
+            @RequestParam(value = "page_token", defaultValue = "") String pageToken,
+
+            @Parameter(description = "페이지 크기", example = "10")
+            @RequestParam(value = "page_size", defaultValue = "10") int pageSize,
+
+            @Parameter(description = "정렬 기준 (sort_by)", example = "created_at desc")
+            @RequestParam(value = "sort_by", defaultValue = "created_at desc") String sortBy,
+
+            @Parameter(description = "필터 JSON 문자열 (URL 인코딩 필요)", example = "{\"predicates\":[{\"key\":\"storage_state\",\"operation\":\"NOT_EQUALS\",\"string_value\":\"ARCHIVED\"}]}")
+            @RequestParam(value = "filter", required = false) String filter
+    ) {
+        try {
+            // filter가 없으면 기본값 적용
+            if (filter == null || filter.isBlank()) {
+                filter = "{\"predicates\":[{\"key\":\"storage_state\",\"operation\":\"NOT_EQUALS\",\"string_value\":\"ARCHIVED\"}]}";
+            }
+
+            String encodedFilter = URLEncoder.encode(filter, StandardCharsets.UTF_8);
+
+            String uri = String.format(
+                    "%s/apis/v2beta1/runs?page_token=%s&page_size=%d&sort_by=%s&filter=%s",
+                    kubeflowBaseUrl, pageToken, pageSize, URLEncoder.encode(sortBy, StandardCharsets.UTF_8), encodedFilter
+            );
+
+            return webClientBuilder.build()
+                    .get()
+                    .uri(uri)
+                    .accept(MediaType.APPLICATION_JSON)
+                    .retrieve()
+                    .bodyToMono(Map.class)
+                    .map(ResponseEntity::ok)
+                    .doOnError(e -> log.error("Kubeflow Runs 조회 실패", e));
+
+        } catch (Exception e) {
+            log.error("URI 생성 실패", e);
+            return Mono.just(ResponseEntity.status(500).body(Map.of(
+                    "status", 500,
+                    "error", "Internal Server Error",
+                    "message", e.getMessage()
+            )));
+        }
+    }
+
     @Operation(summary = "Experiment 수정")
     @PutMapping("/{id}")
     public ResponseEntity<ExperimentsEntity> updateExperiment(