69 lines
1.5 KiB
JavaScript
69 lines
1.5 KiB
JavaScript
|
import Ember from 'ember';
|
||
|
|
import { task } from 'ember-concurrency';
|
||
|
|
|
||
|
|
const { Service, inject, computed } = Ember;
|
||
|
|
|
||
|
|
const hasFeature = featureKey => {
|
||
|
|
return computed('features', 'features.[]', function() {
|
||
|
|
const features = this.get('features');
|
||
|
|
if (!features) {
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
return features.includes(featureKey);
|
||
|
|
});
|
||
|
|
};
|
||
|
|
export default Service.extend({
|
||
|
|
_features: null,
|
||
|
|
features: computed.readOnly('_features'),
|
||
|
|
version: null,
|
||
|
|
store: inject.service(),
|
||
|
|
|
||
|
|
hasPerfReplication: hasFeature('Performance Replication'),
|
||
|
|
|
||
|
|
hasDRReplication: hasFeature('DR Replication'),
|
||
|
|
|
||
|
|
isEnterprise: computed.match('version', /\+\w+$/),
|
||
|
|
|
||
|
|
isOSS: computed.not('isEnterprise'),
|
||
|
|
|
||
|
|
setVersion(resp) {
|
||
|
|
this.set('version', resp.version);
|
||
|
|
},
|
||
|
|
|
||
|
|
setFeatures(resp) {
|
||
|
|
if (!resp.features) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.set('_features', resp.features);
|
||
|
|
},
|
||
|
|
|
||
|
|
getVersion: task(function*() {
|
||
|
|
if (this.get('version')) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
let response = yield this.get('store').adapterFor('cluster').health();
|
||
|
|
this.setVersion(response);
|
||
|
|
return;
|
||
|
|
}),
|
||
|
|
|
||
|
|
getFeatures: task(function*() {
|
||
|
|
if (this.get('features.length') || this.get('isOSS')) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
try {
|
||
|
|
let response = yield this.get('store').adapterFor('cluster').features();
|
||
|
|
this.setFeatures(response);
|
||
|
|
return;
|
||
|
|
} catch (err) {
|
||
|
|
throw err;
|
||
|
|
}
|
||
|
|
}).keepLatest(),
|
||
|
|
|
||
|
|
fetchVersion: function() {
|
||
|
|
return this.get('getVersion').perform();
|
||
|
|
},
|
||
|
|
fetchFeatures: function() {
|
||
|
|
return this.get('getFeatures').perform();
|
||
|
|
},
|
||
|
|
});
|