socketserver.js

const {waitFor} = require('./helper');
const Room = require('./room');
const Dice = require('./dice');

class SocketServer{
    constructor(socket,io,server){
        this.socket = socket;
        this.io = io;
        this.server = server;
        this.curRoom;
        this.playerIndex = -1;
        this.player;
        this.playerRole;
        this.addSocket = this.addSocket.bind(this);
        this.endTurn = this.endTurn.bind(this);
        this.roll = this.roll.bind(this);
        this.reroll = this.reroll.bind(this);
        this.sendMessage = this.sendMessage.bind(this);
        this.disconnect = this.disconnect.bind(this);

        this.socket.on('addSocket',this.addSocket);
        this.socket.on('endTurn', this.endTurn);
        this.socket.on('roll', this.roll);
        this.socket.on('reroll', this.reroll);
        this.socket.on('sendMessage', this.sendMessage);
        this.socket.on('disconnect', this.disconnect);

        waitFor(() => this.curRoom && this.curRoom.started).then(()=>{
          this.setupAllConnected();
        });

    }

    //Adds a socket to the room
    addSocket(roomName){
        this.curRoom = this.server.rooms.find(x => x.name === roomName);
        this.socket.join(this.curRoom.name);
    
        for (let i in this.curRoom.connections){
          if (this.curRoom.connections[i] === null){
            this.playerIndex = parseInt(i);
            break;
          }
        }
        if (this.playerIndex === -1) return
        this.curRoom.connections[this.playerIndex] = this.socket;
        if (this.curRoom.allPlayersConnected()){
          this.curRoom.start();
          console.log(this.curRoom.name+": "+"a játék elindult");
          
        }
        this.io.to(this.curRoom.name).emit('updatePlayerNumber',this.curRoom.playerLimit,this.curRoom.playerLimit-this.curRoom.playersLeft);

      }

      //Sets the player's data, then sends it to the client-side
    setupAllConnected(){
      this.player = this.curRoom.players[this.playerIndex];
      this.player.index = this.playerIndex;
      this.playerRole = this.curRoom.roles[this.playerIndex];
      this.io.to(this.curRoom.name).emit('updateChat',this.curRoom.chat);
      this.socket.emit('playersDataSetup',this.curRoom.players,this.playerIndex,this.playerRole,this.curRoom.arrowsLeft);
    }
    
    //Checks if the player's health reached 0, and removes them from the game if yes.
    checkIfKilled(player){
      if (player.life<=0){
        if (!player.killed){
          player.killed = true;
          this.curRoom.chat.push(player.name+" meghalt.");
          this.curRoom.arrowsLeft += player.arrows;
          player.arrows = 0;
          player.life = 0;
          player.role = this.curRoom.roles[player.index];
  
          //Checks if the killed player is the current one
          if (player.name==this.player.name){
            this.endTurn([]);
          }
          this.io.to(this.curRoom.name).emit('playersDataRefresh',this.curRoom.players, this.curRoom.arrowsLeft, this.curRoom.chat);
        }
      }
    }
    //Checks if there is a winner, and ends the game if so
    checkForWinner(){
      let winner = this.curRoom.checkWinConditions(this.curRoom.playerLimit)
      if (winner){
        console.log(this.curRoom.name+": a nyertes: "+winner)
        this.io.to(this.curRoom.name).emit('gameEnd', winner);
        this.server.rooms.splice(this.server.rooms.indexOf(this.curRoom), 1);
      }
    }

