feat(repeat): add immediately opt for repeat

src/classes/repeat.ts

@@ -54,7 +54,7 @@ export class Repeat extends QueueBase {
           name,
           nextMillis,
           repeatJobKey,
-          { ...opts, repeat: repeatOpts },
+          { ...opts, repeat: { ...repeatOpts, immediately: false } },
           data,
           currentCount,
         );
@@ -215,7 +215,11 @@ function getNextMillis(millis: number, opts: RepeatOptions) {
   }
 
   if (opts.every) {
-    return Math.floor(millis / opts.every) * opts.every + opts.every;
+    console.log('immediately', opts.immediately);
+    return (
+      Math.floor(millis / opts.every) * opts.every +
+      (opts.immediately ? 0 : opts.every)
+    );
   }
 
   const currentDate =
@@ -235,7 +239,5 @@ function getNextMillis(millis: number, opts: RepeatOptions) {
 }
 
 function md5(str: string) {
-  return createHash('md5')
-    .update(str)
-    .digest('hex');
+  return createHash('md5').update(str).digest('hex');
 }

src/interfaces/repeat-options.ts

@@ -29,7 +29,11 @@ export interface RepeatOptions {
    * (`cron` setting cannot be used together with this setting.)
    */
   every?: number;
-
+  /**
+   * Repeated job should start right now
+   * ( work only with every settings)
+   */
+  immediately?: boolean;
   /**
    * The start value for the repeat iteration count.
    */

src/test/test_repeat.ts

@@ -20,7 +20,7 @@ const MAX_INT = 2147483647;
 
 const NoopProc = async (job: Job) => {};
 
-describe('repeat', function() {
+describe.only('repeat', function() {
   this.timeout(10000);
   let repeat: Repeat;
   let queue: Queue;
@@ -274,6 +274,56 @@ describe('repeat', function() {
     await worker.close();
   });
 
+  it.only('should repeat every 2 seconds and start immediately', async function() {
+    this.timeout(2000);
+    const queueScheduler = new QueueScheduler(queueName);
+    await queueScheduler.waitUntilReady();
+
+    const date = new Date('2017-02-07 9:24:00');
+    this.clock.setSystemTime(date);
+    const nextTick = 2 * ONE_SECOND;
+
+    const worker = new Worker(queueName, async () => {});
+
+    await queue.add(
+      'repeat',
+      { foo: 'bar' },
+      {
+        repeat: {
+          every: 2000,
+          immediately: true,
+        },
+      },
+    );
+
+    this.clock.tick(500);
+
+    let prev: Job;
+    let counter = 0;
+
+    const completing = new Promise<void>(resolve => {
+      worker.on('completed', async job => {
+        this.clock.tick(nextTick);
+        if (prev && counter === 1) {
+          expect(prev.timestamp).to.be.lt(job.timestamp);
+          expect(job.timestamp - prev.timestamp).to.be.gte(500);
+        } else if (prev) {
+          expect(prev.timestamp).to.be.lt(job.timestamp);
+          expect(job.timestamp - prev.timestamp).to.be.gte(2000);
+        }
+        prev = job;
+        counter++;
+        if (counter === 5) {
+          resolve();
+        }
+      });
+    });
+
+    await completing;
+    await queueScheduler.close();
+    await worker.close();
+  });
+
   // Skipped until we find a way of simulating time to avoid waiting 5 days
   it.skip('should repeat once a day for 5 days', async function() {
     const queueScheduler = new QueueScheduler(queueName);