Avonyel's Solution'

.gitignore

@@ -0,0 +1,2 @@
+node_modules/
+data-structure.txt

index.js

@@ -0,0 +1,89 @@
+const http = require("http");
+const express = require("express");
+const app = express();
+const hbs = require("express-handlebars");
+const bodyParser = require("body-parser");
+const redis = require("./lib/redisWrapper.js");
+const cookieParser = require("cookie-parser");
+const server = http.createServer(app);
+const io = require("socket.io")(server);
+const cookie = require("cookie");
+app.engine("handlebars", hbs({ defaultLayout: "main" }));
+app.set("view engine", "handlebars");
+
+app.use(cookieParser());
+app.use(bodyParser.urlencoded({ extended: false }));
+app.use(
+  "/socket.io",
+  express.static(__dirname + "/node_modules/socket.io-client/dist/")
+);
+
+app.use("/", express.static(__dirname + "/public"));
+app.use(
+  "/handlebars",
+  express.static(__dirname + "/node_modules/handlebars/dist/")
+);
+
+app.get("/", (req, res) => {
+  if (!req.cookies.user) {
+    res.render("login");
+  } else {
+  	console.log(req.cookies.user);
+    redis.getRooms(req.cookies.user).then(rooms => {
+    	console.log(rooms);
+      res.render("index", {
+        rooms: rooms,
+        user: req.cookies.user
+      });
+    });
+  }
+});
+
+app.post("/", (req, res) => {
+  let user = req.body.user;
+  redis.saveUser(user);
+  res.cookie("user", user, { httpOnly: false });
+
+  res.redirect("/");
+});
+
+app.post("/logout", (req, res) => {
+  res.clearCookie("user");
+  res.redirect("/");
+});
+
+io.on("connection", client => {
+  let cookies = client.handshake.headers.cookie;
+  let user = cookie.parse(cookies).user;
+  console.log("New connection");
+
+  client.on("newMessage", data => {
+    redis.saveMessage(data.body, data.author, data.room).then(() => {
+      io.emit("updateMessages", data);
+    });
+  });
+
+  client.on("newRoom", data => {
+    redis.saveRoom(user, data).then(() => {
+      client.emit("updateRooms", data);
+    });
+  });
+
+  client.on("showRoom", data => {
+    redis.loadRoomMessages(data, messages => {
+      let output = {
+        messages: messages,
+        room: data
+      };
+      client.emit("roomLoaded", output);
+    });
+  });
+
+  client.on("leaveRoom", room => {
+    redis.leaveRoom(user, room).then(() => {
+      client.emit("leftRoom", room);
+    });
+  });
+});
+
+server.listen(3000);

lib/redisWrapper.js

@@ -0,0 +1,74 @@
+const redisClient = require("redis").createClient();
+const shortid = require("shortid");
+
+var wrapperStuff = {
+  saveMessage: (body, author, room) => {
+    return new Promise((resolve, reject) => {
+      var messageID = "message-" + shortid.generate();
+      redisClient.lpush([room, messageID]);
+      redisClient.hmset(messageID, [
+        "body",
+        body,
+        "author",
+        author,
+        "room",
+        room
+      ]);
+      resolve(true);
+    });
+  },
+
+  loadRoomMessages: (roomName, callback) => {
+    redisClient.lrange(roomName, 0, -1, (err, messages) => {
+      messages = messages.map(message => {
+        let p = new Promise((resolve, reject) => {
+          redisClient.hgetall(message, (err, obj) => {
+            let newObj = {
+              body: obj.body,
+              author: obj.author,
+              room: obj.room
+            };
+
+            resolve(newObj);
+          });
+        });
+        return p;
+      });
+
+      Promise.all(messages).then(resolvedMessages => {
+        callback(resolvedMessages);
+      });
+    });
+  },
+
+  saveUser: user => {
+    redisClient.hsetnx("users", user, user);
+    redisClient.hsetnx(`user-${user}`, "main-room", "main-room");
+  },
+
+  saveRoom: (user, roomName) => {
+    return new Promise((resolve, reject) => {
+      redisClient.lpush(["rooms", roomName]);
+      redisClient.hsetnx(`user-${user}`, roomName, roomName);
+      resolve();
+    });
+  },
+
+  leaveRoom: (user, roomName) => {
+    return new Promise((resolve, reject) => {
+      redisClient.hdel(`user-${user}`, roomName);
+      resolve();
+    });
+  },
+
+  getRooms: user => {
+    return new Promise((resolve, reject) => {
+      redisClient.hgetall(`user-${user}`, (err, rooms) => {
+        console.log(rooms);
+        resolve(rooms);
+      });
+    });
+  }
+};
+
+module.exports = wrapperStuff;

