node-go/packages/server/services/gameServices.js

const Game = require("./Game").Game;

const GameService = ({ moveQueries, gameQueries }) => {
  const storeGame = (game) => {
    gamesInProgress[game.id] = Game(game);
    return gamesInProgress[game.id];
  };
  const gamesInProgress = {};

  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();
      }
      return this.getDataForUI(id);
    },

    async makeMove({ id, move }) {
      // check cache
      if (!gamesInProgress[id]) {
        try {
          let gameRecord;
          if (moveQueries) {
            gameRecord = await moveQueries.findGameRecord(id);
          }
          storeGame({ id, gameRecord }).initGame();
        } catch {
          return { message: "error restoring game" };
        }
      }
      gamesInProgress[id] = gamesInProgress[id].makeMove(move);
      if (gamesInProgress[id].success === false)
        return { message: "illegal move" };
      try {
        if (moveQueries) {
          const priorMove = gamesInProgress[id].gameRecord.length;
          const moveInsert = {
            gameId: id,
            player: move.player,
            x: move.pos.x,
            y: move.pos.y,
            gameRecord: true,
            priorMove,
          };
          let moveDbResult;
          moveDbResult = await moveQueries.addMove(moveInsert);
        }
      } catch {
        gamesInProgress[id].returnToMove(-1);
      } finally {
        return this.getDataForUI(id);
      }
    },

    getDataForUI: (id) => {
      return {
        board: gamesInProgress[id].legalMoves,
        territory: gamesInProgress[id].territory,
        ...gamesInProgress[id].getMeta(),
      };
    },

    dropGame: (id) => {
      return { message: `${delete gamesInProgress[id]}` };
    },

    getAllGames: () => {
      return gamesInProgress;
    },

    resign: ({ id, player }) => {
      return gamesInProgress[id].submitResign(player).getMeta();
    },

    async pass({ id, player }) {
      gamesInProgress[id] = gamesInProgress[id].submitPass(player);
      if (gamesInProgress[id].success === false)
        return { message: "illegal move" };
      try {
        if (moveQueries) {
          const priorMove = gamesInProgress[id].gameRecord.length;
          const movePass = {
            gameId: id,
            player,
            x: 0,
            y: 0,
            gameRecord: true,
            priorMove,
          };
          let moveDbResult;
          moveDbResult = await moveQueries.addMove(movePass);
        }
      } catch {
        gamesInProgress[id].returnToMove(-1);
      } finally {
        return this.getDataForUI(id);
      }
    },

    toggleTerritory({ id, point }) {
      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);
    },
  };
};

module.exports = GameService;