Create LICENSE

Bump lodash from 4.17.15 to 4.17.19

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2021 Sorrel
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

packages/play-node-go/package-lock.json

@@ -8500,9 +8500,9 @@
       }
     },
     "lodash": {
-      "version": "4.17.15",
-      "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.17.15.tgz",
-      "integrity": "sha512-8xOcRHvCjnocdS5cpwXQXVzmmh5e5+saE2QGoeQmbKmRS6J3VQppPOIt0MnmE+4xlZoumy0GPG0D0MVIQbNA1A=="
+      "version": "4.17.19",
+      "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.17.19.tgz",
+      "integrity": "sha512-JNvd8XER9GQX0v2qJgsaN/mzFCNA5BRe/j8JN9d+tWyGLSodKQHKFicdwNYzWwI3wjRnaKPsGj1XkBjx/F96DQ=="
     },
     "lodash._reinterpolate": {
       "version": "3.0.0",

packages/server/data/migrations/20200120224032_game.js

@@ -1,49 +1,81 @@
-const winType = [
-  'B+R', 'B+', 'B+T',
-  'W+R', 'W+', 'W+T',
-  '0', 'Void', '?'
-]
+const winType = ["B+R", "B+", "B+T", "W+R", "W+", "W+T", "0", "Void", "?"];
 
 const rankArray = [
-  'D9', 'D8', 'D7', 'D6', 'D5', 'D4', 'D3', 'D2', 'D1',
-  'K1', 'K2', 'K3', 'K4', 'K5', 'K6', 'K7', 'K8', 'K9', 'K10',
-  'K11', 'K12', 'K13', 'K14', 'K15', 'K16', 'K17', 'K18', 'K19', 'K20',
-  'K21', 'K22', 'K23', 'K24', 'K25', 'K26', 'K27', 'K28', 'K29', 'K30', 'UR'
-]
+  "D9",
+  "D8",
+  "D7",
+  "D6",
+  "D5",
+  "D4",
+  "D3",
+  "D2",
+  "D1",
+  "K1",
+  "K2",
+  "K3",
+  "K4",
+  "K5",
+  "K6",
+  "K7",
+  "K8",
+  "K9",
+  "K10",
+  "K11",
+  "K12",
+  "K13",
+  "K14",
+  "K15",
+  "K16",
+  "K17",
+  "K18",
+  "K19",
+  "K20",
+  "K21",
+  "K22",
+  "K23",
+  "K24",
+  "K25",
+  "K26",
+  "K27",
+  "K28",
+  "K29",
+  "K30",
+  "UR",
+];
 
