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 }) {
  while (true) {
    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');
  while (true) {
    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;