server.js

/*
 *@autor: Rio 3D Studios
 *@description:  java script server that works as master server of the Basic Example of WebGL Multiplayer Kit
 */
var express = require("express"); //import express NodeJS framework module
var app = express(); // create an object of the express module
var http = require("http").Server(app); // create a http web server using the http library
var io = require("socket.io")(http); // import socketio communication module
const qs = require("qs");
const axios = require("axios");
var shortId = require("shortid"); //import shortid module
const config = require("./public/config/secret");
var indexRouter = require("./routes/index");
// app.use('/', indexRouter);
var session = require("express-session");
app.use(
  session({
    secret: "@#@$MYSIGN#@$#$",
    resave: false,
    saveUninitialized: true
  })
);
const cookieParser = require("cookie-parser");
app.use(cookieParser());
app.get("/kakaoLogin", (req, res) => {
  console.log("Get request");
  console.log(`idToken in get kakao ${req.query.idToken}`);
  res.cookie("cookieToken", req.query.idToken);
  res.redirect("/home");
  res.send();
});
const bodyParser = require("body-parser");
app.use(bodyParser.urlencoded({ extended: true }));

// routes settings
app.use(
  "/public/TemplateData",
  express.static(__dirname + "/public/TemplateData")
);
app.use("/public/Build", express.static(__dirname + "/public/Build"));
app.set("views", __dirname + "/public/views");
app.set("view engine", "ejs");
app.use(express.static(__dirname + "/public"));

const kakaoConfig = {
  clientID: config.REST_API_KEY,
  redirectUri: config.REDIRECT_URI
};

// Page View

app.get("/", (req, res) => {
  res.render("index");
});

app.get("/plaza", (req, res) => {
  user = axios({
    method: "get",
    url: "http://localhost:8000/user/",
    headers: {
      token: req.cookies["cookieToken"]
    }
  }).then(function(response) {
    console.log(response);
    user = response.data;
    console.log(user);
    res.render("plaza", {
      userName: user.userName,
      univName: user.univName,
      kakaoEmail: user.kakaoEmail
    });
  });
});

app.get("/home", (req, res) => {
  user = axios({
    method: "get",
    url: "http://localhost:8000/user/",
    headers: {
      token: req.cookies["cookieToken"]
    }
  }).then(function(response) {
    console.log(response);
    user = response.data;
    console.log(user);
    res.render("mainPage", {
      userNameTest: "sdf",
      userName: user.userName,
      univName: user.univName,
      kakaoEmail: user.kakaoEmail,
      idToken: req.cookies["cookieToken"]
    });
  });
  // console.log(user.user);
  setTimeout(() => {
    console.log("token이다" + req.cookies["cookieToken"]);
  }, 100);
});

var clients = []; // to storage clients
var clientLookup = {}; // clients search engine
var sockets = {}; //// to storage sockets

