Merge pull request #19 from Jfelix61/types/agenda

Added agenda typescript implementation

Author: santiq

package.json

@@ -54,6 +54,7 @@
     "winston": "^3.2.1"
   },
   "devDependencies": {
+    "@types/agenda": "^2.0.4",
     "@types/express": "^4.16.0",
     "@types/jest": "^23.3.8",
     "@types/lodash": "^4.14.118",

src/config/index.ts

@@ -39,7 +39,7 @@ export default {
   agenda: {
     dbCollection: process.env.AGENDA_DB_COLLECTION,
     pooltime: process.env.AGENDA_POOL_TIME,
-    concurrency: process.env.AGENDA_CONCURRENCY,
+    concurrency: parseInt(process.env.AGENDA_CONCURRENCY, 10),
   },
 
   /**

src/loaders/agenda.ts

@@ -4,10 +4,10 @@ import config from '../config';
 export default ({ mongoConnection }) => {
   return new Agenda({
     mongo: mongoConnection,
-    collection: config.agenda.dbCollection,
+    db: { collection: config.agenda.dbCollection },
     processEvery: config.agenda.pooltime,
     maxConcurrency: config.agenda.concurrency,
-  }) as any;
+  });
   /**
    * This voodoo magic is proper from agenda.js so I'm not gonna explain too much here.
    * https://github.com/agenda/agenda#mongomongoclientinstance

src/loaders/jobs.ts

@@ -1,7 +1,8 @@
 import config from '../config';
 import EmailSequenceJob from '../jobs/emailSequence';
+import Agenda from 'agenda';
 
-export default ({ agenda }) => {
+export default ({ agenda }: { agenda: Agenda }) => {
   agenda.define(
     'send-email',
     { priority: 'high', concurrency: config.agenda.concurrency },