gerrit.js

var child_process = require('child_process');
var Ssh2Connection;

var getProcessUsername = function(callback) {
  child_process.exec('whoami', function(err, res) {
    if (err) callback(err);
    else {
      res = res.split('\n')[0];
      if (res.indexOf('/') != -1) res = res.split('/').pop();
      res = res.trim();
      callback(null, res);
    }
  });
};

var ssh2 = function(sshConfig, command, callback) {
  if (!Ssh2Connection) Ssh2Connection = require('ssh2');

  var connection = new Ssh2Connection();
  connection.on('connect', function() {
  });
  connection.on('ready', function() {
    connection.exec(command, function(err, stream) {
      if (err) return callback(err);
      var result = '';
      stream.on('data', function(data, extended) {
        result += data.toString();
      });
      stream.on('end', function() {
        callback(null, result);
      });
    });
  });
  connection.on('error', function(err) {
    callback(err);
  });
  var doConnect = function() { connection.connect(sshConfig); };
  if (sshConfig.username) doConnect();
  else getProcessUsername(function(err, username) {
      if (err) callback(err);
      else {
        sshConfig.username = username;
        doConnect();
      }
    });
};

var gerrit = function(sshConfig, command, res, callback) {
  command = 'gerrit ' + command;
  ssh2(sshConfig, command, function(error, result) {
    var errorCode = 'unknown'
    if (result && result.indexOf('gerrit: command not found') != -1) {
      errorCode = error = 'not-a-gerrit-remote';
    }
    if (error) {
      var err = { errorCode: errorCode, command: command, error: error.toString() };
      if (!callback || !callback(err, result)) {
        res.json(400, err);
      }
    } else {
      callback(null, result);
    }
  });
};

module.exports = gerrit;