Add Ceph RGW S3 compatibility.

src/internal/client.ts

@@ -29,7 +29,9 @@ export class AWSClient {
      * the specific AWS service the child class implements the functionalities of.
      */
     public get host() {
-        if (this._host == undefined) {
+        if (this.awsConfig.forcePathStyle) {
+            return this.awsConfig.endpoint
+        } else if (this._host == undefined) {
             return `${this.serviceName}.${this.awsConfig.region}.${this.awsConfig.endpoint}`
         }
         return this._host

src/internal/config.ts

@@ -46,6 +46,13 @@ export class AWSConfig {
      */
     endpoint: string = 'amazonaws.com'
 
+    /**
+     * Path-style bucket.
+     *
+     * @type {boolean}
+     */
+    forcePathStyle: boolean = false
+
     /**
      * Create an AWSConfig.
      *
@@ -98,6 +105,10 @@ export class AWSConfig {
         if (options.endpoint !== undefined) {
             this.endpoint = options.endpoint
         }
+
+        if (options.forcePathStyle !== undefined) {
+            this.forcePathStyle = options.forcePathStyle
+        }
     }
 }
 
@@ -146,6 +157,13 @@ export interface AWSConfigOptions {
      * @type {string}
      */
     endpoint?: string
+
+    /**
+     * Path-Style bucket.
+     *
+     * @type {boolean}
+     */
+    forcePathStyle?: boolean
 }
 
 /** Class representing an invalid AWS configuration */

src/internal/s3.ts

@@ -24,7 +24,7 @@ export class S3Client extends AWSClient {
             service: this.serviceName,
             region: this.awsConfig.region,
             credentials: {
-                accessKeyId: this.awsConfig.accessKeyID,
+                accessKeyId: this.awsConfig.accessKeyId,
                 secretAccessKey: this.awsConfig.secretAccessKey,
                 sessionToken: this.awsConfig.sessionToken,
             },
@@ -47,8 +47,8 @@ export class S3Client extends AWSClient {
 
         const signedRequest: SignedHTTPRequest = this.signature.sign(
             {
-                method: 'GET',
-                protocol: 'https',
+                method: method,
+                protocol: this.awsConfig.scheme,
                 hostname: this.host,
                 path: '/',
                 headers: {},
@@ -101,14 +101,22 @@ export class S3Client extends AWSClient {
     listObjects(bucketName: string, prefix?: string): Array<S3Object> {
         // Prepare request
         const method = 'GET'
-        const host = `${bucketName}.${this.host}`
+        let host
+        let path
+        if (this.awsConfig.forcePathStyle) {
+            host = `${this.host}`
+            path = `/${bucketName}/`
+        } else {
+            host = `${bucketName}.${this.host}`
+            path = `/`
+        }
 
         const signedRequest: SignedHTTPRequest = this.signature.sign(
             {
                 method: 'GET',
-                protocol: 'https',
+                protocol: this.awsConfig.scheme,
                 hostname: host,
-                path: '/',
+                path: path,
                 query: {
                     'list-type': '2',
                     prefix: prefix || '',
@@ -170,14 +178,22 @@ export class S3Client extends AWSClient {
     getObject(bucketName: string, objectKey: string): S3Object {
         // Prepare request
         const method = 'GET'
-        const host = `${bucketName}.${this.host}`
+        let host
+        let path
+        if (this.awsConfig.forcePathStyle) {
+            host = `${this.host}`
+            path = `/${bucketName}/${objectKey}`
+        } else {
+            host = `${bucketName}.${this.host}`
+            path = `/${objectKey}`
+        }
 
         const signedRequest = this.signature.sign(
             {
                 method: 'GET',
-                protocol: 'https',
+                protocol: this.awsConfig.scheme,
                 hostname: host,
-                path: `/${objectKey}`,
+                path: path,
                 headers: {},
             },
             {}
@@ -215,14 +231,22 @@ export class S3Client extends AWSClient {
     putObject(bucketName: string, objectKey: string, data: string | ArrayBuffer) {
         // Prepare request
         const method = 'PUT'
-        const host = `${bucketName}.${this.host}`
+        let host
+        let path
+        if (this.awsConfig.forcePathStyle) {
+            host = `${this.host}`
+            path = `/${bucketName}/${objectKey}`
+        } else {
+            host = `${bucketName}.${this.host}`
+            path = `/${objectKey}`
+        }
 
         const signedRequest = this.signature.sign(
             {
                 method: method,
-                protocol: 'https',
+                protocol: this.awsConfig.scheme,
                 hostname: host,
-                path: `/${objectKey}`,
+                path: path,
                 headers: {},
                 body: data,
             },
@@ -247,14 +271,22 @@ export class S3Client extends AWSClient {
     deleteObject(bucketName: string, objectKey: string): void {
         // Prepare request
         const method = 'DELETE'
-        const host = `${bucketName}.${this.host}`
+        let host
+        let path
+        if (this.awsConfig.forcePathStyle) {
+            host = `${this.host}`
+            path = `/${bucketName}/${objectKey}`
+        } else {
+            host = `${bucketName}.${this.host}`
+            path = `/${objectKey}`
+        }
 
         const signedRequest = this.signature.sign(
             {
                 method: method,
-                protocol: 'https',
+                protocol: this.awsConfig.scheme,
                 hostname: host,
-                path: `/${objectKey}`,
+                path: path,
                 headers: {},
             },
             {}