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;