QuickChess/server.js

74 lines
1.7 KiB
JavaScript

const { textFromBoard } = require('./src/logic')
const { Board } = require('./src/backend');
const express = require('express');
const http = require('http');
const socketIo = require('socket.io');
const port = process.env.PORT || 4001;
const app = express();
const server = http.createServer(app);
const io = socketIo(server, {
cors: {
cors: true,
}
});
let interval;
let games = new Map();
io.on("connection", (socket) => {
console.log("New client connected");
if (interval) {
clearInterval(interval);
}
//interval = setInterval(() => getApiAndEmit(socket), 5000);
socket.on("disconnect", () => {
console.log("Client disconnected");
clearInterval(interval);
});
socket.on("find", key => {
key = key?.toLowerCase()
console.log(`Finding game '${key}'`);
let game = games.get(key);
if(game) {
console.log(`Found game '${key}'`);
game.sockets.push(socket);
} else {
game = {
sockets: [socket],
board: new Board(),
moveDate: null,
};
console.log(`Created game '${key}'`);
}
games.set(key, game);
getApiAndEmit(socket, game.board);
});
socket.on("move", (key, move) => {
console.log(`Received move at '${key}'`);
let game = games.get(key);
if(move && game.board.makeMove(move.from, move.to) === 0) {
games.set(key, game);
for (const s of game.sockets) {
getApiAndEmit(s, game.board);
}
}
});
});
const getApiAndEmit = (socket, board) => {
const response = textFromBoard(board)
console.log(response);
// Emitting a new message. Will be consumed by the client
socket.emit("FromAPI", response);
};
server.listen(port, () => console.log(`Listening on port ${port}`));