index.js

// express stuffs
const express = require("express");
const app = express();

// server stuffs
const http = require("http");
const server = http.createServer(app);
const port = process.env.PORT || 3000;

// io stuffs
const socketio = require("socket.io");
const io = socketio(server);

// util stuffs
const path = require("path");
const moment = require("moment");
var bodyParser = require('body-parser');
app.use(bodyParser.json()); // support json encoded bodies
app.use(bodyParser.urlencoded({ extended: true })); // support encoded bodies

app.get("/time/:time", (req, res)=>{
    maxTime = req.params.time;
    res.send(`Maximum time set to ${maxTime}`);
});

app.get("/roles/", (req, res)=>{
    rolesURL = req.query.names.split(';');
    roles = rolesURL;
    let result = "Roles set to ";
    roles.forEach((role)=>{result+=role + " "});
    res.send(result);
});

class User{
    constructor(username, password, role, status){
        this.id = -1;
        this.username = username;
        this.password = password;
        this.role = role;
        this.status = status;
        this.vote = 0;
        this.werewolfVote = 0;
        this.protected = false;
    }
}

// const users = [new User("Murat", "12345", "Villager", 1),
//                 new User("Ahmet", "6789", "Werewolf", 1),
//                 new User("Mehmet", "asdasd", "Doctor", 1),
//                 new User("Kardelen", "asdasd", "Werewolf", 1),
//                 new User("Musa", "asdasd", "Werewolf", 1),
//                 new User("Alper", "asdasd", "Villager", 1),
//                 new User("Can", "asdasd", "Villager", 1)];

let users = [];
let usersChat = {All:[], Werewolf:[]};
let readyGame = false;
let time = 0;
let status = "Day";
let rolesURL;
let roles = ["Villager","Doctor","Veteran","Villager","Werewolf","Werewolf","Werewolf", "Lookout"];
let gameFinished = false;
let winner = "";
let gameLoop;
let maxTime = 10;

