From 36465387454cdb797f886f732d40a70faa92cbad Mon Sep 17 00:00:00 2001 From: eug-vs Date: Sat, 14 Nov 2020 16:31:59 +0300 Subject: refactor: reuse Mongoose connection in Agenda --- src/services/events/event.service.js | 35 +++++++++++++++++++++++++++++++++++ 1 file changed, 35 insertions(+) create mode 100644 src/services/events/event.service.js (limited to 'src/services/events') diff --git a/src/services/events/event.service.js b/src/services/events/event.service.js new file mode 100644 index 0000000..5c5bcff --- /dev/null +++ b/src/services/events/event.service.js @@ -0,0 +1,35 @@ +const Agenda = require('agenda'); +const { getConnection } = require('../../connectDb.js'); + + +class Events { + setup(app) { + this.collectionName = 'events'; + + const connection = getConnection(); + this.agenda = new Agenda(); + this.agenda.mongo( + connection.collection(this.collectionName).conn.db, + this.collectionName + ); + + this.defineJobs(); + + return this.agenda.start(); + }; + + defineJobs() { + this.agenda.define('attend class', async job => { + console.log('Running attend class job with attrs:'); + console.log(job.attrs); + }); + }; + + async create(data, params) { + return this.agenda.schedule(data.date, 'attend class', { data }); + }; +} + + +module.exports = app => app.use('/events', new Events()); + -- cgit v1.2.3