diff options
Diffstat (limited to 'frontend/src/sagas/gameBrowser.js')
-rw-r--r-- | frontend/src/sagas/gameBrowser.js | 33 |
1 files changed, 27 insertions, 6 deletions
diff --git a/frontend/src/sagas/gameBrowser.js b/frontend/src/sagas/gameBrowser.js index 5492107a..dd916df9 100644 --- a/frontend/src/sagas/gameBrowser.js +++ b/frontend/src/sagas/gameBrowser.js @@ -3,19 +3,28 @@ import { createSubscriptionChannel } from '../utils/websocket'; import { push } from 'react-router-redux'; import { normalize } from 'normalizr'; -import { game as gameSchema, gameList as gameListSchema } from '../schemas/games'; +import { + game as gameSchema, + gameList as gameListSchema, +} from '../schemas/games'; import { actions as gameActions, types } from '../redux/games'; import { actions as playerActions } from '../redux/players'; function* watchGames({ socket }) { - const gamesChannel = yield call(createSubscriptionChannel, socket, '/topic/games'); + const gamesChannel = yield call( + createSubscriptionChannel, + socket, + '/topic/games' + ); try { while (true) { const gameList = yield take(gamesChannel); const normGameList = normalize(gameList, gameListSchema); // for an empty game array, there is no players/games entity maps - yield put(playerActions.updatePlayers(normGameList.entities.players || {})); + yield put( + playerActions.updatePlayers(normGameList.entities.players || {}) + ); yield put(gameActions.updateGames(normGameList.entities.games || {})); } } finally { @@ -24,7 +33,11 @@ function* watchGames({ socket }) { } function* watchLobbyJoined({ socket }) { - const joinedLobbyChannel = yield call(createSubscriptionChannel, socket, '/user/queue/lobby/joined'); + const joinedLobbyChannel = yield call( + createSubscriptionChannel, + socket, + '/user/queue/lobby/joined' + ); try { const joinedLobby = yield take(joinedLobbyChannel); const normalized = normalize(joinedLobby, gameSchema); @@ -41,14 +54,22 @@ function* watchLobbyJoined({ socket }) { function* createGame({ socket }) { while (true) { const { gameName } = yield take(types.REQUEST_CREATE_GAME); - yield apply(socket, socket.send, ['/app/lobby/create', JSON.stringify({ gameName }), {}]); + yield apply(socket, socket.send, [ + '/app/lobby/create', + JSON.stringify({ gameName }), + {}, + ]); } } function* joinGame({ socket }) { while (true) { const { gameId } = yield take(types.REQUEST_JOIN_GAME); - yield apply(socket, socket.send, ['/app/lobby/join', JSON.stringify({ gameId }), {}]); + yield apply(socket, socket.send, [ + '/app/lobby/join', + JSON.stringify({ gameId }), + {}, + ]); } } |