io.on("connection",(socket)=>{
    //console.log("Someone connected with id:" + socket.id );
    socket.on("userJoined",(newUserSocket)=>{
        if(readyGame){
            //socket.emit("error","You cannot join, game is already started.");
        }else{
            //console.log("User joined");
            let existingUser = undefined;
            users.forEach((user)=>{
               if(user.username === newUserSocket.player.username)
                existingUser = user;
            });
            if(existingUser == undefined){
                newUserSocket.player.id = socket.id;
                newUserSocket.player.role = randomRole();
                users.push(newUserSocket.player);
                io.emit("current_users", {users});
                socket.emit("role_change", newUserSocket.player.role);
            }else{
                socket.id = newUserSocket.player.id;
            }
            // MESSAGE CHAT
            //get user and send it to room
            //socket.join(newUserSocket.player.role);
            socket.join("All");
            //console.log(newUserSocket.player.role);
            //console.log(newUserSocket.player.role == "Werewolf");
            if(newUserSocket.player.role == "Werewolf"){
                socket.join("Werewolf");
                usersChat.Werewolf.push(newUserSocket.player.username);
                io.to("Werewolf").emit("users", usersChat.Werewolf);
            }
            usersChat.All.push(newUserSocket.player.username);
            io.to("All").emit("users", usersChat.All);

            socket.emit("messageD", createMessage("Server", `Welcome to chat room ${newUserSocket.player.username}.`, 0));
            socket.on("messageD", (socket3)=>{
                io.to("All").emit("messageD", createMessage(socket3.username, socket3.message,1));
            });
            socket.on("messageN", (socket3)=>{
                //console.log(`Gece mesaji ${socket3.username} mesaj: ${socket3.message}`);
                //console.log(usersChat);
                io.to("Werewolf").emit("messageN", createMessage(socket3.username, socket3.message,1));
            });
            socket.on("messageS", (socket3)=>{
                if(socket3.type == 0){
                    // system to everyone
                    io.to("All").emit("messageD", createMessage("System", socket3.message, 1));
                }else if(socket3.type == 1){
                    // system to socket3.to
                    if(socket3.to == "Werewolf"){
                        io.to("Werewolf").emit("messageD", createMessage("System", socket3.message, 1));
                    }else if(socket3.to == "Villager"){
                        io.to("All").emit("messageD", createMessage("System", socket3.message, 1));
                    }else{
                        // to a person
                        socket.emit("messageD", createMessage("System", socket3.message, 1));
                    }
                    
                }
            });
            //socket.broadcast.to(newUserSocket.player.role).emit("message", createMessage("Server", `${newUserSocket.player.username} joined chat!`, 0));
            socket.on("disconnect", (socket4)=>{
            if(newUserSocket.player.role == "Werewolf"){
                usersChat.Werewolf = usersChat.Werewolf.filter(item => item !== newUserSocket.player.username);
                io.to("Werewolf").emit("users", usersChat.Werewolf);
            }else{
                usersChat.All = usersChat.All.filter(item => item !== newUserSocket.player.username);
                io.to("All").emit("users", usersChat.All);
            }
            });


            // CHAT END

        }
        //console.log(readyGame); 
    });

    socket.on("userReady",(readyUserSocket)=>{
        users.forEach((user)=>{
            if(user.username == readyUserSocket.player.username){
                //console.log(`User ${user.username} status changed to ${readyUserSocket.player.status}`);
                user.status = readyUserSocket.player.status;
            }
        });
        let isOk = true;
        users.forEach((user)=>{
            //console.log(`User ${user.username} status is  ${user.status}`);
            if(user.status == 0){
                isOk = false;
            }
        });
        if(isOk) readyGame = true; else readyGame = false;
        if(readyGame){
            gameLoop = setInterval(()=>{
                if(time == "0"){
                    if(status == "Day"){
                        status = "Vote";
                    }else if(status == "Vote"){
                        killMostVoted();
                        status = "Night";
                    }else if(status == "Night"){
                        killMostVoted();
                        status = "Day";
                    }
                    time = maxTime;
                }else{
                    time = time - 1;
                }

                //console.log(`Time:${time}`);
                //console.log(`Status:${status}`);
                io.emit("updateGame", {time, status});
            },1000);
        }
        io.emit("gameStarted", readyGame);
        //console.log(readyGame);
    });

    socket.on("finishGameS",()=>{
        console.log("game finished");
        users = [];
        usersChat = {All:[], Werewolf:[]};
        readyGame = false;
        time = 0;
        status = "Day";
        if(rolesURL == undefined)
            roles = ["Villager","Doctor","Veteran","Villager","Werewolf","Werewolf","Werewolf", "Lookout"];
        else   
            roles = rolesURL;
        gameFinished = false;
        winner = "";
        clearInterval(gameLoop);
    })

    socket.on("vote_update_user",(afterVoteSocket)=>{
        newUser = afterVoteSocket.user;
        users.forEach((user)=>{
            if(user.username == newUser.username){
                user.vote = newUser.vote;
                user.werewolfVote = newUser.werewolfVote;
            }
        });
        io.emit("current_users", {users});
    });

    socket.on("doctor_update_user",(afterVoteSocket)=>{
        newUser = afterVoteSocket.user;
        users.forEach((user)=>{
            if(user.username == newUser.username){
                user.protected = newUser.protected;
                if(user.role == "Veteran")
                    youDied = true;
            }
        });
        if(youDied){
            let killedUser = afterVoteSocket.player;
            let selectedUserId;
            users.forEach((user, index)=>{
                if(user.username == killedUser.username)
                    selectedUserId = index;
            });
            users.splice(selectedUserId, 1);
            voteClear();
            io.emit("after_killed_users", {users,killedUser, type:0});
        }else{
            io.emit("current_users", {users});
        }
    });

    socket.on("veteran_update_user",(afterVoteSocket)=>{
        newUser = afterVoteSocket.player;
        users.forEach((user)=>{
            if(user.username == newUser.username){
                user.protected = newUser.protected;
            }
        });
        io.emit("current_users", {users});
    });

    socket.on("lookout_update_user",(afterVoteSocket)=>{
        newUser = afterVoteSocket.user;
        let selectedRole;
        let youDied = false;
        users.forEach((user)=>{
            if(user.username == newUser.username){
                selectedRole = user.role;
                if(user.role == "Veteran")
                    youDied = true;
            }
        });
        if(youDied){
            let killedUser = afterVoteSocket.player;
            let selectedUserId;
            users.forEach((user, index)=>{
                if(user.username == killedUser.username)
                    selectedUserId = index;
            });
            users.splice(selectedUserId, 1);
            voteClear();
            io.emit("after_killed_users", {users,killedUser, type:0});
        }else{
            socket.emit("messageD", createMessage("System", "The role of "+newUser.username + " is " + selectedRole, 1));
            io.emit("current_users", {users});
        }
    });
    

    socket.on("disconnect",(exitedUser)=>{
        users.forEach((value, index)=>{
            if(value.id == socket.id){
                users.splice(index, 1);
            }
        });
        //console.log(users);
        io.emit("current_users", {users});
    });
});

