feat(bullmq): support removing repeatable jobs (#667)

Author: roggervalf

example/bullmq.js

@@ -69,6 +69,7 @@ async function main() {
 
   // adding delayed jobs
   const delayedJob = await queue.add('delayed', {}, {delay: 60 * 1000});
+  await queue.add('cron', {}, {repeat: {pattern: '* 1 * 1 *'}});
   delayedJob.log('Log message');
 
   Arena(

src/server/views/api/repeatableJobRemove.js

@@ -9,10 +9,12 @@ async function handler(req, res) {
   if (!job) return res.status(404).send({error: 'job not found'});
 
   try {
-    if (job.opts.repeat.key) {
-      await queue.removeRepeatableByKey(job.opts.repeat.key);
+    if (job.opts.repeat.key || job.repeatJobKey) {
+      await queue.removeRepeatableByKey(
+        job.opts.repeat.key || job.repeatJobKey
+      );
     } else {
-      await queue.removeRepeatable(job.name, job.opts.repeat);
+      await queue.removeRepeatable(job.name, job.opts.repeat, job.opts.jobId);
     }
     return res.sendStatus(200);
   } catch (e) {

src/server/views/dashboard/queueJobsByState.js

@@ -138,7 +138,7 @@ async function _html(req, res) {
       jobs[i].showRetryButton = !queue.IS_BEE || jobState === 'failed';
       jobs[i].retryButtonText = jobState === 'failed' ? 'Retry' : 'Trigger';
       jobs[i].showPromoteButton = !queue.IS_BEE && jobState === 'delayed';
-      jobs[i].showDeleteRepeatableButton = queue.IS_BULL && jobs[i].opts.repeat;
+      jobs[i].showDeleteRepeatableButton = !queue.IS_BEE && jobs[i].opts.repeat;
       jobs[i].parent = JobHelpers.getKeyProperties(jobs[i].parentKey);
     }
   }