cli/actions.js

   1 'use strict';
   2
   3 exports.login = login;
   4 exports.put = put;
   5 exports.get = get;
   6 exports.del = del;
   7
   8 var superagent = require('superagent'),
   9     config = require('./config.js'),
  10     readlineSync = require('readline-sync'),
  11     async = require('async'),
  12     fs = require('fs'),
  13     path = require('path');
  14
  15 require('colors');
  16
  17 var API = '/api/files/';
  18
  19 var gQuery = {};
  20
  21 function checkConfig() {
  22     if (!config.server() || !config.username() || !config.password()) {
  23         console.log('You have run "login" first');
  24         process.exit(1);
  25     }
  26
  27     gQuery = { username: config.username(), password: config.password() };
  28
  29     console.log('Using server %s', config.server().yellow);
  30 }
  31
  32 function collectFiles(filesOrFolders) {
  33     var tmp = [];
  34
  35     filesOrFolders.forEach(function (filePath) {
  36         var stat = fs.statSync(filePath);
  37
  38         if (stat.isFile()) {
  39             tmp.push(filePath);
  40         } else if (stat.isDirectory()) {
  41             var files = fs.readdirSync(filePath).map(function (file) { return path.join(filePath, file); });
  42             tmp = tmp.concat(collectFiles(files));
  43         } else {
  44             console.log('Skipping %s', filePath.cyan);
  45         }
  46     });
  47
  48     return tmp;
  49 }
  50
  51 function checkResponse(error, result) {
  52     if (error && error.status === 401) {
  53         console.log('Login failed');
  54         process.exit(1);
  55     } else if (error) {
  56         console.log('Error', result ? result.text : error);
  57         process.exit(1);
  58     }
  59 }
  60
  61 function login(server) {
  62     if (server[server.length-1] === '/') server = server.slice(0, -1);
  63
  64     console.log('Using server', server);
  65
  66     var username = readlineSync.question('Username: ', { hideEchoBack: false });
  67     var password = readlineSync.question('Password: ', { hideEchoBack: true });
  68
  69     superagent.get(server + API + '/').query({ username: username, password: password }).end(function (error, result) {
  70         console.log(result.status);
  71
  72         if (result.status === 401) {
  73             console.log('Login failed.');
  74             process.exit(1);
  75         }
  76
  77         config.set('server', server);
  78         config.set('username', username);
  79
  80         // TODO this is clearly bad and needs fixing
  81         config.set('password', password);
  82
  83         gQuery = { username: username, password: password };
  84     });
  85 }
  86
  87 function put(filePath, otherFilePaths, options) {
  88     checkConfig();
  89
  90     var files = collectFiles([ filePath ].concat(otherFilePaths));
  91
  92     async.eachSeries(files, function (file, callback) {
  93         var relativeFilePath = path.resolve(file).slice(process.cwd().length + 1);
  94
  95         console.log('Uploading file %s -> %s', relativeFilePath.cyan, ((options.destination ? options.destination : '') + '/' + relativeFilePath).cyan);
  96
  97         superagent.put(config.server() + API + relativeFilePath).query(gQuery).attach('file', file).end(callback);
  98     }, function (error) {
  99         if (error) {
 100             console.log('Failed to put file.', error);
 101             process.exit(1);
 102         }
 103
 104         console.log('Done');
 105     });
 106 }
 107
 108 function get(filePath) {
 109     checkConfig();
 110
 111     superagent.get(config.server() + API + filePath).query(gQuery).end(function (error, result) {
 112         if (error && error.status === 401) return console.log('Login failed');
 113         if (error && error.status === 404) return console.log('No such file or directory');
 114         if (error) return console.log('Failed', result ? result.body : error);
 115
 116         if (result.body && result.body.entries) {
 117             console.log('Files:');
 118             result.body.entries.forEach(function (entry) {
 119                 console.log('\t %s', entry);
 120             });
 121         } else {
 122             console.log(result.text);
 123         }
 124     });
 125 }
 126
 127 function del(filePath) {
 128     checkConfig();
 129
 130     var relativeFilePath = path.resolve(filePath).slice(process.cwd().length + 1);
 131     superagent.del(config.server() + API + relativeFilePath).query(gQuery).end(function (error, result) {
 132         if (error && error.status === 401) return console.log('Login failed');
 133         if (error && error.status === 404) return console.log('No such file or directory');
 134         if (error) return console.log('Failed', result ? result.body : error);
 135         console.log('Success', result.body);
 136     });
 137 }