-exports.up = function(knex) {
-  return knex.schema.createTable("game", table => {
-    table.increments('id').primary();
-    table.datetime('date');
-    table.float('komi').default(6.5);
-    table.integer('handicap').default(0);
-    table.integer('board_size').default(19);
-    table.boolean('open').default(true);
+exports.up = function (knex) {
+  return knex.schema.createTable("game", (table) => {
+    table.increments("id").primary();
+    table.datetime("date");
+    table.float("komi").default(6.5);
+    table.integer("handicap").default(0);
+    table.integer("board_size").default(19);
+    table.boolean("open").default(true);
 
-    table.string('application');
-    table.string('application_version');
+    table.string("application");
+    table.string("application_version");
     table.timestamps(true, true);
 
-    table.string('player_black');
-    table.string('player_white');
-    table.enu('player_black_rank', rankArray).default('UR');
-    table.enu('player_white_rank', rankArray).default('UR');
-    
-    table.string('event');
-    table.string('name');
-    table.string('description');
-    table.integer('round');
-    
-    table.enu('win_type', winType);
-    table.float('score');
-    table.integer('captures_black');
-    table.integer('captures_white');
+    table.string("player_black");
+    table.string("player_white");
+    table.enu("player_black_rank", rankArray).default("UR");
+    table.enu("player_white_rank", rankArray).default("UR");
 
-    table.integer('user_black').references('id').inTable('user');
-    table.integer('user_white').references('id').inTable('user');
-    table.integer('room').references('id').inTable('room');
-    table.integer('time_setting').references('id').inTable('time_setting');
-  })
+    table.string("event");
+    table.string("name");
+    table.string("description");
+    table.integer("round");
+
+    table.enu("win_type", winType);
+    table.float("score");
+    table.integer("captures_black");
+    table.integer("captures_white");
+
+    table.integer("user_black").references("id").inTable("user");
+    table.integer("user_white").references("id").inTable("user");
+    table.integer("room").references("id").inTable("room");
+    table.integer("time_setting").references("id").inTable("time_setting");
+  });
 };
 
-exports.down = knex => knex.schema.dropTableIfExists("game");
+exports.down = (knex) => knex.schema.dropTableIfExists("game");

packages/server/data/migrations/20200120230921_move.js

@@ -1,17 +1,18 @@
-const players = ['white', 'black']
+const players = ["white", "black"];
 
-exports.up = knex => {
-  return knex.schema.createTable("move", table => {
-    table.increments('id').primary();
-    table.enu('player', players).notNullable();
-    table.integer('point_x').notNullable();
-    table.integer('point_y').notNullable();
-    table.integer('number').notNullable();
-    table.boolean('game_record').notNullable().default(true);
+exports.up = (knex) => {
+  return knex.schema.createTable("move", (table) => {
+    table.increments("id").primary();
+    table.enu("player", players).notNullable();
+    table.integer("point_x").notNullable();
+    table.integer("point_y").notNullable();
+    table.integer("number").notNullable();
+    table.boolean("game_record").notNullable().default(true);
+    table.boolean("placement").notNullable().default(false);
 
-    table.integer('game').references('id').inTable('game').notNullable();
-    table.integer('prior_move').references('id').inTable('move');
+    table.integer("game").references("id").inTable("game").notNullable();
+    table.integer("prior_move").references("id").inTable("move");
   });
 };
 
-exports.down = knex => knex.schema.dropTableIfExists("move");
+exports.down = (knex) => knex.schema.dropTableIfExists("move");

packages/server/data/queries/game.js

@@ -70,17 +70,23 @@ const findGameByRoom = async (roomId) => {
 
 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;
+const endGame = async ({ id, winType, score, bCaptures, wCaptures }) => {
+  try {
+    const game = await knex
+      .from("game")
+      .returning(gameDetailSelect)
+      .where({ id: id })
+      .update({
+        win_type: winType,
+        score: score,
+        captures_black: bCaptures,
+        captures_white: wCaptures,
+        open: false,
+      });
+    return game;
+  } catch (e) {
+    return e;
+  }
 };
 
 module.exports = {

packages/server/data/queries/move.js

@@ -1,36 +1,47 @@
-const knex = require('../db');
+const knex = require("../db");
 
 const findGameRecord = async (gameId) => {
-  return await knex('move')
-  .where({ 'game': gameId, 'game_record': true })
-  .select('player', 'point_x', 'point_y', 'number')
-  .orderBy('number')
-  .then(record => record.map(({player, point_x, point_y}) => ({player, pos: { x: point_x, y: point_y } }) ))
+  return await knex("move")
+    .where({ game: gameId, game_record: true })
+    .select("player", "point_x", "point_y", "number", "prior_move", "placement")
+    .orderBy("number")
+    .then((record) =>
+      record.map(({ player, point_x, point_y }) => ({
+        player,
+        pos: { x: point_x, y: point_y },
+      }))
+    );
   // .then(res => res)
-}
+};
 
 // id: 1, player: 'black', point_x: 3,  point_y: 3, number: 1, game_record: true, game: 1, prior_move: null
 
 const addMove = async ({ gameId, player, x, y, gameRecord, priorMove }) => {
+  // ! priorMove must be FK not move number
   const number = priorMove + 1;
   let result;
-  try { 
-  result = await knex('move')
-    .returning('*')
-    .insert({ game: gameId, player, point_x: x, point_y: y, number, game_record: gameRecord, prior_move: priorMove  })
-    .then(res => res);
-  }
-  catch (e) {
-    result = e
-  }
-  finally {
+  try {
+    result = await knex("move")
+      .returning("*")
+      .insert({
+        game: gameId,
+        player,
+        point_x: x,
+        point_y: y,
+        number,
+        game_record: gameRecord,
+        prior_move: priorMove,
+      })
+      .then((res) => res);
+  } catch (e) {
+    result = e;
+  } finally {
     console.log(result);
     return result;
   }
-  
-}
+};
 
 module.exports = {
   findGameRecord,
-  addMove
-}
+  addMove,
+};

packages/server/package-lock.json

@@ -1359,9 +1359,9 @@
       }
     },
     "lodash": {
-      "version": "4.17.15",
-      "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.17.15.tgz",
-      "integrity": "sha512-8xOcRHvCjnocdS5cpwXQXVzmmh5e5+saE2QGoeQmbKmRS6J3VQppPOIt0MnmE+4xlZoumy0GPG0D0MVIQbNA1A=="
+      "version": "4.17.19",
+      "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.17.19.tgz",
+      "integrity": "sha512-JNvd8XER9GQX0v2qJgsaN/mzFCNA5BRe/j8JN9d+tWyGLSodKQHKFicdwNYzWwI3wjRnaKPsGj1XkBjx/F96DQ=="
     },
     "lodash.includes": {
       "version": "4.3.0",

packages/server/services/Game.js

@@ -181,13 +181,18 @@ const Game = ({ gameData = {}, gameRecord = [] } = {}) => {
       this.kos = [];
     },
   };
-
   if (gameRecord.length) {
     // play through all the moves
-    return gameRecord.reduce(
+    const game = gameRecord.reduce(
       (game, move) => game.makeMove(move),
       Game({ gameData }).initGame()
     );
+    // ? why is this being wrapped?
+    if (gameData && gameData.gameData && gameData.gameData.winner) {
+      const { winner, score } = gameData.gameData;
+      return game.manualEnd({ winner, score });
+    }
+    return game;
   }
   return {
     winner: gameData.winner || null,
@@ -239,28 +244,58 @@ const Game = ({ gameData = {}, gameRecord = [] } = {}) => {
       };
     },
 
+    checkMove: function ({ player, pos: { x, y } }) {
+      // if game is over
+      // TODO either change logic here or add additional method for handling moves off of record
+      if (this.pass > 1) {
+        return { ...this, success: false };
+      }
+      const point = this.boardState[`${x}-${y}`];
+      const isTurn =
+        (this.turn === 1 && player === "black") ||
+        (this.turn === -1 && player === "white");
+      if (isTurn) {
+        if (point.legal) {
+          return { ...this, success: true, move: { player, pos: { x, y } } };
+        }
+      }
+      return { ...this, success: false };
+    },
+
     makeMove: function ({ player, pos: { x, y } }) {
       if (this.pass > 1) {
         return { ...this, success: false };
       }
-      if (x === 0) return this.submitPass(player);
-      let game = this;
+      
       let success = false;
-      const point = game.boardState[`${x}-${y}`];
-      const isTurn =
-        (game.turn === 1 && player === "black") ||
-        (game.turn === -1 && player === "white");
-      if (isTurn) {
-        if (point.legal) {
-          game.pass = 0;
-          game.addToRecord({ player, pos: { x, y } });
-          if (this.kos.length) helper.clearKo.call(this);
-          point.makeMove(game);
-          game.turn *= -1;
-          success = true;
-        }
+      let game = this;
+      
+      if (x === 0) return game.submitPass(player);
+
+      // if checkMove has not been run, determine legality
+      if (!game.move) {
+        game = game.checkMove({ player, pos: { x, y } });
+      }
+      if (
+        // if move is legal
+        // ? unclear if checking move values is beneficial to prevent race conditions
+        game.move &&
+        game.move.player === player &&
+        game.move.pos.x === x &&
+        game.move.pos.y
+      ) {
+        const point = game.boardState[`${x}-${y}`];
+        game.pass = 0;
+        // allows for recording of prior move on game record
+        game.addToRecord(game.move);
+        if (game.kos.length) helper.clearKo.call(game);
+        point.makeMove(game);
+        game.turn *= -1;
+        success = true;
       }
       game.boardState = getBoardState(game);
+      // remove move attribute to prevent duplicate moves
+      delete game.move;
       return { ...game, legalMoves: getLegalMoves(game), success };
     },
 
@@ -389,6 +424,14 @@ const Game = ({ gameData = {}, gameRecord = [] } = {}) => {
         this.playerState.bScore - (this.playerState.wScore + this.komi);
       return { ...this, score, winner: score > 0 ? 1 : -1 };
     },
+
+    // for playing historic games
+    manualEnd: function ({ winner, score }) {
+      this.turn = 0;
+      this.winner = winner;
+      this.score = score;
+      return this;
+    },
   };
 };
 

packages/server/services/gameServices.js

@@ -7,11 +7,33 @@ const GameService = ({ moveQueries, gameQueries }) => {
   };
   const gamesInProgress = {};
 
+  const storeMove = (gameId) => async ({ player, pos: { x, y } }) => {
+    let move = { player, pos: { x, y } };
+    try {
+      if (moveQueries) {
+        const { id } = await moveQueries.addMove({
+          gameId,
+          player,
+          x,
+          y,
+          gameRecord: true,
+          priorMove: null,
+        });
+        move.id = id;
+        move.success = true;
+      }
+    } catch (e) {
+      console.log(e);
+      move.success = false;
+    } finally {
+      return move;
+    }
+  };
+
   return {
     initGame({ id, gameRecord = [], ...gameData }) {
       if (gamesInProgress[id]) return this.getDataForUI(id);
       if (gameRecord.length) {
-        console.log("here");
         gamesInProgress[id] = Game({ gameData, gameRecord });
       } else {
         gamesInProgress[id] = Game({ gameData }).initGame();
@@ -32,6 +54,7 @@ const GameService = ({ moveQueries, gameQueries }) => {
           return { message: "error restoring game" };
         }
       }
+      gamesInProgress[id] = await gamesInProgress[id].checkMove(move);
       gamesInProgress[id] = gamesInProgress[id].makeMove(move);
       if (gamesInProgress[id].success === false)
         return { message: "illegal move" };
@@ -73,6 +96,7 @@ const GameService = ({ moveQueries, gameQueries }) => {
     },
 
     resign: ({ id, player }) => {
+      // add resign gamesQueries
       return gamesInProgress[id].submitResign(player).getMeta();
     },
 
@@ -108,9 +132,19 @@ const GameService = ({ moveQueries, gameQueries }) => {
 
     async endGame({ id }) {
       gamesInProgress[id] = gamesInProgress[id].endGame();
+      const { winner, score, playerState } = gamesInProgress[id];
+      const { bCaptures, wCaptures } = playerState;
+      const winType = winner > 0 ? "B+" : "W+";
       try {
         if (gameQueries) {
-          // TODO add end game query
+          const result = await gameQueries.endGame({
+            id,
+            winType,
+            score,
+            bCaptures,
+            wCaptures,
+          });
+          console.log(result);
         }
       } catch (e) {
         console.log(e);

packages/server/socket.js

@@ -1,4 +1,4 @@
-// TODO const someSocketLogic = require('./middleware/socketssockets/...');
+// TODO const someSocketLogic = require('./middleware/sockets/...');
 const socketIO = require("socket.io");
 const io = socketIO({ cookie: false });
 
@@ -24,8 +24,23 @@ io.on("connection", async (socket) => {
       socket.on("connect_game", (data) => {
         const game = `game-${data.game.id}`;
         socket.join(game, async () => {
+          // TODO move this logic into game service
+          const gameData = await gameQueries.findGameById(data.game.id);
+          const convertWinType = (winType) => {
+            if (winType.includes("B")) return 1;
+            if (winType.includes("W")) return -1;
+            if (winType.includes("0")) return "D";
+            return "?";
+          };
+          gameData.winner = gameData.win_type
+            ? convertWinType(gameData.win_type)
+            : 0;
           const gameRecord = await moveQueries.findGameRecord(data.game.id);
-          await gameServices.initGame({ id: data.game.id, gameRecord });
+          await gameServices.initGame({
+            id: data.game.id,
+            gameRecord,
+            gameData,
+          });
           const { board, ...meta } = await gameServices.getDataForUI(
             data.game.id
           );
@@ -37,7 +52,6 @@ io.on("connection", async (socket) => {
       socket.on("make_move", async (data) => {
         const { user, move, board, game, room } = data;
         const gameNsp = `game-${data.game.id}`;
-
         try {
           const { board, message, ...meta } = await gameServices.makeMove({
             id: data.game.id,