Add persistence of connection

server.mjs

@@ -11,6 +11,38 @@ const handler = app.getRequestHandler();
 
 let active_rooms = {}
 
+function findUserBySocketId(roomId, socketId){
+  let ans = null
+  active_rooms[roomId].users.forEach((player, index) => {
+    if(player.id == socketId){
+      ans = index
+    }
+  })
+  return ans
+} 
+
+function findUserByBrowserId(roomId, browserId){
+  let ans = null
+  active_rooms[roomId].users.forEach((player, index) => {
+    if(player.browserId == browserId){
+      ans = index
+    }
+  })
+  return ans
+}
+
+function removeUnusedRoom(roomId){
+  let removeRoom = true
+  active_rooms[roomId].users.forEach((player) => {
+    if(player.connected == true){
+      removeRoom = false
+    }
+  })
+  if(removeRoom){
+    delete active_rooms[roomId]
+  }
+}
+
 app.prepare().then(() => {
   const httpServer = createServer(handler);
 
@@ -22,19 +54,31 @@ app.prepare().then(() => {
     socket.on('room_connect', (params) => {
       if(!Object.keys(active_rooms).includes(params.id)){
         console.log("First person joined " + params.id + " ! " + params.name + " is owner.")
-        active_rooms[params.id] = [{id: socket.id, name: params.name, avatar: params.avatar, role: "owner", vote: ""}]
-        socket.emit("room_joined", {"room_users": active_rooms[params.id], "role": "owner"})
+        active_rooms[params.id] = { users: [{id: socket.id, name: params.name, avatar: params.avatar, browserId: params.browserId, connected: true, role: "owner", vote: ""}]}
+        socket.emit("room_joined", {"room_users": active_rooms[params.id].users, role: "owner"})
       } else {
-        socket.to(params.id).emit("new_player",{"id": socket.id, "name": params.name, avatar: params.avatar, role: "player"})
-        active_rooms[params.id].push({id: socket.id, name: params.name, avatar: params.avatar, role: "player", vote: ""})
-        socket.emit("room_joined", {"room_users": active_rooms[params.id], role: "player"})
-        console.log("New person joined " + params.id + " ! " + params.name + " is player.")
+        let userIndexByBrowserId = findUserByBrowserId(params.id, params.browserId)
+        if(userIndexByBrowserId != null) {
+          active_rooms[params.id].users[userIndexByBrowserId].connected = true
+          active_rooms[params.id].users[userIndexByBrowserId].id = socket.id
+          socket.emit("room_joined", {"room_users": active_rooms[params.id].users, role: active_rooms[params.id].users[userIndexByBrowserId].role})
+          socket.emit("start_game",{possibleChoice: active_rooms[params.id].possibleChoice, question: active_rooms[params.id].question, questionNbr: active_rooms[params.id].questionNbr, duration: 15})
+        } else {
+          socket.to(params.id).emit("new_player",{"id": socket.id, "name": params.name, avatar: params.avatar, browserId: params.browserId, connected: true, role: "player"})
+          active_rooms[params.id].users.push({id: socket.id, name: params.name, avatar: params.avatar, browserId: params.browserId, connected: true, role: "player", vote: ""})
+          socket.emit("room_joined", {"room_users": active_rooms[params.id].users, role: "player"})
+          console.log("New person joined " + params.id + " ! " + params.name + " is player.")
+        }
       }
       socket.join(params.id)
     })
 
     socket.on("start_game", (params) => {
-      socket.to(params.roomId).emit("start_game",{possibleChoice: params.possibleChoice, question: params.question, duration: params.duration})
+      active_rooms[params.roomId].question = params.question
+      active_rooms[params.roomId].questionNbr = 1
+      active_rooms[params.roomId].possibleChoice = params.possibleChoice
+      active_rooms[params.roomId].duration = params.duration
+      socket.to(params.roomId).emit("start_game",{possibleChoice: params.possibleChoice, question: params.question, questionNbr: 1, duration: params.duration})
     })
 
     socket.on("reset_game", (params) => {
@@ -42,6 +86,10 @@ app.prepare().then(() => {
     })
 
     socket.on("next_question", (params) => {
+      active_rooms[params.roomId].question = params.question
+      active_rooms[params.roomId].questionNbr += 1
+      active_rooms[params.roomId].possibleChoice = params.possibleChoice
+      active_rooms[params.roomId].duration = params.duration
       socket.to(params.roomId).emit("next_question",{possibleChoice: params.possibleChoice, question: params.question, duration: params.duration})
     })
 
@@ -49,6 +97,19 @@ app.prepare().then(() => {
       console.log(params)
       socket.to(params.roomId).emit("player_choice", {choice: params.choice, player: params.player})
     })
+
+    socket.on("disconnecting", (reason) => {
+      for (const room of socket.rooms) {
+        if (room !== socket.id) {
+          let roomUserIndex = findUserBySocketId(room, socket.id)
+          if(roomUserIndex != null){
+            active_rooms[room].users[roomUserIndex].connected = false
+            socket.to(room).emit("player_disconnected")
+            removeUnusedRoom(room)
+          }
+        }
+      }
+    })
     // ...
   });