Untitled

var connect = require('connect')
  , app = connect.createServer(connect.static(__dirname))
  , io = require('../../socket.io').listen(app);

//io.set('transports', ['xhr-polling']);
//io.set('heartbeat interval', .25);
//io.set('close timeout', .25);

io.sockets.on('connection', function (socket) {
  var messages = [];

  socket.on('print', function (msg) {
    if (messages.indexOf(msg) >= 0) {
      console.error('duplicate message', msg);
    }

    console.log('has message', msg);

    messages.push(msg);
    if (messages.length == 2) {
      socket.emit('done');
    }
  });
});

app.listen(8080);