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> 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 updateExperiment(