import { inject as service } from '@ember/service';
import { or } from '@ember/object/computed';
import { isPresent } from '@ember/utils';
import Mixin from '@ember/object/mixin';
import { task } from 'ember-concurrency';
export default Mixin.create({
store: service(),
router: service(),
loading: or('save.isRunning', 'submitSuccess.isRunning'),
onEnable() {},
onDisable() {},
onPromote() {},
submitHandler: task(function*(action, clusterMode, data, event) {
let replicationMode = (data && data.replicationMode) || this.get('replicationMode');
if (event && event.preventDefault) {
event.preventDefault();
}
this.setProperties({
errors: [],
});
if (data) {
data = Object.keys(data).reduce((newData, key) => {
var val = data[key];
if (isPresent(val)) {
if (key === 'dr_operation_token_primary' || key === 'dr_operation_token_promote') {
newData['dr_operation_token'] = val;
} else {
newData[key] = val;
return newData;
}, {});
delete data.replicationMode;
return yield this.save.perform(action, replicationMode, clusterMode, data);
}),
save: task(function*(action, replicationMode, clusterMode, data) {
let resp;
try {
resp = yield this.get('store')
.adapterFor('cluster')
.replicationAction(action, replicationMode, clusterMode, data);
} catch (e) {
return this.submitError(e);
return yield this.submitSuccess.perform(resp, action, clusterMode);
}).drop(),
submitSuccess: task(function*(resp, action, mode) {
const cluster = this.get('cluster');
const replicationMode = this.get('selectedReplicationMode') || this.get('replicationMode');
const store = this.get('store');
if (!cluster) {
return;
if (resp && resp.wrap_info) {
this.set('token', resp.wrap_info.token);
if (action === 'secondary-token') {
loading: false,
primary_api_addr: null,
primary_cluster_addr: null,
return cluster;
if (this.reset) {
this.reset();
if (action === 'enable') {
// do something to show model is pending
cluster.set(
replicationMode,
store.createFragment('replication-attributes', {
mode: 'bootstrapping',
})
);
if (mode === 'secondary' && replicationMode === 'performance') {
// if we're enabing a secondary, there could be mount filtering,
// so we should unload all of the backends
store.unloadAll('secret-engine');
yield cluster.reload();
// no error handling here
cluster.rollbackAttributes();
if (action === 'disable') {
yield this.onDisable();
if (action === 'promote') {
yield this.onPromote();
/// onEnable is a method available only to route vault.cluster.replication.index
// if action 'enable' is called from vault.cluster.replication.mode.index this method is not called
yield this.onEnable(replicationMode, mode);
submitError(e) {
if (e.errors) {
this.set('errors', e.errors);
throw e;
},