1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
import { call, put, take, apply } from 'redux-saga/effects'
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 { 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')
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(gameActions.updateGames(normGameList.entities.games || {}))
}
} finally {
yield apply(gamesChannel, gamesChannel.close)
}
}
function *watchLobbyJoined({socket}) {
const joinedLobbyChannel = yield call(createSubscriptionChannel, socket, '/user/queue/lobby/joined')
try {
const joinedLobby = yield take(joinedLobbyChannel)
const normalized = normalize(joinedLobby, gameSchema)
const gameId = normalized.result
yield put(playerActions.updatePlayers(normalized.entities.players))
yield put(gameActions.updateGames(normalized.entities.games))
yield put(gameActions.enterLobby(normalized.entities.games[gameId]))
yield put(push(`/lobby/${gameId}`))
} finally {
yield apply(joinedLobbyChannel, joinedLobbyChannel.close)
}
}
function *createGame({socket}) {
const {gameName} = yield take(types.REQUEST_CREATE_GAME)
yield apply(socket, socket.send, ['/app/lobby/create', JSON.stringify({gameName}), {}])
}
function *joinGame({socket}) {
const {gameId} = yield take(types.REQUEST_JOIN_GAME)
yield apply(socket, socket.send, ['/app/lobby/join', JSON.stringify({gameId}), {}])
}
function *gameBrowserSaga(socketConnection) {
yield [
call(watchGames, socketConnection),
call(watchLobbyJoined, socketConnection),
call(createGame, socketConnection),
call(joinGame, socketConnection)
]
}
export default gameBrowserSaga
|
