server.js

var express = require('express');
var Docker = require('dockerode');
var path = require('path');
var fs = require('fs');

var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var ss = require('socket.io-stream');
app.use('/public', express.static('public'));


app.get('/', function (req,res) {
  res.sendFile(path.join(__dirname , 'ui.html'))
});

http.listen(3000, function(){
  console.log('listening on *:3000');
});

/*
Writing /Users/henry/.boot2docker/certs/boot2docker-vm/ca.pem
Writing /Users/henry/.boot2docker/certs/boot2docker-vm/cert.pem
Writing /Users/henry/.boot2docker/certs/boot2docker-vm/key.pem

To connect the Docker client to the Docker daemon, please set:
    export DOCKER_HOST=tcp://192.168.59.103:2376
    export DOCKER_CERT_PATH=/Users/henry/.boot2docker/certs/boot2docker-vm
    export DOCKER_TLS_VERIFY=1
*/

io.on('connection' , function (socket){
  global.socket = socket;
  console.log('hi lo')
})


app.get('/create-container', function (req,res,next){
  console.log('CREAATENOW');
    var clientConfig = {
      DOCKER_HOST : req.query['DOCKER_HOST'],
      DOCKER_CERT_PATH : req.query['DOCKER_CERT_PATH']
    }
    try {
      clientConfig.host = clientConfig.DOCKER_HOST.slice(clientConfig.DOCKER_HOST.indexOf('tcp://') + 6 , clientConfig.DOCKER_HOST.lastIndexOf(':'))
      clientConfig.port = clientConfig.DOCKER_HOST.slice(clientConfig.DOCKER_HOST.lastIndexOf(':') + 1, clientConfig.DOCKER_HOST.length)
      var fields = ['ca', 'cert', 'key'];
      fields.forEach(function (item) {
        clientConfig[item] = path.join(clientConfig.DOCKER_CERT_PATH , item + '.pem')
      })
    var dockerConfig = {
      host:  clientConfig.host || '192.168.59.103',
      port:  clientConfig.port || 2376,
      ca: fs.readFileSync(clientConfig.ca || '/Users/henry/.boot2docker/certs/boot2docker-vm/ca.pem'),
      cert: fs.readFileSync(clientConfig.cert || '/Users/henry/.boot2docker/certs/boot2docker-vm/cert.pem'),
      key: fs.readFileSync(clientConfig.key || '/Users/henry/.boot2docker/certs/boot2docker-vm/key.pem')
    };
    } catch (e) {
      io.emit('error!',JSON.stringify(e));
      console.log(e);
    }

    console.log(JSON.stringify(
      dockerConfig
      ))
  var ourDocker = new Docker(dockerConfig);

  function stopAndRemoveAll (callback) {
    ourDocker.listContainers(function (err, containers) {
      console.log(JSON.stringify(containers));
      console.log(JSON.stringify(err));
      if (containers.length == 0) callback();
      containers.forEach(function (containerInfo) {
        ourDocker.getContainer(containerInfo.Id).stop(function (err, data) {
                console.log(err);
          ourDocker.getContainer(containerInfo.Id).remove(function (err, data) {
                console.log(err);
                callback();
          });
        });
      });
    });
  }
  stopAndRemoveAll(function (){

  ourDocker.createContainer({
   Tty: true  , 
   Image: 'ubuntu', 
   Cmd: ['sh'], 
   name: (Math.random()*100000).toString(),
    'OpenStdin': true,
  }, function(err, container) {

    console.log(err);
    console.log(JSON.stringify(container));
    container.attach({stream: true, stdout: true, stderr: true, stdin:true}, function (err, stream) {
      stream.pipe(process.stdout);
      var isRaw = process.isRaw;
      process.stdin.resume();
      process.stdin.setRawMode(true);
      //process.stdin.pipe(stream);

      stream.on('data', function (chunk) {
        io.emit('docker-print', chunk.toString());
      })

        socket.on('keyboard-hit', function(content, data) {
          var character = String.fromCharCode(parseInt(content));
          stream.write(character);
        });



      process.stdin.on('data', function (chunk) {
        if ((new String(chunk)).charCodeAt(0) === 3) {
          process.exit();
        }
      })
    });
    container.start(function (err, data) {
    });

    })
  });
})