feat: support access style override

minio · Nov 14, 2020 · f34483e · f34483e
1 parent fdbc801
commit f34483e
Show file tree

Hide file tree

Showing 4 changed files with 47 additions and 9 deletions.
diff --git a/docs/API.md b/docs/API.md
@@ -65,6 +65,7 @@ __Parameters__
 |`transport`    | _string_  |Set this value to pass in a custom transport. (Optional)|
 |`sessionToken`    | _string_  |Set this value to provide x-amz-security-token (AWS S3 specific). (Optional)|
 |`partSize`    | _number_  |Set this value to override default part size of 64MB for multipart uploads. (Optional)|
+|`accessStyle`    | _string_  |Set this value to override default access behavior. Supported styles are 'path' and 'virtual-hosted'. (Optional)|
 
 
 __Example__
@@ -96,6 +97,20 @@ var s3Client = new Minio.Client({
 })
 ```
 
+## Ali OSS 
+
+```js
+var Minio = require('minio')
+
+var s3Client = new Minio.Client({
+    endPoint:  'oss-cn-hangzhou.aliyuncs.com',
+    accessKey: 'YOUR-ACCESSKEYID',
+    secretKey: 'YOUR-SECRETACCESSKEY',
+    bucket: 'YOUR-BUCKET',
+    accessStyle: 'virtual-hosted',
+    region: 'oss-cn-hangzhou'
+})
+```
 
 ## 2. Bucket operations
 <a name="makeBucket"></a>

diff --git a/docs/zh_CN/API.md b/docs/zh_CN/API.md
@@ -23,10 +23,26 @@ var Minio = require('minio')
 
 var s3Client = new Minio.Client({
     endPoint:  's3.amazonaws.com',
-	accessKey: 'YOUR-ACCESSKEYID',
-	secretKey: 'YOUR-SECRETACCESSKEY'
+    accessKey: 'YOUR-ACCESSKEYID',
+    secretKey: 'YOUR-SECRETACCESSKEY'
 })
 ```
+
+## Ali OSS 
+
+```js
+var Minio = require('minio')
+
+var s3Client = new Minio.Client({
+    endPoint:  'oss-cn-hangzhou.aliyuncs.com',
+    accessKey: 'YOUR-ACCESSKEYID',
+    secretKey: 'YOUR-SECRETACCESSKEY',
+    bucket: 'YOUR-BUCKET',
+    accessStyle: 'virtual-hosted',
+    region: 'oss-cn-hangzhou'
+})
+```
+
 | 操作存储桶       | 操作对象      | Presigned操作 | 存储桶策略/通知  |
 | ------------- |-------------| -----| ----- |
 | [`makeBucket`](#makeBucket)    | [`getObject`](#getObject) | [`presignedUrl`](#presignedUrl) | [`getBucketNotification`](#getBucketNotification) |
@@ -64,7 +80,7 @@ __参数__
 |`transport`    | _string_  |Set this value to pass in a custom transport. (Optional) - To be translated |
 |`sessionToken`    | _string_  |Set this value to provide x-amz-security-token (AWS S3 specific). (Optional) - To be translated|
 |`partSize`    | _number_  |Set this value to override default part size of 64MB for multipart uploads. (Optional) - To be translated|
-
+|`accessStyle`    | _string_  |设置该值以覆盖默认访问方式。支持方式有 'path' 与 'virtual-hosted'。（可选）|
 
 __示例__
 

diff --git a/src/main/helpers.js b/src/main/helpers.js
@@ -94,11 +94,18 @@ export function isAmazonEndpoint(endpoint) {
 // style if the protocol is 'https:', this is due to SSL wildcard
 // limitation. For all other buckets and Amazon S3 endpoint we will
 // default to virtual host style.
-export function isVirtualHostStyle(endpoint, protocol, bucket) {
+export function isVirtualHostStyle(endpoint, protocol, bucket, accessStyle) {
   if (protocol === 'https:' && bucket.indexOf('.') > -1) {
+    if (accessStyle !== undefined && accessStyle !== 'path') {
+      console.log("Protocol is https and bucket contains a dot, ignoring override, force path style.")
+    }
     return false
   }
-  return isAmazonEndpoint(endpoint)
+  switch (accessStyle) {
+  case 'path': return false
+  case 'virtual-hosted': return true
+  default: return isAmazonEndpoint(endpoint)
+  }
 }
 
 var ipv4Regex = /^(\d{1,3}\.){3,3}\d{1,3}$/

diff --git a/src/main/minio.js b/src/main/minio.js
@@ -121,6 +121,7 @@ export class Client {
     this.accessKey = params.accessKey
     this.secretKey = params.secretKey
     this.sessionToken = params.sessionToken
+    this.accessStyle = params.accessStyle
     this.userAgent = `${libraryAgent}`
 
     if (!this.accessKey) this.accessKey = ''
@@ -178,9 +179,7 @@ export class Client {
     // Verify if virtual host supported.
     var virtualHostStyle
     if (bucketName) {
-      virtualHostStyle = isVirtualHostStyle(this.host,
-                                            this.protocol,
-                                            bucketName)
+      virtualHostStyle = isVirtualHostStyle(this.host, this.protocol, bucketName, this.accessStyle)
     }
 
     if (this.port) reqOptions.port = this.port
@@ -489,7 +488,8 @@ export class Client {
     //   the error XML also provides Region of the bucket. To validate
     //   this region is proper we retry the same request with the newly
     //   obtained region.
-    var pathStyle = typeof window === 'undefined'
+    var pathStyle = typeof window === 'undefined' && this.accessStyle !== 'virtual-hosted'
+
     this.makeRequest({method, bucketName, query, pathStyle}, '', 200, 'us-east-1', true, (e, response) => {
       if (e) {
         if (e.name === 'AuthorizationHeaderMalformed') {