index.js

var express = require("express");
var app = express();
var http = require("http");
var https = require("https");
var fs = require("fs");
var path = require("path");
var numClients = 0;

var usernames = [];
var data = { rooms: [] };
var sockets = {};
var ids = {};

var server = http.createServer(app);
fs.exists = fs.exists || require("path").exists;

//app.listen(8080);
app.root = __dirname;

server.listen(8080);

app.use("/", express.static(__dirname + "/app"));
app.get("/", function (req, res) {
  console.log("Req ", req);
  res.sendFile("/app/index.html", { root: __dirname });
});

app.get("/dailystatstest", function (req, res) {
  res.sendFile("/index.html", { root: __dirname + "/app" });
});

var io = null;
if (process.env.SSL == "true") {
  console.log("IO created with SSL");
  var options = {
    key: fs.readFileSync("ssl/server.key"),
    cert: fs.readFileSync("ssl/server.crt"),
    ca: fs.readFileSync("ssl/ca.crt"),
    requestCert: true,
    rejectUnauthorized: false,
    passphrase: "v2ZIZj2jKUap",
  };
  var httpsServer = https.createServer(options, app);
  httpsServer.listen(4430);
  io = require("socket.io").listen(httpsServer);
} else {
  console.log("IO created");
  io = require("socket.io").listen(server);
}

io.sockets.on("connection", function (socket) {
  // convenience function to log server messages on the client
  function log() {
    var array = [">>> Message from server: "];
    for (var i = 0; i < arguments.length; i++) {
      array.push(arguments[i]);
    }
    socket.emit("log", array);
  }

  socket.on("signaling", function (message, to, from) {
    console.log("Got message:", message.type, to, from, io.sockets.sockets.length);
    if (io.sockets && io.sockets.sockets[ids[to]])
      io.sockets.sockets[ids[to]].emit("onSignaling", message, from, to);
  });

  socket.on("participant", function (room, userId) {
    console.log("Got participant", room, userId);
    socket.username = userId;
    socket.roomId = room;
    console.log(userId + " has connected with socketid " + socket.id);
    ids[userId] = socket.id;
    usernames.push(userId);

    log("Room " + room + " has " + numClients + " client(s)");
    log("Request to create or join room " + room);
    socket.join(room);
    if (numClients === 0) {
      socket.emit("created", room);
    } //else if (numClients >= 1) {
    //   //io.sockets.in(room).emit('newUserJoin', userId);
    //   socket.join(room);
    //   //socket.emit('newUserJoined', userId);
    // }

    io.sockets.emit("newUserJoined", userId);
    numClients++;
    socket.emit("emit(): client " + socket.id + " joined room " + room);
    socket.broadcast.emit(
      "broadcast(): client " + socket.id + " joined room " + room
    );
  });

  socket.on("disconnect", function () {
    var room = socket.roomId;
    console.log("User disconnected ", socket.username, room);
    for (var key in usernames) {
      if (usernames[key] === socket.username) {
        usernames.splice(key, 1);
        socket.leave(room);
      }
    }
    delete ids[socket.id];
    io.sockets.emit("userlist", encodeURIComponent(usernames + ""));
  });
});