import { call, put, takeLatest } from 'redux-saga/effects';
import { notification } from 'antd';
import * as actionTypes from './actionTypes';
import * as actions from './actions';

import Connection from 'backend/common/store-manager/connection';
import AwsService from 'backend/services/aws/aws.service';
import VersionService from 'backend/services/version/version.service';
import KeyManagerService from 'backend/services/key-manager/key-manager.service';
import AccountService from 'backend/services/account/account.service';

function* loadMnemonicSaga() {
  try {
    const keyManagerService = new KeyManagerService();
    const mnemonicPhrase = yield call([keyManagerService, 'mnemonicGenerate']);
    yield put(actions.keyvaultLoadMnemonicSuccess(mnemonicPhrase));
  } catch (error) {
    yield put(actions.keyvaultLoadMnemonicFailure(error));
    notification.error({ message: 'Error', description: error.message });
  }
}

function* saveMnemonicSaga(action) {
  try {
    const { payload: { mnemonic } } = action;
    const keyManagerService = new KeyManagerService();
    const seed = yield call([keyManagerService, 'seedFromMnemonicGenerate'], mnemonic);
    yield Connection.db().set('seed', seed);
    yield put(actions.keyvaultSaveMnemonicSuccess());
  }
  catch (error) {
    if (error) {
      yield put(actions.keyvaultSaveMnemonicFailure(error));
      notification.error({ message: 'Error', description: error.message });
    }
  }
}

function* loadLatestVersionSaga() {
  try {
    const versionService = new VersionService();
    const latestVersion = yield call([versionService, 'getLatestKeyVaultVersion']);
    yield put(actions.keyvaultLoadLatestVersionSuccess(latestVersion));
  } catch (error) {
    yield put(actions.keyvaultLoadLatestVersionFailure(error));
    notification.error({ message: 'Error', description: error.message });
  }
}

function* validatePassphraseSaga() {
  try {
    yield put(actions.keyvaultValidatePassphraseSuccess());
  }
  catch (error) {
    yield put(actions.keyvaultValidatePassphraseFailure(error));
    notification.error({ message: 'Error', description: error.message });
  }
}

function* checkRecoveryCredentialsSaga(action) {
  try {
    const { payload } = action;
    const accountService = new AccountService();
    yield call([accountService, 'recovery'], payload);
    yield put(actions.validateRecoveryCredentialsSuccess());
  }
  catch (error) {
    yield put(actions.validateRecoveryCredentialsFailure(error));
  }
}

function* validateAwsKeysSaga(action) {
  try {
    const { payload } = action;
    yield call([AwsService, 'validateAWSCredentials'], payload);
    yield put(actions.validateAwsKeysSuccess());
  }
  catch (error) {
    yield put(actions.validateAwsKeysFailure(error));
  }
}

export default function* keyVaultManagementSaga() {
  yield takeLatest(actionTypes.KEYVAULT_LOAD_MNEMONIC, loadMnemonicSaga);
  yield takeLatest(actionTypes.KEYVAULT_SAVE_MNEMONIC, saveMnemonicSaga);
  yield takeLatest(actionTypes.KEYVAULT_LOAD_LATEST_VERSION, loadLatestVersionSaga);
  yield takeLatest(actionTypes.KEYVAULT_VALIDATE_PASSPHRASE, validatePassphraseSaga);
  yield takeLatest(actionTypes.VALIDATE_RECOVERY_CREDENTIALS, checkRecoveryCredentialsSaga);
  yield takeLatest(actionTypes.VALIDATE_AWS_KEYS, validateAwsKeysSaga);
}