    //Handles the ending of turns, performs the actions on the dices
    endTurn(selections){
  
      //Ending turn
      if (this.player.curTurn){
          console.log(this.curRoom.name+": "+this.player.name+" körének vége!");

          if (!this.player.killed){
            //Resolving the dices
        
            //Character check: suzy lafayette
            if (this.player.character.name === 'suzy_lafayette' && selections.filter(x => x.type === 2 || x.type === 3).length === 0){
              if (this.player.life<this.player.startingLife-2){
                this.player.life+=2;
              } else if (this.player.life===this.player.startingLife-1){
                this.player.life++;
              }
            }
            //Character check: el gringo 
            if (selections.some(x => (x.type === 2 || x.type === 3) && this.curRoom.players[x.selection].character.name === 'el_gringo')){
                this.addArrows(this.player,1);
                this.curRoom.chat.push(this.player.name+' kapott egy nyilat.');
            }
        
            for (let s of selections){
              if (s != null){
                let dice_type = s.type;
                let selectedPlayer = this.curRoom.players[s.selection];
                if (dice_type === 2 || dice_type === 3){
                  selectedPlayer.life--;
                  this.curRoom.chat.push(selectedPlayer.name + ' kapott egy lövést: '+ '<img class="smallDices" src="'+s.image+'">');
                } else if (dice_type === 4 && selectedPlayer.life < selectedPlayer.startingLife){
                  //Character check: jesse jones
                  if (selectedPlayer.character.name === 'jesse_jones' && selectedPlayer === this.player && selectedPlayer.life <= 4){
                    selectedPlayer.life+=2;
                    this.curRoom.chat.push(selectedPlayer.name + ' kapott két sört: '+ '<img class="smallDices" src="'+s.image+'">');
                  } else {
                    if (selectedPlayer.life<selectedPlayer.startingLife) selectedPlayer.life++;
                    this.curRoom.chat.push(selectedPlayer.name + ' kapott egy sört: '+ '<img class="smallDices" src="'+s.image+'">');
                  }
                }
              }
            }
        
            let gatlingDices = selections.filter(x => x.type === 5);
            //Character check: willy the kid
            if (gatlingDices.length >= 3 || (gatlingDices.length === 2 && this.player.character.name === 'willy_the_kid')){
              this.curRoom.chat.push(this.player.name + ' gatlingot használt, így eldobja a nyilait.');
              this.curRoom.arrowsLeft += this.player.arrows;
              this.player.arrows = 0;
              for (let p of this.curRoom.players){
                //Character check: paul regret
                if (p != this.player && !p.killed && p.character.name != 'paul_regret'){
                  p.life--;
                  this.curRoom.chat.push(p.name + ' sebezve lett gatling által');
                }
              }
            }
        
            for (let p of this.curRoom.players){
              this.checkIfKilled(p);
            }
            this.checkForWinner();
          }

        this.curRoom.nextPlayer(this.player);
      }
      
      this.io.to(this.curRoom.name).emit('playersDataRefresh',this.curRoom.players, this.curRoom.arrowsLeft, this.curRoom.chat);
    }
    //adds arrows to the player
    addArrows(player,arrows){
      while (this.curRoom.arrowsLeft>0 && arrows>0){
          player.arrows++;
          this.curRoom.arrowsLeft--;
          arrows--;
      }
      this.checkArrowsLeft();
  }
    //Check if no arrows are left, and damages the players if they have arrows
    checkArrowsLeft(){
     if (this.curRoom.arrowsLeft <= 0){
      this.io.to(this.curRoom.name).emit('noArrowsLeft');
        for (let p of this.curRoom.players){
          if (!p.killed){
            //Character check: jourdonnais
            if (p.character.name != 'jourdonnais'){
              p.life -= p.arrows;
              this.curRoom.chat.push(p.name+' kapott ' + p.arrows +' sebzést a nyilaktól.');
            } else {
              if (p.arrows!=0) {
                p.life--;
                this.curRoom.chat.push(p.name+' kapott 1 sebzést a nyilaktól.');
              }
            }

            p.arrows = 0;
            this.checkIfKilled(p)
          }
        }
        this.checkForWinner();
        this.curRoom.arrowsLeft = 9;
      }
      this.io.to(this.curRoom.name).emit('playersDataRefresh',this.curRoom.players, this.curRoom.arrowsLeft, this.curRoom.chat);
    }
    
