summaryrefslogtreecommitdiff
path: root/frontend/src/sagas/gameBrowser.js
diff options
context:
space:
mode:
Diffstat (limited to 'frontend/src/sagas/gameBrowser.js')
-rw-r--r--frontend/src/sagas/gameBrowser.js33
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 }),
+ {},
+ ]);
}
}
bgstack15