index.js

// Importing packages
import 'dotenv/config'
import express from "express";
import { Server } from "socket.io";
import { createServer } from "http";
import { corsOptions } from "./cors.js";

// My custom modules and their functions imported
import { router } from "./router.js";
import { addUser, updateUser, getUser } from "./users.js";
import { updateRoom } from "./words.js";
import { addTotalScore } from "./score.js";
import { myClientList, timers, lines, turnTime, updatePlayers, restartGame, turn, updateMsgTextAndAddPoints, disconnectCleanUp } from "./socketio_util.js";

// App set up
const PORT = process.env.PORT || 5001;
const app = express();
export const server = createServer(app);
export const io = new Server(server, {
	allowEIO3: false,
	cors: corsOptions
});

// socket events
io.on("connection", (socket) => {
	console.log("We have a new connection", socket.id);
	// Add new socket connection
	myClientList[socket.id] = socket;

	// Join event to handle new players joining
	socket.on("join", ({ name, room, avatar, update }, callback) => {
		if (update) {
			var { error, user } = updateUser({
				id: socket.id,
				name,
				room,
				avatar,
				update,
			});
		} else {
			var { error, user } = addUser({
				id: socket.id,
				name,
				room,
				avatar,
				update,
			});
		}

		if (error) return callback(error);
		socket.join(user.room);
		updatePlayers(socket, user.room);
		if (update) {
			socket.emit("closeModal");
		}
		// Update player with line data if game has already started
		if (timers[room] != undefined) {
			socket.emit("waitingFalse");
			if (lines[room]) {
				lines[room].map((data) => {
					socket.emit("draw_line", data);
				});
			}
			addTotalScore(room);
			socket.emit("message", {
				user: "admin",
				text:
					"You have joined an existing game. The timer and round number will update in the next turn. You can guess now.",
			});
			socket.broadcast.to(room).emit("message", {
				user: "admin",
				text: user.name[0].toUpperCase() + user.name.slice(1) + " has joined!",
			});
		}
	});

	// change waiting event, emits when game started to let everyone enter the game room
	socket.on("changeWaiting", (room) => {
		socket.broadcast.to(room).emit("waitingFalse");
	});

	// chosen word event, updates room information
	socket.on("chosenWord", ({ word, room }) => {
		updateRoom(room, word);
	});

	// game start event, starts turn logic
	socket.on("gameStart", (room) => {
		restartGame(room, socket);
		turn(room, io);
		console.log("start interval timer", new Date().toLocaleTimeString());
		timers[room] = setInterval(() => {
			console.log("interval timer completed", new Date().toLocaleTimeString());
			turn(room, io);
		}, turnTime);
	});

	// emit drawing event, emits drawing data to players
	socket.on("emitDrawing", ({ data, room }) => {
		if (lines[room]) {
			lines[room].push(data);
		} else {
			lines[room] = [];
			lines[room].push(data);
		}
		socket.broadcast.to(room).emit("draw_line", data);
	});

	// send message event, emits whether guess was right or wrong to all players
	socket.on("sendMessage", (message, callback) => {
		const user = getUser(socket.id);
		const text = updateMsgTextAndAddPoints(socket, user, message);
		io.to(user.room).emit("message", {
			user: user.name,
			text: text,
			img: user.avatar,
		});
		callback();
	});

	// clear event, emits clear canvas event to players
	socket.on("clear", (room) => {
		lines[room] = [];
		socket.broadcast.to(room).emit("clear");
	});

	// undo event, emits undo event to players (so all players in the room see the same drawing)
	socket.on("undo", (room) => {
		lines[room] = lines[room].slice(0, -10);
		socket.broadcast.to(room).emit("undo");
	});

	// disconnect event, when player leaves the room
	socket.on("disconnect", () => {
		console.log("User has left", socket.id);
		disconnectCleanUp(socket, io);
	});
});

app.use(router);
server.listen(PORT, () => console.log(`Server has started on port ${PORT}`));