open-vault/ui/lib/core/addon/mixins/replication-actions.js
Matthew Irish c642b814d4
move replication-actions into core addon so that secondary recovery works (#7226)
* move replication-actions component into core addon so that secondary recovery works

* move the rest of replication action components
2019-08-05 14:05:32 -05:00

109 lines
2.9 KiB
JavaScript

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() {},
submitHandler(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)) {
newData[key] = val;
}
return newData;
}, {});
delete data.replicationMode;
}
return 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);
}
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') {
this.setProperties({
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');
}
}
try {
yield cluster.reload();
} catch (e) {
// no error handling here
}
cluster.rollbackAttributes();
if (action === 'disable') {
yield this.onDisable();
}
if (action === 'enable') {
yield this.onEnable(replicationMode);
}
if (mode === 'secondary' && replicationMode === 'dr') {
yield this.router.transitionTo('vault.cluster');
}
}).drop(),
submitError(e) {
if (e.errors) {
this.set('errors', e.errors);
} else {
throw e;
}
},
});