package.json

@@ -0,0 +1,31 @@
+{
+  "name": "project_superchat",
+  "version": "1.0.0",
+  "description": "Super Simple Chat Client",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/Avonyel/project_superchat.git"
+  },
+  "author": "Stephanie and Greg",
+  "license": "ISC",
+  "bugs": {
+    "url": "https://github.com/Avonyel/project_superchat/issues"
+  },
+  "homepage": "https://github.com/Avonyel/project_superchat#readme",
+  "dependencies": {
+    "body-parser": "^1.17.2",
+    "cookie": "^0.3.1",
+    "cookie-parser": "^1.4.3",
+    "express": "^4.15.3",
+    "express-handlebars": "^3.0.0",
+    "handlebars": "^4.0.10",
+    "redis": "^2.7.1",
+    "shortid": "^2.2.8",
+    "socket.io": "^2.0.3",
+    "socket.io-client": "^2.0.3"
+  }
+}

public/javascripts/message_form_compiled.js

@@ -0,0 +1,102 @@
+(function() {
+  var template = Handlebars.template,
+    templates = (Handlebars.templates = Handlebars.templates || {});
+  templates["message_form_compiled.js"] = template({
+    compiler: [7, ">= 4.0.0"],
+    main: function(container, depth0, helpers, partials, data) {
+      return "";
+    },
+    useData: true
+  });
+  templates["message_form"] = template({
+    "1": function(container, depth0, helpers, partials, data, blockParams) {
+      var stack1,
+        alias1 = container.lambda,
+        alias2 = container.escapeExpression;
+
+      return (
+        '    <div class="message row">\r\n      <div class="col-xs-12">\r\n        <p>\r\n        <span class="author">' +
+        alias2(
+          alias1(
+            (stack1 = blockParams[0][0]) != null ? stack1.author : stack1,
+            depth0
+          )
+        ) +
+        ": </span>\r\n          " +
+        alias2(
+          alias1(
+            (stack1 = blockParams[0][0]) != null ? stack1.body : stack1,
+            depth0
+          )
+        ) +
+        "\r\n        </p>\r\n      </div>\r\n    </div>\r\n"
+      );
+    },
+    compiler: [7, ">= 4.0.0"],
+    main: function(container, depth0, helpers, partials, data, blockParams) {
+      var stack1,
+        helper,
+        alias1 = depth0 != null ? depth0 : container.nullContext || {},
+        alias2 = helpers.helperMissing,
+        alias3 = "function",
+        alias4 = container.escapeExpression;
+
+      return (
+        '<div class="form form-group">\r\n  <form class="messageForm" id="' +
+        alias4(
+          (
+            (helper =
+              (helper =
+                helpers.room || (depth0 != null ? depth0.room : depth0)) != null
+                ? helper
+                : alias2),
+            typeof helper === alias3
+              ? helper.call(alias1, {
+                  name: "room",
+                  hash: {},
+                  data: data,
+                  blockParams: blockParams
+                })
+              : helper
+          )
+        ) +
+        '">\r\n    <div class="form-group">\r\n      <input type="text" name="message" class="form-control"/>\r\n    </div>\r\n    <button class="btn btn-default">Send Message</button>\r\n  </form>\r\n</div>\r\n\r\n<div id="messages' +
+        alias4(
+          (
+            (helper =
+              (helper =
+                helpers.room || (depth0 != null ? depth0.room : depth0)) != null
+                ? helper
+                : alias2),
+            typeof helper === alias3
+              ? helper.call(alias1, {
+                  name: "room",
+                  hash: {},
+                  data: data,
+                  blockParams: blockParams
+                })
+              : helper
+          )
+        ) +
+        '" class="container scrolling">\r\n' +
+        ((stack1 = helpers.each.call(
+          alias1,
+          depth0 != null ? depth0.messages : depth0,
+          {
+            name: "each",
+            hash: {},
+            fn: container.program(1, data, 1, blockParams),
+            inverse: container.noop,
+            data: data,
+            blockParams: blockParams
+          }
+        )) != null
+          ? stack1
+          : "") +
+        "</div>\r\n"
+      );
+    },
+    useData: true,
+    useBlockParams: true
+  });
+})();

