sshclient.js

//Thanks ssh-client(git://github.com/exfm/node-ssh-client.git )
var util = require('util'),
    EventEmitter = require('events').EventEmitter,
    child_process = require('child_process'),
    spawn = child_process.spawn,
    exec = child_process.exec;

module.exports = function(username, host, port,connectcb){
  return new SSHClient(username, host, port, connectcb);
};

function SSHClient(username, host, port, connectcb){
  var self = this, outBuff = "", out;
  this.queue = [];
  this.lastError = null;
  this.cb = null;
  this.interval = null;
  this.working = true;
  this.connected = false;
  this.killedSafe = false;

  this.ssh = spawn('ssh', ['-t', '-t', '-p ' + port, username + '@' + host]);
  this.ssh.stdout.on('data', function (data){
    if(self.connected === false){
      self.connected = true;
      self.working = false;
      return self.exec('pwd', function(){
        self.emit('connect');
      });
    }

    var isEnd = data.toString().indexOf('__SSHCLIENT__\r\n') > -1;
    outBuff += data.toString();

    if(self.cb && isEnd){
      outBuff = outBuff.split("echo __SSHCLIENT__;\r\n");
      out = (outBuff[1] && outBuff[1].length > 0) ? outBuff[1] : 'OK: ' + outBuff[0];
      out = out.replace("\r\n__SSHCLIENT__\r\n", "");
      self.emit('data', out);

      self.cb(null, out);

      outBuff = "";
      self.cb = null;
    }
    self.working = false;
  });

  this.ssh.stderr.on('data', function (data) {

    if(data.toString() === "Pseudo-terminal will not be allocated because stdin is not a terminal.\r\n"){
      return;
    }

    if(data.toString() === "Killed by signal 1.\r\n"){
      return this.emit('close');
    }

    if(data.toString().toLowerCase().indexOf('warn') > -1){
      return;
    }

    self.lastError = data.toString();

    if(self.cb){
      self.cb(new Error(data.toString()), null);
      self.cb = null;
    }
    self.working = false;
  });

  this.ssh.on('exit', function (code, signal) {
    if(code !==0 && self.killedSafe === false){
      setTimeout(function(){
        console.error('Exited, ', self.lastError);
        self.emit('error', self.lastError);
      }, 50);
    }
  });

  this.on('close', function(){
    clearInterval(this.interval);
    this.killedSafe = true;
    this.ssh.kill('SIGHUP');
  });
  this.on('error' , function(err){
    if(err) throw err;
  });

  this.on('connect', function(){
    self.working = false;
    connectcb();
    if(self.queue.length === 0){
      return;
    }
  });

  this.interval = setInterval(function(){
    if(self.queue.length > 0 && self.working === false){
      var d = self.queue.shift(), s = '';
      self.cb = d[1];
      self.working = true;
      self.emit('sending', d[0]);

      if(d[0].charAt(d[0].length - 1) !== "&"){
        s = ";";
      }
      self.ssh.stdin.write(d[0] + s + " echo __SSHCLIENT__;\n");
    }
  }, 100);
}
util.inherits(SSHClient, EventEmitter);

SSHClient.prototype.exec = function(cmd, cb){
  this.queue.push([cmd, cb]);
};

SSHClient.prototype.close = function(){
  clearInterval(this.interval);
  this.killedSafe = true;
  this.ssh.kill('SIGHUP');
};

SSHClient.prototype.cd = function(dir, cb){
  this.exec("cd " + dir, cb);
};

SSHClient.prototype.mkdir = function(dir, cb){
  this.exec("mkdir -p " + dir, cb);
};