fix(repeatable): validate endDate when adding next repeatable job

src/classes/repeat.ts

@@ -1,4 +1,5 @@
 import { createHash } from 'crypto';
+import { isUndefined } from 'lodash';
 import { JobsOptions, RepeatOptions } from '../interfaces';
 import { QueueBase } from './queue-base';
 import { Job } from './job';
@@ -24,6 +25,14 @@ export class Repeat extends QueueBase {
     }
 
     let now = Date.now();
+
+    if (
+      !isUndefined(repeatOpts.endDate) &&
+      now > new Date(repeatOpts.endDate).getTime()
+    ) {
+      return;
+    }
+
     now = prevMillis < now ? now : prevMillis;
 
     const nextMillis = getNextMillis(now, repeatOpts);

src/test/test_repeat.ts

@@ -32,7 +32,7 @@ describe('repeat', function() {
   });
 
   beforeEach(async function() {
-    queueName = 'test-' + v4();
+    queueName = `test-${v4()}`;
     queue = new Queue(queueName);
     repeat = new Repeat(queueName);
     queueEvents = new QueueEvents(queueName);
@@ -47,6 +47,49 @@ describe('repeat', function() {
     await removeAllQueueData(new IORedis(), queueName);
   });
 
+  it('it should stop repeating after endDate', async function() {
+    const queueScheduler = new QueueScheduler(queueName);
+    await queueScheduler.waitUntilReady();
+    const every = 100;
+    const date = new Date('2017-02-07 9:24:00');
+    this.clock.setSystemTime(date);
+    const worker = new Worker(queueName, NoopProc);
+    await worker.waitUntilReady();
+
+    let processed = 0;
+    const completing = new Promise(resolve => {
+      worker.on('completed', async () => {
+        this.clock.tick(every);
+        processed++;
+        if (processed === 10) {
+          resolve();
+        }
+      });
+    });
+
+    await queue.add(
+      'test',
+      { foo: 'bar' },
+      {
+        repeat: {
+          endDate: Date.now() + 1000,
+          every: 100,
+        },
+      },
+    );
+
+    this.clock.tick(every + 1);
+
+    await completing;
+    const delayed = await queue.getDelayed();
+
+    expect(delayed).to.have.length(0);
+    expect(processed).to.be.equal(10);
+
+    await queueScheduler.close();
+    await worker.close();
+  });
+
   it('should create multiple jobs if they have the same cron pattern', async function() {
     const cron = '*/10 * * * * *';