added game handler

2022-05-30 10:59:33 +02:00
parent 5eea80b804
commit 7a72626f87
8 changed files with 286 additions and 211 deletions
@@ -0,0 +1,56 @@
+const RoomModel = require('../schemas/room');
+const { getPositionAfterMove } = require('../utils/functions');
+/* 
+    Function handle all requests
+    file constains functions:
+    1. roll
+    2. move
+*/
+module.exports = (io, socket) => {
+    const req = socket.request;
+    const roll = () => {
+        const rolledNumber = Math.ceil(Math.random() * 6);
+        req.session.reload(err => {
+            if (err) return socket.disconnect();
+            // Saving session data
+            req.session.rolledNumber = rolledNumber;
+            req.session.save();
+            socket.emit('game:roll', rolledNumber);
+        });
+    };
+
+    const move = ({ pawnId }) => {
+        RoomModel.findOne({ _id: req.session.roomId }, function (err, room) {
+            if (!room) return err;
+            const pawnIndex = room.pawns.findIndex(pawn => pawn._id == pawnId);
+            room.pawns[pawnIndex].position = getPositionAfterMove(req.session.rolledNumber, room.pawns[pawnIndex]);
+            const pawnsOnPos = room.pawns.filter(pawn => pawn.position == room.pawns[pawnIndex].position);
+            pawnsOnPos.forEach(pawn => {
+                if (pawn.color !== req.session.color) {
+                    const index = room.pawns.findIndex(i => i._id === pawn._id);
+                    room.pawns[index].position = room.pawns[index].basePos;
+                }
+            });
+            // Updating moving player
+            const playerIndex = room.players.findIndex(player => player.nowMoving === true);
+            const roomSize = room.players.length;
+            room.players[playerIndex].nowMoving = false;
+            if (playerIndex + 1 === roomSize) {
+                room.players[0].nowMoving = true;
+            } else {
+                room.players[playerIndex + 1].nowMoving = true;
+            }
+            // Updating timer
+            room.nextMoveTime = Date.now() + 15000;
+            // Pushing above data to database
+            RoomModel.findOneAndUpdate({ _id: req.session.roomId }, room, (err, updatedRoom) => {
+                if (!updatedRoom) return err;
+                io.to(req.session.roomId).emit('room:data', JSON.stringify(updatedRoom));
+                socket.emit('room:move');
+            });
+        });
+    };
+
+    socket.on('game:roll', roll);
+    socket.on('game:move', move);
+};