diff options
Diffstat (limited to 'src/main/scala/xyz/driver/core/file/GcsStorage.scala')
| -rw-r--r-- | src/main/scala/xyz/driver/core/file/GcsStorage.scala | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/main/scala/xyz/driver/core/file/GcsStorage.scala b/src/main/scala/xyz/driver/core/file/GcsStorage.scala index 76438cf..629b1d8 100644 --- a/src/main/scala/xyz/driver/core/file/GcsStorage.scala +++ b/src/main/scala/xyz/driver/core/file/GcsStorage.scala @@ -84,13 +84,19 @@ class GcsStorage(storageClient: Storage, override def list(directoryPath: Path): ListT[Future, FileLink] = ListT.listT(Future { + val directory = s"$directoryPath/" val page = storageClient.list( bucketName.value, BlobListOption.currentDirectory(), - BlobListOption.prefix(s"$directoryPath/") + BlobListOption.prefix(directory) ) - page.iterateAll().asScala.map(blobToFileLink(directoryPath, _)).toList + page + .iterateAll() + .asScala + .filter(_.getName != directory) + .map(blobToFileLink(directoryPath, _)) + .toList }) protected def blobToFileLink(path: Path, blob: Blob): FileLink = { |