1 files changed, 66 insertions, 0 deletions
diff --git a/frontend/src/sagas/gameBrowser.js b/frontend/src/sagas/gameBrowser.js
new file mode 100644
index 00000000..19d52df9
--- /dev/null
+++ b/frontend/src/sagas/gameBrowser.js
@@ -0,0 +1,66 @@
+import { call, put, take } from 'redux-saga/effects'
+import { eventChannel } from 'redux-saga'
+import { fromJS } from 'immutable'
+import { push } from 'react-router-redux'
+
+import { actions, types } from '../redux/game'
+
+function gameBrowserChannel(socket) {
+  return eventChannel(emit => {
+
+    const makeHandler = type => event => {
+      const response = fromJS(JSON.parse(event.body))
+      emit({ type, response })
+    }
+
+    const newGame = socket.subscribe('/topic/games', makeHandler(types.CREATE_OR_UPDATE_GAMES))
+    const joinGame = socket.subscribe('/user/queue/lobby/joined', makeHandler(types.JOIN_GAME))
+
+    const unsubscribe = () => {
+      newGame.unsubscribe()
+      joinGame.unsubscribe()
+    }
+
+    return unsubscribe
+  })
+}
+
+export function* watchGames({ socket }) {
+  const socketChannel = gameBrowserChannel(socket)
+
+  try {
+    while (true) {
+      const { type, response } = yield take(socketChannel)
+
+      switch (type) {
+        case types.CREATE_OR_UPDATE_GAMES:
+          yield put(actions.createOrUpdateGame(response))
+          break;
+        case types.JOIN_GAME:
+          yield put(actions.joinGame(response))
+          socketChannel.close();
+          yield put(push(`/lobby/${response.id}`))
+          break;
+        default:
+          console.error('Unknown type')
+      }
+    }
+  } finally {
+    console.info('gameBrowserChannel closed')
+  }
+}
+
+export function* createGame({ socket }) {
+  const { name } = yield take(types.CREATE_GAME)
+
+  socket.send("/app/lobby/create", JSON.stringify({ gameName: name }), {})
+}
+
+export function* gameBrowserSaga(socketConnection) {
+  yield [
+    call(watchGames, socketConnection),
+    call(createGame, socketConnection)
+  ]
+}
+
+export default gameBrowserSaga