From a02576532dc325f4e6e8148235d10430ef6308cd Mon Sep 17 00:00:00 2001
From: Sorrel Bri <sorrel.bri.june@gmail.com>
Date: Sat, 2 May 2020 23:22:57 -0700
Subject: [PATCH] refactor server side socket for connection with new Game
 service

---
 packages/server/socket.js | 26 ++++++++++++++------------
 1 file changed, 14 insertions(+), 12 deletions(-)

diff --git a/packages/server/socket.js b/packages/server/socket.js
index 1a6c4e6..83d9a4b 100644
--- a/packages/server/socket.js
+++ b/packages/server/socket.js
@@ -5,41 +5,43 @@ const io = socketIO({ cookie: false });
 const gameQueries = require('./data/queries/game');
 const gameServices = require('./services/gameServices');
 
-io.on('connection', socket=> {
+io.on('connection', async socket=> {
   socket.emit('connected', {message: 'socket connected'});
-  socket.on('connect_room', data => {
+  socket.on('connect_room', async data => {
     if (data.user && data.user.email) {
       delete data.user.email;
     }
-    const room= data.room;
+    const room = data.room;
     const roomIo = io.of(room);
-    roomIo.on('connection', socket => {
+    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 
-          gameServices.initGame({id: data.game.id})
+          await gameServices.initGame({id: data.game.id})
           // ! end-temp
-          const gameData = await gameServices.getBoard(data.game.id);
+          const gameData = await gameServices.getDataForUI(data.game.id);
           io.of(room).to(game).emit('game_connected', gameData)
         });
       });
-      socket.on('make_move', data => {
-        
+      socket.on('make_move', async data => {
         const { user, move, board, game, room } = data;
         const gameNsp = `game-${data.game.id}`;
         
         try {
-          const updatedBoard = gameServices.makeMove(1, move);
+          const result =  await gameServices.makeMove({ id: 1, move });
+          console.log(result)
+          let socketAction = 'update_board';
+          if (result.message) socketAction = 'error';
           socket.join(gameNsp, () => {
-            io.of(room).to(gameNsp).emit('update_board', updatedBoard)
+            io.of(room).to(gameNsp).emit(socketAction, result)
           });
         }
-        catch (err) {
+        catch (e) {
           socket.join(gameNsp, () => {
-            io.of(room).to(gameNsp).emit('error', err)
+            io.of(room).to(gameNsp).emit('error', e)
           });
 
         }