81 lines
2.0 KiB
JavaScript
81 lines
2.0 KiB
JavaScript
import { inject as service } from '@ember/service';
|
|
import Watchable from './watchable';
|
|
|
|
export default Watchable.extend({
|
|
system: service(),
|
|
|
|
findAll() {
|
|
const namespace = this.get('system.activeNamespace');
|
|
return this._super(...arguments).then(data => {
|
|
data.forEach(job => {
|
|
job.Namespace = namespace ? namespace.get('id') : 'default';
|
|
});
|
|
return data;
|
|
});
|
|
},
|
|
|
|
findRecord(store, type, id, snapshot) {
|
|
const [, namespace] = JSON.parse(id);
|
|
const namespaceQuery = namespace && namespace !== 'default' ? { namespace } : {};
|
|
|
|
return this._super(store, type, id, snapshot, namespaceQuery);
|
|
},
|
|
|
|
urlForFindAll() {
|
|
const url = this._super(...arguments);
|
|
const namespace = this.get('system.activeNamespace.id');
|
|
return associateNamespace(url, namespace);
|
|
},
|
|
|
|
urlForFindRecord(id, type, hash) {
|
|
const [name, namespace] = JSON.parse(id);
|
|
let url = this._super(name, type, hash);
|
|
return associateNamespace(url, namespace);
|
|
},
|
|
|
|
xhrKey(url, method, options = {}) {
|
|
const plainKey = this._super(...arguments);
|
|
const namespace = options.data && options.data.namespace;
|
|
return associateNamespace(plainKey, namespace);
|
|
},
|
|
|
|
relationshipFallbackLinks: {
|
|
summary: '/summary',
|
|
},
|
|
|
|
fetchRawDefinition(job) {
|
|
const url = this.urlForFindRecord(job.get('id'), 'job');
|
|
return this.ajax(url, 'GET');
|
|
},
|
|
|
|
forcePeriodic(job) {
|
|
if (job.get('periodic')) {
|
|
const url = addToPath(this.urlForFindRecord(job.get('id'), 'job'), '/periodic/force');
|
|
return this.ajax(url, 'POST');
|
|
}
|
|
},
|
|
|
|
stop(job) {
|
|
const url = this.urlForFindRecord(job.get('id'), 'job');
|
|
return this.ajax(url, 'DELETE');
|
|
},
|
|
});
|
|
|
|
function associateNamespace(url, namespace) {
|
|
if (namespace && namespace !== 'default') {
|
|
url += `?namespace=${namespace}`;
|
|
}
|
|
return url;
|
|
}
|
|
|
|
function addToPath(url, extension = '') {
|
|
const [path, params] = url.split('?');
|
|
let newUrl = `${path}${extension}`;
|
|
|
|
if (params) {
|
|
newUrl += `?${params}`;
|
|
}
|
|
|
|
return newUrl;
|
|
}
|