add socket send game_end message from FE

packages/play-node-go/src/components/GameUI/Board/Board.js

@@ -42,9 +42,9 @@ const Board = (props) => {
       const posY = (i % boardSize) + 1;
       const pointData = board[`${posX}-${posY}`];
       const dotData =
-        meta?.turn && pointData
-          ? game.turn || meta.turn
-          : meta?.territory[`${posX}-${posY}`];
+        meta && meta.turn === 0
+          ? meta?.territory[`${posX}-${posY}`]
+          : game.turn || meta?.turn;
       boardPoints.push(
         <Point
           key={`${posX}-${posY}`}

packages/play-node-go/src/components/GameUI/PlayerArea/PlayerArea.js

@@ -10,16 +10,27 @@ const PlayerArea = ({
   const { stones, player, rank, captures } = playerMeta;
   const isTurn =
     (stones === "black" && turn === 1) || (stones === "white" && turn === -1);
+  const bowlAttributes = () => {
+    if (isTurn || turn === 0)
+      return {
+        "data-turn": true,
+        onClick: () => handlePassClick(stones),
+      };
+    return null;
+  };
+  const bowlText = () => {
+    if (isTurn) return "Pass?";
+    if (turn === 0) return "End Game?";
+    // return;
+  };
 
   return (
     <div className={`player-container player-container--${stones}`}>
       <div
         className={`player-container__bowl player-container__bowl--${stones}`}
-        {...(isTurn
-          ? { "data-turn": true, onClick: () => handlePassClick(stones) }
-          : null)}
+        {...bowlAttributes()}
       >
-        <p>Pass?</p>
+        <p>{bowlText()}</p>
       </div>
       <div
         className={`player-container__name-space player-container__name-space--${stones}`}

packages/play-node-go/src/io.js

@@ -46,6 +46,10 @@ const launch = (nsp, dispatch) => {
     dispatch({ type: "GAMES", message: "GAME_RESIGN", body: data });
   });
 
+  socket.on("game_end", (data) => {
+    dispatch({ type: "GAMES", message: "GAME_END", body: data });
+  });
+
   return socket;
 };
 

packages/play-node-go/src/pages/Game/Game.js

@@ -71,6 +71,14 @@ const Game = (props) => {
   };
 
   const handlePassClick = (player) => {
+    if (state?.meta && state?.meta?.turn === 0) {
+      const action = {
+        type: "SOCKET",
+        message: "END_GAME",
+        body: { game, player },
+      };
+      return dispatch(action);
+    }
     const action = {
       type: "SOCKET",
       message: "PASS",

packages/play-node-go/src/reducers/games/reducer.games.js

@@ -8,58 +8,42 @@ export const gamesReducer = (state, action) => {
     }
 
     case "JOIN_REQUEST": {
-      if (!Object.entries(state.user).length) {
-        const errAction = {
-          type: "ERR",
-          message: "JOIN_GAME_ERROR",
-          body: { joinGameError: "user not logged in" },
-        };
-        return stateReducer(state, errAction);
-      }
-      const id = action.body;
-      return { ...state, joinGame: id };
+      return joinRequest(state, action);
     }
 
     case "UPDATE_BOARD": {
-      const {
-        gameRecord,
-        pass,
-        turn,
-        winner,
-        playerState,
-        territory,
-      } = action.body.meta;
-      return {
-        ...state,
-        board: action.body.board,
-        meta: { gameRecord, pass, turn, winner, playerState, territory },
-      };
+      return updateBoard(state, action);
     }
 
     case "GAME_RESIGN": {
-      const { gameRecord, pass, turn, winner, playerState } = action.body;
-      return {
-        ...state,
-        meta: { gameRecord, pass, turn, winner, playerState },
-      };
+      return gameResign(state, action);
     }
 
     case "SET_ACTIVE": {
       return { ...state, active: action.body };
     }
 
+    case "GAME_END": {
+      console.log(action.body);
+      return state;
+    }
+
     default: {
       return state;
     }
   }
 };
 
+// parse ranks from db in K9 format to 9k format
 function parseRank(rank) {
   switch (rank[0]) {
+    // Dan ranks
     case "D":
       return `${rank.slice(1)}${rank[0].toLowerCase()}`;
+    // Kyu ranks
     case "K":
       return `${rank.slice(1)}${rank[0].toLowerCase()}`;
+    // Unranked
     case "U":
       return "?";
     default:
@@ -82,3 +66,40 @@ function formatGames(action) {
 
   return games;
 }
+
+function joinRequest(state, action) {
+  if (!Object.entries(state.user).length) {
+    const errAction = {
+      type: "ERR",
+      message: "JOIN_GAME_ERROR",
+      body: { joinGameError: "user not logged in" },
+    };
+    return stateReducer(state, errAction);
+  }
+  const id = action.body;
+  return { ...state, joinGame: id };
+}
+
+function updateBoard(state, action) {
+  const {
+    gameRecord,
+    pass,
+    turn,
+    winner,
+    playerState,
+    territory,
+  } = action.body.meta;
+  return {
+    ...state,
+    board: action.body.board,
+    meta: { gameRecord, pass, turn, winner, playerState, territory },
+  };
+}
+
+function gameResign(state, action) {
+  const { gameRecord, pass, turn, winner, playerState } = action.body;
+  return {
+    ...state,
+    meta: { gameRecord, pass, turn, winner, playerState },
+  };
+}

packages/play-node-go/src/reducers/socket/reducer.socket.js

@@ -46,6 +46,10 @@ export const socketReducer = (state, action) => {
       return toggleTerritory(state, action);
     }
 
+    case "END_GAME": {
+      return endGame(state, action);
+    }
+
     default:
       return state;
   }
@@ -92,3 +96,10 @@ function toggleTerritory(state, action) {
   socket.emit("toggle_territory", { ...action.body });
   return state;
 }
+
+function endGame(state, action) {
+  console.log("end game");
+  const socket = state.socket;
+  socket.emit("end_game", { ...action.body });
+  return state;
+}

packages/server/data/queries/game.js

@@ -1,48 +1,91 @@
-const knex = require('../db');
+const knex = require("../db");
 
 const gameDetailSelect = [
-  'game.id', 'application', 'application_version',
-  'board_size', 'komi', 'handicap', 'open', 'win_type',
-  'player_black', 'player_black_rank', 'player_white', 'player_white_rank',
-  'captures_black', 'captures_white', 'score', 'win_type',
-  'description', 'event', 'round', 'name', 'room'
-]
+  "game.id",
+  "application",
+  "application_version",
+  "board_size",
+  "komi",
+  "handicap",
+  "open",
+  "win_type",
+  "player_black",
+  "player_black_rank",
+  "player_white",
+  "player_white_rank",
+  "captures_black",
+  "captures_white",
+  "score",
+  "win_type",
+  "description",
+  "event",
+  "round",
+  "name",
+  "room",
+];
 
 const timeSettingSelect = [
-  'main_time', 'time_period', 'period_length', 'overtime', 'overtime_period', 'overtime_length'
-]
+  "main_time",
+  "time_period",
+  "period_length",
+  "overtime",
+  "overtime_period",
+  "overtime_length",
+];
 
 const gameOverviewSelect = [
-  'id', 'board_size', 'komi', 'handicap', 'open', 'win_type',
-  'player_black', 'player_black_rank', 'player_white', 'player_white_rank'
-]
+  "id",
+  "board_size",
+  "komi",
+  "handicap",
+  "open",
+  "win_type",
+  "player_black",
+  "player_black_rank",
+  "player_white",
+  "player_white_rank",
+];
 
 const findGameById = async function (gameId) {
   const selection = gameDetailSelect.concat(timeSettingSelect);
 
   const game = await knex
-  .from('game')
-  .select(selection)
-  .where({'game.id': gameId})
-  .leftJoin('time_setting', function() { this.on('time_setting.id', '=', 'game.time_setting')})
-  
+    .from("game")
+    .select(selection)
+    .where({ "game.id": gameId })
+    .leftJoin("time_setting", function () {
+      this.on("time_setting.id", "=", "game.time_setting");
+    });
+
   return game[0];
-}
+};
 
 const findGameByRoom = async (roomId) => {
-  const games = await knex('game')
-  .where({'room': roomId})
-  .select(gameOverviewSelect);
-  
+  const games = await knex("game")
+    .where({ room: roomId })
+    .select(gameOverviewSelect);
+
   return games;
-}
+};
 
