144 lines
3.6 KiB
JavaScript
144 lines
3.6 KiB
JavaScript
import { Actions } from 'thundercats';
|
|
import store from 'store';
|
|
import debugFactory from 'debug';
|
|
import { jsonp$ } from '../../../../utils/jsonp$';
|
|
|
|
const debug = debugFactory('freecc:jobs:actions');
|
|
const assign = Object.assign;
|
|
|
|
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 ?
|
|
assign({}, oldState, { currentJob: foundJob }) :
|
|
null;
|
|
};
|
|
},
|
|
setError: null,
|
|
getJob: null,
|
|
saveJobToDb: null,
|
|
getJobs(params) {
|
|
return { params };
|
|
},
|
|
openModal() {
|
|
return { showModal: true };
|
|
},
|
|
closeModal() {
|
|
return { showModal: false };
|
|
},
|
|
handleForm(value) {
|
|
return {
|
|
transform(oldState) {
|
|
const { form } = oldState;
|
|
const newState = assign({}, oldState);
|
|
newState.form = assign(
|
|
{},
|
|
form,
|
|
value
|
|
);
|
|
return newState;
|
|
}
|
|
};
|
|
},
|
|
saveForm: null,
|
|
getSavedForm: null,
|
|
clearSavedForm: null,
|
|
setForm(form) {
|
|
return { form };
|
|
},
|
|
getFollowers: null,
|
|
setFollowersCount(numOfFollowers) {
|
|
return { numOfFollowers };
|
|
}
|
|
})
|
|
.refs({ displayName: 'JobActions' })
|
|
.init(({ instance: jobActions, args: [cat, 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 });
|
|
}
|
|
if (job) {
|
|
jobActions.setJobs({ currentJob: job });
|
|
}
|
|
jobActions.setJobs({});
|
|
});
|
|
});
|
|
|
|
jobActions.saveForm.subscribe((form) => {
|
|
store.set('newJob', form);
|
|
});
|
|
|
|
jobActions.getSavedForm.subscribe(() => {
|
|
const job = store.get('newJob');
|
|
if (job && !Array.isArray(job) && typeof job === 'object') {
|
|
jobActions.setForm(job);
|
|
}
|
|
});
|
|
|
|
jobActions.clearSavedForm.subscribe(() => {
|
|
store.remove('newJob');
|
|
});
|
|
|
|
jobActions.saveJobToDb.subscribe(({ goTo, job }) => {
|
|
const appActions = cat.getActions('appActions');
|
|
services.create('jobs', { job }, null, (err, job) => {
|
|
if (err) {
|
|
debug('job services experienced an issue', err);
|
|
return jobActions.setError(err);
|
|
}
|
|
jobActions.setJobs({ job });
|
|
appActions.goTo(goTo);
|
|
});
|
|
});
|
|
|
|
jobActions.getFollowers.subscribe(() => {
|
|
const url = 'https://cdn.syndication.twimg.com/widgets/followbutton/' +
|
|
'info.json?lang=en&screen_names=CamperJobs' +
|
|
'&callback=JSONPCallback';
|
|
|
|
jsonp$(url)
|
|
.map(({ response }) => {
|
|
return response[0]['followers_count'];
|
|
})
|
|
.subscribe(
|
|
count => jobActions.setFollowersCount(count),
|
|
err => jobActions.setError(err)
|
|
);
|
|
});
|
|
|
|
return jobActions;
|
|
});
|