SPC/snark
5
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

SNRK-68: Implement missed

Browse Source
This commit is contained in:
Kirill Grachev 2023-05-05 00:17:56 +03:00
parent 4441172ef7
commit 203aa52efe
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
snark-storage-driver/src/main/kotlin/space/kscience/snark/storage/s3/S3Root.kt
View File

@ -25,6 +25,10 @@ internal class S3Root(private val client: S3Client) : Directory {
throw NoSuchFileException(Path(filename).toFile()) throw NoSuchFileException(Path(filename).toFile())
} }
override suspend fun get(filename: Path): FileReader {
throw NoSuchFileException(filename.toFile())
}
override suspend fun create(filename: String, ignoreIfExists: Boolean) { override suspend fun create(filename: String, ignoreIfExists: Boolean) {
throw NoSuchFileException(Path(filename).toFile()) throw NoSuchFileException(Path(filename).toFile())
} }
@ -33,6 +37,10 @@ internal class S3Root(private val client: S3Client) : Directory {
throw NoSuchFileException(Path(filename).toFile()) throw NoSuchFileException(Path(filename).toFile())
} }
override suspend fun put(filename: Path): FileWriter {
throw NoSuchFileException(filename.toFile())
}
override suspend fun getSubdir(path: Path): Directory = try { override suspend fun getSubdir(path: Path): Directory = try {
val (bucketName, filePath) = splitPathIntoBucketAndPath(path) val (bucketName, filePath) = splitPathIntoBucketAndPath(path)
client.headBucket { client.headBucket {
@ -53,6 +61,9 @@ internal class S3Root(private val client: S3Client) : Directory {
throw AccessDeniedException(Path(dirname).toFile(), reason = ex.message) throw AccessDeniedException(Path(dirname).toFile(), reason = ex.message)
} }
override val path: Path
get() = Path("")
override fun close() { override fun close() {
} }