-const insertGame = async (game) => {
+const insertGame = async (game) => {};
 
-}
+const endGame = async ({ id }) => {
+  const game = await knex(game).where({ id: id }).update(
+    {
+      win_type: winType,
+      score: score,
+      captures_black: capturesBlack,
+      captures_white: capturesWhite,
+    }
+    // ["id"]
+  );
+  return game;
+};
 
 module.exports = {
   findGameById,
   findGameByRoom,
-  insertGame
-}
+  insertGame,
+  endGame,
+};

packages/server/services/gameServices.js

@@ -1,6 +1,6 @@
 const Game = require("./Game").Game;
 
-const GameService = (moveQueries) => {
+const GameService = ({ moveQueries, gameQueries }) => {
   const storeGame = (game) => {
     gamesInProgress[game.id] = Game(game);
     return gamesInProgress[game.id];
@@ -105,6 +105,18 @@ const GameService = (moveQueries) => {
       gamesInProgress[id] = gamesInProgress[id].toggleTerritory(point);
       return this.getDataForUI(id);
     },
+
+    async endGame({ id }) {
+      gamesInProgress[id] = gamesInProgress[id].endGame();
+      try {
+        if (gameQueries) {
+          // TODO add end game query
+        }
+      } catch (e) {
+        console.log(e);
+      }
+      return this.getDataForUI(id);
+    },
   };
 };
 

packages/server/socket.js

@@ -4,7 +4,11 @@ const io = socketIO({ cookie: false });
 
 // const gameQueries = require('./data/queries/game');
 const moveQueries = require("./data/queries/move");
-const gameServices = require("./services/gameServices")(moveQueries);
+const gameQueries = require("./data/queries/game");
+const gameServices = require("./services/gameServices")({
+  moveQueries,
+  gameQueries,
+});
 
 io.on("connection", async (socket) => {
   socket.emit("connected", { message: "socket connected" });
@@ -110,6 +114,24 @@ io.on("connection", async (socket) => {
           console.log(e);
         }
       });
+
+      // END GAME
+      socket.on("end_game", async ({ user, game }) => {
+        const { id, room } = game;
+        const gameNsp = `game${id}`;
+        try {
+          const { board, ...meta } = await gameServices.endGame({ id });
+          socket.join(gameNsp, () => {
+            io.of(room).to(gameNsp).emit("end_game", { board, meta });
+          });
+        } catch (e) {
+          console.log(e);
+        } finally {
+          socket.join(gameNsp, () => {
+            io.of(room).to(gameNsp).emit("end_game", { board, meta });
+          });
+        }
+      });
     });
   });
 });