public/javascripts/script.js

@@ -0,0 +1,88 @@
+var socket = io.connect("http://localhost:3000");
+
+let formHandler = function() {
+  $(".messageForm").on("submit", e => {
+    e.preventDefault();
+    var data = {};
+    data.body = $("input[name='message']").val();
+    $("input").val("");
+    data.author = document.cookie.replace(
+      /(?:(?:^|.*;\s*)user\s*\=\s*([^;]*).*$)|^.*$/,
+      "$1"
+    );
+    data.author = data.author.replace("%20", " ");
+    data.room = $(".messageForm").attr("id");
+    socket.emit("newMessage", data);
+  });
+};
+
+let onLeaveRoom = function() {
+  $(".leaveRoom").on("click", function(e) {
+    e.stopPropagation();
+    let roomName = $(this).parent().parent().attr("id");
+    socket.emit("leaveRoom", roomName);
+  });
+};
+
+$(document).ready(function() {
+  // Emit events
+
+  $("#create-room").on("submit", e => {
+    e.preventDefault();
+    let data = $("#create-room-form").val();
+    $("#create-room-form").val("");
+    socket.emit("newRoom", data);
+  });
+
+  $("#rooms").on("click", ".room", e => {
+    let $target = $(e.target);
+    let roomName = $target.parent().attr("id");
+    socket.emit("showRoom", roomName);
+  });
+
+  // Listen for events
+
+  socket.on("updateMessages", data => {
+    $(`#messages${data.room}`).prepend(
+      $(`<div class='message row'>
+          <div class='col-xs-12'>
+            <p><span class="author">${data.author}: </span>${data.body}</p>
+          </div>
+        </div>`)
+    );
+    if ($(`#messages${data.room}`).length === 0) {
+      $(`#newMessage${data.room}`).text("new");
+    }
+  });
+
+  socket.on("updateRooms", data => {
+    $("#rooms").prepend(
+      $(`<div class='room' id="${data}">
+          <h3>
+            <span class="leaveRoom">X</span>
+            ${data} 
+            <span id="newMessage${data}" class="label label-danger"></span>
+          </h3>
+        </div>`)
+    );
+
+    onLeaveRoom();
+  });
+
+  socket.on("roomLoaded", output => {
+    let messageFormHBS = Handlebars.templates["message_form"](output);
+    $(".active").removeClass("active");
+    $(`div#${output.room}`).addClass("active");
+    $messages = $("#messageContainer");
+    $messages.empty().append(messageFormHBS).addClass("panel-body");
+    $messages.parent().addClass("panel panel-default");
+    $(`#${output.room} span.label`).text("");
+    formHandler();
+  });
+
+  socket.on("leftRoom", room => {
+    $(`#${room}`).remove();
+  });
+
+  onLeaveRoom();
+});