queenshow/scripts/uploadSftp.js

'use strict';

var ClientLib = require('scp2');

var client = new ClientLib.Client();

function UploadSftp(options) {
  this.options = options;
}

UploadSftp.prototype.apply = function (callbck) {
  var self = this;

  var remotePath = self.options.remotePath;
  var path = self.options.path;
  var username = self.options.username;
  var host = self.options.host;
  var password = self.options.password;
  var port = self.options.port || '22';
  var verbose = self.options.verbose;

  var startTime;
  var endTime;

  client.on('connect', function () {
    // console.log('connected');
  });

  client.on('ready', function () {
    // console.log('ready');
    startTime = new Date();
    console.log('[Start Uploading] ' + startTime);
  });

  client.on('transfer', function (buf, up, total) {});

  client.on('write', function (p) {
    if (verbose) {
      console.log('Transfer ' + p.source + ' => ' + p.destination);
    }
  });

  client.on('end', function () {
    endTime = new Date();
    console.log('[End Uploading] ' + new Date());
  });

  client.on('error', function (err) {
    console.log('[Error] ' + err);
  });

  client.on('close', function () {
    console.log(
      'Transfer with SFTP Completed in [' +
        (+endTime - +startTime) / 1000 +
        '] seconds!',
    );

    callbck && callbck();
  });

  var srcPath = path;
  var destPath =
    username + ':' + password + '@' + host + ':' + port + ':' + remotePath;

  uploadByDir(srcPath, destPath, client);
};

/**
 * [uploadByDir: Upload Directory Directory & Cannot Get Detailed Uploading Info for Files]
 * @param  {[String]} src    [description]
 * @param  {[String]} dest   [description]
 * @param  {[Object]} client [description]
 */
function uploadByDir(src, dest, client) {
  ClientLib.scp(src, dest, client, function (err) {
    if (err) {
      console.log(err);
    }
  });
}

module.exports = UploadSftp;