Merge pull request #18 from alexleroyross/clean_jobs

Add 'Clean Jobs' to Delayed Jobs

Author: vcapretz

.gitignore

@@ -1,3 +1,4 @@
 node_modules/
 static/
-yarn-error.log
+yarn-error.log
+*.rdb

index.js

@@ -18,6 +18,7 @@ function UI() {
   router.get('/queues', require('./routes/queues'))
   router.put('/queues/:queueName/retry', require('./routes/retryAll'))
   router.put('/queues/:queueName/:id/retry', require('./routes/retryJob'))
+  router.put('/queues/:queueName/clean', require('./routes/cleanAll'))
   router.get('/', require('./routes/index'))
 
   app.use(bodyParser.json())

routes/cleanAll.js

@@ -0,0 +1,23 @@
+module.exports = async function handler(req, res) {
+  try {
+    const { queueName } = req.params
+    const { queues } = req.app.locals
+
+    const GRACE_TIME_MS = 5000
+
+    const queue = queues[queueName]
+    if (!queue) {
+      return res.status(404).send({ error: 'queue not found' })
+    }
+
+    await queue.clean(GRACE_TIME_MS, 'delayed')
+
+    return res.sendStatus(200)
+  } catch (e) {
+    const body = {
+      error: 'queue error',
+      details: e.stack,
+    }
+    return res.status(500).send(body)
+  }
+}

ui/components/App.js

@@ -11,6 +11,7 @@ export default function App({ basePath }) {
     setSelectedStatuses,
     retryJob,
     retryAll,
+    cleanAll,
   } = useStore(basePath)
 
   return (
@@ -30,6 +31,7 @@ export default function App({ basePath }) {
                 selectStatus={setSelectedStatuses}
                 retryJob={retryJob(queue.name)}
                 retryAll={retryAll(queue.name)}
+                cleanAll={cleanAll(queue.name)}
               />
             ))}
           </>

ui/components/Queue.js

@@ -251,6 +251,9 @@ const actions = {
   failed: ({ retryAll }) => {
     return <button onClick={retryAll}>Retry all</button>
   },
+  delayed: ({ cleanAll }) => {
+    return <button onClick={cleanAll}>Clean all</button>
+  },
 }
 
 function QueueActions(props) {
@@ -269,6 +272,7 @@ function QueueActions(props) {
 export default function Queue({
   retryAll,
   retryJob,
+  cleanAll,
   queue,
   selectStatus,
   selectedStatus,
@@ -291,6 +295,7 @@ export default function Queue({
         <>
           <QueueActions
             retryAll={retryAll}
+            cleanAll={cleanAll}
             queue={queue}
             status={selectedStatus}
           />

ui/components/hooks/useStore.js

@@ -54,5 +54,17 @@ export default function useStore(basePath) {
       update,
     )
 
-  return { state, retryJob, retryAll, selectedStatuses, setSelectedStatuses }
+  const cleanAll = queueName => () =>
+    fetch(`${basePath}/queues/${queueName}/clean`, { method: 'put' }).then(
+      update,
+    )
+
+  return {
+    state,
+    retryJob,
+    retryAll,
+    cleanAll,
+    selectedStatuses,
+    setSelectedStatuses,
+  }
 }