64 lines
1.7 KiB
JavaScript
64 lines
1.7 KiB
JavaScript
import { Actions } from 'thundercats';
|
|
import debugFactory from 'debug';
|
|
|
|
const debug = debugFactory('freecc:jobs:actions');
|
|
|
|
export default Actions({
|
|
setJobs: null,
|
|
// findJob assumes that the job is already in the list of jobs
|
|
findJob(id) {
|
|
return oldState => {
|
|
const { currentJob = {}, jobs = [] } = oldState;
|
|
// currentJob already set
|
|
// do nothing
|
|
if (currentJob.id === id) {
|
|
return null;
|
|
}
|
|
const foundJob = jobs.reduce((newJob, job) => {
|
|
if (job.id === id) {
|
|
return job;
|
|
}
|
|
return newJob;
|
|
}, null);
|
|
|
|
// if no job found this will be null which is a op noop
|
|
return foundJob ?
|
|
Object.assign({}, oldState, { currentJob: foundJob }) :
|
|
null;
|
|
};
|
|
},
|
|
setError: null,
|
|
getJob: null,
|
|
getJobs(params) {
|
|
return { params };
|
|
}
|
|
})
|
|
.refs({ displayName: 'JobActions' })
|
|
.init(({ instance: jobActions, args: [services] }) => {
|
|
jobActions.getJobs.subscribe(() => {
|
|
services.read('jobs', null, null, (err, jobs) => {
|
|
if (err) {
|
|
debug('job services experienced an issue', err);
|
|
return jobActions.setError({ err });
|
|
}
|
|
jobActions.setJobs({ jobs });
|
|
});
|
|
});
|
|
|
|
jobActions.getJob.subscribe(({ id, isPrimed }) => {
|
|
// job is already set, do nothing.
|
|
if (isPrimed) {
|
|
debug('job is primed');
|
|
return;
|
|
}
|
|
services.read('jobs', { id }, null, (err, job) => {
|
|
if (err) {
|
|
debug('job services experienced an issue', err);
|
|
return jobActions.setError({ err });
|
|
}
|
|
jobActions.setJobs({ currentJob: job });
|
|
});
|
|
});
|
|
return jobActions;
|
|
});
|