//open a connection with the specific client
io.on("connection", function(socket) {
  //print a log in node.js command prompt
  console.log("A user ready for connection!");

  //to store current client connection
  var currentUser;

  //create a callback fuction to listening EmitPing() method in NetworkMannager.cs unity script
  socket.on("PING", function(_pack) {
    //console.log('_pack# '+_pack);
    var pack = JSON.parse(_pack);

    console.log("message from user# " + socket.id + ": " + pack.msg);

    //emit back to NetworkManager in Unity by client.js script
    socket.emit("PONG", socket.id, pack.msg);
  });

  //create a callback fuction to listening EmitJoin() method in NetworkMannager.cs unity script
  socket.on("LOGIN", function(_data) {
    console.log("[INFO] JOIN received !!! ");

    var data = JSON.parse(_data);
    console.log(data);

    // fills out with the information emitted by the player in the unity
    currentUser = {
      name: data.name,
      avatar: data.avatar,
      position: data.position,
      rotation: "0",
      id: socket.id, //alternatively we could use socket.id
      socketID: socket.id, //fills out with the id of the socket that was open
      animation: "",
      health: 100,
      maxHealth: 100,
      kills: 0,
      timeOut: 0,
      isDead: false
    }; //new user  in clients list
    console.log("[INFO] socket" + currentUser.socketID);
    console.log("[INFO] player " + currentUser.name + ": logged!");
    console.log("[INFO] currentUser.position " + currentUser.position);

    //add currentUser in clients list
    clients.push(currentUser);

    //add client in search engine
    clientLookup[currentUser.id] = currentUser;

    console.log("[INFO] Total players: " + clients.length);

    /*********************************************************************************************/

    //send to the client.js script
    socket.emit(
      "LOGIN_SUCCESS",
      currentUser.id,
      currentUser.name,
      currentUser.avatar,
      currentUser.position
    );

    //spawn all connected clients for currentUser client
    clients.forEach(function(i) {
      if (i.id != currentUser.id) {
        //send to the client.js script
        socket.emit("SPAWN_PLAYER", i.id, i.name, i.avatar, i.position);
      } //END_IF
    }); //end_forEach

    // spawn currentUser client on clients in broadcast
    socket.broadcast.emit(
      "SPAWN_PLAYER",
      currentUser.id,
      currentUser.name,
      currentUser.avatar,
      currentUser.position
    );
  }); //END_SOCKET_ON

  //create a callback fuction to listening method in NetworkMannager.cs unity script
  socket.on("RESPAWN", function(_info) {
    var info = JSON.parse(_info);

    if (currentUser) {
      currentUser.isDead = false;

      currentUser.health = currentUser.maxHealth;

      socket.emit(
        "RESPAWN_PLAYER",
        currentUser.id,
        currentUser.name,
        currentUser.avatar,
        currentUser.position
      );

      socket.broadcast.emit(
        "SPAWN_PLAYER",
        currentUser.id,
        currentUser.name,
        currentUser.avatar,
        currentUser.position
      );

      console.log("[INFO] User " + currentUser.name + " respawned!");
    }
  }); //END_SOCKET_ON

  //create a callback fuction to listening EmitMoveAndRotate() method in NetworkMannager.cs unity script
  socket.on("MOVE_AND_ROTATE", function(_data) {
    var data = JSON.parse(_data);

    if (currentUser) {
      currentUser.position = data.position;

      currentUser.rotation = data.rotation;

      // send current user position and  rotation in broadcast to all clients in game
      socket.broadcast.emit(
        "UPDATE_MOVE_AND_ROTATE",
        currentUser.id,
        currentUser.position,
        currentUser.rotation
      );
    }
  }); //END_SOCKET_ON

  //create a callback fuction to listening EmitAnimation() method in NetworkMannager.cs unity script
  socket.on("ANIMATION", function(_data) {
    var data = JSON.parse(_data);

    if (currentUser) {
      currentUser.timeOut = 0;

      //send to the client.js script
      //updates the animation of the player for the other game clients
      socket.broadcast.emit(
        "UPDATE_PLAYER_ANIMATOR",
        currentUser.id,
        data.animation
      );
    } //END_IF
  }); //END_SOCKET_ON

  //create a callback fuction to listening EmitAnimation() method in NetworkMannager.cs unity script
  socket.on("ATTACK", function() {
    if (currentUser) {
      // console.log("attack received");
      socket.broadcast.emit("UPDATE_ATTACK", currentUser.id);
    }
  }); //END_SOCKET_ON

  //create a callback fuction to listening EmitPhisicstDamage method in NetworkMannager.cs unity script
  socket.on("PHISICS_DAMAGE", function(_data) {
    var data = JSON.parse(_data);
    if (currentUser) {
      var target = clientLookup[data.targetId];

      var _damage = 1;

      // if health target is not empty
      if (target.health - _damage > 0) {
        // console.log("player: "+target.name+"receive damage from : "+currentUser.name);

        //  console.log(target.name+"health: "+ target.health);

        target.health -= _damage; //decrease target health
      } else {
        if (!target.isDead) {
          target.isDead = true; //target is dead

          target.kills = 0;

          //console.log("currentuser"+currentUser.name+" kills: "+currentUser.kills);

          currentUser.kills += 1;

          jo_pack = {
            targetId: data.targetId
          };

          //emit only for the currentUser
          socket.emit("DEATH", jo_pack.targetId);

          //emit to all connected clients in broadcast
          socket.broadcast.emit("DEATH", jo_pack.targetId);
        } //END_ if
      } //END_ELSE

      damage_pack = {
        targetId: data.targetId,
        targetHealth: target.health
      };

      socket.emit(
        "UPDATE_PHISICS_DAMAGE",
        damage_pack.targetId,
        damage_pack.targetHealth
      );
      socket.broadcast.emit(
        "UPDATE_PHISICS_DAMAGE",
        damage_pack.targetId,
        damage_pack.targetHealth
      );
    } //END_IF
  }); //END_SOCKET_ON

  // called when the user desconnect
  socket.on("disconnect", function() {
    if (currentUser) {
      currentUser.isDead = true;

      //send to the client.js script
      //updates the currentUser disconnection for all players in game
      socket.broadcast.emit("USER_DISCONNECTED", currentUser.id);

      for (var i = 0; i < clients.length; i++) {
        if (
          clients[i].name == currentUser.name &&
          clients[i].id == currentUser.id
        ) {
          console.log("User " + clients[i].name + " has disconnected");
          clients.splice(i, 1);
        }
      }
    }
  }); //END_SOCKET_ON
}); //END_IO.ON

http.listen(process.env.PORT || 3000, function() {
  console.log("listening on *:3000");
});
console.log("------- server is running -------");