blob: 4d87c6cd24dc67ede8ddd8bab4cb723a7002a3c9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
const { Types } = require('mongoose');
const { Service } = require('feathers-mongoose');
const _ = require('lodash');
const cron = require('cron');
const Bluebird = require('bluebird');
const Model = require('./event.model.js');
const handleAttendClassJob = require('../../handlers');
const CronJob = cron.CronJob;
const handleTestJob = () => new Promise(res => setTimeout(res, 10000));
class Events extends Service {
async setup(app, path) {
this.jobs = [];
await this.rescheduleMissedEvents();
const job = new CronJob('*/10 * * * * *', () => this.updateJobs());
job.start();
}
startAllJobs() {
this.jobs.forEach(job => job.start());
}
stopAllJobs() {
this.jobs.forEach(job => job.stop());
}
async rescheduleMissedEvents() {
const missedEvents = await this.Model.findMissedEvents();
return Bluebird.map(missedEvents, event => event.save());
}
async updateJobs() {
// Reschedule missed events before we stop jobs to avoid
// accidentally stopping the job that has not triggered yet
// (if event schedule resonates with updateJobs schedule)
await this.rescheduleMissedEvents();
this.stopAllJobs();
const events = await this.Model.findNextEvents();
if (!events.length) this.log('No upcoming events.');
this.jobs = events.map(event => new CronJob(
event.schedule,
() => this.run(event._id)
));
this.startAllJobs();
}
log(message) {
const dateOpts = { timeStyle: 'medium', dateStyle: 'short' };
const timestamp = new Date().toLocaleString('en', dateOpts);
return console.log(`[${timestamp}] ${message}`);
}
async run(id) {
const event = await this.Model.findById(id);
event.lastRunAt = new Date();
event.setStatus('running')
try {
this.log(`Event ${event.name} started`)
await handleTestJob(event);
this.log(`Event ${event.name} ended`)
} catch (error) {
event.setStatus('failed')
}
if (event.status === 'running') {
event.setStatus('complete')
}
}
}
module.exports = app => {
app.use('/events', new Events({ Model }));
};
|
