socket-server.js

"use strict";
var socketIO = require("socket.io");
var ot = require("ot");
var roomList = {};

module.exports = function(server) {
  var str = "This is markdown \n\n" + " var i = i + 1; ";

  var io = socketIO(server);
  io.on("connection", function(socket) {
    socket.on("chatMessage", function(data) {
      io.to(socket.room).emit("chatMessage", data);
    });

    socket.on("joinRoom", function(data) {
      if (!roomList[data.room]) {
        var socketIOServer = new ot.EditorSocketIOServer(
          str,
          [],
           
          function(socket, cb) {
            var self = this;
            Task.findByIdAndUpdate(
              data.room,
              { content: self.document },
              function(err) {
                if (err) return cb(false);
                cb(true);
              }
            );
          }
        );
        roomList[data.room] = socketIOServer;
      }
      roomList[data.room].addClient(socket);
      roomList[data.room].setName(socket, data.username);

      socket.room = data.room;
      socket.join(data.room); //initialising room using roomId
    });

    socket.on("disconnect", function() {
      socket.leave(socket.room);
    });
  });
};