Merge pull request resque#365 from andreacfm/master

Add Resque.delayed?
playup · Feb 17, 2014 · e0e91aa · e0e91aa
2 parents 2330e33 + d54ff32
commit e0e91aa
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 0 deletions.
diff --git a/AUTHORS.md b/AUTHORS.md
@@ -3,6 +3,7 @@ Resque Scheduler authors
 
 - Aaron Suggs
 - Alexander Simonov
+- Andrea Campolonghi
 - Ben VandenBos
 - Bernerd Schaefer
 - Bogdan Gusiev

diff --git a/lib/resque_scheduler.rb b/lib/resque_scheduler.rb
@@ -344,6 +344,15 @@ def count_all_scheduled_jobs
     total_jobs
   end
 
+  # Discover if a job hs been delayed.
+  # Examples
+  #   Resque.delayed? MyJob
+  #   Resque.delayed? MyJob, id: 1
+  # Returns true if the job has been delayed
+  def delayed?(klass, *args)
+    !scheduled_at(klass, *args).empty?
+  end
+
   # Returns delayed jobs schedule timestamp for +klass+, +args+.
   def scheduled_at(klass, *args)
     search = encode(job_to_hash(klass, args))

diff --git a/test/delayed_queue_test.rb b/test/delayed_queue_test.rb
@@ -529,4 +529,16 @@
       Resque.inline = false
     end
   end
+
+  test 'delayed?' do
+    Resque.enqueue_at Time.now + 1, SomeIvarJob
+    Resque.enqueue_at Time.now + 1, SomeIvarJob, id: 1
+
+    assert(Resque.delayed?(SomeIvarJob, id: 1))
+    assert(!Resque.delayed?(SomeIvarJob, id: 2))
+    assert(Resque.delayed?(SomeIvarJob))
+    assert(!Resque.delayed?(SomeJob))
+
+  end
+
 end