1 files changed, 59 insertions, 2 deletions
diff --git a/src/server/index.js b/src/server/index.js
index 2b85ea5..2799805 100644
--- a/src/server/index.js
+++ b/src/server/index.js
@@ -1,11 +1,68 @@
 const express = require('express');
-const path = require('path');
 const app = express();
+const http = require('http').Server(app);
+const path = require('path');
+
+// const io = require('socket.io')(http);
+const io = require("socket.io")(http, {
+  cors: {
+    origin: ["http://localhost:5000", "http://localhost:3000"],
+    "Access-Control-Allow-Origin": "*",
+    methods: ["GET", "POST"]
+  }
+});
+
+const allEqual = (arr) =>
+  arr.includes(2) ? false : arr.every(i => i === arr[0])
+
+const getRow = (board, r) => board.slice(r * 3, (r * 3) + 3);
+const getRows = (board, r = 0) =>
+  r <= 2 ? [getRow(board, r)].concat(getRows(board, r+1)) : getRow(board, r)
+
+const getCol = (board, c) => board.map((i) => i[c])
+const getCols = (rows, c = 0) =>
+  c < 2 ? [getCol(rows, c)].concat(getCols(rows, c+1)) : [getCol(rows, c)]
+
+const getLeftDiagonal = (board, i = 0) =>
+  i < 3 ? [getRow(board, i)[i]].concat(getLeftDiagonal(board, i+1)) : [];
+
+const getRightDiagonal = (board, i = 2) =>
+  i >= 0 ? [getRow(board, 2-i)[i]].concat(getRightDiagonal(board, i-1)) : [];
+
+const getScore = (winner, scoreX, scoreO, board) => ({
+  winner: winner < 2 
+    ? (winner === 0 ? 'O' : 'X') 
+    : (board.includes(2) ? undefined : 'Draw'),
+  scoreX: winner === 1 ? scoreX + 1 : scoreX,
+  scoreO: winner === 0 ? scoreO + 1 : scoreO
+})
+
+io.on('connection', (socket) => {
+  socket.on('update-remote-data', (data) => {
+    if (data.board.includes(0) || data.board.includes(1)) {
+      const rows = getRows(data.board);
+      const winner = (rows.some((i) => allEqual(i))
+        || getCols(rows).some((i) => allEqual(i))
+        || [getLeftDiagonal(data.board), getRightDiagonal(data.board)].some((i) => allEqual(i))
+      ) ? data.turn : 2;
+
+      const score = getScore(winner, data.scoreX, data.scoreO, data.board)
+      io.emit('update-client-data', {
+        board: data.board, 
+        turn: score.winner ? data.turn : (data.turn === 0 ? 1 : 0),
+        score: score
+      });
+      
+      score.winner && io.emit('update-winner', score)
+    };
+  });
+});
 
+// serve static front end
 app.use(express.static(path.join(__dirname, '../../build')));
 
 // Start the server
 const PORT = process.env.PORT || 5000;
-app.listen(PORT, () => {
+http.listen(PORT, () => {
     console.log(`App listening on port ${PORT}`);
 });