Moon Patel
127 lines
4.3 KiB
JavaScript
127 lines
4.3 KiB
JavaScript
const express = require("express");
|
|
const bodyParser = require("body-parser");
|
|
const cors = require("cors");
|
|
const authRoutes = require("./routes/auth");
|
|
const userRoutes = require("./routes/user");
|
|
const roomRoutes = require('./routes/room')
|
|
const mongoose = require("mongoose");
|
|
require("dotenv").config();
|
|
|
|
mongoose
|
|
.connect("mongodb://127.0.0.1:27017/test")
|
|
.then((res) => console.log("Connected to MongoDB"))
|
|
.catch((err) => console.log("Error in connecting to database"));
|
|
|
|
const app = express();
|
|
const http = require("http");
|
|
const server = http.createServer(app);
|
|
const { Server } = require("socket.io");
|
|
const { sendEmail } = require("./mail");
|
|
const { User } = require("./models/user");
|
|
const io = new Server(server, { cors: { origin: "*" } });
|
|
|
|
const activeRooms = new Map();
|
|
const pendingChallenges = new Map();
|
|
|
|
io.on("connection", (socket) => {
|
|
console.log("Client connected:", socket.id);
|
|
|
|
socket.on("disconnect", () => {
|
|
console.log("Disconnecting");
|
|
});
|
|
|
|
// Handle join event
|
|
socket.on("join-room", async (roomID, playerUsername, challengedPlayerUsername, gameData) => {
|
|
// room exists
|
|
console.log(roomID, playerUsername, challengedPlayerUsername);
|
|
console.log("activeRooms", activeRooms);
|
|
console.log("pendingChallenges", pendingChallenges);
|
|
// if (activeRooms.has(roomID)) {
|
|
// socket.emit("room-full");
|
|
// console.log('Room full');
|
|
// return;
|
|
// } else
|
|
if (pendingChallenges.has(roomID)) {
|
|
const challenge = pendingChallenges.get(roomID);
|
|
pendingChallenges.delete(roomID);
|
|
let newRoom = {
|
|
id: roomID,
|
|
players: {
|
|
challenger: {
|
|
id: challenge.challengerID,
|
|
name: challenge.challengerUsername,
|
|
},
|
|
challenged: {
|
|
id: socket.id,
|
|
name: playerUsername,
|
|
},
|
|
},
|
|
};
|
|
console.log("New room created", roomID);
|
|
socket.join(roomID);
|
|
activeRooms.set(roomID, newRoom);
|
|
socket.emit("joined-room", {
|
|
color: challenge.challengerColor === "w" ? "b" : "w",
|
|
timeLimit: challenge.timeLimit,
|
|
});
|
|
// io.to(roomID).emit("joined-room");
|
|
} else {
|
|
// no room on pending challenges found
|
|
const challenge = {
|
|
roomID,
|
|
challengerID: socket.id,
|
|
challengerUsername: playerUsername,
|
|
challengedUsername: challengedPlayerUsername,
|
|
challengerColor: gameData.color,
|
|
timeLimit: gameData.timeLimit,
|
|
};
|
|
pendingChallenges.set(roomID, challenge);
|
|
|
|
console.log(challengedPlayerUsername);
|
|
// notify the challenged player
|
|
const email = (await User.findOne({ username: challengedPlayerUsername })).email;
|
|
sendEmail(
|
|
email,
|
|
`Challenge from ${playerUsername}`,
|
|
`To accept the challenge follow the link: http://192.168.136.99:5173/game/challenges/${challengedPlayerUsername}/${roomID} \n login through: http://192.168.136.99:5173/login \n roomid:${roomID}`
|
|
);
|
|
|
|
socket.join(roomID);
|
|
socket.emit("joined-room");
|
|
}
|
|
});
|
|
|
|
socket.on("move", (roomID, moveData) => {
|
|
socket.to(roomID).emit("opponent-move", moveData);
|
|
});
|
|
});
|
|
|
|
app.use(cors({ origin: "*" }));
|
|
app.use(bodyParser.json());
|
|
app.use((req, res, next) => {
|
|
res.setHeader("Access-Control-Allow-Origin", "*");
|
|
res.setHeader("Access-Control-Allow-Methods", "GET,POST,PATCH,DELETE");
|
|
res.setHeader("Access-Control-Allow-Headers", "Content-Type,Authorization");
|
|
next();
|
|
});
|
|
|
|
app.use((req, res, next) => {
|
|
console.log(req.url);
|
|
next();
|
|
});
|
|
|
|
// app.use("/", (req, res, next) => res.send('Hello'));
|
|
app.use("/api/auth", authRoutes);
|
|
app.use("/api/user", userRoutes);
|
|
app.use("/api/room", roomRoutes)
|
|
|
|
app.use((error, req, res, next) => {
|
|
const status = error.status || 500;
|
|
const message = error.message || "Something went wrong.";
|
|
res.status(status).json({ message: message });
|
|
});
|
|
|
|
server.listen(8080, () => {
|
|
console.log("Listening on server 8080");
|
|
});
|