파일 count 기능 추가

src/main/java/com/kamco/cd/training/model/dto/ModelTrainMngDto.java

@@ -41,6 +41,7 @@ public class ModelTrainMngDto {
     private String trainType;
     private String modelNo;
     private Long currentAttemptId;
+    private String requestPath;
 
     public String getStatusName() {
       if (this.statusCd == null || this.statusCd.isBlank()) return null;

src/main/java/com/kamco/cd/training/model/service/ModelTrainMngService.java

@@ -12,6 +12,7 @@ import com.kamco.cd.training.model.dto.ModelTrainMngDto;
 import com.kamco.cd.training.model.dto.ModelTrainMngDto.SearchReq;
 import com.kamco.cd.training.postgres.core.HyperParamCoreService;
 import com.kamco.cd.training.postgres.core.ModelTrainMngCoreService;
+import com.kamco.cd.training.train.service.TmpDatasetService;
 import java.util.List;
 import java.util.UUID;
 import lombok.RequiredArgsConstructor;

src/main/java/com/kamco/cd/training/model/service/TmpDatasetService.java

@@ -1,147 +0,0 @@
-package com.kamco.cd.training.model.service;
-
-import java.io.IOException;
-import java.nio.file.*;
-import java.util.List;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Service;
-
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class TmpDatasetService {
-
-  @Value("${train.docker.requestDir}")
-  private String requestDir;
-
-  @Value("${train.docker.basePath}")
-  private String trainBaseDir;
-
-  public String buildTmpDatasetSymlink(String uid, List<String> datasetUids) throws IOException {
-
-    log.info("========== buildTmpDatasetHardlink START ==========");
-    log.info("uid={}", uid);
-    log.info("datasetUids={}", datasetUids);
-    log.info("requestDir(raw)={}", requestDir);
-
-    Path BASE = toPath(requestDir);
-    Path tmp = Path.of(trainBaseDir, "tmp", uid);
-
-    log.info("BASE={}", BASE);
-    log.info("BASE exists? {}", Files.isDirectory(BASE));
-    log.info("tmp={}", tmp);
-
-    long noDir = 0, scannedDirs = 0, regularFiles = 0, hardlinksMade = 0;
-
-    // tmp 디렉토리 준비
-    for (String type : List.of("train", "val", "test")) {
-      for (String part : List.of("input1", "input2", "label", "label-json")) {
-        Path dir = tmp.resolve(type).resolve(part);
-        Files.createDirectories(dir);
-        log.info("createDirectories: {}", dir);
-      }
-    }
-
-    // 하드링크는 "같은 파일시스템"에서만 가능하므로 BASE/tmp가 같은 FS인지 미리 확인(권장)
-    try {
-      var baseStore = Files.getFileStore(BASE);
-      var tmpStore = Files.getFileStore(tmp.getParent()); // BASE/tmp
-      if (!baseStore.name().equals(tmpStore.name()) || !baseStore.type().equals(tmpStore.type())) {
-        throw new IOException(
-            "Hardlink requires same filesystem. baseStore="
-                + baseStore.name()
-                + "("
-                + baseStore.type()
-                + "), tmpStore="
-                + tmpStore.name()
-                + "("
-                + tmpStore.type()
-                + ")");
-      }
-    } catch (Exception e) {
-      // FileStore 비교가 환경마다 애매할 수 있어서, 여기서는 경고만 주고 실제 createLink에서 최종 판단하게 둘 수도 있음.
-      log.warn("FileStore check skipped/failed (will rely on createLink): {}", e.toString());
-    }
-
-    for (String id : datasetUids) {
-      Path srcRoot = BASE.resolve(id);
-      log.info("---- dataset id={} srcRoot={} exists? {}", id, srcRoot, Files.isDirectory(srcRoot));
-
-      for (String type : List.of("train", "val", "test")) {
-        for (String part : List.of("input1", "input2", "label", "label-json")) {
-
-          Path srcDir = srcRoot.resolve(type).resolve(part);
-
-          if (!Files.isDirectory(srcDir)) {
-            log.warn("SKIP (not directory): {}", srcDir);
-            noDir++;
-            continue;
-          }
-
-          scannedDirs++;
-          log.info("SCAN dir={}", srcDir);
-
-          try (DirectoryStream<Path> stream = Files.newDirectoryStream(srcDir)) {
-            for (Path f : stream) {
-              if (!Files.isRegularFile(f)) {
-                log.debug("skip non-regular file: {}", f);
-                continue;
-              }
-
-              regularFiles++;
-
-              String dstName = id + "__" + f.getFileName();
-              Path dst = tmp.resolve(type).resolve(part).resolve(dstName);
-
-              // dst가 남아있으면 삭제(심볼릭링크든 파일이든)
-              if (Files.exists(dst) || Files.isSymbolicLink(dst)) {
-                Files.delete(dst);
-                log.debug("deleted existing: {}", dst);
-              }
-
-              try {
-                // 하드링크 생성 (dst가 새 파일로 생기지만 inode는 f와 동일)
-                Files.createLink(dst, f);
-                hardlinksMade++;
-                log.debug("created hardlink: {} => {}", dst, f);
-              } catch (IOException e) {
-                // 여기서 바로 실패시키면 “tmp는 만들었는데 내용은 0개” 같은 상태를 방지할 수 있음
-                log.error("FAILED create hardlink: {} => {}", dst, f, e);
-                throw e;
-              }
-            }
-          }
-        }
-      }
-    }
-
-    if (hardlinksMade == 0) {
-      throw new IOException(
-          "No hardlinks created. regularFiles="
-              + regularFiles
-              + ", scannedDirs="
-              + scannedDirs
-              + ", noDir="
-              + noDir);
-    }
-
-    log.info("tmp dataset created: {}", tmp);
-    log.info(
-        "summary: scannedDirs={}, noDir={}, regularFiles={}, hardlinksMade={}",
-        scannedDirs,
-        noDir,
-        regularFiles,
-        hardlinksMade);
-
-    return uid;
-  }
-
-  private static Path toPath(String p) {
-    if (p.startsWith("~/")) {
-      return Paths.get(System.getProperty("user.home")).resolve(p.substring(2)).normalize();
-    }
-    return Paths.get(p).toAbsolutePath().normalize();
-  }
-}