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}`));