import { apply, call, put, take } from 'redux-saga/effects'
import { createSubscriptionChannel } from '../utils/websocket'
import { push } from 'react-router-redux'

import { actions, types } from '../redux/players'

function *sendUsername({ socket }) {
  const {username} = yield take(types.REQUEST_CHOOSE_USERNAME)

  yield apply(socket, socket.send, ['/app/chooseName', JSON.stringify({ playerName: username  })])
}

function *validateUsername({ socket }) {
  const usernameChannel = yield call(createSubscriptionChannel, socket, '/user/queue/nameChoice')
  const user = yield take(usernameChannel)
  yield put(actions.setCurrentPlayer(user))
  yield apply(usernameChannel, usernameChannel.close)
  yield put(push('/games'))
}

function *usernameChoiceSaga(wsConnection) {
  // TODO: Run sendUsername in loop when we have the ability to cancel saga on route change
  yield [
    call(sendUsername, wsConnection),
    call(validateUsername, wsConnection),
  ]
}

export default usernameChoiceSaga