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 fs = require("fs");
const axios = require("axios");
var shortId = require("shortid"); //import shortid module
const config = require("./public/config/secret");
const csurf = require("csurf");
var indexRouter = require("./routes/index");
var request = require("request");
// app.use('/', indexRouter);
var session = require("express-session");
app.use(
  session({
    secret: "@#@$MYSIGN#@$#$",
    resave: false,
    saveUninitialized: true,
  })
);
// app.use(function(req, res, next) {
//   var token = req.csrfToken();
//   res.cookie("XSRF-TOKEN", token);
//   res.locals.csrfToken = token;
//   next();
// });

const cookieParser = require("cookie-parser");
app.use(cookieParser());
// const csrfMiddleware = csurf({
//   cookie: true
// });
// app.use(csrfMiddleware);
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 }));
app.use(bodyParser.json());

// bootstrap module
app.use("/js", express.static(__dirname + "/node_modules/bootstrap/dist/js")); // redirect bootstrap JS
app.use("/css", express.static(__dirname + "/node_modules/bootstrap/dist/css")); // redirect CSS bootstrap

// routes settings
// app.use(
//   "/public/TemplateData",
//   express.static(__dirname + "/public/TemplateData")
// );
// app.use("/public/Build", express.static(__dirname + "/public/Build"));

app.use(
  "/public/TemplateDataPlaza",
  express.static(__dirname + "/public/TemplateDataPlaza")
);
app.use("/public/BuildPlaza", express.static(__dirname + "/public/BuildPlaza"));

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://172.30.1.33: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,
      kakaoId: user.kakaoId,
      nickName: user.nickName,
    });
  });
});

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

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

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

app.get("/ranking/:part", async (req, res) => {
  const { part } = req.params;

  const user = await axios({
    method: "get",
    url: "http://172.30.1.33:8000/user/",
    headers: {
      token: req.cookies["cookieToken"],
    },
  });

  const URL = "http://172.30.1.33:8000/ranking/" + part;

  console.log("URL: ${URL}");

  res.render("ranking", {
    userName: user.userName,
    univName: user.univName,
    kakaoEmail: user.kakaoEmail,
    idToken: req.cookies["cookieToken"],
    nickName: user.nickName,
    part,
  });
});

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;
  socket.on("newUserConnect", function (name) {
    socket.name = name;
    io.sockets.emit("updateMessage", {
      name: "SERVER",
      message: name + "님이 접속했습니다.",
    });
  });
  socket.on("userDisconnect", function () {
    io.sockets.emit("updateMessage", {
      name: "SERVER",
      message: socket.name + "님이 퇴장했습니다.",
    });
  });
  socket.on("sendMessage", function (data) {
    data.name = socket.name;
    io.sockets.emit("updateMessage", data);
  });

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

    var data = JSON.parse(_data);

    // fills out with the information emitted by the player in the unity
    let currentURL = data.url;

    //add currentUser in clients list
    if (!(currentURL in clients)) clients[currentURL] = [];

    const spawnPos = [
      "-126.48:38.48:-146.3",
      "-135.39:38.48:-146.3",
      "-65:122.63:13.6",
      "-55:122.63:13.6",
      "-45:122.63:13.6",
    ];

    let posData = data.position;
    let rotationAngle = "0";
    if (currentURL.includes("game")) {
      posData = spawnPos[clients[currentURL].length];
      rotationAngle = "180";
    }

    currentUser = {
      kakaoId: data.name,
      avatar: data.avatar,
      name: data.userName,
      position: posData,
      rotation: rotationAngle,
      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,
      playingURL: currentURL,
      kakaoUniqueId: data.name,
    };

    console.log("[INFO] socket" + currentUser.socketID);
    console.log("[INFO] player kakaoId " + currentUser.kakaoId + ": logged!");
    console.log("[INFO] currentUser.position " + currentUser.position);

    clients[currentURL].push(currentUser);

    //add client in search engine
    clientLookup[currentUser.id] = currentUser;
    console.log(
      `[INFO ${currentURL}]-Total accesor: ${clients[currentURL].length}`
    );

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

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

    //spawn all connected clients for currentUser client
    clients[currentURL].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,
          i.kakaoUniqueId
        );
      } //END_IF
    }); //end_forEach

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

  //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(`pack data parsing: ${pack.kakaoUniqueId}`);

    console.log("message from user# " + socket.id + ": " + pack.msg);
    console.log(`User arrived at the track: ${currentUser.kakaoId}`);
    // timer.stopTimer(timerInterv);
    let endTime = new Date().getTime();
    console.log("-->", endTime);
    if (currentUser.kakaoId === pack.kakaoUniqueId) {
      console.log(`-> Axios: curr: ${currentUser.kakaoId}`);
      console.log(`-> Axios: ping: ${pack.kakaoUniqueId}`);
      axios({
        method: "get",
        url: "http://172.30.1.33:8000/game/api/update-record",
        headers: {
          kakaoId: currentUser.kakaoId,
          currentURL: currentUser.playingURL,
          endTime: parseInt(endTime),
        },
      }).then(function (response) {
        console.log(`게임 종료 !\n${response}`);
      });
    }
    //emit back to NetworkManager in Unity by client.js script
    socket.emit("PONG", socket.id, pack.msg);
  });

  //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,
        currentUser.kakaoUniqueId
      );

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

      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 -------");