server.js

const express = require("express");
const bodyParser = require("body-parser");
const compression = require("compression");
const helmet = require("helmet");
const cors = require("cors");
const path = require("path");

const app = express();
const server = require("http").createServer(app);

const io = require("socket.io")(server, {
  cors: {
    methods: ["GET", "POST"],
  },
});

const port = process.env.PORT || 7878;

// Express config
app.use(compression());
app.use(helmet());
app.use(cors());
app.use(express.static(path.join(__dirname, "./../../")));
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());

// app.get("*", (req, res) => {
//   res.sendFile(path.join(__dirname, "../../public/index.html"));
// });

server.listen(port, (serverError) => {
  if (serverError) throw serverError;
  console.info(`App is running on ${port}`);
});

let Data = [];
const db = require("./model/index");
const { users, kds, vcnvs, tts, vds, chps } = db;
db.mongoose
  .connect(db.url, {
    useNewUrlParser: true,
    useUnifiedTopology: true,
  })
  .then(() => {
    console.log("connect database");
  })
  .catch((e) => {
    console.log(e);
    process.exit();
  });
// {
//   username: String, // #
//   gmail: String, // #
//   password: String, // #
//   score: Number,
//   tooken: String
// }
app.post("/users/create", async (req, res) => {
  let usera = new users(req.body);
  try {
    await usera.save();
    res.send(usera);
  } catch (e) {
    console.log(e);
  }
});
app.get("/users", async (req, res) => {
  users.find({}, (err, database) => {
    if (err) {
      res.send(err);
    }
    res.send(database);
  });
});
app.get("/kds", async (req, res) => {
  kds.find({}, (err, database) => {
    if (err) {
      res.send(err);
    }
    res.send(database);
  });
});
app.get("/vcnvs", async (req, res) => {
  vcnvs.find({}, (err, database) => {
    if (err) {
      res.send(err);
    }
    res.send(database);
  });
});
app.get("/tts", async (req, res) => {
  tts.find({}, (err, database) => {
    if (err) {
      res.send(err);
    }
    res.send(database);
  });
});
app.get("/vds", async (req, res) => {
  vds.find({}, (err, database) => {
    if (err) {
      res.send(err);
    }
    res.send(database);
  });
});
app.get("/chps", async (req, res) => {
  chps.find({}, (err, database) => {
    if (err) {
      res.send(err);
    }
    res.send(database);
  });
});
app.get("/kds/create", async (req, res) => {
  let kda = new kds({ ques: "chun co bi ngu ko" });
  try {
    await kda.save();
    res.send("Create kd successfully !");
  } catch (e) {
    console.log(e);
  }
});
app.get("/vcnvs/create", async (req, res) => {
  let vcnva = new vcnvs({
    ques: "chun co bi ngu ko",
    answer: "chun",
    score: 10,
  });
  try {
    await vcnva.save();
    res.send("Create vcnv successfully !");
  } catch (e) {
    console.log(e);
  }
});
app.get("/tts/create", async (req, res) => {
  let tta = new tts({ ques: "chun co bi ngu ko", answer: "chun" });
  try {
    await tta.save();
    res.send("Create tt successfully !");
  } catch (e) {
    console.log(e);
  }
});
app.get("/vds/create", async (req, res) => {
  let vda = new vds({ ques: "chun co bi ngu ko 10", point: 10 });
  try {
    await vda.save();
    res.send("Create vd successfully !");
  } catch (e) {
    console.log(e);
  }
});
app.get("/chps/create", async (req, res) => {
  let vda = new chps({ ques: "chun co bi ngu ko chp", point: 10 });
  try {
    await vda.save();
    res.send("Create chp successfully !");
  } catch (e) {
    console.log(e);
  }
});
function addData(Obj, col) {
  MongoClient.connect(url, function (err, db) {
    if (err) throw err;
    dbo = db.db("mydb");
    dbo.collection(col).insertOne(Obj, function (err, res) {
      if (err) throw err;
      console.log("insert : " + Obj.name);
      db.close();
    });
  });
}

// function getData() {
//   // update
//   MongoClient.connect(url, function (err, db) {
//     if (err) throw err;
//     dbo = db.db("mydb");
//     dbo
//       .collection("users")
//       .find({})
//       .toArray(function (err, result) {
//         Data = result;

//         db.close();
//       });
//   });
//   console.log(Data);

//   return Data;
// }
async function AddPoint(myQuery, NewQuery) {
  await users.updateOne(myQuery, NewQuery, function (err, res) {
    if (err) throw err;
    console.log("1 document updated");
  });
  // MongoClient.connect(url, function (err, db) {
  //   if (err) throw err;
  //   var dbo = db.db("mydb");
  //   // var myQuery = { address: "Valley 345" };
  //   //var NewQuery = { $set: { name: "Mickey", address: "Canyon 123" } };
  //   dbo.collection("users").updateOne(myQuery, NewQuery, function (err, res) {
  //     if (err) throw err;
  //     console.log("1 document updated");
  //     db.close();
  //   });
  // });
  // let id = req.params.id;
  // let updateGame = req.body;
  // try {
  //   await users.findById(id, (err, game) => {
  //     users.rank = updateGame.rank;
  //     users.save();
  //     res.send(game);
  //   });
  // } catch (err) {
  //   console.log(err);
  // }
}

