add job#remove method

agenda · Mar 9, 2014 · b188139 · b188139
1 parent 879d39f
commit b188139
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/lib/job.js b/lib/job.js
@@ -137,6 +137,10 @@ Job.prototype.save = function(cb) {
   return this;
 };
 
+Job.prototype.remove = function(cb) {
+  this.agenda._db.remove({_id: this.attrs._id}, cb);
+};
+
 function parsePriority(priority) {
   var priorityMap = {
     lowest: -20,

diff --git a/test/agenda.js b/test/agenda.js
@@ -281,6 +281,20 @@ describe('Job', function() {
 
   });
 
+  describe.only('remove', function() {
+    it('removes the job', function(done) {
+      var job = new Job({agenda: jobs, name: 'removed job'});
+      job.save(function() {
+        job.remove(function() {
+          mongo.collection('agendaJobs').find({_id: job.attrs._id}).toArray(function(err, j) {
+            expect(j).to.have.length(0);
+            done();
+          });
+        });
+      });
+    });
+  });
+
   describe('run', function() {
     var job,
         definitions = jobs._definitions;