// Dependencies const express = require('express'); const http = require('http'); const socketIO = require('socket.io'); const app = express(); const server = http.Server(app); const io = socketIO(server); const CronJob = require('cron').CronJob; var activeGames = {}; // cron job for periodically clearing finished games const job = new CronJob('0 0 */2 * * *', function() { console.log(activeGames); for (const key in activeGames) { if (activeGames.hasOwnProperty(key) && activeGames[key].state === "ended") { delete activeGames[key]; } } console.log("Games pruned at: " + (new Date().toDateString()) + " " + (new Date()).toTimeString()); }); console.log("cron job created"); job.start(); app.set('port', 5000); app.use('/static', express.static(__dirname + '/static')); // Routing app.use('/assets', express.static(__dirname + '/assets')); // Routing app.get('/', function(request, response) { response.sendFile(__dirname + '/views/index.html'); }); app.get('/learn', function(request, response) { response.sendFile(__dirname + '/views/learn.html'); }); app.get('/create', function(request, response) { response.sendFile(__dirname + '/views/create_game.html'); }); app.get('/join', function(request, response) { response.sendFile(__dirname + '/views/join_game.html'); }); app.get('/:code', function(request, response) { response.sendFile(__dirname + '/views/game.html'); }); // Starts the server. server.listen(process.env.PORT || 5000, function() { console.log('Starting server on port 5000'); }); function teamWon(game) { let wolvesAlive = 0; let villagersAlive = 0; let hunterAlive = false; for (const player of game.players) { if (player.card.team === "good" && !player.dead) { villagersAlive++; } if (player.card.role === "Werewolf" && !player.dead) { wolvesAlive++; } if (player.card.role === "Hunter" && !player.dead) { hunterAlive = true; } } console.log("wolves: " + wolvesAlive + " villagers: " + villagersAlive); if (wolvesAlive === 0) { return "village" } if ((wolvesAlive === villagersAlive) && (wolvesAlive + villagersAlive !== 2)) { return "wolf"; } if (wolvesAlive + villagersAlive === 2) { return hunterAlive ? "village" : "wolf" } return false; } // Add the WebSocket handlers io.on('connection', function(socket) { socket.on('newGame', function(game, onSuccess) { activeGames[game.accessCode] = game; onSuccess(); }); socket.on('joinGame', function(playerInfo) { const game = activeGames[Object.keys(activeGames).find((key) => key === playerInfo.code)]; if (game && game.players.length < game.size) { activeGames[Object.keys(activeGames).find((key) => key === playerInfo.code)].players.push({name: playerInfo.name, id: playerInfo.id}); socket.emit('success'); } else { if (game && game.players.length === game.size) { socket.emit("joinError", "This game is full - sorry!") } else { socket.emit("joinError", "No game found"); } } }); // broadcast current game state to all sockets in the room with a particular access code socket.on('requestState', function(data) { if(Object.keys(socket.rooms).includes(data.code) === false) { socket.join(data.code, function() { io.to(data.code).emit('state', activeGames[Object.keys(activeGames).find((key) => key === data.code)]); }); } else { io.to(data.code).emit('state', activeGames[Object.keys(activeGames).find((key) => key === data.code)]); } }); socket.on('startGame', function(gameData) { let game = activeGames[Object.keys(activeGames).find((key) => key === gameData.code)]; game.state = "started"; game.players = gameData.players; if (game.time) { let d = new Date(); d.setMinutes(d.getMinutes() + parseInt(game.time)); game.endTime = d.toJSON(); } io.to(gameData.code).emit('state', game); }); socket.on('pauseGame', function(code) { let game = activeGames[Object.keys(activeGames).find((key) => key === code)]; game.pauseTime = (new Date()).toJSON(); game.paused = true; io.to(code).emit('state', game); }); socket.on('resumeGame', function(code) { let game = activeGames[Object.keys(activeGames).find((key) => key === code)]; game.paused = false; let newTime = new Date(game.endTime).getTime() + (new Date().getTime() - new Date(game.pauseTime).getTime()); let newDate = new Date(game.endTime); newDate.setTime(newTime); game.endTime = newDate.toJSON(); io.to(code).emit('state', game); }); socket.on("timerExpired", function(code) { let game = activeGames[Object.keys(activeGames).find((key) => key === code)]; game.winningTeam = "wolf"; game.state = "ended"; io.to(code).emit('state', game); }); socket.on('killPlayer', function(id, code) { let game = activeGames[Object.keys(activeGames).find((key) => key === code)]; let player = game.players.find((player) => player.id === id); game.players.find((player) => player.id === id).dead = true; game.message = player.name + ", a " + player.card.role + ", has been killed!"; const winCheck = teamWon(game); if (winCheck === "wolf") { game.winningTeam = "wolf"; game.state = "ended"; io.to(code).emit('state', game); } else if (winCheck === "village") { game.winningTeam = "village"; game.state = "ended"; io.to(code).emit('state', game); } else { io.to(code).emit('state', game); } }); });