Merge pull request #46 from SimonErm/feature/retry+remove_jobs

Feature/retry+remove jobs

Author: SimonErm

example/App.tsx

@@ -56,11 +56,34 @@ export default class App extends React.Component<IAppProps, IAppState> {
                 <Button
                     title='cancel Job'
                     onPress={() => {
-                      if(this.state.jobId){
-                        queue.cancelJob(this.state.jobId, {message: 'Canceled'})
-                      } else {
-                        console.log("no job running");
-                      }
+                        if (this.state.jobId) {
+                            queue.cancelJob(this.state.jobId, { message: 'Canceled' })
+                        } else {
+                            console.log("no job running");
+                        }
+                    }}
+                />
+                <Button
+                    title='remove failed Jobs'
+                    onPress={async () => {
+                        let jobs = await queue.getJobs();
+                        let jobRemovals = jobs.filter(job => job.failed !== '').map(async job => await queue.removeJob(job))
+                        await Promise.all(jobRemovals)
+                    }}
+                />
+                <Button
+                    title='requeue failed Jobs'
+                    onPress={async () => {
+                        let jobs = await queue.getJobs();
+                        let jobRequeues = jobs.filter(job => job.failed !== '').map(async job => await queue.requeueJob(job))
+                        await Promise.all(jobRequeues)
+                    }}
+                />
+                <Button
+                    title='getJobs'
+                    onPress={async () => {
+                        let jobs = await queue.getJobs();
+                        console.log(jobs)
                     }}
                 />
                 <Button

src/Queue.ts

@@ -97,6 +97,18 @@ export class Queue {
     async getJobs() {
         return await this.jobStore.getJobs();
     }
+    /**
+     * @param job the job to be deleted
+     */
+    async removeJob(job: RawJob) {
+        return await this.jobStore.removeJob(job);
+    }
+    /**
+     * @param job the job which should be requeued
+     */
+    async requeueJob(job: RawJob) {
+        return await this.jobStore.updateJob({ ...job, failed: '' });
+    }
 
     configure(options: QueueOptions) {
         const {