feat: add ability to get if queue is paused or not

taskforcesh · Dec 16, 2020 · e98b7d8 · e98b7d8
1 parent 49fe957
commit e98b7d8
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/src/classes/queue.ts b/src/classes/queue.ts
@@ -120,6 +120,12 @@ export class Queue<
     this.emit('resumed');
   }
 
+  async isPaused() {
+    const client = await this.client;
+    const pausedKeyExists = await client.hexists(this.keys.meta, 'paused');
+    return pausedKeyExists === 1;
+  }
+
   async getRepeatableJobs(start?: number, end?: number, asc?: boolean) {
     return (await this.repeat).getRepeatableJobs(start, end, asc);
   }

diff --git a/src/test/test_pause.ts b/src/test/test_pause.ts
@@ -302,4 +302,14 @@ describe('Pause', function() {
       });
     });
   });
+
+  it('gets the right response from isPaused', async () => {
+    await queue.pause();
+    const isPausedQueuePaused = await queue.isPaused();
+    expect(isPausedQueuePaused).to.be.true;
+
+    await queue.resume();
+    const isResumedQueuePaused = await queue.isPaused();
+    expect(isResumedQueuePaused).to.be.false;
+  });
 });