nodemiral/lib/coreTasks.js

module.exports = function(hitler) {
  hitler.registerTask('copy', copy);
  hitler.registerTask('execute', execute);
  hitler.registerTask('executeScript', executeScript);
}

function copy(session, options, callback) {
  if(options.vars) {
    session.copy(options.src, options.dest, options.vars, sendCallback(callback));
  } else {
    session.copy(options.src, options.dest, sendCallback(callback));
  }
}

function execute(session, options, callback) {
  session.execute(options.command, sendCallback(callback));
}

function executeScript(session, options, callback) {
  session.executeScript(options.script, options.vars || {}, sendCallback(callback));
}

function sendCallback(callback) {
  return function(err, code, logs) {
    if (err) {
      callback(err);
    } else if(code !== 0) {
      
      var errorMessage = '\n-----------------------------------STDERR-----------------------------------\n';
      errorMessage += tail(logs.stderr);
      errorMessage += (errorMessage[errorMessage.length-1] != '\n')? '\n' : "";
      errorMessage += '-----------------------------------STDOUT-----------------------------------\n';
      errorMessage += tail(logs.stdout);
      errorMessage += (errorMessage[errorMessage.length-1] != '\n')? '\n' : "";
      errorMessage += '----------------------------------------------------------------------------';

      callback(new Error(errorMessage));
    } else {
      callback();
    }
  };

  function tail(str) {
    if(str) {
      return str.substring(str.length-1000);
    } else {
      return "";
    }
  }
}