groups

server.js

@@ -8,7 +8,7 @@ const app = express();
 
 const http = require('http').Server(app);
 const io = require('socket.io')(http);
-const {Messages} = require('./models/');
+const { Messages, Room } = require('./models/');
 
 
 const sequelize = require('./config/connection');
@@ -55,7 +55,7 @@ io.on("connection", function (socket) {
   console.log(`User connected to server.`);
 
 
-  socket.on("createUser", function (username) {
+  socket.on("createUser", async function (username) {
     socket.username = username;
     usernames[username] = username;
     socket.currentRoom = "global";
@@ -68,18 +68,24 @@ io.on("connection", function (socket) {
       .to("global")
       .emit("updateChat", "INFO", username + " has joined global room");
     io.sockets.emit("updateUsers", usernames);
+
+
+    const updatedRooms = await Room.findAll({ raw: true });
+
     socket.emit("updateRooms", rooms, "global");
   });
 
   socket.on("sendMessage", function (data) {
     io.sockets.to(socket.currentRoom).emit("updateChat", socket.username, data);
   });
 
-  socket.on("createRoom", function (room) {
+  socket.on("createRoom", async function (room) {
     if (room != null) {
-      rooms.push({ name: room, creator: socket.username });
-      // run Room.create({ name: room, creator: socket.username })
-      io.sockets.emit("updateRooms", rooms, null);
+      rooms.push({ name: room, description: socket.username });
+      await Room.create({ name: room, description: socket.username })
+      const updatedRooms = await Room.findAll({ raw: true });
+
+      io.sockets.emit("updateRooms", updatedRooms, null);
     }
   });