Chatroulette-style messenger

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');

var routes = require('./routes/index');
var users = require('./routes/users');

var app = express();
var server = require('http').Server(app);
var io = require('socket.io')(server);


// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'hbs');

// uncomment after placing your favicon in /public
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
app.use(function(req, res, next){
  res.io = io;
  next();
});
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, '/public')));

app.use('/', routes);
app.use('/users', users);

// catch 404 and forward to error handler
app.use(function(req, res, next) {
  var err = new Error('Not Found');
  err.status = 404;
  next(err);
});

// error handlers

// development error handler
// will print stacktrace
if (app.get('env') === 'development') {
  app.use(function(err, req, res, next) {
    res.status(err.status || 500);
    res.render('error', {
      message: err.message,
      error: err
    });
  });
}


var rooms = {} //rooms by socket1.id+socket2.id
var queue = {}; //CHANGE TO OBJECT STYLE OF ALL USERS
var allUsers = {}; //contains sockets, key is socket.id
var peerId;


function isEmpty(obj) {
    return Object.keys(obj).length === 0;
}
var findPartnerSocket = function(socket){
  var client =allUsers[socket.id]
  var peer;
  if(socket.verified && !isEmpty(queue)){
    console.log("inside queue~~~~   ", queue)
      var match = false;
      for(id in queue){
        peer = queue[id]
        if(peer.topic === client.topic){
          match = true
          break
        }
      }
    if(match === false){
      console.log("no match found, pushing ", socket.id, " to queue");
      queue[socket.id] = socket;
      socket.emit("waitingForPartner", "Waiting for another partner. One moment please")
    }
    else{ //if there is a match, do this
      var peer = allUsers[peer.id];
      console.log("matching two lonely sockets, the peerId is... ", peer.id)
      delete queue[peer.id]; 
      var roomId = socket.id+"&"+peer.id;
      peer.join(roomId);
      socket.join(roomId);
      console.log("socketID "+socket.id+" and peer " + peer.id, " joined roomId number ", roomId)
      allUsers[socket.id].roomId = roomId;
      allUsers[peer.id].roomId = roomId;
      socket.broadcast.to(roomId).emit('message', {"message": "Welcome! You've chosen to discuss "+ socket.topic + " with "+ peer.name +". Don't be shy!"})
      socket.emit("chatStart", {'peerName': peer.name, 'roomId': roomId})
      peer.emit("chatStart", {'peerName': allUsers[socket.id].name, 'roomId': roomId})
    }
  }
  else{ //if queue is empty do this
    console.log("pushing socket " + socket.id, " to queue")
    socket.emit("waitingForPartner", "Waiting for another person to join. One moment please")
    queue[socket.id] = socket
  }
}
io.on('connection', function (socket) {
  console.log("connected to socket ", socket.id)
  
  socket.on('join', function(data){
    console.log("new user joined")
    this.name = data.name;
    this.topic = data.topic;
    if(data.studentId.indexOf(process.env.CUHK_ID)){
      this.verified = true
    }
    else{
      socket.emit("verificationFailed")
      return;
    }
    allUsers[this.id] = socket;
    findPartnerSocket(socket);
  })

  socket.emit('greeting', "Hello from Ventbox", socket.id) // only SENDS TO INDIVIDUAL NOT THE ROOM

  socket.on('message', function(msgObj){
    console.log("Server side message")
    var roomId = allUsers[socket.id].roomId;
    socket.broadcast.to(roomId).emit('message', {"message": msgObj.message, "senderId": msgObj.id });
  });

  socket.on('leaveRoom', function(){
        var roomId = socket.roomId;
        socket.broadcast.to(roomId).emit("chatEnd");
        var peerID = roomId.split('&');
        peerID = peerID[0] === socket.id ? peerID[1] : peerID[0];
        findPartnerSocket(allUsers[peerID]);
        findPartnerSocket(socket);
  });
  socket.on('disconnect', function(){
      if(!socket.roomId){
        return false;
      }
      var roomId = socket.roomId;
      console.log("ROOM ID", roomId);//
      socket.broadcast.to(roomId).emit("chatEnd", "Chat has ended, finding you a new partner...");
      var peerID = roomId.split('&');
      peerID = peerID[0] === socket.id ? peerID[1] : peerID[0];
      findPartnerSocket(allUsers[peerID]);
  });
});

app.use(function(err, req, res, next) {
  res.status(err.status || 500);
  res.render('error', {
    message: err.message,
    error: {}
  });
});



module.exports = {app: app, server: server};