aws-s3-component Bug #16 - add region (#17)

Added region to Verification UI and actions and verification code
commented listing of empty bucket in the verification because it was throwing an access exception despite access id and secret being correct

* draft adding region

* don't use bucket during verification

* testing bucket file list

* log bucket name

* add region in verification and in all the actions
don't use the bucket during verification

Author: phachem

component.json

@@ -13,6 +13,11 @@
         "label": "Secret Access Key",
         "required": true,
         "viewClass": "TextFieldView"
+      },
+      "region": {
+        "label": "Region",
+        "required": true,
+        "viewClass": "TextFieldView"
       }
     }
   },

lib/actions/deleteObject.js

@@ -6,6 +6,7 @@ exports.process = async function (msg, cfg) {
   const s3 = new aws.S3({
     accessKeyId: cfg.accessKeyId,
     secretAccessKey: cfg.accessKeySecret,
+    region: cfg.region
   });
 
   // eslint-disable-next-line no-param-reassign

lib/actions/getAllFilesInBucket.js

@@ -6,11 +6,12 @@ exports.process = async function (msg, cfg) {
   const s3 = new aws.S3({
     accessKeyId: cfg.accessKeyId,
     secretAccessKey: cfg.accessKeySecret,
+    region: cfg.region
   });
 
   // eslint-disable-next-line no-param-reassign
   cfg.bucketName = msg.body.bucketName ? msg.body.bucketName : cfg.bucketName;
-
+ 
   // eslint-disable-next-line no-use-before-define
   const data = await s3.listObjects(createAWSInputs(cfg.bucketName)).promise();
   data.Contents.forEach((c) => {
@@ -26,5 +27,5 @@ function createAWSInputs(bucketName) {
     const bucket = bucketName.substring(0, index);
     return { Bucket: bucket, Delimiter: '/', Prefix: folder };
   }
-  return { Bucket: bucketName };
+  return { Bucket: bucketName } ; 
 }

lib/actions/readFile.js

@@ -11,6 +11,7 @@ exports.process = async function (msg, cfg) {
   const s3 = new aws.S3({
     accessKeyId: cfg.accessKeyId,
     secretAccessKey: cfg.accessKeySecret,
+    region: cfg.region
   });
 
   // eslint-disable-next-line no-param-reassign

lib/actions/streamToCsv.js

@@ -32,6 +32,7 @@ function processAction(msg, cfg) {
       const s3client = new AWS.S3({
         accessKeyId: cfg.accessKeyId,
         secretAccessKey: cfg.accessKeySecret,
+        region: cfg.region
       });
       const streamClient = s3Stream(s3client);
       const csv = cfg.csv || {};

lib/actions/streamToFile.js

@@ -11,6 +11,7 @@ exports.process = async function (msg, cfg) {
   const s3 = new aws.S3({
     accessKeyId: cfg.accessKeyId,
     secretAccessKey: cfg.accessKeySecret,
+    region: cfg.region
   });
 
   // eslint-disable-next-line no-param-reassign

verifyCredentials.js

@@ -16,11 +16,12 @@ module.exports = function verifyCredentials(credentials, cb) {
     const s3 = new aws.S3({
       accessKeyId: credentials.accessKeyId,
       secretAccessKey: credentials.accessKeySecret,
+      region: credentials.region 
     });
 
     // eslint-disable-next-line no-use-before-define
-    const data = await s3.listObjects({ Bucket: '' }).promise();
-    debug('Root dir files: %j', data.Contents.forEach(c => c.Key));
+    //const data = await s3.listObjects({ Bucket: '' }).promise();
+    //debug('Root dir files: %j', data.Contents.forEach(c => c.Key));
     console.log('Verification completed');
 
     cb(null, { verified: true });