app.use(express.static(path.join(__dirname, "public")));
server.listen(port, ()=> console.log("Server established on port " + port));


function voteClear(){
    users.forEach((user)=>{
        user.werewolfVote = 0;
        user.vote = 0;
        user.protected = false;
    });
}

function killMostVoted() {
    let max = 0;
    let selectedUserId;
    if(status == "Vote"){
        users.forEach((user, index) => {
            if(max < user.vote){
                selectedUserId = index;
                max = user.vote;
            }else if(max = user.vote){
                selectedUserId = undefined;
                max = user.vote;
            }
        });
        if(selectedUserId != undefined){
            //document.querySelector("button#"+users[selectedUserId].username).remove();
            //if(player.username == users[selectedUserId]){
            //    userKilled = true;
            //}
            //console.log(`User ${users[selectedUserId].username} killed with votes`);
            let killedUser = users[selectedUserId];
            users.splice(selectedUserId, 1);
            voteClear();
            io.emit("after_killed_users", {users,killedUser, type:1});
        }else{
            voteClear();
            io.to("All").emit("messageD", createMessage("System", "No one hanged because of equality", 1));
            io.emit("current_users",{users});
        }
    }else if(status == "Night"){
        //console.log(users);
        users.forEach((user, index) => {
            if(max < user.werewolfVote){
                selectedUserId = index;
                max = user.werewolfVote;
            }else if(max = user.werewolfVote){
                selectedUserId = undefined;
                max = user.werewolfVote;
            }
        });
        //console.log(selectedUserId);
        if(selectedUserId != undefined){
            if(!users[selectedUserId].protected){
                // document.querySelector("button#"+users[selectedUserId].username).remove();
                // if(player.username == users[selectedUserId]){
                //     killUser();
                // }
                let killedUser = users[selectedUserId];
                users.splice(selectedUserId, 1);
                // console.log("AFTER DEATH USERS");
                voteClear();
                io.emit("after_killed_users", {users,killedUser, type:0});
            }else{
                if(users[selectedUserId].role == "Veteran"){
                    users.forEach((user, index)=>{
                        if(user.role == "Werewolf")
                            selectedUserId = index;
                    });
                    if(selectedUserId != undefined){
                        let killedUser = users[selectedUserId];
                        users.splice(selectedUserId, 1);
                        // console.log("AFTER DEATH USERS");
                        voteClear();
                        io.emit("after_killed_users", {users,killedUser, type:0});
                    }else{
                        voteClear();
                        io.to("All").emit("messageD", createMessage("System", "There is no death, interesting...", 1));
                        io.emit("current_users",{users});
                    }
                }else{
                    voteClear();
                    io.to("All").emit("messageD", createMessage("System", "There is no death, interesting...", 1));
                    io.emit("current_users",{users});
                }
            }
        }else{
            voteClear();
            io.to("All").emit("messageD", createMessage("System", "There is no death, interesting...", 1));
            io.emit("current_users",{users});
        }
    }

    // check win after every kill attempt
    let villageWin = true;
    let werewolfWin = true;
    users.forEach((user) =>{
        if(user.role == "Villager" || user.role == "Doctor" || user.role == "Lookout"){
            werewolfWin = false;
        }else if(user.role == "Werewolf"){
            villageWin = false;
        }
    });
    //console.log(villageWin);
    //console.log(werewolfWin);
    if(villageWin && !werewolfWin){
        gameFinished = true;
        winner = "Villager";
        io.emit("finishGame", winner);
        clearInterval(gameLoop);
    }else if(!villageWin && werewolfWin){
        gameFinished = true;
        winner = "Werewolf";
        io.emit("finishGame", winner);
    }else{
        gameFinished = false;
    }
}

function randomRole(){
    let randomIndex = Math.floor(Math.random() * roles.length);
    let randomString = roles[randomIndex];
    roles.splice(randomIndex, 1);
    //console.log(roles);
    return randomString;
}


/////////// CHAT //////////////

function createMessage(username, message, type){
    return {username:username,
            message: message,
            date: moment().format("LT"),
            type: type};
}