jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-19 18:05:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix(storage): returning full uris for file search

Browse Source
This commit is contained in:
brian.mulier
2023-12-01 15:30:23 +01:00
committed by brian-mulier-p
parent 587c7d91fe
commit e27a99bc9a
4 changed files with 33 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
storage-local/src/main/java/io/kestra/storage/local/LocalStorage.java
View File

@@ -51,12 +51,15 @@ public class LocalStorage implements StorageInterface {
}
@Override
public List<String> filePathsByPrefix(String tenantId, URI prefix) throws IOException {
Path prefixPath = getPath(tenantId, prefix);
try (Stream<Path> walk = Files.walk(prefixPath).filter(Files::isRegularFile)) {
public List<URI> filesByPrefix(String tenantId, URI prefix) throws IOException {
Path fsPath = getPath(tenantId, prefix);
try (Stream<Path> walk = Files.walk(fsPath).filter(Files::isRegularFile)) {
return walk.sorted(Comparator.reverseOrder())
.map(prefixPath::relativize)
.map(path -> "/" + path)
.map(fsPath::relativize)
.map(path -> {
String prefixPath = prefix.getPath();
return URI.create("kestra://" + prefixPath + (prefixPath.endsWith("/") ? "" : "/") + path);
})
.toList();
}
}