Fix old recurring job processing

package.json

@@ -1,6 +1,6 @@
 {
   "name": "mongodb-cron",
-  "version": "1.6.0",
+  "version": "1.7.0",
   "description": "MongoDB collection as crontab",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

src/cron.ts

@@ -190,7 +190,9 @@ export class MongoCron {
         currentDate: future.toDate(),
         endDate: dot.pick(this.config.repeatUntilFieldPath, doc),
       });
-      return interval.next().toDate();
+      const next = interval.next().toDate();
+      const now = moment().toDate();
+      return next < now ? now : next; // process old recurring jobs only once
     } catch (err) {
       return null;
     }

src/tests/cron.test.ts

@@ -128,6 +128,24 @@ spec.test('recurring documents should be unlocked when prossed', async (ctx) =>
   ctx.is(processed, 3);
 });
 
+spec.test('recurring documents should process from current date', async (ctx) => {
+  let processed = 0;
+  const past = moment().subtract(10, 'days');
+  const collection = ctx.get('collection');
+  const cron = new MongoCron({
+    collection,
+    onDocument: () => processed++,
+  });
+  await collection.insertOne({
+    sleepUntil: past.toDate(), // should be treated as now() date
+    interval: '* * * * * *',
+  });
+  await cron.start();
+  await sleep(2000);
+  await cron.stop();
+  ctx.true(processed <= 4);
+});
+
 spec.test('condition should filter lockable documents', async (ctx) => {
   let count = 0;
   const collection = ctx.get('collection');