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}) {
  while (true) {
    const {gameName} = yield take(types.REQUEST_CREATE_GAME)
    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}), {}])
  }
}

function *gameBrowserSaga(socketConnection) {
  yield [
    call(watchGames, socketConnection),
    call(watchLobbyJoined, socketConnection),
    call(createGame, socketConnection),
    call(joinGame, socketConnection)
  ]
}

export default gameBrowserSaga