diff options
author | eug-vs <eug-vs@keemail.me> | 2020-11-28 01:21:41 +0300 |
---|---|---|
committer | eug-vs <eug-vs@keemail.me> | 2020-11-28 01:31:23 +0300 |
commit | c3b76d1b5d0f85deb9a52dbe516c665ab4de8c07 (patch) | |
tree | cfb7d6fae788ca16260199f6d52d40e45920f94b /src/services/events/event.service.js | |
parent | 2a1b70edbdef4ab934d0091a92c14327dde8a256 (diff) | |
download | bsu-fantom-c3b76d1b5d0f85deb9a52dbe516c665ab4de8c07.tar.gz |
fix: re-fetch event before running
Diffstat (limited to 'src/services/events/event.service.js')
-rw-r--r-- | src/services/events/event.service.js | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/src/services/events/event.service.js b/src/services/events/event.service.js index 227480d..f2185a6 100644 --- a/src/services/events/event.service.js +++ b/src/services/events/event.service.js @@ -45,11 +45,23 @@ class Events extends Service { if (!events.length) console.log('WARNING: no upcoming events'); this.jobs = events.map(event => new CronJob( event.schedule, - () => event.run(handleTestJob) + () => this.run(event._id) )); this.startAllJobs(); } + + async run(id) { + const event = await this.Model.findById(id); + + try { + event.start(); + await handleAttendClassJob(event); + return event.complete(); + } catch (error) { + event.fail(error); + } + } } |