71 lines
1.8 KiB
JavaScript
71 lines
1.8 KiB
JavaScript
|
import Component from '@ember/component';
|
||
|
|
import { inject as service } from '@ember/service';
|
||
|
|
import { computed } from '@ember/object';
|
||
|
|
import { task } from 'ember-concurrency';
|
||
|
|
import messageFromAdapterError from 'nomad-ui/utils/message-from-adapter-error';
|
||
|
|
import localStorageProperty from 'nomad-ui/utils/properties/local-storage';
|
||
|
|
|
||
|
|
export default Component.extend({
|
||
|
|
store: service(),
|
||
|
|
|
||
|
|
job: null,
|
||
|
|
onSubmit() {},
|
||
|
|
|
||
|
|
parseError: null,
|
||
|
|
planError: null,
|
||
|
|
runError: null,
|
||
|
|
|
||
|
|
planOutput: null,
|
||
|
|
|
||
|
|
showPlanMessage: localStorageProperty('nomadMessageJobPlan', true),
|
||
|
|
showEditorMessage: localStorageProperty('nomadMessageJobEditor', true),
|
||
|
|
|
||
|
|
stage: computed('planOutput', function() {
|
||
|
|
return this.get('planOutput') ? 'plan' : 'editor';
|
||
|
|
}),
|
||
|
|
|
||
|
|
plan: task(function*() {
|
||
|
|
this.reset();
|
||
|
|
|
||
|
|
try {
|
||
|
|
yield this.get('job').parse();
|
||
|
|
} catch (err) {
|
||
|
|
const error = messageFromAdapterError(err) || 'Could not parse input';
|
||
|
|
this.set('parseError', error);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
try {
|
||
|
|
yield this.get('job').plan();
|
||
|
|
const plan = this.get('store').peekRecord('job-plan', this.get('job.id'));
|
||
|
|
this.set('planOutput', plan);
|
||
|
|
} catch (err) {
|
||
|
|
const error = messageFromAdapterError(err) || 'Could not plan job';
|
||
|
|
this.set('planError', error);
|
||
|
|
}
|
||
|
|
}).drop(),
|
||
|
|
|
||
|
|
submit: task(function*() {
|
||
|
|
try {
|
||
|
|
yield this.get('job').run();
|
||
|
|
|
||
|
|
const id = this.get('job.plainId');
|
||
|
|
const namespace = this.get('job.namespace.name') || 'default';
|
||
|
|
|
||
|
|
this.reset();
|
||
|
|
|
||
|
|
// Treat the job as ephemeral and only provide ID parts.
|
||
|
|
this.get('onSubmit')(id, namespace);
|
||
|
|
} catch (err) {
|
||
|
|
const error = messageFromAdapterError(err) || 'Could not submit job';
|
||
|
|
this.set('runError', error);
|
||
|
|
}
|
||
|
|
}),
|
||
|
|
|
||
|
|
reset() {
|
||
|
|
this.set('planOutput', null);
|
||
|
|
this.set('planError', null);
|
||
|
|
this.set('parseError', null);
|
||
|
|
},
|
||
|
|
});
|