feat: add aws provider implementation

Author: socaseinpoint

src/providers/aws.js

@@ -61,7 +61,14 @@ class ProviderFactory {
   // eslint-disable-next-line class-methods-use-this
   getProviderAWS(transport) {
     const ProviderAWS = require('./aws');
-    const provider = new ProviderAWS(transport);
+    const bucket = transport.options.bucket.name;
+
+    // delegate logging facility
+    transport.options.logger = this.logger.child({ bucket });
+
+    // init provider
+    debug('passing options %j', transport.options);
+    const provider = new ProviderAWS(transport.options);
 
     return provider;
   }

src/providers/factory.js

@@ -19,6 +19,7 @@ class GCETransport extends AbstractFileTransfer {
   constructor(opts = {}) {
     super();
     this._config = merge({}, GCETransport.defaultOpts, opts);
+
     this._logger = this._config.logger;
     this.setupGCE();
   }

src/providers/gce.js

@@ -19,45 +19,46 @@ exports.amqp = {
   },
 };
 
-exports.transport = [{
-  name: 'gce',
-  options: {
-    gce: {
-      projectId: env.GCLOUD_PROJECT_ID,
-      credentials: {
-        client_email: env.GCLOUD_PROJECT_EMAIL,
-        private_key: env.GCLOUD_PROJECT_PK,
+exports.transport = [
+  //   {
+  //   name: 'gce',
+  //   options: {
+  //     gce: {
+  //       projectId: env.GCLOUD_PROJECT_ID,
+  //       credentials: {
+  //         client_email: env.GCLOUD_PROJECT_EMAIL,
+  //         private_key: env.GCLOUD_PROJECT_PK,
+  //       },
+  //     },
+  //     bucket: {
+  //       name: env.TEST_BUCKET,
+  //       metadata: {
+  //         location: env.GCLOUD_BUCKET_LOCATION || 'EUROPE-WEST1',
+  //         dra: true,
+  //       },
+  //     },
+  //     // test for direct public URLs
+  //   },
+  //   // its not a public name!
+  //   cname: 'gce',
+  // },
+  {
+    name: 'aws',
+    options: {
+      aws: {
+        credentials: {
+          accessKeyId: env.AWS_ACCESS_KEY_ID,
+          secretAccessKey: env.AWS_SECRET_ACCESS_KEY,
+        },
       },
-    },
-    bucket: {
-      name: env.TEST_BUCKET,
-      metadata: {
-        location: env.GCLOUD_BUCKET_LOCATION || 'EUROPE-WEST1',
-        dra: true,
-      },
-    },
-    // test for direct public URLs
-  },
-  // its not a public name!
-  cname: 'gce',
-},
-{
-  name: 'aws',
-  options: {
-    aws: {
-      credentials: {
-        accessKeyId: env.AWS_ACCESS_KEY_ID,
-        secretAccessKey: env.AWS_SECRET_ACCESS_KEY,
+      bucket: {
+        name: env.TEST_BUCKET,
       },
+      // test for direct public URLs
     },
-    bucket: {
-      name: env.TEST_BUCKET,
-    },
-    // test for direct public URLs
-  },
-  // its not a public name!
-  cname: 'aws',
-}];
+    // its not a public name!
+    cname: 'aws',
+  }];
 
 exports.hooks = {
   // return input, assume there are models

test/configs/generic/core.js

@@ -188,7 +188,7 @@ function upload(location, file) {
   });
 }
 
-function uploadSimple(meta, file, isPublic) {
+async function uploadSimple(meta, file, isPublic) {
   const { query: { Expires } } = url.parse(meta.location);
 
   const headers = {
@@ -204,9 +204,10 @@ function uploadSimple(meta, file, isPublic) {
   return request.put({
     url: meta.location,
     body: file,
-    headers,
-    simple: false,
+    // headers,
+    // simple: false,
     resolveWithFullResponse: true,
+    ACL: 'public-read',
   });
 }
 
@@ -222,6 +223,7 @@ function uploadFiles(msg, rsp) {
       const file = files[idx];
       const { location } = part;
       const isSimple = location.indexOf('Signature') !== -1;
+      console.log('isSimple upload', isSimple);
       return isSimple ? uploadSimple(part, file, rsp.public) : upload(location, file);
     });
 }