add vendor info to tests

README.md

@@ -40,16 +40,15 @@ func main() {
 
 ## 📁 Supported Storage Providers
 
-| Provider       | Module Path                | Required Fields                                 |
-|----------------|----------------------------|-------------------------------------------------|
-| Local          | `oss/local/localfile.go`   | `Path`                                          |
-| Aliyun OSS     | `oss/aliyun/aliyun.go`     | `Endpoint`, `AccessKey`, `SecretKey`, `Bucket`  |
-| AWS S3         | `oss/s3/s3.go`             | `Region`, `AccessKey`, `SecretKey`, `Bucket`    |
-| Azure Blob     | `oss/azureblob/blob.go`    | `AccountName`, `AccountKey`, `Container`        |
-| Google GCS     | `oss/gcsblob/gcs.go`       | `CredentialsJSON`, `Bucket`                     |
-| Tencent COS    | `oss/tencentcos/cos.go`    | `SecretId`, `SecretKey`, `Bucket`, `Region`     |
-| Huawei OBS     | `oss/huaweiobs/obs.go`    | `AK`, `SK`, `Endpoint`, `Bucket`                |
-| Volcengine TOS | `oss/volcenginetos/tos.go` | `Endpoint`,  `AccessKey`, `SecretKey`, `Bucket` |
+| Provider     | Module Path                  | Required Fields |
+|--------------|------------------------------|-----------------|
+| Local        | `oss/local/localfile.go`     | `Path`          |
+| Aliyun OSS   | `oss/aliyun/aliyun.go`       | `Endpoint`, `AccessKey`, `SecretKey`, `Bucket` |
+| AWS S3       | `oss/s3/s3.go`               | `Region`, `AccessKey`, `SecretKey`, `Bucket` |
+| Azure Blob   | `oss/azureblob/blob.go`      | `AccountName`, `AccountKey`, `Container` |
+| Google GCS   | `oss/gcsblob/gcs.go`         | `CredentialsJSON`, `Bucket` |
+| Tencent COS  | `oss/tencentcos/cos.go`      | `SecretId`, `SecretKey`, `Bucket`, `Region` |
+| Huawei OBS   | `oss/huanweiobs/obs.go`      | `AK`, `SK`, `Endpoint`, `Bucket` |
 
 ## 🏗️ Usage with Factory
 
@@ -100,12 +99,11 @@ This project is licensed under the [Apache 2.0 License](LICENSE).
 ## NOTICE
 Some parts of the code in this project originate from [dify-plugin-daemon](https://github.com/langgenius/dify-plugin-daemon)
 
-| Provider       | Author | PR |
-|----------------|---|---|
-| Aliyun OSS     |[bravomark](https://github.com/bravomark)|https://github.com/langgenius/dify-plugin-daemon/pull/261 |
-| Azure Blob     |[techan](https://github.com/te-chan)|https://github.com/langgenius/dify-plugin-daemon/pull/172|
-| Google GCS     |[Hironori Yamamoto](https://github.com/hiro-o918)|https://github.com/langgenius/dify-plugin-daemon/pull/237|
-| Local          |[lengyhua](https://github.com/lengyhua)|https://github.com/langgenius/dify-plugin-daemon/pull/157|
-| AWS S3         |[Yeuoly](https://github.com/Yeuoly)|https://github.com/langgenius/dify-plugin-daemon/commit/9ad9d7d4de1d123956ab07955e541bc4053e5170|
-| Tencent COS    |[quicksand](https://github.com/quicksandznzn)|https://github.com/langgenius/dify-plugin-daemon/pull/97|
-| Volcengine TOS |[quicksand](https://github.com/quicksandznzn)|https://github.com/langgenius/dify-cloud-kit/pull/2|
+|Provider | Author | PR |
+|---|---|---|
+|Aliyun OSS|[bravomark](https://github.com/bravomark)|https://github.com/langgenius/dify-plugin-daemon/pull/261 |
+|Azure Blob|[techan](https://github.com/te-chan)|https://github.com/langgenius/dify-plugin-daemon/pull/172|
+|Google GCS|[Hironori Yamamoto](https://github.com/hiro-o918)|https://github.com/langgenius/dify-plugin-daemon/pull/237|
+|Local|[lengyhua](https://github.com/lengyhua)|https://github.com/langgenius/dify-plugin-daemon/pull/157|
+|AWS S3|[Yeuoly](https://github.com/Yeuoly)|https://github.com/langgenius/dify-plugin-daemon/commit/9ad9d7d4de1d123956ab07955e541bc4053e5170|
+|Tencent COS|[quicksand](https://github.com/quicksandznzn)|https://github.com/langgenius/dify-plugin-daemon/pull/97|

go.mod

@@ -1,94 +1,89 @@
 module github.com/langgenius/dify-cloud-kit
 
-go 1.25.0
+go 1.23.3
 
 require (
 	cloud.google.com/go/storage v1.54.0
-	github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.9.0
 	github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.6.1
 	github.com/aliyun/aliyun-oss-go-sdk v3.0.2+incompatible
-	github.com/aws/aws-sdk-go-v2 v1.41.5
+	github.com/aws/aws-sdk-go-v2 v1.36.3
 	github.com/aws/aws-sdk-go-v2/config v1.29.14
 	github.com/aws/aws-sdk-go-v2/credentials v1.17.67
-	github.com/aws/aws-sdk-go-v2/service/s3 v1.97.3
-	github.com/aws/smithy-go v1.24.2
-	github.com/huaweicloud/huaweicloud-sdk-go-obs v3.25.4+incompatible
-	github.com/stretchr/testify v1.11.1
+	github.com/aws/aws-sdk-go-v2/service/s3 v1.79.4
+	github.com/aws/smithy-go v1.22.2
+	github.com/stretchr/testify v1.10.0
 	github.com/tencentyun/cos-go-sdk-v5 v0.7.65
-	github.com/volcengine/ve-tos-golang-sdk/v2 v2.7.12
-	google.golang.org/api v0.232.0
 )
 
 require (
-	cel.dev/expr v0.25.1 // indirect
+	cel.dev/expr v0.20.0 // indirect
 	cloud.google.com/go v0.121.0 // indirect
 	cloud.google.com/go/auth v0.16.1 // indirect
 	cloud.google.com/go/auth/oauth2adapt v0.2.8 // indirect
-	cloud.google.com/go/compute/metadata v0.9.0 // indirect
+	cloud.google.com/go/compute/metadata v0.6.0 // indirect
 	cloud.google.com/go/iam v1.5.2 // indirect
 	cloud.google.com/go/monitoring v1.24.0 // indirect
 	github.com/Azure/azure-sdk-for-go/sdk/azcore v1.18.0 // indirect
 	github.com/Azure/azure-sdk-for-go/sdk/internal v1.11.1 // indirect
-	github.com/AzureAD/microsoft-authentication-library-for-go v1.4.2 // indirect
-	github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.30.0 // indirect
+	github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0 // indirect
 	github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/metric v0.51.0 // indirect
 	github.com/GoogleCloudPlatform/opentelemetry-operations-go/internal/resourcemapping v0.51.0 // indirect
-	github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.8 // indirect
+	github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.10 // indirect
 	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.30 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.21 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.21 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.34 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.34 // indirect
 	github.com/aws/aws-sdk-go-v2/internal/ini v1.8.3 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/v4a v1.4.22 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.13.7 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.9.13 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.13.21 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.19.21 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.34 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.2 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.15 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.15 // indirect
 	github.com/aws/aws-sdk-go-v2/service/sso v1.25.3 // indirect
 	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.30.1 // indirect
 	github.com/aws/aws-sdk-go-v2/service/sts v1.33.19 // indirect
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/clbanning/mxj v1.8.4 // indirect
-	github.com/cncf/xds/go v0.0.0-20251210132809-ee656c7534f5 // indirect
-	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
-	github.com/envoyproxy/go-control-plane/envoy v1.36.0 // indirect
-	github.com/envoyproxy/protoc-gen-validate v1.3.0 // indirect
+	github.com/cncf/xds/go v0.0.0-20250121191232-2f005788dc42 // indirect
+	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/envoyproxy/go-control-plane/envoy v1.32.4 // indirect
+	github.com/envoyproxy/protoc-gen-validate v1.2.1 // indirect
 	github.com/felixge/httpsnoop v1.0.4 // indirect
-	github.com/go-jose/go-jose/v4 v4.1.4 // indirect
-	github.com/go-logr/logr v1.4.3 // indirect
+	github.com/go-jose/go-jose/v4 v4.0.4 // indirect
+	github.com/go-logr/logr v1.4.2 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
-	github.com/golang-jwt/jwt/v5 v5.2.2 // indirect
 	github.com/google/go-querystring v1.0.0 // indirect
 	github.com/google/s2a-go v0.1.9 // indirect
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/googleapis/enterprise-certificate-proxy v0.3.6 // indirect
 	github.com/googleapis/gax-go/v2 v2.14.1 // indirect
-	github.com/kylelemons/godebug v1.1.0 // indirect
+	github.com/huaweicloud/huaweicloud-sdk-go-obs v3.25.4+incompatible // indirect
 	github.com/mitchellh/mapstructure v1.4.3 // indirect
 	github.com/mozillazg/go-httpheader v0.2.1 // indirect
-	github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c // indirect
 	github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10 // indirect
-	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
-	github.com/spiffe/go-spiffe/v2 v2.6.0 // indirect
-	go.opentelemetry.io/auto/sdk v1.2.1 // indirect
-	go.opentelemetry.io/contrib/detectors/gcp v1.39.0 // indirect
+	github.com/pmezard/go-difflib v1.0.0 // indirect
+	github.com/spiffe/go-spiffe/v2 v2.5.0 // indirect
+	github.com/zeebo/errs v1.4.0 // indirect
+	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
+	go.opentelemetry.io/contrib/detectors/gcp v1.35.0 // indirect
 	go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.60.0 // indirect
 	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.60.0 // indirect
-	go.opentelemetry.io/otel v1.43.0 // indirect
-	go.opentelemetry.io/otel/metric v1.43.0 // indirect
-	go.opentelemetry.io/otel/sdk v1.43.0 // indirect
-	go.opentelemetry.io/otel/sdk/metric v1.43.0 // indirect
-	go.opentelemetry.io/otel/trace v1.43.0 // indirect
-	golang.org/x/crypto v0.52.0 // indirect
-	golang.org/x/net v0.55.0 // indirect
-	golang.org/x/oauth2 v0.34.0 // indirect
-	golang.org/x/sync v0.20.0 // indirect
-	golang.org/x/sys v0.45.0 // indirect
-	golang.org/x/text v0.37.0 // indirect
+	go.opentelemetry.io/otel v1.35.0 // indirect
+	go.opentelemetry.io/otel/metric v1.35.0 // indirect
+	go.opentelemetry.io/otel/sdk v1.35.0 // indirect
+	go.opentelemetry.io/otel/sdk/metric v1.35.0 // indirect
+	go.opentelemetry.io/otel/trace v1.35.0 // indirect
+	golang.org/x/crypto v0.37.0 // indirect
+	golang.org/x/net v0.39.0 // indirect
+	golang.org/x/oauth2 v0.30.0 // indirect
+	golang.org/x/sync v0.14.0 // indirect
+	golang.org/x/sys v0.32.0 // indirect
+	golang.org/x/text v0.24.0 // indirect
 	golang.org/x/time v0.11.0 // indirect
+	google.golang.org/api v0.232.0 // indirect
 	google.golang.org/genproto v0.0.0-20250303144028-a0af3efb3deb // indirect
-	google.golang.org/genproto/googleapis/api v0.0.0-20251202230838-ff82c1b0f217 // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20251202230838-ff82c1b0f217 // indirect
-	google.golang.org/grpc v1.79.3 // indirect
-	google.golang.org/protobuf v1.36.10 // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20250505200425-f936aa4a68b2 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20250505200425-f936aa4a68b2 // indirect
+	google.golang.org/grpc v1.72.0 // indirect
+	google.golang.org/protobuf v1.36.6 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )

go.sum

@@ -1,13 +1,13 @@
-cel.dev/expr v0.25.1 h1:1KrZg61W6TWSxuNZ37Xy49ps13NUovb66QLprthtwi4=
-cel.dev/expr v0.25.1/go.mod h1:hrXvqGP6G6gyx8UAHSHJ5RGk//1Oj5nXQ2NI02Nrsg4=
+cel.dev/expr v0.20.0 h1:OunBvVCfvpWlt4dN7zg3FM6TDkzOePe1+foGJ9AXeeI=
+cel.dev/expr v0.20.0/go.mod h1:MrpN08Q+lEBs+bGYdLxxHkZoUSsCp0nSKTs0nTymJgw=
 cloud.google.com/go v0.121.0 h1:pgfwva8nGw7vivjZiRfrmglGWiCJBP+0OmDpenG/Fwg=
 cloud.google.com/go v0.121.0/go.mod h1:rS7Kytwheu/y9buoDmu5EIpMMCI4Mb8ND4aeN4Vwj7Q=
 cloud.google.com/go/auth v0.16.1 h1:XrXauHMd30LhQYVRHLGvJiYeczweKQXZxsTbV9TiguU=
 cloud.google.com/go/auth v0.16.1/go.mod h1:1howDHJ5IETh/LwYs3ZxvlkXF48aSqqJUM+5o02dNOI=
 cloud.google.com/go/auth/oauth2adapt v0.2.8 h1:keo8NaayQZ6wimpNSmW5OPc283g65QNIiLpZnkHRbnc=
 cloud.google.com/go/auth/oauth2adapt v0.2.8/go.mod h1:XQ9y31RkqZCcwJWNSx2Xvric3RrU88hAYYbjDWYDL+c=
-cloud.google.com/go/compute/metadata v0.9.0 h1:pDUj4QMoPejqq20dK0Pg2N4yG9zIkYGdBtwLoEkH9Zs=
-cloud.google.com/go/compute/metadata v0.9.0/go.mod h1:E0bWwX5wTnLPedCKqk3pJmVgCBSM6qQI1yTBdEb3C10=
+cloud.google.com/go/compute/metadata v0.6.0 h1:A6hENjEsCDtC1k8byVsgwvVcioamEHvZ4j01OwKxG9I=
+cloud.google.com/go/compute/metadata v0.6.0/go.mod h1:FjyFAW1MW0C203CEOMDTu3Dk1FlqW3Rga40jzHL4hfg=
 cloud.google.com/go/iam v1.5.2 h1:qgFRAGEmd8z6dJ/qyEchAuL9jpswyODjA2lS+w234g8=
 cloud.google.com/go/iam v1.5.2/go.mod h1:SE1vg0N81zQqLzQEwxL2WI6yhetBdbNQuTvIKCSkUHE=
 cloud.google.com/go/logging v1.13.0 h1:7j0HgAp0B94o1YRDqiqm26w4q1rDMH7XNRU34lJXHYc=
@@ -24,20 +24,16 @@ github.com/Azure/azure-sdk-for-go/sdk/azcore v1.18.0 h1:Gt0j3wceWMwPmiazCa8MzMA0
 github.com/Azure/azure-sdk-for-go/sdk/azcore v1.18.0/go.mod h1:Ot/6aikWnKWi4l9QB7qVSwa8iMphQNqkWALMoNT3rzM=
 github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.9.0 h1:OVoM452qUFBrX+URdH3VpR299ma4kfom0yB0URYky9g=
 github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.9.0/go.mod h1:kUjrAo8bgEwLeZ/CmHqNl3Z/kPm7y6FKfxxK0izYUg4=
-github.com/Azure/azure-sdk-for-go/sdk/azidentity/cache v0.3.2 h1:yz1bePFlP5Vws5+8ez6T3HWXPmwOK7Yvq8QxDBD3SKY=
-github.com/Azure/azure-sdk-for-go/sdk/azidentity/cache v0.3.2/go.mod h1:Pa9ZNPuoNu/GztvBSKk9J1cDJW6vk/n0zLtV4mgd8N8=
 github.com/Azure/azure-sdk-for-go/sdk/internal v1.11.1 h1:FPKJS1T+clwv+OLGt13a8UjqeRuh0O4SJ3lUriThc+4=
 github.com/Azure/azure-sdk-for-go/sdk/internal v1.11.1/go.mod h1:j2chePtV91HrC22tGoRX3sGY42uF13WzmmV80/OdVAA=
 github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/storage/armstorage v1.8.0 h1:LR0kAX9ykz8G4YgLCaRDVJ3+n43R8MneB5dTy2konZo=
 github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/storage/armstorage v1.8.0/go.mod h1:DWAciXemNf++PQJLeXUB4HHH5OpsAh12HZnu2wXE1jA=
 github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.6.1 h1:lhZdRq7TIx0GJQvSyX2Si406vrYsov2FXGp/RnSEtcs=
 github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.6.1/go.mod h1:8cl44BDmi+effbARHMQjgOKA2AYvcohNm7KEt42mSV8=
-github.com/AzureAD/microsoft-authentication-extensions-for-go/cache v0.1.1 h1:WJTmL004Abzc5wDB5VtZG2PJk5ndYDgVacGqfirKxjM=
-github.com/AzureAD/microsoft-authentication-extensions-for-go/cache v0.1.1/go.mod h1:tCcJZ0uHAmvjsVYzEFivsRTN00oz5BEsRgQHu5JZ9WE=
 github.com/AzureAD/microsoft-authentication-library-for-go v1.4.2 h1:oygO0locgZJe7PpYPXT5A29ZkwJaPqcva7BVeemZOZs=
 github.com/AzureAD/microsoft-authentication-library-for-go v1.4.2/go.mod h1:wP83P5OoQ5p6ip3ScPr0BAq0BvuPAvacpEuSzyouqAI=
-github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.30.0 h1:sBEjpZlNHzK1voKq9695PJSX2o5NEXl7/OL3coiIY0c=
-github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.30.0/go.mod h1:P4WPRUkOhJC13W//jWpyfJNDAIpvRbAUIYLX/4jtlE0=
+github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0 h1:ErKg/3iS1AKcTkf3yixlZ54f9U1rljCkQyEXWUnIUxc=
+github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0/go.mod h1:yAZHSGnqScoU556rBOVkwLze6WP5N+U11RHuWaGVxwY=
 github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/metric v0.51.0 h1:fYE9p3esPxA/C0rQ0AHhP0drtPXDRhaWiwg1DPqO7IU=
 github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/metric v0.51.0/go.mod h1:BnBReJLvVYx2CS/UHOgVz2BXKXD9wsQPxZug20nZhd0=
 github.com/GoogleCloudPlatform/opentelemetry-operations-go/internal/cloudmock v0.51.0 h1:OqVGm6Ei3x5+yZmSJG1Mh2NwHvpVmZ08CB5qJhT9Nuk=
@@ -47,70 +43,66 @@ github.com/GoogleCloudPlatform/opentelemetry-operations-go/internal/resourcemapp
 github.com/QcloudApi/qcloud_sign_golang v0.0.0-20141224014652-e4130a326409/go.mod h1:1pk82RBxDY/JZnPQrtqHlUFfCctgdorsd9M06fMynOM=
 github.com/aliyun/aliyun-oss-go-sdk v3.0.2+incompatible h1:8psS8a+wKfiLt1iVDX79F7Y6wUM49Lcha2FMXt4UM8g=
 github.com/aliyun/aliyun-oss-go-sdk v3.0.2+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
-github.com/aws/aws-sdk-go-v2 v1.41.5 h1:dj5kopbwUsVUVFgO4Fi5BIT3t4WyqIDjGKCangnV/yY=
-github.com/aws/aws-sdk-go-v2 v1.41.5/go.mod h1:mwsPRE8ceUUpiTgF7QmQIJ7lgsKUPQOUl3o72QBrE1o=
-github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.8 h1:eBMB84YGghSocM7PsjmmPffTa+1FBUeNvGvFou6V/4o=
-github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.8/go.mod h1:lyw7GFp3qENLh7kwzf7iMzAxDn+NzjXEAGjKS2UOKqI=
+github.com/aws/aws-sdk-go-v2 v1.36.3 h1:mJoei2CxPutQVxaATCzDUjcZEjVRdpsiiXi2o38yqWM=
+github.com/aws/aws-sdk-go-v2 v1.36.3/go.mod h1:LLXuLpgzEbD766Z5ECcRmi8AzSwfZItDtmABVkRLGzg=
+github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.10 h1:zAybnyUQXIZ5mok5Jqwlf58/TFE7uvd3IAsa1aF9cXs=
+github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.10/go.mod h1:qqvMj6gHLR/EXWZw4ZbqlPbQUyenf4h82UQUlKc+l14=
 github.com/aws/aws-sdk-go-v2/config v1.29.14 h1:f+eEi/2cKCg9pqKBoAIwRGzVb70MRKqWX4dg1BDcSJM=
 github.com/aws/aws-sdk-go-v2/config v1.29.14/go.mod h1:wVPHWcIFv3WO89w0rE10gzf17ZYy+UVS1Geq8Iei34g=
 github.com/aws/aws-sdk-go-v2/credentials v1.17.67 h1:9KxtdcIA/5xPNQyZRgUSpYOE6j9Bc4+D7nZua0KGYOM=
 github.com/aws/aws-sdk-go-v2/credentials v1.17.67/go.mod h1:p3C44m+cfnbv763s52gCqrjaqyPikj9Sg47kUVaNZQQ=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.30 h1:x793wxmUWVDhshP8WW2mlnXuFrO4cOd3HLBroh1paFw=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.30/go.mod h1:Jpne2tDnYiFascUEs2AWHJL9Yp7A5ZVy3TNyxaAjD6M=
-github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.21 h1:Rgg6wvjjtX8bNHcvi9OnXWwcE0a2vGpbwmtICOsvcf4=
-github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.21/go.mod h1:A/kJFst/nm//cyqonihbdpQZwiUhhzpqTsdbhDdRF9c=
-github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.21 h1:PEgGVtPoB6NTpPrBgqSE5hE/o47Ij9qk/SEZFbUOe9A=
-github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.21/go.mod h1:p+hz+PRAYlY3zcpJhPwXlLC4C+kqn70WIHwnzAfs6ps=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.34 h1:ZK5jHhnrioRkUNOc+hOgQKlUL5JeC3S6JgLxtQ+Rm0Q=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.34/go.mod h1:p4VfIceZokChbA9FzMbRGz5OV+lekcVtHlPKEO0gSZY=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.34 h1:SZwFm17ZUNNg5Np0ioo/gq8Mn6u9w19Mri8DnJ15Jf0=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.34/go.mod h1:dFZsC0BLo346mvKQLWmoJxT+Sjp+qcVR1tRVHQGOH9Q=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.8.3 h1:bIqFDwgGXXN1Kpp99pDOdKMTTb5d2KyU5X/BZxjOkRo=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.8.3/go.mod h1:H5O/EsxDWyU+LP/V8i5sm8cxoZgc2fdNR9bxlOFrQTo=
-github.com/aws/aws-sdk-go-v2/internal/v4a v1.4.22 h1:rWyie/PxDRIdhNf4DzRk0lvjVOqFJuNnO8WwaIRVxzQ=
-github.com/aws/aws-sdk-go-v2/internal/v4a v1.4.22/go.mod h1:zd/JsJ4P7oGfUhXn1VyLqaRZwPmZwg44Jf2dS84Dm3Y=
-github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.13.7 h1:5EniKhLZe4xzL7a+fU3C2tfUN4nWIqlLesfrjkuPFTY=
-github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.13.7/go.mod h1:x0nZssQ3qZSnIcePWLvcoFisRXJzcTVvYpAAdYX8+GI=
-github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.9.13 h1:JRaIgADQS/U6uXDqlPiefP32yXTda7Kqfx+LgspooZM=
-github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.9.13/go.mod h1:CEuVn5WqOMilYl+tbccq8+N2ieCy0gVn3OtRb0vBNNM=
-github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.13.21 h1:c31//R3xgIJMSC8S6hEVq+38DcvUlgFY0FM6mSI5oto=
-github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.13.21/go.mod h1:r6+pf23ouCB718FUxaqzZdbpYFyDtehyZcmP5KL9FkA=
-github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.19.21 h1:ZlvrNcHSFFWURB8avufQq9gFsheUgjVD9536obIknfM=
-github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.19.21/go.mod h1:cv3TNhVrssKR0O/xxLJVRfd2oazSnZnkUeTf6ctUwfQ=
-github.com/aws/aws-sdk-go-v2/service/s3 v1.97.3 h1:HwxWTbTrIHm5qY+CAEur0s/figc3qwvLWsNkF4RPToo=
-github.com/aws/aws-sdk-go-v2/service/s3 v1.97.3/go.mod h1:uoA43SdFwacedBfSgfFSjjCvYe8aYBS7EnU5GZ/YKMM=
+github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.34 h1:ZNTqv4nIdE/DiBfUUfXcLZ/Spcuz+RjeziUtNJackkM=
+github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.34/go.mod h1:zf7Vcd1ViW7cPqYWEHLHJkS50X0JS2IKz9Cgaj6ugrs=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.3 h1:eAh2A4b5IzM/lum78bZ590jy36+d/aFLgKF/4Vd1xPE=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.3/go.mod h1:0yKJC/kb8sAnmlYa6Zs3QVYqaC8ug2AbnNChv5Ox3uA=
+github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.2 h1:BCG7DCXEXpNCcpwCxg1oi9pkJWH2+eZzTn9MY56MbVw=
+github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.7.2/go.mod h1:iu6FSzgt+M2/x3Dk8zhycdIcHjEFb36IS8HVUVFoMg0=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.15 h1:dM9/92u2F1JbDaGooxTq18wmmFzbJRfXfVfy96/1CXM=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.15/go.mod h1:SwFBy2vjtA0vZbjjaFtfN045boopadnoVPhu4Fv66vY=
+github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.15 h1:moLQUoVq91LiqT1nbvzDukyqAlCv89ZmwaHw/ZFlFZg=
+github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.15/go.mod h1:ZH34PJUc8ApjBIfgQCFvkWcUDBtl/WTD+uiYHjd8igA=
+github.com/aws/aws-sdk-go-v2/service/s3 v1.79.4 h1:4yxno6bNHkekkfqG/a1nz/gC2gBwhJSojV1+oTE7K+4=
+github.com/aws/aws-sdk-go-v2/service/s3 v1.79.4/go.mod h1:qbn305Je/IofWBJ4bJz/Q7pDEtnnoInw/dGt71v6rHE=
 github.com/aws/aws-sdk-go-v2/service/sso v1.25.3 h1:1Gw+9ajCV1jogloEv1RRnvfRFia2cL6c9cuKV2Ps+G8=
 github.com/aws/aws-sdk-go-v2/service/sso v1.25.3/go.mod h1:qs4a9T5EMLl/Cajiw2TcbNt2UNo/Hqlyp+GiuG4CFDI=
 github.com/aws/aws-sdk-go-v2/service/ssooidc v1.30.1 h1:hXmVKytPfTy5axZ+fYbR5d0cFmC3JvwLm5kM83luako=
 github.com/aws/aws-sdk-go-v2/service/ssooidc v1.30.1/go.mod h1:MlYRNmYu/fGPoxBQVvBYr9nyr948aY/WLUvwBMBJubs=
 github.com/aws/aws-sdk-go-v2/service/sts v1.33.19 h1:1XuUZ8mYJw9B6lzAkXhqHlJd/XvaX32evhproijJEZY=
 github.com/aws/aws-sdk-go-v2/service/sts v1.33.19/go.mod h1:cQnB8CUnxbMU82JvlqjKR2HBOm3fe9pWorWBza6MBJ4=
-github.com/aws/smithy-go v1.24.2 h1:FzA3bu/nt/vDvmnkg+R8Xl46gmzEDam6mZ1hzmwXFng=
-github.com/aws/smithy-go v1.24.2/go.mod h1:YE2RhdIuDbA5E5bTdciG9KrW3+TiEONeUWCqxX9i1Fc=
+github.com/aws/smithy-go v1.22.2 h1:6D9hW43xKFrRx/tXXfAlIZc4JI+yQe6snnWcQyxSyLQ=
+github.com/aws/smithy-go v1.22.2/go.mod h1:irrKGvNn1InZwb2d7fkIRNucdfwR8R+Ts3wxYa/cJHg=
 github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
 github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/clbanning/mxj v1.8.4 h1:HuhwZtbyvyOw+3Z1AowPkU87JkJUSv751ELWaiTpj8I=
 github.com/clbanning/mxj v1.8.4/go.mod h1:BVjHeAH+rl9rs6f+QIpeRl0tfu10SXn1pUSa5PVGJng=
-github.com/cncf/xds/go v0.0.0-20251210132809-ee656c7534f5 h1:6xNmx7iTtyBRev0+D/Tv1FZd4SCg8axKApyNyRsAt/w=
-github.com/cncf/xds/go v0.0.0-20251210132809-ee656c7534f5/go.mod h1:KdCmV+x/BuvyMxRnYBlmVaq4OLiKW6iRQfvC62cvdkI=
-github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
+github.com/cncf/xds/go v0.0.0-20250121191232-2f005788dc42 h1:Om6kYQYDUk5wWbT0t0q6pvyM49i9XZAv9dDrkDA7gjk=
+github.com/cncf/xds/go v0.0.0-20250121191232-2f005788dc42/go.mod h1:W+zGtBO5Y1IgJhy4+A9GOqVhqLpfZi+vwmdNXUehLA8=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
-github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
-github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
-github.com/envoyproxy/go-control-plane v0.14.0 h1:hbG2kr4RuFj222B6+7T83thSPqLjwBIfQawTkC++2HA=
-github.com/envoyproxy/go-control-plane v0.14.0/go.mod h1:NcS5X47pLl/hfqxU70yPwL9ZMkUlwlKxtAohpi2wBEU=
-github.com/envoyproxy/go-control-plane/envoy v1.36.0 h1:yg/JjO5E7ubRyKX3m07GF3reDNEnfOboJ0QySbH736g=
-github.com/envoyproxy/go-control-plane/envoy v1.36.0/go.mod h1:ty89S1YCCVruQAm9OtKeEkQLTb+Lkz0k8v9W0Oxsv98=
+github.com/envoyproxy/go-control-plane v0.13.4 h1:zEqyPVyku6IvWCFwux4x9RxkLOMUL+1vC9xUFv5l2/M=
+github.com/envoyproxy/go-control-plane v0.13.4/go.mod h1:kDfuBlDVsSj2MjrLEtRWtHlsWIFcGyB2RMO44Dc5GZA=
+github.com/envoyproxy/go-control-plane/envoy v1.32.4 h1:jb83lalDRZSpPWW2Z7Mck/8kXZ5CQAFYVjQcdVIr83A=
+github.com/envoyproxy/go-control-plane/envoy v1.32.4/go.mod h1:Gzjc5k8JcJswLjAx1Zm+wSYE20UrLtt7JZMWiWQXQEw=
 github.com/envoyproxy/go-control-plane/ratelimit v0.1.0 h1:/G9QYbddjL25KvtKTv3an9lx6VBE2cnb8wp1vEGNYGI=
 github.com/envoyproxy/go-control-plane/ratelimit v0.1.0/go.mod h1:Wk+tMFAFbCXaJPzVVHnPgRKdUdwW/KdbRt94AzgRee4=
-github.com/envoyproxy/protoc-gen-validate v1.3.0 h1:TvGH1wof4H33rezVKWSpqKz5NXWg5VPuZ0uONDT6eb4=
-github.com/envoyproxy/protoc-gen-validate v1.3.0/go.mod h1:HvYl7zwPa5mffgyeTUHA9zHIH36nmrm7oCbo4YKoSWA=
+github.com/envoyproxy/protoc-gen-validate v1.2.1 h1:DEo3O99U8j4hBFwbJfrz9VtgcDfUKS7KJ7spH3d86P8=
+github.com/envoyproxy/protoc-gen-validate v1.2.1/go.mod h1:d/C80l/jxXLdfEIhX1W2TmLfsJ31lvEjwamM4DxlWXU=
 github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
 github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
-github.com/go-jose/go-jose/v4 v4.1.4 h1:moDMcTHmvE6Groj34emNPLs/qtYXRVcd6S7NHbHz3kA=
-github.com/go-jose/go-jose/v4 v4.1.4/go.mod h1:x4oUasVrzR7071A4TnHLGSPpNOm2a21K9Kf04k1rs08=
+github.com/go-jose/go-jose/v4 v4.0.4 h1:VsjPI33J0SB9vQM6PLmNjoHqMQNGPiZ0rHL7Ni7Q6/E=
+github.com/go-jose/go-jose/v4 v4.0.4/go.mod h1:NKb5HO1EZccyMpiZNbdUw/14tiXNyUJh188dfnMCAfc=
 github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
-github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=
-github.com/go-logr/logr v1.4.3/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
+github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
+github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
 github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
 github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
 github.com/golang-jwt/jwt/v5 v5.2.1/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
@@ -135,13 +127,8 @@ github.com/googleapis/gax-go/v2 v2.14.1 h1:hb0FFeiPaQskmvakKu5EbCbpntQn48jyHuvrk
 github.com/googleapis/gax-go/v2 v2.14.1/go.mod h1:Hb/NubMaVM88SrNkvl8X/o8XWwDJEPqouaLeN2IUxoA=
 github.com/huaweicloud/huaweicloud-sdk-go-obs v3.25.4+incompatible h1:yNjwdvn9fwuN6Ouxr0xHM0cVu03YMUWUyFmu2van/Yc=
 github.com/huaweicloud/huaweicloud-sdk-go-obs v3.25.4+incompatible/go.mod h1:l7VUhRbTKCzdOacdT4oWCwATKyvZqUOlOqr0Ous3k4s=
-github.com/keybase/go-keychain v0.0.1 h1:way+bWYa6lDppZoZcgMbYsvC7GxljxrskdNInRtuthU=
-github.com/keybase/go-keychain v0.0.1/go.mod h1:PdEILRW3i9D8JcdM+FmY6RwkHGnhHxXwkPPMeUgOK1k=
-github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
-github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
-github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc=
@@ -154,86 +141,70 @@ github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c h1:+mdjkGKdHQG3305AYmd
 github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c/go.mod h1:7rwL4CYBLnjLxUqIJNnCWiEdr3bn6IUYi15bNlnbCCU=
 github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10 h1:GFCKgmp0tecUJ0sJuv4pzYCqS9+RGSn52M3FUwPs+uo=
 github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10/go.mod h1:t/avpk3KcrXxUnYOhZhMXJlSEyie6gQbtLq5NM3loB8=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U=
-github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/redis/go-redis/v9 v9.7.3 h1:YpPyAayJV+XErNsatSElgRZZVCwXX9QzkKYNvO7x0wM=
-github.com/redis/go-redis/v9 v9.7.3/go.mod h1:bGUrSggJ9X9GUmZpZNEOQKaANxSGgOEBRltRTZHSvrA=
-github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
-github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
-github.com/sirupsen/logrus v1.9.0/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
-github.com/spiffe/go-spiffe/v2 v2.6.0 h1:l+DolpxNWYgruGQVV0xsfeya3CsC7m8iBzDnMpsbLuo=
-github.com/spiffe/go-spiffe/v2 v2.6.0/go.mod h1:gm2SeUoMZEtpnzPNs2Csc0D/gX33k1xIx7lEzqblHEs=
+github.com/rogpeppe/go-internal v1.13.1 h1:KvO1DLK/DRN07sQ1LQKScxyZJuNnedQ5/wKSR38lUII=
+github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWNMNyH2VO9fmH0o=
+github.com/spiffe/go-spiffe/v2 v2.5.0 h1:N2I01KCUkv1FAjZXJMwh95KK1ZIQLYbPfhaxw8WS0hE=
+github.com/spiffe/go-spiffe/v2 v2.5.0/go.mod h1:P+NxobPc6wXhVtINNtFjNWGBTreew1GBUCwT2wPmb7g=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
-github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
-github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
-github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
+github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
+github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.563/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/kms v1.0.563/go.mod h1:uom4Nvi9W+Qkom0exYiJ9VWJjXwyxtPYTkKkaLMlfE0=
 github.com/tencentyun/cos-go-sdk-v5 v0.7.65 h1:+WBbfwThfZSbxpf1Dw6fyMwyzVtWBBExqfDJ5giiR2s=
 github.com/tencentyun/cos-go-sdk-v5 v0.7.65/go.mod h1:8+hG+mQMuRP/OIS9d83syAvXvrMj9HhkND6Q1fLghw0=
-github.com/volcengine/ve-tos-golang-sdk/v2 v2.7.12 h1:u9+32DXQIOFPG8oQ3xrjSAUSyAcaq5bqO4cEBom/6lA=
-github.com/volcengine/ve-tos-golang-sdk/v2 v2.7.12/go.mod h1:IrjK84IJJTuOZOTMv/P18Ydjy/x+ow7fF7q11jAxXLM=
-go.opentelemetry.io/auto/sdk v1.2.1 h1:jXsnJ4Lmnqd11kwkBV2LgLoFMZKizbCi5fNZ/ipaZ64=
-go.opentelemetry.io/auto/sdk v1.2.1/go.mod h1:KRTj+aOaElaLi+wW1kO/DZRXwkF4C5xPbEe3ZiIhN7Y=
-go.opentelemetry.io/contrib/detectors/gcp v1.39.0 h1:kWRNZMsfBHZ+uHjiH4y7Etn2FK26LAGkNFw7RHv1DhE=
-go.opentelemetry.io/contrib/detectors/gcp v1.39.0/go.mod h1:t/OGqzHBa5v6RHZwrDBJ2OirWc+4q/w2fTbLZwAKjTk=
+github.com/zeebo/errs v1.4.0 h1:XNdoD/RRMKP7HD0UhJnIzUy74ISdGGxURlYG8HSWSfM=
+github.com/zeebo/errs v1.4.0/go.mod h1:sgbWHsvVuTPHcqJJGQ1WhI5KbWlHYz+2+2C/LSEtCw4=
+go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA=
+go.opentelemetry.io/auto/sdk v1.1.0/go.mod h1:3wSPjt5PWp2RhlCcmmOial7AvC4DQqZb7a7wCow3W8A=
+go.opentelemetry.io/contrib/detectors/gcp v1.35.0 h1:bGvFt68+KTiAKFlacHW6AhA56GF2rS0bdD3aJYEnmzA=
+go.opentelemetry.io/contrib/detectors/gcp v1.35.0/go.mod h1:qGWP8/+ILwMRIUf9uIVLloR1uo5ZYAslM4O6OqUi1DA=
 go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.60.0 h1:x7wzEgXfnzJcHDwStJT+mxOz4etr2EcexjqhBvmoakw=
 go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.60.0/go.mod h1:rg+RlpR5dKwaS95IyyZqj5Wd4E13lk/msnTS0Xl9lJM=
 go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.60.0 h1:sbiXRNDSWJOTobXh5HyQKjq6wUC5tNybqjIqDpAY4CU=
 go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.60.0/go.mod h1:69uWxva0WgAA/4bu2Yy70SLDBwZXuQ6PbBpbsa5iZrQ=
-go.opentelemetry.io/otel v1.43.0 h1:mYIM03dnh5zfN7HautFE4ieIig9amkNANT+xcVxAj9I=
-go.opentelemetry.io/otel v1.43.0/go.mod h1:JuG+u74mvjvcm8vj8pI5XiHy1zDeoCS2LB1spIq7Ay0=
+go.opentelemetry.io/otel v1.35.0 h1:xKWKPxrxB6OtMCbmMY021CqC45J+3Onta9MqjhnusiQ=
+go.opentelemetry.io/otel v1.35.0/go.mod h1:UEqy8Zp11hpkUrL73gSlELM0DupHoiq72dR+Zqel/+Y=
 go.opentelemetry.io/otel/exporters/stdout/stdoutmetric v1.35.0 h1:PB3Zrjs1sG1GBX51SXyTSoOTqcDglmsk7nT6tkKPb/k=
 go.opentelemetry.io/otel/exporters/stdout/stdoutmetric v1.35.0/go.mod h1:U2R3XyVPzn0WX7wOIypPuptulsMcPDPs/oiSVOMVnHY=
-go.opentelemetry.io/otel/metric v1.43.0 h1:d7638QeInOnuwOONPp4JAOGfbCEpYb+K6DVWvdxGzgM=
-go.opentelemetry.io/otel/metric v1.43.0/go.mod h1:RDnPtIxvqlgO8GRW18W6Z/4P462ldprJtfxHxyKd2PY=
-go.opentelemetry.io/otel/sdk v1.43.0 h1:pi5mE86i5rTeLXqoF/hhiBtUNcrAGHLKQdhg4h4V9Dg=
-go.opentelemetry.io/otel/sdk v1.43.0/go.mod h1:P+IkVU3iWukmiit/Yf9AWvpyRDlUeBaRg6Y+C58QHzg=
-go.opentelemetry.io/otel/sdk/metric v1.43.0 h1:S88dyqXjJkuBNLeMcVPRFXpRw2fuwdvfCGLEo89fDkw=
-go.opentelemetry.io/otel/sdk/metric v1.43.0/go.mod h1:C/RJtwSEJ5hzTiUz5pXF1kILHStzb9zFlIEe85bhj6A=
-go.opentelemetry.io/otel/trace v1.43.0 h1:BkNrHpup+4k4w+ZZ86CZoHHEkohws8AY+WTX09nk+3A=
-go.opentelemetry.io/otel/trace v1.43.0/go.mod h1:/QJhyVBUUswCphDVxq+8mld+AvhXZLhe+8WVFxiFff0=
-golang.org/x/crypto v0.52.0 h1:RMs7fP2rXdep0CftQlK8Uf+kibLm7qkCcradZWYz988=
-golang.org/x/crypto v0.52.0/go.mod h1:1QgfPxDqh0T2M/elOJtp9RvuR95kVjir0e6/BvEmGbc=
-golang.org/x/net v0.55.0 h1:bcvxaJn3e1U6InsFWt1JUq1aSjnRxLzT2rtD2KfkDF8=
-golang.org/x/net v0.55.0/go.mod h1:L5U2KuzuOe1lY7Z+aWVIKK6qEeJXnXV9yzGA+WCHJww=
-golang.org/x/oauth2 v0.34.0 h1:hqK/t4AKgbqWkdkcAeI8XLmbK+4m4G5YeQRrmiotGlw=
-golang.org/x/oauth2 v0.34.0/go.mod h1:lzm5WQJQwKZ3nwavOZ3IS5Aulzxi68dUSgRHujetwEA=
-golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.20.0 h1:e0PTpb7pjO8GAtTs2dQ6jYa5BWYlMuX047Dco/pItO4=
-golang.org/x/sync v0.20.0/go.mod h1:9xrNwdLfx4jkKbNva9FpL6vEN7evnE43NNNJQ2LF3+0=
-golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.1.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.45.0 h1:dO4czNzziLiiXplLQgBCEpCvXQ3dnkn0SdaZSYdQ+FY=
-golang.org/x/sys v0.45.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
-golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
-golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
-golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
+go.opentelemetry.io/otel/metric v1.35.0 h1:0znxYu2SNyuMSQT4Y9WDWej0VpcsxkuklLa4/siN90M=
+go.opentelemetry.io/otel/metric v1.35.0/go.mod h1:nKVFgxBZ2fReX6IlyW28MgZojkoAkJGaE8CpgeAU3oE=
+go.opentelemetry.io/otel/sdk v1.35.0 h1:iPctf8iprVySXSKJffSS79eOjl9pvxV9ZqOWT0QejKY=
+go.opentelemetry.io/otel/sdk v1.35.0/go.mod h1:+ga1bZliga3DxJ3CQGg3updiaAJoNECOgJREo9KHGQg=
+go.opentelemetry.io/otel/sdk/metric v1.35.0 h1:1RriWBmCKgkeHEhM7a2uMjMUfP7MsOF5JpUCaEqEI9o=
+go.opentelemetry.io/otel/sdk/metric v1.35.0/go.mod h1:is6XYCUMpcKi+ZsOvfluY5YstFnhW0BidkR+gL+qN+w=
+go.opentelemetry.io/otel/trace v1.35.0 h1:dPpEfJu1sDIqruz7BHFG3c7528f6ddfSWfFDVt/xgMs=
+go.opentelemetry.io/otel/trace v1.35.0/go.mod h1:WUk7DtFp1Aw2MkvqGdwiXYDZZNvA/1J8o6xRXLrIkyc=
+golang.org/x/crypto v0.37.0 h1:kJNSjF/Xp7kU0iB2Z+9viTPMW4EqqsrywMXLJOOsXSE=
+golang.org/x/crypto v0.37.0/go.mod h1:vg+k43peMZ0pUMhYmVAWysMK35e6ioLh3wB8ZCAfbVc=
+golang.org/x/net v0.39.0 h1:ZCu7HMWDxpXpaiKdhzIfaltL9Lp31x/3fCP11bc6/fY=
+golang.org/x/net v0.39.0/go.mod h1:X7NRbYVEA+ewNkCNyJ513WmMdQ3BineSwVtN2zD/d+E=
+golang.org/x/oauth2 v0.30.0 h1:dnDm7JmhM45NNpd8FDDeLhK6FwqbOf4MLCM9zb1BOHI=
+golang.org/x/oauth2 v0.30.0/go.mod h1:B++QgG3ZKulg6sRPGD/mqlHQs5rB3Ml9erfeDY7xKlU=
+golang.org/x/sync v0.14.0 h1:woo0S4Yywslg6hp4eUFjTVOyKt0RookbpAHG4c1HmhQ=
+golang.org/x/sync v0.14.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
+golang.org/x/sys v0.32.0 h1:s77OFDvIQeibCmezSnk/q6iAfkdiQaJi4VzroCFrN20=
+golang.org/x/sys v0.32.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/text v0.24.0 h1:dd5Bzh4yt5KYA8f9CJHCP4FB4D51c2c6JvN37xJJkJ0=
+golang.org/x/text v0.24.0/go.mod h1:L8rBsPeo2pSS+xqN0d5u2ikmjtmoJbDBT1b7nHvFCdU=
 golang.org/x/time v0.11.0 h1:/bpjEDfN9tkoN/ryeYHnv5hcMlc8ncjMcM4XBk5NWV0=
 golang.org/x/time v0.11.0/go.mod h1:CDIdPxbZBQxdj6cxyCIdrNogrJKMJ7pr37NYpMcMDSg=
-golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-gonum.org/v1/gonum v0.16.0 h1:5+ul4Swaf3ESvrOnidPp4GZbzf0mxVQpDCYUQE7OJfk=
-gonum.org/v1/gonum v0.16.0/go.mod h1:fef3am4MQ93R2HHpKnLk4/Tbh/s0+wqD5nfa6Pnwy4E=
 google.golang.org/api v0.232.0 h1:qGnmaIMf7KcuwHOlF3mERVzChloDYwRfOJOrHt8YC3I=
 google.golang.org/api v0.232.0/go.mod h1:p9QCfBWZk1IJETUdbTKloR5ToFdKbYh2fkjsUL6vNoY=
 google.golang.org/genproto v0.0.0-20250303144028-a0af3efb3deb h1:ITgPrl429bc6+2ZraNSzMDk3I95nmQln2fuPstKwFDE=
 google.golang.org/genproto v0.0.0-20250303144028-a0af3efb3deb/go.mod h1:sAo5UzpjUwgFBCzupwhcLcxHVDK7vG5IqI30YnwX2eE=
-google.golang.org/genproto/googleapis/api v0.0.0-20251202230838-ff82c1b0f217 h1:fCvbg86sFXwdrl5LgVcTEvNC+2txB5mgROGmRL5mrls=
-google.golang.org/genproto/googleapis/api v0.0.0-20251202230838-ff82c1b0f217/go.mod h1:+rXWjjaukWZun3mLfjmVnQi18E1AsFbDN9QdJ5YXLto=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20251202230838-ff82c1b0f217 h1:gRkg/vSppuSQoDjxyiGfN4Upv/h/DQmIR10ZU8dh4Ww=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20251202230838-ff82c1b0f217/go.mod h1:7i2o+ce6H/6BluujYR+kqX3GKH+dChPTQU19wjRPiGk=
-google.golang.org/grpc v1.79.3 h1:sybAEdRIEtvcD68Gx7dmnwjZKlyfuc61Dyo9pGXXkKE=
-google.golang.org/grpc v1.79.3/go.mod h1:KmT0Kjez+0dde/v2j9vzwoAScgEPx/Bw1CYChhHLrHQ=
-google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE=
-google.golang.org/protobuf v1.36.10/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
+google.golang.org/genproto/googleapis/api v0.0.0-20250505200425-f936aa4a68b2 h1:vPV0tzlsK6EzEDHNNH5sa7Hs9bd7iXR7B1tSiPepkV0=
+google.golang.org/genproto/googleapis/api v0.0.0-20250505200425-f936aa4a68b2/go.mod h1:pKLAc5OolXC3ViWGI62vvC0n10CpwAtRcTNCFwTKBEw=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250505200425-f936aa4a68b2 h1:IqsN8hx+lWLqlN+Sc3DoMy/watjofWiU8sRFgQ8fhKM=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250505200425-f936aa4a68b2/go.mod h1:qQ0YXyHHx3XkvlzUtpXDkS29lDSafHMZBAZDc03LQ3A=
+google.golang.org/grpc v1.72.0 h1:S7UkcVa60b5AAQTaO6ZKamFp1zMZSU0fGDK2WZLbBnM=
+google.golang.org/grpc v1.72.0/go.mod h1:wH5Aktxcg25y1I3w7H69nHfXdOG3UiadoBtjh3izSDM=
+google.golang.org/protobuf v1.36.6 h1:z1NpPI8ku2WgiWnf+t9wTPsn6eP1L7ksHUlkfLvd9xY=
+google.golang.org/protobuf v1.36.6/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

oss/aliyun/aliyun.go

@@ -36,7 +36,6 @@ func NewAliyunOSSStorage(args difyoss.OSSArgs) (difyoss.OSS, error) {
 	authVersion := args.AliyunOSS.AuthVersion
 	path := args.AliyunOSS.Path
 	bucketName := args.AliyunOSS.Bucket
-	cloudboxId := args.AliyunOSS.CloudBoxId
 
 	// options
 	var options []oss.ClientOption
@@ -46,10 +45,6 @@ func NewAliyunOSSStorage(args difyoss.OSSArgs) (difyoss.OSS, error) {
 		options = append(options, oss.Region(region))
 	}
 
-	if cloudboxId != "" {
-		options = append(options, oss.CloudBoxId(cloudboxId))
-	}
-
 	// set auth-version
 	if authVersion == "v1" {
 		options = append(options, oss.AuthVersion(oss.AuthV1))

oss/azureblob/blob.go

@@ -5,7 +5,6 @@ import (
 	"context"
 	"strings"
 
-	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
 	"github.com/Azure/azure-sdk-for-go/sdk/storage/azblob"
 	"github.com/langgenius/dify-cloud-kit/oss"
 )
@@ -16,34 +15,20 @@ type AzureBlobStorage struct {
 }
 
 func NewAzureBlobStorage(args oss.OSSArgs) (oss.OSS, error) {
-	var client *azblob.Client
-	var err error
-
 	if args.AzureBlob == nil {
 		return nil, oss.ErrArgumentInvalid.WithDetail("can't find Azure Blob argument in OSSArgs")
 	}
-	err = args.AzureBlob.Validate()
+	err := args.AzureBlob.Validate()
 	if err != nil {
 		return nil, err
 	}
+	connectionString := args.AzureBlob.ConnectionString
 	containerName := args.AzureBlob.ContainerName
-	if args.AzureBlob.UseManagedIdentity {
-		cred, err := azidentity.NewDefaultAzureCredential(nil)
-		if err != nil {
-			return nil, oss.ErrProviderInit.WithError(err)
-		}
-		client, err = azblob.NewClient(args.AzureBlob.ServiceURL, cred, nil)
-		if err != nil {
-			return nil, oss.ErrProviderInit.WithError(err)
-		}
-	} else {
-		connectionString := args.AzureBlob.ConnectionString
-		client, err = azblob.NewClientFromConnectionString(connectionString, nil)
-		if err != nil {
-			return nil, oss.ErrProviderInit.WithError(err)
-		}
-
+	client, err := azblob.NewClientFromConnectionString(connectionString, nil)
+	if err != nil {
+		return nil, oss.ErrProviderInit.WithError(err)
 	}
+
 	return &AzureBlobStorage{
 		client:        client,
 		containerName: containerName,

oss/factory/factory.go

@@ -7,11 +7,10 @@ import (
 	"github.com/langgenius/dify-cloud-kit/oss/aliyun"
 	"github.com/langgenius/dify-cloud-kit/oss/azureblob"
 	"github.com/langgenius/dify-cloud-kit/oss/gcsblob"
-	"github.com/langgenius/dify-cloud-kit/oss/huaweiobs"
+	"github.com/langgenius/dify-cloud-kit/oss/huanweiobs"
 	"github.com/langgenius/dify-cloud-kit/oss/local"
 	"github.com/langgenius/dify-cloud-kit/oss/s3"
 	"github.com/langgenius/dify-cloud-kit/oss/tencentcos"
-	"github.com/langgenius/dify-cloud-kit/oss/volcenginetos"
 )
 
 var OSSFactory = map[string]func(oss.OSSArgs) (oss.OSS, error){
@@ -20,11 +19,9 @@ var OSSFactory = map[string]func(oss.OSSArgs) (oss.OSS, error){
 
 	"s3":     s3.NewS3Storage,
 	"aws_s3": s3.NewS3Storage,
-	"aws-s3": s3.NewS3Storage,
 
 	"azure":      azureblob.NewAzureBlobStorage,
 	"azure_blob": azureblob.NewAzureBlobStorage,
-	"azure-blob": azureblob.NewAzureBlobStorage,
 
 	"aliyun":     aliyun.NewAliyunOSSStorage,
 	"aliyun-oss": aliyun.NewAliyunOSSStorage,
@@ -36,15 +33,10 @@ var OSSFactory = map[string]func(oss.OSSArgs) (oss.OSS, error){
 
 	"gcs":            gcsblob.NewGoogleCloudStorage,
 	"google-storage": gcsblob.NewGoogleCloudStorage,
-	"google_storage": gcsblob.NewGoogleCloudStorage,
 
-	"huawei":     huaweiobs.NewHuaweiOBSStorage,
-	"huawei-obs": huaweiobs.NewHuaweiOBSStorage,
-	"huawei_obs": huaweiobs.NewHuaweiOBSStorage,
-
-	"volcengine":     volcenginetos.NewVolcengineTOSStorage,
-	"volcengine_tos": volcenginetos.NewVolcengineTOSStorage,
-	"volcengine-tos": volcenginetos.NewVolcengineTOSStorage,
+	"huawei":     huanweiobs.NewHuaweiOBSStorage,
+	"huawei-obs": huanweiobs.NewHuaweiOBSStorage,
+	"huawei_obs": huanweiobs.NewHuaweiOBSStorage,
 }
 
 func Load(name string, args oss.OSSArgs) (oss.OSS, error) {

oss/gcsblob/gcs.go

@@ -29,22 +29,13 @@ func NewGoogleCloudStorage(args oss.OSSArgs) (oss.OSS, error) {
 	ctx := context.Background()
 	bucket := args.GoogleCloudStorage.Bucket
 	credentialsB64 := args.GoogleCloudStorage.CredentialsB64
-
-	var client *storage.Client
-	if credentialsB64 == "" {
-		client, err = storage.NewClient(ctx)
-		if err != nil {
-			return nil, oss.ErrProviderInit.WithError(err).WithDetail("failed to initialize GCS client with ADC")
-		}
-	} else {
-		credentials, err := base64.StdEncoding.DecodeString(credentialsB64)
-		if err != nil {
-			return nil, oss.ErrProviderInit.WithError(err).WithDetail("credentials must be a base64 encoded string")
-		}
-		client, err = storage.NewClient(ctx, option.WithCredentialsJSON(credentials))
-		if err != nil {
-			return nil, oss.ErrProviderInit.WithError(err)
-		}
+	credentials, err := base64.StdEncoding.DecodeString(credentialsB64)
+	if err != nil {
+		return nil, oss.ErrProviderInit.WithError(err).WithDetail("credentials must be a base64 encoded string")
+	}
+	client, err := storage.NewClient(ctx, option.WithCredentialsJSON(credentials))
+	if err != nil {
+		return nil, oss.ErrProviderInit.WithError(err)
 	}
 	return &GoogleCloudStorage{
 		bucket: bucket,
@@ -55,6 +46,7 @@ func NewGoogleCloudStorage(args oss.OSSArgs) (oss.OSS, error) {
 func (g *GoogleCloudStorage) Save(key string, data []byte) error {
 	ctx := context.Background()
 	obj := g.client.Bucket(g.bucket).Object(key)
+	obj = obj.If(storage.Conditions{DoesNotExist: true})
 
 	wc := obj.NewWriter(ctx)
 	if _, err := wc.Write(data); err != nil {
@@ -125,7 +117,7 @@ func (g *GoogleCloudStorage) List(prefix string) ([]oss.OSSPath, error) {
 		key = strings.TrimPrefix(key, "/")
 
 		res = append(res, oss.OSSPath{
-			Path:  key,
+			Path:  attrs.Name,
 			IsDir: false,
 		})
 

oss/huanweiobs/obs.go

@@ -1,12 +1,13 @@
-package huaweiobs
+package huanweiobs
 
 import (
 	"io"
-	"math/rand"
 	"os"
 	"strings"
 	"time"
 
+	"math/rand"
+
 	"github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
 	"github.com/langgenius/dify-cloud-kit/oss"
 )
@@ -29,8 +30,7 @@ func NewHuaweiOBSStorage(args oss.OSSArgs) (oss.OSS, error) {
 	sk := args.HuaweiOBS.SecretKey
 	endpoint := args.HuaweiOBS.Server
 	bucket := args.HuaweiOBS.Bucket
-	pathStyle := args.HuaweiOBS.PathStyle
-	client, err := obs.New(ak, sk, endpoint, obs.WithPathStyle(pathStyle))
+	client, err := obs.New(ak, sk, endpoint)
 	if err != nil {
 		return nil, oss.ErrProviderInit.WithError(err)
 	}
@@ -114,41 +114,30 @@ func (h *HuaweiOBSStorage) State(key string) (oss.OSSState, error) {
 }
 
 func (h *HuaweiOBSStorage) List(prefix string) ([]oss.OSSPath, error) {
-	if !strings.HasSuffix(prefix, "/") {
-		prefix = prefix + "/"
+	output, err := h.client.ListObjects(&obs.ListObjectsInput{
+		Bucket: h.bucket,
+		ListObjsInput: obs.ListObjsInput{
+			Prefix: prefix,
+		},
+	})
+	if err != nil {
+		return nil, err
 	}
-
-	marker := ""
 	paths := []oss.OSSPath{}
-	for {
-		output, err := h.client.ListObjects(&obs.ListObjectsInput{
-			Bucket: h.bucket,
-			ListObjsInput: obs.ListObjsInput{
-				Prefix: prefix,
-			},
-			Marker: marker,
+	for _, v := range output.Contents {
+		key := strings.TrimPrefix(v.Key, prefix)
+		key = strings.TrimPrefix(key, "/")
+
+		if key == "" {
+			continue
+		}
+		paths = append(paths, oss.OSSPath{
+			Path: v.Key,
+			IsDir: func() bool {
+				return strings.HasSuffix(v.Key, "/")
+			}(),
 		})
-		if err != nil {
-			return nil, err
-		}
-
-		for _, v := range output.Contents {
-			key, ok := listedObjectPath(prefix, v.Key)
-			if !ok {
-				continue
-			}
-			paths = append(paths, oss.OSSPath{
-				Path:  key,
-				IsDir: false,
-			})
-		}
-		if output.IsTruncated {
-			marker = output.NextMarker
-		} else {
-			break
-		}
 	}
-
 	return paths, nil
 }
 
@@ -164,16 +153,6 @@ func (h *HuaweiOBSStorage) Type() string {
 	return oss.OSS_TYPE_HUAWEI_OBS
 }
 
-func listedObjectPath(prefix string, objectKey string) (string, bool) {
-	key := strings.TrimPrefix(objectKey, prefix)
-	key = strings.TrimLeft(key, "/")
-	if key == "" || strings.HasSuffix(key, "/") {
-		return "", false
-	}
-
-	return key, true
-}
-
 const charset = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
 
 func randomString(length int) string {

oss/huaweiobs/obs_test.go

@@ -1,59 +0,0 @@
-package huaweiobs
-
-import "testing"
-
-func TestListedObjectPath(t *testing.T) {
-	tests := []struct {
-		name      string
-		prefix    string
-		objectKey string
-		want      string
-		wantOK    bool
-	}{
-		{
-			name:      "file under prefix",
-			prefix:    "plugins/",
-			objectKey: "plugins/langgenius/model-provider.difypkg",
-			want:      "langgenius/model-provider.difypkg",
-			wantOK:    true,
-		},
-		{
-			name:      "file under prefix without trailing slash",
-			prefix:    "plugins",
-			objectKey: "plugins/langgenius/model-provider.difypkg",
-			want:      "langgenius/model-provider.difypkg",
-			wantOK:    true,
-		},
-		{
-			name:      "directory placeholder under prefix",
-			prefix:    "plugins/",
-			objectKey: "plugins/langgenius/",
-			wantOK:    false,
-		},
-		{
-			name:      "prefix placeholder",
-			prefix:    "plugins/",
-			objectKey: "plugins/",
-			wantOK:    false,
-		},
-		{
-			name:      "leading slash after prefix",
-			prefix:    "plugins",
-			objectKey: "plugins//langgenius/model-provider.difypkg",
-			want:      "langgenius/model-provider.difypkg",
-			wantOK:    true,
-		},
-	}
-
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			got, ok := listedObjectPath(tt.prefix, tt.objectKey)
-			if ok != tt.wantOK {
-				t.Fatalf("listedObjectPath() ok = %v, want %v", ok, tt.wantOK)
-			}
-			if got != tt.want {
-				t.Fatalf("listedObjectPath() = %q, want %q", got, tt.want)
-			}
-		})
-	}
-}

oss/oss.go

@@ -9,14 +9,13 @@ import (
 // such as local file system, AWS S3, and Tencent COS.
 // The interface defines methods for saving, loading, checking existence,
 const (
-	OSS_TYPE_LOCAL          = "local"
-	OSS_TYPE_S3             = "aws_s3"
-	OSS_TYPE_TENCENT_COS    = "tencent_cos"
-	OSS_TYPE_AZURE_BLOB     = "azure_blob"
-	OSS_TYPE_GCS            = "gcs"
-	OSS_TYPE_ALIYUN_OSS     = "aliyun_oss"
-	OSS_TYPE_HUAWEI_OBS     = "huawei_obs"
-	OSS_TYPE_VOLCENGINE_TOS = "volcengine_tos"
+	OSS_TYPE_LOCAL       = "local"
+	OSS_TYPE_S3          = "aws_s3"
+	OSS_TYPE_TENCENT_COS = "tencent_cos"
+	OSS_TYPE_AZURE_BLOB  = "azure_blob"
+	OSS_TYPE_GCS         = "gcs"
+	OSS_TYPE_ALIYUN_OSS  = "aliyun_oss"
+	OSS_TYPE_HUAWEI_OBS  = "huawei_obs"
 )
 
 type OSSState struct {
@@ -55,52 +54,36 @@ type OSSArgs struct {
 	TencentCOS         *TencentCOS
 	GoogleCloudStorage *GoogleCloudStorage
 	HuaweiOBS          *HuaweiOBS
-	VolcengineTOS      *VolcengineTOS
 }
 
 type S3 struct {
-	UseAws           bool
-	Endpoint         string
-	UsePathStyle     bool
-	AccessKey        string
-	SecretKey        string
-	Bucket           string
-	Region           string
-	UseIamRole       bool
-	SignatureVersion string
+	UseAws       bool
+	Endpoint     string
+	UsePathStyle bool
+	AccessKey    string
+	SecretKey    string
+	Bucket       string
+	Region       string
 }
 
 func (s *S3) Validate() error {
 	if s.Bucket == "" || s.Region == "" {
-		msg := "bucket and region cannot be empty."
+		msg := fmt.Sprintf("bucket and region cannot be empty.")
 		return ErrArgumentInvalid.WithDetail(msg)
 	}
 	return nil
 }
 
 type AzureBlob struct {
-	ConnectionString   string
-	ContainerName      string
-	UseManagedIdentity bool
-	ServiceURL         string
+	ConnectionString string
+	ContainerName    string
 }
 
 func (a *AzureBlob) Validate() error {
-	if a.ContainerName == "" {
-		msg := "containerName cannot be empty"
+	if a.ConnectionString == "" || a.ContainerName == "" {
+		msg := fmt.Sprintf("connectorString and containerName cannot be empty.")
 		return ErrArgumentInvalid.WithDetail(msg)
 	}
-	if a.UseManagedIdentity {
-		if a.ServiceURL == "" {
-			msg := "service url cannot be empty. e.g. https://<account>.blob.core.windows.net/."
-			return ErrArgumentInvalid.WithDetail(msg)
-		}
-	} else {
-		if a.ConnectionString == "" {
-			msg := "connectorString cannot be empty."
-			return ErrArgumentInvalid.WithDetail(msg)
-		}
-	}
 	return nil
 }
 
@@ -123,7 +106,6 @@ type AliyunOSS struct {
 	AuthVersion string
 	Path        string
 	Bucket      string
-	CloudBoxId  string
 }
 
 func (a *AliyunOSS) Validate() error {
@@ -139,7 +121,6 @@ type TencentCOS struct {
 	SecretID  string
 	SecretKey string
 	Bucket    string
-	Endpoint  string
 }
 
 func (t *TencentCOS) Validate() error {
@@ -156,8 +137,8 @@ type GoogleCloudStorage struct {
 }
 
 func (g *GoogleCloudStorage) Validate() error {
-	if g.Bucket == "" {
-		msg := fmt.Sprintf("bucket cannot be empty.")
+	if g.Bucket == "" || g.CredentialsB64 == "" {
+		msg := fmt.Sprintf("bucket and credentials cannot be empty.")
 		return ErrArgumentInvalid.WithDetail(msg)
 	}
 	return nil
@@ -168,7 +149,6 @@ type HuaweiOBS struct {
 	AccessKey string
 	SecretKey string
 	Server    string
-	PathStyle bool
 }
 
 func (h *HuaweiOBS) Validate() error {
@@ -178,19 +158,3 @@ func (h *HuaweiOBS) Validate() error {
 	}
 	return nil
 }
-
-type VolcengineTOS struct {
-	Region    string
-	Endpoint  string
-	AccessKey string
-	SecretKey string
-	Bucket    string
-}
-
-func (t *VolcengineTOS) Validate() error {
-	if t.Bucket == "" || t.Endpoint == "" || t.AccessKey == "" || t.SecretKey == "" {
-		msg := fmt.Sprintf("bucket, endpoint,accessKey, secretKey cannot be empty.")
-		return ErrArgumentInvalid.WithDetail(msg)
-	}
-	return nil
-}

oss/s3/s3.go

@@ -37,35 +37,25 @@ func NewS3Storage(args oss.OSSArgs) (oss.OSS, error) {
 	endpoint := args.S3.Endpoint
 	usePathStyle := args.S3.UsePathStyle
 	bucket := args.S3.Bucket
-	useIamRole := args.S3.UseIamRole
-	signatureVersion := args.S3.SignatureVersion
 
 	var cfg aws.Config
 	var client *s3.Client
 
 	if useAws {
-		if (ak == "" && sk == "") || useIamRole {
+		if ak == "" && sk == "" {
 			cfg, err = config.LoadDefaultConfig(
 				context.TODO(),
 				config.WithRegion(region),
 			)
 		} else {
-			// 处理签名版本和凭证
-			var credProvider aws.CredentialsProvider
-			if strings.ToLower(signatureVersion) == "unsigned" {
-				credProvider = aws.AnonymousCredentials{}
-			} else {
-				credProvider = credentials.NewStaticCredentialsProvider(
-					ak,
-					sk,
-					"",
-				)
-			}
-
 			cfg, err = config.LoadDefaultConfig(
 				context.TODO(),
 				config.WithRegion(region),
-				config.WithCredentialsProvider(credProvider),
+				config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(
+					ak,
+					sk,
+					"",
+				)),
 			)
 		}
 		if err != nil {
@@ -76,29 +66,21 @@ func NewS3Storage(args oss.OSSArgs) (oss.OSS, error) {
 			if endpoint != "" {
 				options.BaseEndpoint = aws.String(endpoint)
 			}
-			options.UsePathStyle = usePathStyle
 		})
 	} else {
-		var credProvider aws.CredentialsProvider
-		if strings.ToLower(signatureVersion) == "unsigned" {
-			credProvider = aws.AnonymousCredentials{}
-		} else {
-			credProvider = credentials.NewStaticCredentialsProvider(ak, sk, "")
-		}
 		client = s3.New(s3.Options{
-			Credentials:  credProvider,
+			Credentials:  credentials.NewStaticCredentialsProvider(ak, sk, ""),
 			UsePathStyle: usePathStyle,
 			Region:       region,
 			EndpointResolver: s3.EndpointResolverFunc(
 				func(region string, options s3.EndpointResolverOptions) (aws.Endpoint, error) {
-					signingMethod := normalizeSignatureVersion(signatureVersion)
 					return aws.Endpoint{
 						URL:               endpoint,
 						HostnameImmutable: false,
 						SigningName:       "s3",
 						PartitionID:       "aws",
 						SigningRegion:     region,
-						SigningMethod:     signingMethod,
+						SigningMethod:     "v4",
 						Source:            aws.EndpointSourceCustom,
 					}, nil
 				}),
@@ -123,17 +105,6 @@ func NewS3Storage(args oss.OSSArgs) (oss.OSS, error) {
 	return &S3Storage{bucket: bucket, client: client}, nil
 }
 
-func normalizeSignatureVersion(version string) string {
-	switch strings.ToLower(version) {
-	case "unsigned":
-		return ""
-	case "":
-		return "v4"  // 默认使用 v4
-	default:
-		return version
-	}
-}
-
 func (s *S3Storage) Save(key string, data []byte) error {
 	_, err := s.client.PutObject(context.TODO(), &s3.PutObjectInput{
 		Bucket: aws.String(s.bucket),

oss/tencentcos/cos.go

@@ -33,11 +33,7 @@ func NewTencentCOSStorage(args oss.OSSArgs) (oss.OSS, error) {
 	region := args.TencentCOS.Region
 	secretID := args.TencentCOS.SecretID
 	secretKey := args.TencentCOS.SecretKey
-	endpoint := args.TencentCOS.Endpoint
-	if endpoint == "" {
-		endpoint = "https://" + bucket + ".cos." + region + ".myqcloud.com"
-	}
-	u, err := url.Parse(endpoint)
+	u, err := url.Parse("https://" + bucket + ".cos." + region + ".myqcloud.com")
 	if err != nil {
 		return nil, oss.ErrProviderInit.WithError(err).WithDetail("url parse failed")
 	}

oss/volcenginetos/tos.go

@@ -1,146 +0,0 @@
-package volcenginetos
-
-import (
-	"bytes"
-	"context"
-	"github.com/langgenius/dify-cloud-kit/oss"
-	"github.com/volcengine/ve-tos-golang-sdk/v2/tos"
-	"io"
-	"strings"
-)
-
-type VolcengineTOSStorage struct {
-	bucket string
-	client *tos.ClientV2
-}
-
-func NewVolcengineTOSStorage(args oss.OSSArgs) (oss.OSS, error) {
-	if args.VolcengineTOS == nil {
-		return nil, oss.ErrArgumentInvalid.WithDetail("can't find Volcengine TOS argument in OSSArgs")
-	}
-
-	err := args.VolcengineTOS.Validate()
-	if err != nil {
-		return nil, err
-	}
-
-	bucket := args.VolcengineTOS.Bucket
-	accessKey := args.VolcengineTOS.AccessKey
-	secretKey := args.VolcengineTOS.SecretKey
-	endpoint := args.VolcengineTOS.Endpoint
-	region := args.VolcengineTOS.Region
-
-	client, err := tos.NewClientV2(endpoint,
-		tos.WithRegion(region),
-		tos.WithCredentials(tos.NewStaticCredentials(accessKey, secretKey)),
-	)
-	if err != nil {
-		return nil, oss.ErrProviderInit.WithError(err)
-	}
-	return &VolcengineTOSStorage{
-		bucket: bucket,
-		client: client,
-	}, nil
-}
-
-func (s *VolcengineTOSStorage) Save(key string, data []byte) error {
-	_, err := s.client.PutObjectV2(context.Background(), &tos.PutObjectV2Input{
-		PutObjectBasicInput: tos.PutObjectBasicInput{
-			Bucket: s.bucket,
-			Key:    key,
-		},
-		Content: bytes.NewReader(data),
-	})
-	return err
-}
-
-func (s *VolcengineTOSStorage) Load(key string) ([]byte, error) {
-	resp, err := s.client.GetObjectV2(context.Background(), &tos.GetObjectV2Input{
-		Bucket: s.bucket,
-		Key:    key,
-	})
-	if err != nil {
-		return nil, err
-	}
-	return io.ReadAll(resp.Content)
-}
-
-func (s *VolcengineTOSStorage) Exists(key string) (bool, error) {
-	_, err := s.client.HeadObjectV2(context.Background(), &tos.HeadObjectV2Input{
-		Bucket: s.bucket,
-		Key:    key,
-	})
-	if err != nil {
-		if tosErr, ok := err.(*tos.TosServerError); ok && tosErr.StatusCode == 404 {
-			return false, nil
-		}
-		return false, err
-	}
-	return true, nil
-}
-
-func (s *VolcengineTOSStorage) State(key string) (oss.OSSState, error) {
-	resp, err := s.client.HeadObjectV2(context.Background(), &tos.HeadObjectV2Input{
-		Bucket: s.bucket,
-		Key:    key,
-	})
-	if err != nil {
-		return oss.OSSState{}, err
-	}
-	return oss.OSSState{
-		Size:         resp.ContentLength,
-		LastModified: resp.LastModified,
-	}, nil
-}
-
-func (s *VolcengineTOSStorage) List(prefix string) ([]oss.OSSPath, error) {
-	if !strings.HasSuffix(prefix, "/") {
-		prefix = prefix + "/"
-	}
-	var result []oss.OSSPath
-	truncated := true
-	continuationToken := ""
-	for truncated {
-
-		resp, err := s.client.ListObjectsType2(context.Background(), &tos.ListObjectsType2Input{
-			Bucket:            s.bucket,
-			Prefix:            prefix,
-			MaxKeys:           1000,
-			ContinuationToken: continuationToken,
-		})
-		if err != nil {
-			return nil, err
-		}
-		for _, obj := range resp.Contents {
-			// remove prefix
-			key := strings.TrimPrefix(obj.Key, prefix)
-			// remove leading slash
-			key = strings.TrimPrefix(key, "/")
-			if key == "" {
-				continue
-			}
-			result = append(result, oss.OSSPath{
-				Path:  key,
-				IsDir: false,
-			})
-		}
-		if !resp.IsTruncated {
-			break
-		}
-		truncated = resp.IsTruncated
-		continuationToken = resp.NextContinuationToken
-	}
-	return result, nil
-}
-
-func (s *VolcengineTOSStorage) Delete(key string) error {
-	_, err := s.client.DeleteObjectV2(context.Background(), &tos.DeleteObjectV2Input{
-		Bucket: s.bucket,
-		Key:    key,
-	})
-	return err
-}
-
-func (s *VolcengineTOSStorage) Type() string {
-	return oss.OSS_TYPE_VOLCENGINE_TOS
-}

tests/oss/oss_test.go

@@ -35,7 +35,6 @@ var allCases = []testArgsCases{
 			S3: &oss.S3{
 				UseAws:       true,
 				UsePathStyle: true,
-				UseIamRole:   false,
 				AccessKey:    os.Getenv("AWS_S3_ACCESS_KEY"),
 				SecretKey:    os.Getenv("AWS_S3_SECRET_KEY"),
 				Bucket:       os.Getenv("AWS_S3_BUCKET"),
@@ -65,7 +64,6 @@ var allCases = []testArgsCases{
 				AuthVersion: os.Getenv("ALIYUN_OSS_AUTH_VERSION"),
 				Path:        os.Getenv("ALIYUN_OSS_PATH"),
 				Bucket:      os.Getenv("ALIYUN_OSS_BUCKET"),
-				CloudBoxId:  os.Getenv("ALIYUN_OSS_CLOUDBOX_ID"),
 			},
 		},
 		skip: false,
@@ -100,35 +98,10 @@ var allCases = []testArgsCases{
 				AccessKey: os.Getenv("HUAWEI_OBS_ACCESS_KEY"),
 				SecretKey: os.Getenv("HUAWEI_OBS_SECRET_KEY"),
 				Server:    os.Getenv("HUAWEI_OBS_SERVER"),
-				PathStyle: true,
 			},
 		},
 		skip: false,
 	},
-	{
-		vendor: "volcengine",
-		args: oss.OSSArgs{
-			VolcengineTOS: &oss.VolcengineTOS{
-				Region:    os.Getenv("VOLCENGINE_TOS_REGION"),
-				Endpoint:  os.Getenv("VOLCENGINE_TOS_ENDPOINT"),
-				AccessKey: os.Getenv("VOLCENGINE_TOS_ACCESS_KEY"),
-				SecretKey: os.Getenv("VOLCENGINE_TOS_SECRET_KEY"),
-				Bucket:    os.Getenv("VOLCENGINE_TOS_BUCKET"),
-			},
-		},
-		skip: false,
-	},
-	{
-		vendor: "azure",
-		args: oss.OSSArgs{
-			AzureBlob: &oss.AzureBlob{
-				UseManagedIdentity: true,
-				ContainerName:      os.Getenv("AZURE_CONTAINER"),
-				ServiceURL:         os.Getenv("AZURE_SERVICE_URL"),
-			},
-		},
-		skip: true,
-	},
 }
 
 const charset = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
@@ -145,21 +118,14 @@ func randomString(length int) string {
 func TestAll(t *testing.T) {
 	prefix := randomString(5)
 	key := fmt.Sprintf("%s/%s", prefix, randomString(10))
-	vendorFilter := os.Getenv("OSS_TEST_VENDOR")
-	dirPlaceholderKey := ""
 
 	size := 1 * 1024 * 1024
 	data := make([]byte, size)
 
-	tested := false
 	for _, c := range allCases {
 		if c.skip {
 			continue
 		}
-		if vendorFilter != "" && c.vendor != vendorFilter {
-			continue
-		}
-		tested = true
 		storage, err := factory.Load(c.vendor, c.args)
 		if err != nil {
 			log.Fatal(err)
@@ -177,12 +143,6 @@ func TestAll(t *testing.T) {
 		err = storage.Save(key, data)
 		assert.Nil(t, err, info)
 
-		if c.vendor == "huawei" {
-			dirPlaceholderKey = fmt.Sprintf("%s/langgenius/", prefix)
-			err = storage.Save(dirPlaceholderKey, []byte{})
-			assert.Nil(t, err, info)
-		}
-
 		rdata, err := storage.Load(key)
 		assert.Equal(t, data, rdata, info)
 		assert.Nil(t, err, info)
@@ -198,21 +158,10 @@ func TestAll(t *testing.T) {
 		ossPaths, err = storage.List(prefix)
 		assert.Equal(t, 1, len(ossPaths), info)
 		assert.Nil(t, err, info)
-		// Verify that List returns relative paths (without prefix)
-		expectedRelativePath := key[len(prefix)+1:] // +1 for the "/" separator
-		if assert.Equal(t, 1, len(ossPaths), info) {
-			assert.Equal(t, expectedRelativePath, ossPaths[0].Path, info+" - List should return relative path")
-		}
 
 		err = storage.Delete(key)
 		assert.Nil(t, err, info)
 
-		if dirPlaceholderKey != "" {
-			err = storage.Delete(dirPlaceholderKey)
-			assert.Nil(t, err, info)
-			dirPlaceholderKey = ""
-		}
-
 		exist, err = storage.Exists(key)
 		assert.Equal(t, false, exist, info)
 		assert.Nil(t, err, info)
@@ -221,8 +170,4 @@ func TestAll(t *testing.T) {
 		assert.Equal(t, 0, len(ossPaths), info)
 		assert.Nil(t, err, info)
 	}
-
-	if vendorFilter != "" && !tested {
-		t.Fatalf("no oss test cases matched OSS_TEST_VENDOR=%q", vendorFilter)
-	}
 }