fix(change-delay): add current time to delay (#789) fixes #787

src/classes/scripts.ts

@@ -370,7 +370,8 @@ export class Scripts {
   ): Promise<void> {
     const client = await queue.client;
 
-    const args = this.changeDelayArgs(queue, jobId, delay);
+    const delayTimestamp = Date.now() + delay;
+    const args = this.changeDelayArgs(queue, jobId, delayTimestamp);
     const result = await (<any>client).changeDelay(args);
     if (result < 0) {
       throw this.finishedErrors(result, jobId, 'changeDelay', 'delayed');

src/test/test_job.ts

@@ -499,42 +499,42 @@ describe('Job', function() {
   });
 
   describe('.changeDelay', () => {
-    it('can change delay of a delayed job', async () => {
-      const clock = sinon.useFakeTimers();
-      const date = new Date();
-      clock.setSystemTime(date);
+    it('can change delay of a delayed job', async function() {
+      this.timeout(8000);
+
       const queueScheduler = new QueueScheduler(queueName);
       await queueScheduler.waitUntilReady();
-      const nextTick = 2 * ONE_SECOND;
+
+      const worker = new Worker(queueName, async job => {});
+      await worker.waitUntilReady();
+
+      const startTime = new Date().getTime();
+
+      const completing = new Promise<void>((resolve, reject) => {
+        worker.on('completed', async () => {
+          const timeDiff = new Date().getTime() - startTime;
+          expect(timeDiff).to.be.gte(4000);
+          resolve();
+        });
+      });
 
       const job = await Job.create(
         queue,
         'test',
         { foo: 'bar' },
         { delay: 2000 },
       );
+
       const isDelayed = await job.isDelayed();
       expect(isDelayed).to.be.equal(true);
 
       await job.changeDelay(4000);
-      clock.tick(nextTick);
 
       const isDelayedAfterChangeDelay = await job.isDelayed();
       expect(isDelayedAfterChangeDelay).to.be.equal(true);
 
-      const worker = new Worker(queueName, async job => {});
-
-      clock.tick(2 * nextTick);
-
-      const completing = new Promise<void>((resolve, reject) => {
-        worker.on('completed', async () => {
-          resolve();
-        });
-      });
-
       await completing;
 
-      clock.restore();
       await queueScheduler.close();
       await worker.close();
     });