62 lines
1.9 KiB
JavaScript
62 lines
1.9 KiB
JavaScript
import Service, { inject as service } from '@ember/service';
|
|
import { computed } from '@ember/object';
|
|
import PromiseObject from '../utils/classes/promise-object';
|
|
import { namespace } from '../adapters/application';
|
|
|
|
export default Service.extend({
|
|
token: service(),
|
|
store: service(),
|
|
|
|
leader: computed(function() {
|
|
const token = this.get('token');
|
|
|
|
return PromiseObject.create({
|
|
promise: token
|
|
.authorizedRequest(`/${namespace}/status/leader`)
|
|
.then(res => res.json())
|
|
.then(rpcAddr => ({ rpcAddr }))
|
|
.then(leader => {
|
|
// Dirty self so leader can be used as a dependent key
|
|
this.notifyPropertyChange('leader.rpcAddr');
|
|
return leader;
|
|
}),
|
|
});
|
|
}),
|
|
|
|
namespaces: computed(function() {
|
|
return this.get('store').findAll('namespace');
|
|
}),
|
|
|
|
shouldShowNamespaces: computed('namespaces.[]', function() {
|
|
const namespaces = this.get('namespaces').toArray();
|
|
return namespaces.length && namespaces.some(namespace => namespace.get('id') !== 'default');
|
|
}),
|
|
|
|
activeNamespace: computed('namespaces.[]', {
|
|
get() {
|
|
const namespaceId = window.localStorage.nomadActiveNamespace || 'default';
|
|
const namespace = this.get('namespaces').findBy('id', namespaceId);
|
|
|
|
if (namespace) {
|
|
return namespace;
|
|
}
|
|
|
|
// If the namespace is localStorage is no longer in the cluster, it needs to
|
|
// be cleared from localStorage
|
|
this.set('activeNamespace', null);
|
|
return this.get('namespaces').findBy('id', 'default');
|
|
},
|
|
set(key, value) {
|
|
if (value == null) {
|
|
window.localStorage.removeItem('nomadActiveNamespace');
|
|
} else if (typeof value === 'string') {
|
|
window.localStorage.nomadActiveNamespace = value;
|
|
return this.get('namespaces').findBy('id', value);
|
|
} else {
|
|
window.localStorage.nomadActiveNamespace = value.get('name');
|
|
return value;
|
|
}
|
|
},
|
|
}),
|
|
});
|