updating readme

Author: mientjan

.gitignore

@@ -14,3 +14,4 @@ node_modules/
 /dist/
 
 ## only ignore in git
+.henkrc

package-lock.json

@@ -24,6 +24,7 @@
     "chai": "^4.2.0",
     "commander": "^2.19.0",
     "fs-extra": "^7.0.1",
+    "glob-promise": "^3.4.0",
     "inquirer": "^6.2.2",
     "mocha": "^6.0.2",
     "opener": "^1.5.1",

package.json

@@ -64,6 +64,7 @@ module.exports = async (data = {}, cli) => {
         { name: 'Mediamonks Preview', value: 'mm-preview' },
         { name: 'Amazon S3', value: 's3' },
         { name: 'FTP (alpha)', value: 'ftp' },
+        { name: 'SFTP (alpha)', value: 'sftp' },
         { name: 'Netflix Monet', value: 'monet', disabled: true },
         { name: 'Google DoubleClick Studio', value: 'doubleclick', disabled: true },
       ],
@@ -73,7 +74,7 @@ module.exports = async (data = {}, cli) => {
   const target = targets[data.type];
 
   if (!target) {
-    throw new Error(`inknown target ${data.type}`);
+    throw new Error(`unknown target ${data.type}`);
   }
 
   data = await conditionalPrompt(data, {
@@ -93,19 +94,5 @@ module.exports = async (data = {}, cli) => {
 
   await target.action(data);
 
-  console.log(`
-              +hho.      
-             -MMMMm      
-            .dMMMMm      
-          \`oNMMMMM/\`\`\`\`  
-\`\`\`\`\`\`  ./dMMMMMMNmmmmdh:
-dmmmmm//mMMMMMMMMMMMMMMMN
-MMMMMMooMMMMMMMMMMMMMMMMo
-MMMMMMooMMMMMMMMMMMMMMMM:
-MMmmMMooMMMMMMMMMMMMMMMd 
-MM//MMooMMMMMMMMMMMMMMM/ 
-hddddd::dmMMMMMMMMMMMMh  
-          \`-/oyhhddhy+\`  
-
-  `);
+  console.log(`Done, Have a nice day.`);
 };

src/index.js

@@ -39,9 +39,7 @@ const preview = {
 		  type: 'input',
 		  name: 'outputDir',
 		  description: 'Please fill in the target directory:',
-		  default: () => {
-		    return `${uuid()}/`
-          },
+		  default: () => `${uuid()}/`,
 		  validate: validateNotEmpty,
 		  errorMessage: 'Missing target ',
 		  required: true,

src/target/mm-preview.js

@@ -30,21 +30,20 @@ module.exports = {
       errorMessage: 'Missing secretAccessKey',
       required: true,
     },
-
     {
       type: 'input',
       name: 'outputDir',
       description: 'Please fill in the target directory:',
       validate: validateNotEmpty,
-      errorMessage: 'Missing target ',
+      errorMessage: 'Missing outputDir',
       required: true,
     },
   ],
   async action(data) {
     validateActionInput(data, this.questions);
 
     await new Uploader({
-      config: './.previewsrc', // can also use environment variables
+      config: './.henkrc', // can also use environment variables
       bucket: data.bucket,
       localPath: `${data.inputDir}`,
       remotePath: `${data.outputDir}`,

src/target/s3.js

@@ -2,6 +2,10 @@ const validateActionInput = require('../util/validateActionInput');
 const validateNotOutsideWorkingDir = require('../util/validate/validateNotOutsideWorkingDir');
 const validateNotEmpty = require('../util/validate/validateNotEmpty');
 const Client = require('ssh2-sftp-client');
+const glob = require('glob-promise');
+const path = require('path');
+const isFile = require('../util/isFile');
+const ProgressBar = require('progress');
 
 module.exports = {
   questions: [
@@ -55,9 +59,40 @@ module.exports = {
         secure: data.secure,
       });
 
-      const fileList = await sftp.list('./');
+      try {
+        await sftp.mkdir(data.outputDir, true);
+      } catch (e) {}
+
+      if (/\*/.test(data.inputDir)) {
+        throw new Error('Globbing pattern is not allowed');
+      }
+
+      const inputDir = path.join(data.inputDir, '**/*');
+      const files = await glob(inputDir);
+
+      const bar = new ProgressBar('[:bar] :percent | :etas | :current / :total | :rate/fps ', {
+        total: files.length,
+        complete: '=',
+        incomplete: ' ',
+        width: 20,
+      });
+
+      const relativeFiles = files.map(file => path.relative(data.inputDir, file));
+      for (let i = 0; i < relativeFiles.length; i++) {
+        const inputFilePath = files[i];
+        const outputFilePath = path.join(data.outputDir, relativeFiles[i]);
+
+        if(!(await isFile(inputFilePath))){
+	        try {
+		        await sftp.mkdir(outputFilePath, true);
+	        } catch (e) {}
+        } else {
+          await sftp.fastPut(inputFilePath, outputFilePath);
+        }
+
+        bar.tick();
+      }
 
-      console.log(fileList);
     } catch (err) {
       console.log(err);
     }

src/target/sftp.js

@@ -14,9 +14,13 @@ module.exports = async function conditionalPrompt(data, questions) {
     // check if data is already there, or validate with validator if validate is there.
     if (
       data[question.name] === undefined ||
-      (question.validate && question.validate(data[question.name]) !== true )
+      (question.validate && question.validate(data[question.name]) !== true)
     ) {
-      if(data[question.name] !== undefined && (question.validate && question.validate(data[question.name]) !== true)){
+      // show message
+      if (
+        data[question.name] !== undefined &&
+        (question.validate && question.validate(data[question.name]) !== true)
+      ) {
         console.log(error(question.validate(data[question.name])));
       }
 

src/util/conditionalPrompt.js

@@ -0,0 +1,8 @@
+const fs = require('fs');
+module.exports = function isFile(path) {
+  return new Promise(resolve => {
+    fs.lstat(path, (err, stats) => {
+      resolve(stats.isFile());
+    });
+  });
+};