mirror of
https://github.com/hashicorp/vault.git
synced 2025-08-19 21:51:09 +02:00
94b64a37e3
* Add replication mirage handler * Add test with skipped failed assertion * Use component-calculated attrsForCurrentMode instead of cluster.replicationAttrs which wasn't triggering component updates * assert previously-skipped assertion * Add changelog
95 lines
2.3 KiB
JavaScript
95 lines
2.3 KiB
JavaScript
/**
|
|
* Copyright (c) HashiCorp, Inc.
|
|
* SPDX-License-Identifier: BUSL-1.1
|
|
*/
|
|
|
|
import { service } from '@ember/service';
|
|
import { computed } from '@ember/object';
|
|
import Component from '@ember/component';
|
|
import decodeConfigFromJWT from 'replication/utils/decode-config-from-jwt';
|
|
import ReplicationActions from 'core/mixins/replication-actions';
|
|
import { task } from 'ember-concurrency';
|
|
import { waitFor } from '@ember/test-waiters';
|
|
|
|
const DEFAULTS = {
|
|
token: null,
|
|
id: null,
|
|
loading: false,
|
|
errors: null,
|
|
primary_api_addr: null,
|
|
primary_cluster_addr: null,
|
|
ca_file: null,
|
|
ca_path: null,
|
|
};
|
|
|
|
export default Component.extend(ReplicationActions, DEFAULTS, {
|
|
replicationMode: 'dr',
|
|
mode: 'primary',
|
|
version: service(),
|
|
rm: service('replication-mode'),
|
|
didReceiveAttrs() {
|
|
this._super(...arguments);
|
|
const initialReplicationMode = this.initialReplicationMode;
|
|
if (initialReplicationMode) {
|
|
this.set('replicationMode', initialReplicationMode);
|
|
}
|
|
},
|
|
showModeSummary: false,
|
|
initialReplicationMode: null,
|
|
cluster: null,
|
|
|
|
attrsForCurrentMode: computed('cluster', 'rm.mode', function () {
|
|
return this.cluster[this.rm.mode];
|
|
}),
|
|
|
|
tokenIncludesAPIAddr: computed('token', function () {
|
|
const config = decodeConfigFromJWT(this.token);
|
|
return config && config.addr ? true : false;
|
|
}),
|
|
|
|
disallowEnable: computed(
|
|
'replicationMode',
|
|
'version.hasPerfReplication',
|
|
'mode',
|
|
'tokenIncludesAPIAddr',
|
|
'primary_api_addr',
|
|
function () {
|
|
const inculdesAPIAddr = this.tokenIncludesAPIAddr;
|
|
if (this.replicationMode === 'performance' && this.version.hasPerfReplication === false) {
|
|
return true;
|
|
}
|
|
if (this.mode !== 'secondary' || inculdesAPIAddr || (!inculdesAPIAddr && this.primary_api_addr)) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
),
|
|
|
|
reset() {
|
|
this.setProperties(DEFAULTS);
|
|
},
|
|
|
|
submit: task(
|
|
waitFor(function* () {
|
|
try {
|
|
yield this.submitHandler.perform(...arguments);
|
|
} catch (e) {
|
|
// do not handle error
|
|
}
|
|
})
|
|
),
|
|
actions: {
|
|
onSubmit(/*action, mode, data, event*/) {
|
|
this.submit.perform(...arguments);
|
|
},
|
|
|
|
clear() {
|
|
this.reset();
|
|
this.setProperties({
|
|
token: null,
|
|
id: null,
|
|
});
|
|
},
|
|
},
|
|
});
|