node-go/packages/server/socket.js

// TODO const someSocketLogic = require('./middleware/socketssockets/...');
const socketIO = require('socket.io');
const io = socketIO({ cookie: false });

// const gameQueries = require('./data/queries/game');
const moveQueries = require('./data/queries/move');
const gameServices = require('./services/gameServices');

io.on('connection', async socket=> {
  socket.emit('connected', {message: 'socket connected'});
  socket.on('connect_room', async data => {
    if (data.user && data.user.email) {
      delete data.user.email;
    }
    const room = data.room;
    const roomIo = io.of(room);
    roomIo.on('connection', async socket => {
      socket.emit('connected')
      socket.emit('new_user', data);
      socket.on('connect_game', data => {
        const game = `game-${data.game.id}`;
        socket.join(game, async () => {
          // ! temp 
          const gameRecord = await moveQueries.findGameRecord(data.game.id);
          console.log(gameRecord)
          await gameServices.initGame({id: data.game.id, gameRecord})
          // ! end-temp
          const { board, ...meta } = await gameServices.getDataForUI(data.game.id);
          io.of(room).to(game).emit('game_connected', { board, meta });
        });
      });
      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: 1, move });
          const socketAction = message ? 'error' : 'update_board';
          socket.join(gameNsp, () => {
            io.of(room).to(gameNsp).emit(socketAction, { board, meta, message })
          });
        }
        catch (e) {
          console.log(e)
          socket.join(gameNsp, () => {
            io.of(room).to(gameNsp).emit('error', e)
          });

        }
      })
    });
  })
})

module.exports = {
  io
}