refactor(stream actions): move segment logic into StreamActionsService

src/main/java/com/ddf/vodsystem/services/media/StreamActionsService.java

@@ -6,10 +6,15 @@ import org.slf4j.LoggerFactory;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import java.io.IOException;
+import java.nio.file.Files;
 import java.nio.file.Path;
+import java.time.Instant;
+import java.util.Comparator;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 /**
  * Service responsible for performing stream-related media actions, such as
@@ -25,6 +30,8 @@ public class StreamActionsService {
     private static final Logger logger = LoggerFactory.getLogger(StreamActionsService.class);
     private final CommandRunner commandRunner;
 
+    private static final int HLS_SEGMENT_LENGTH = 3;
+
     public StreamActionsService(CommandRunner commandRunner) {
         this.commandRunner = commandRunner;
     }
@@ -85,4 +92,27 @@ public class StreamActionsService {
             return CompletableFuture.failedFuture(e);
         }
     }
+
+    public List<Path> getSegmentsInRange(Path streamDirectory, Instant startTime, Instant endTime) throws IOException {
+        long startMs = startTime.toEpochMilli();
+        long endMs = endTime.toEpochMilli();
+
+        try (Stream<Path> files = Files.list(streamDirectory)) {
+            return files
+                    .filter(p -> p.getFileName().toString().endsWith(".ts"))
+                    .filter(p -> {
+                        long segMs = parseTimestampMs(p);
+                        return segMs < endMs && (segMs + HLS_SEGMENT_LENGTH * 1000) > startMs;
+                    })
+                    .sorted(Comparator.comparingLong(this::parseTimestampMs))
+                    .collect(Collectors.toList());
+        }
+    }
+
+    public long parseTimestampMs(Path path) {
+        String name = path.getFileName().toString().replace(".ts", "");
+        long value = Long.parseLong(name);
+        // nginx hls_fragment_naming system uses seconds; convert to ms
+        return value < 1_000_000_000_000L ? value * 1000L : value;
+    }
 }