flik/termora
1
0
Fork 0
mirror of https://github.com/TermoraDev/termora.git synced 2026-01-16 02:12:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: transfer

Browse Source
This commit is contained in:
hstyi
2025-06-21 16:52:55 +08:00
committed by hstyi
parent e6a45d25cd
commit e1eab9db06
113 changed files with 4592 additions and 4695 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/s3/src/main/kotlin/app/termora/plugins/s3/S3ProtocolProvider.kt
View File

@@ -2,8 +2,8 @@ package app.termora.plugins.s3
import app.termora.DynamicIcon
import app.termora.Icons
import app.termora.protocol.FileObjectHandler
import app.termora.protocol.FileObjectRequest
import app.termora.protocol.PathHandler
import app.termora.protocol.PathHandlerRequest
import app.termora.protocol.TransferProtocolProvider
import io.minio.MinioClient
import org.apache.commons.lang3.StringUtils
@@ -30,7 +30,7 @@ class S3ProtocolProvider private constructor() : TransferProtocolProvider {
return S3FileProvider.instance
}
override fun getRootFileObject(requester: FileObjectRequest): FileObjectHandler {
override fun getRootFileObject(requester: PathHandlerRequest): PathHandler {
val host = requester.host
val builder = MinioClient.builder()
.endpoint(host.host)
@@ -53,7 +53,7 @@ class S3ProtocolProvider private constructor() : TransferProtocolProvider {
"s3://${StringUtils.defaultIfBlank(defaultPath, "/")}",
options
)
return FileObjectHandler(file)
return PathHandler(file)
}
}

4
plugins/s3/src/test/kotlin/app/termora/plugins/s3/S3FileProviderTest.kt
View File

@@ -3,7 +3,7 @@ package app.termora.plugins.s3
import app.termora.Authentication
import app.termora.AuthenticationType
import app.termora.Host
import app.termora.protocol.FileObjectRequest
import app.termora.protocol.PathHandlerRequest
import app.termora.vfs2.VFSWalker
import io.minio.MakeBucketArgs
import io.minio.MinioClient
@@ -66,7 +66,7 @@ class S3FileProviderTest {
)
}
val requester = FileObjectRequest(
val requester = PathHandlerRequest(
host = Host(
name = "test",
protocol = S3ProtocolProvider.PROTOCOL,