feat: add aws s3 provider

.mdeprc.js

@@ -8,6 +8,14 @@ module.exports = {
   post_exec: 'yarn coverage:report'
 };
 
+if (process.env.PROVIDER === 'aws') {
+  module.exports.tests = './test/suites/providers/aws/*.js';
+}
+
+if (process.env.PROVIDER !== 'aws') {
+  module.exports.tests = './test/suites/**/!(providers)/*.js';
+}
+
 switch (process.env.DB) {
   case 'sentinel':
     module.exports.services.push('redisSentinel');

package.json

@@ -7,9 +7,10 @@
     "compile": "rimraf ./lib && babel -d ./lib --copy-files ./src",
     "pretest": "yarn compile",
     "test": "rimraf ./coverage && yarn lint && yarn test:e2e",
-    "test:e2e": "yarn test:e2e:cluster && yarn test:e2e:sentinel",
-    "test:e2e:cluster": "DB=cluster mdep test run",
-    "test:e2e:sentinel": "DB=sentinel mdep test run --docker_compose ./test/docker-compose.sentinel.yml",
+    "test:e2e": "yarn test:e2e:cluster && yarn test:e2e:sentinel && test:e2e:aws-provider",
+    "test:e2e:cluster": "PROVIDER=gce DB=cluster mdep test run",
+    "test:e2e:sentinel": "PROVIDER=gce DB=sentinel mdep test run --docker_compose ./test/docker-compose.sentinel.yml",
+    "test:e2e:aws-provider": "PROVIDER=aws DB=sentinel mdep test run --docker_compose ./test/docker-compose.sentinel.yml",
     "start": "mfleet",
     "lint": "eslint ./src ./test",
     "prepublishOnly": "yarn compile",
@@ -41,6 +42,7 @@
     "@microfleet/validation": "9",
     "@sentry/node": "^6.0.2",
     "ali-oss": "^6.13.2",
+    "aws-sdk": "^2.914.0",
     "bl": "^4.0.3",
     "bluebird": "^3.7.2",
     "cluster-key-slot": "^1.1.0",

src/actions/upload.js

@@ -38,6 +38,7 @@ const {
  * @return {Promise}
  */
 async function initFileUpload({ params }) {
+  console.log('init file upload');
   const {
     files,
     meta,

src/configs/core.js

@@ -93,6 +93,7 @@ exports.transport = [{
  * @returns {Provider}
  */
 exports.selectTransport = function selectTransport() {
+  // console.log('my provider 1', this.providers[0]);
   return this.providers[0];
 };
 

src/index.js

@@ -164,8 +164,8 @@ class Files extends Microfleet {
     await super.connect();
     await this.initWebhook();
     await Promise.mapSeries(this.providers, (provider) => {
-      // @todo
-      if (provider.config.name !== 'gce') return null;
+      if (!['aws', 'gce'].includes(provider.config.name)) return null;
+
       if (!provider.config.bucket.channel.pubsub) return null;
       return provider.subscribe(this.handleUploadNotification.bind(this));
     });