    //Dice roll
    roll(types=[-1,-1,-1,-1,-1]){
      if (this.player.rolled === false){
  
        let rollResults = [];
        for (let i = 0; i < 5; i++){
          let cur_dice = new Dice(i,types[i]);
          rollResults.push(cur_dice);
          if (cur_dice.type === 0 || cur_dice.type === 1 || cur_dice.type === 5){ //add all to selections except bullet1/2, beer
            this.player.selections[i] = cur_dice;
            } else {
              this.player.selections[i] = null;
            }
        }
  
        let dynamiteDices = rollResults.filter(x => x.type === 1);
        for (let d of rollResults){
  
          if (d.type === 0){
            this.addArrows(this.player,1);
          }
          else if (d.type === 1){
            d.rerollsLeft = 0;
          }
        }
        if (dynamiteDices.length >= 3){
          this.player.life--;
          this.checkIfKilled(this.player)
          this.checkForWinner();
          dynamiteDices.forEach(x=>x.abilityActivated = true);
          rollResults.forEach(x=>x.rerollsLeft = 0);
        }
        this.player.rolled = true;
        console.log(this.curRoom.name+": "+this.player.name + ' dobott: ',rollResults.map(x => x.name));
        this.curRoom.chat.push(this.player.name + ' dobott: '+ rollResults.map(x => '<img class="smallDices" src="'+x.image+'">'));
  
        this.player.curDices = rollResults;
  
        this.socket.emit('rollResults',this.player.curDices, this.player.selections);
  
        this.io.to(this.curRoom.name).emit('playersDataRefresh',this.curRoom.players, this.curRoom.arrowsLeft, this.curRoom.chat);
  
      }
    }
    
    //Handles the rerolling of the dice
    reroll(rerolledDiceIndex,type=-1){
      let rerolledDice = this.player.curDices[rerolledDiceIndex];
      let originalDice = {...rerolledDice};
  
      rerolledDice.roll(type);
      console.log(this.curRoom.name+": "+this.player.name + ' újradobott: '+ rerolledDice.name, rerolledDice.type);
      this.curRoom.chat.push(this.player.name + ' újradobott: '+ '<img class="smallDices" src="'+originalDice.image+'">'+'->'+'<img class="smallDices" src="'+rerolledDice.image+'">');
  
      if (rerolledDice.type === 0 || rerolledDice.type === 1 ||rerolledDice.type === 5){
        this.player.selections[rerolledDiceIndex] = rerolledDice;
      } else {
        this.player.selections[rerolledDiceIndex] = null;
      }
  
      rerolledDice.rerollsLeft--;
  
      let dynamiteDices = this.player.curDices.filter(x => x.type === 1 && x.abilityActivated === false);
  
      if (rerolledDice.type === 0){
        this.curRoom.chat.push(this.player.name+' kapott egy nyilat.');
        this.addArrows(this.player,1);
      }
      else if (rerolledDice.type === 1){
        rerolledDice.rerollsLeft = 0;
      }
  
      if (dynamiteDices.length >= 3){
        this.curRoom.chat.push(this.player.name + ' 3 dinamitot dobott.');
        this.player.life--;
        this.checkIfKilled(this.player);
        this.checkForWinner();
        dynamiteDices.forEach(x => x.abilityActivated = true);
        this.player.curDices.forEach(x => x.rerollsLeft = 0);
      }
  
      this.socket.emit('rollResults', this.player.curDices, this.player.selections);
  
      this.io.to(this.curRoom.name).emit('playersDataRefresh', this.curRoom.players, this.curRoom.arrowsLeft, this.curRoom.chat);
  
    }
    //Send a message to the chat
    sendMessage(message){
      console.log(this.curRoom.name+": "+this.player.name+" küldött egy üzenetet: "+message);
      this.curRoom.chat.push(this.player.name+": "+message);
      this.io.to(this.curRoom.name).emit('updateChat', this.curRoom.chat);
    }
    
    //Disconnect from the game, and remove the room from the server
    disconnect(){
      this.curRoom.connections[this.playerIndex] = null;
      this.io.to(this.curRoom.name).emit("aPlayerDisconnected");
      if (this.server.rooms.indexOf(this.curRoom) != -1){
        this.server.rooms.splice(this.server.rooms.indexOf(this.curRoom), 1);
      }
    }
}

module.exports = SocketServer;