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
63
64
65
66
67
68
69
70
71
72
73
|
import { call, put, take, apply } from 'redux-saga/effects'
import { eventChannel } from 'redux-saga'
import { push } from 'react-router-redux'
import { normalize } from 'normalizr'
import { game, gameList } from '../schemas/games'
import { actions as gameActions, types } from '../redux/games'
import { actions as playerActions } from '../redux/players'
function gameBrowserChannel(socket) {
return eventChannel(emit => {
const makeHandler = type => event => {
const response = JSON.parse(event.body)
emit({type, response})
}
const newGame = socket.subscribe('/topic/games', makeHandler(types.UPDATE_GAMES))
const joinGame = socket.subscribe('/user/queue/lobby/joined', makeHandler(types.ENTER_LOBBY))
return () => {
newGame.unsubscribe()
joinGame.unsubscribe()
}
})
}
export function *watchGames({socket}) {
const socketChannel = gameBrowserChannel(socket)
try {
while (true) {
const {type, response} = yield take(socketChannel)
switch (type) {
case types.UPDATE_GAMES:
const normGameList = normalize(response, gameList)
yield put(playerActions.updatePlayers(normGameList.entities.players || {}))
yield put(gameActions.updateGames(normGameList.entities.games || {}))
break
case types.ENTER_LOBBY:
const normGame = normalize(response, game)
yield put(gameActions.enterLobby(normGame.entities.games[normGame.result]))
socketChannel.close()
yield put(push('/lobby'))
break
default:
console.error('Unknown type')
}
}
} finally {
console.info('gameBrowserChannel closed')
}
}
export function *createGame({socket}) {
const {gameName} = yield take(types.REQUEST_CREATE_GAME)
yield apply(socket, socket.send, ['/app/lobby/create', JSON.stringify({gameName}), {}])
}
export function *joinGame({socket}) {
const {gameId} = yield take(types.REQUEST_JOIN_GAME)
yield apply(socket, socket.send, ['/app/lobby/join', JSON.stringify({gameId}), {}])
}
export function *gameBrowserSaga(socketConnection) {
yield [call(watchGames, socketConnection), call(createGame, socketConnection), call(joinGame, socketConnection)]
}
export default gameBrowserSaga
|
