d40dd99d20
* ui: Use Datasource for loading related data in ACLs area * ui: Use more manual cleanup for Controller event-sources * Update reconcile to use nspace and add SyncTime to role/policy * Use the correct value for nspace and dc (the one from the item itself) * Remove the // check, we no longer need it. Add some TODO
55 lines
1.9 KiB
JavaScript
55 lines
1.9 KiB
JavaScript
import Service, { inject as service } from '@ember/service';
|
|
import { get } from '@ember/object';
|
|
|
|
export default Service.extend({
|
|
datacenters: service('repository/dc'),
|
|
namespaces: service('repository/nspace'),
|
|
token: service('repository/token'),
|
|
policies: service('repository/policy'),
|
|
policy: service('repository/policy'),
|
|
roles: service('repository/role'),
|
|
type: service('data-source/protocols/http/blocking'),
|
|
source: function(src, configuration) {
|
|
// TODO: Consider adding/requiring nspace, dc, model, action, ...rest
|
|
const [, nspace, dc, model, ...rest] = src.split('/');
|
|
// TODO: Consider throwing if we have an empty nspace or dc
|
|
// we are going to use '*' for 'all' when we need that
|
|
// and an empty value is the same as 'default'
|
|
// reasoning for potentially doing it here is, uri's should
|
|
// always be complete, they should never have things like '///model'
|
|
let find;
|
|
const repo = this[model];
|
|
if (typeof repo.reconcile === 'function') {
|
|
configuration.createEvent = function(result = {}, configuration) {
|
|
const event = {
|
|
type: 'message',
|
|
data: result,
|
|
};
|
|
if (repo.reconcile === 'function') {
|
|
repo.reconcile(get(event, 'data.meta') || {});
|
|
}
|
|
return event;
|
|
};
|
|
}
|
|
switch (model) {
|
|
case 'datacenters':
|
|
find = configuration => repo.findAll(configuration);
|
|
break;
|
|
case 'namespaces':
|
|
find = configuration => repo.findAll(configuration);
|
|
break;
|
|
case 'token':
|
|
find = configuration => repo.self(rest[1], dc);
|
|
break;
|
|
case 'roles':
|
|
case 'policies':
|
|
find = configuration => repo.findAllByDatacenter(dc, nspace, configuration);
|
|
break;
|
|
case 'policy':
|
|
find = configuration => repo.findBySlug(rest[0], dc, nspace, configuration);
|
|
break;
|
|
}
|
|
return this.type.source(find, configuration);
|
|
},
|
|
});
|