io.on("connection", (socket) => {
  const { id } = socket.client;
  console.log(`User connected: ${id}`);
  socket.on("disconnect", function () {
    console.log(socket.id + ": disconnected");
  });
  socket.on("get ques", (a) => {
    io.emit("get ques");
  });
  socket.on("recive data", (msg) => {
    // MongoClient.connect(url, function (err, db) {
    //   if (err) throw err;
    //   dbo = db.db("mydb");
    //   dbo
    //     .collection("users")
    //     .find({})
    //     .toArray(function (err, result) {
    //       io.emit("recive data", result);
    //     });
    // });
    users.find({}, (err, database) => {
      if (err) {
        res.send(err);
      }
      io.emit("recive data", database);
      // res.send(database);
    });
    // io.emit("recive data");
  });
  socket.on("recive current", (m) => {
    // MongoClient.connect(url, function (err, db) {
    //   if (err) throw err;
    //   dbo = db.db("mydb");
    //   dbo
    //     .collection("current")
    //     .find({})
    //     .toArray(function (err, result) {
    //       //Data = result;
    //       if (err) throw err;
    //       io.emit("recive current", result);
    //     });
    // });
    //===============
  });
  //=====================================================================================================
  socket.on("add data", (user) => {
    addData(user, "users");
    io.emit("add data ok ", getData());
  });

  socket.on("add point", (point) => {
    AddPoint({ name: point.name }, { $set: { score: point.point } });
    io.emit("add point ok", {
      point: point.point,
      stt: point.stt,
      data: point.users,
    });
    // console.log(updateuser.user);
    // try {
    //    users.findById(updateuser.user.id, (err, user) => {
    //     user.score = updateuser.score;
    //     user.save();
    //     res.send(user);
    //   });
    // } catch (err) {
    //   console.log(err);
    // }
  });
  //======================================================
  socket.on("on send answer", (UserAns) => {
    io.emit("on send answer", UserAns);
  });
  socket.on("play sound VCNV", (UserAns) => {
    io.emit("play sound VCNV", UserAns);
  });
  socket.on("play sound TT", (UserAns) => {
    io.emit("play sound TT", UserAns);
  });
  socket.on("change people", (point) => {
    io.emit("change pp", "wqe");
  });
  //=====================================================================================================
  socket.on("choose ques", (ques) => {
    console.log(ques);
    io.emit("choose ques", ques);
  });
  socket.on("check ans vd", (ques) => {
    io.emit("check ans vd", ques);
  });

  //=====================================================================================================
  socket.on("disable", (dis) => {
    io.emit("disable", dis);
  });
  socket.on("show list VCNV", (ques) => {
    io.emit("show list VCNV", ques);
  });

  socket.on("on send VD", (ques) => {
    io.emit("on send VD", ques);
  });

  socket.on("show list TT", (ques) => {
    console.log("qergwerg");

    io.emit("show list TT", ques);
  });
  socket.on("Wrong Answer", (ques) => {
    io.emit("Wrong Answer", ques);
  });
  socket.on("show answervcnv", (ques) => {
    io.emit("show answervcnv", ques);
  });
  socket.on("Open Picture", (ques) => {
    io.emit("Open Picture", ques);
  });
  socket.on("Add score", (obj) => {
    AddPoint({ name: obj.name }, { $set: { score: obj.score } });
    io.emit("Add score", obj);
  });
  socket.on("Add score TT", (obj) => {
    AddPoint({ name: obj.name }, { $set: { score: obj.score } });
    io.emit("Add score TT", obj);
  });
  socket.on("submit ques", (ques) => {
    io.emit("choose ques", ques);
  });
  socket.on("on VCNV", (data) => {
    io.emit("on VCNV", data);
  });
  socket.on("time VD", (data) => {
    io.emit("time VD", data);
  });
  socket.on("start time", (data) => {
    io.emit("start time", data);
  });
  socket.on("send VD", (data) => {
    io.emit("send VD", data);
  });
  socket.on("choose Star", (data) => {
    io.emit("choose Star", data);
  });
  socket.on("open choose quesVD", (data) => {
    io.emit("open choose quesVD", data);
  });
  socket.on("close choose quesVD", (data) => {
    io.emit("close choose quesVD", data);
  });
  socket.on("next pp vd", (data) => {
    io.emit("next pp vd", data);
  });
  socket.on("true chp", (data) => {
    io.emit("true chp", data);
  });
  socket.on("TongKetDiem", (data) => {
    io.emit("TongKetDiem", data);
  });
  socket.on("get ques", async (data) => {
    let questions = [];
    await kds.find({}, async (err, database1) => {
      await vcnvs.find({}, async (err, database2) => {
        await tts.find({}, async (err, database3) => {
          await vds.find({}, async (err, database4) => {
            await chps.find({}, async (err, database5) => {
              questions.push(database1);
              questions.push(database2);
              questions.push(database3);
              questions.push(database4);
              questions.push(database5);
              console.log(questions);
              io.emit("get ques", questions);
            });
          });
        });
      });
    });
  });
});

//