From daf76d88ce32ca6f6199d1088d9b19fcd7cc94be Mon Sep 17 00:00:00 2001 From: Aaron Quint Date: Wed, 20 Jan 2010 15:02:59 -0500 Subject: [PATCH] Added the ability to clear statuses via the resque-web interface --- lib/resque/server/views/statuses.erb | 5 +++++ lib/resque/status_server.rb | 5 +++++ resque-status.gemspec | 5 ++++- 3 files changed, 14 insertions(+), 1 deletion(-) diff --git a/lib/resque/server/views/statuses.erb b/lib/resque/server/views/statuses.erb index 7a7a1f0..17f9f4d 100644 --- a/lib/resque/server/views/statuses.erb +++ b/lib/resque/server/views/statuses.erb @@ -1,6 +1,11 @@ <%= status_view :status_styles, :layout => false %>

Statuses

+<%unless @statuses.empty?%> +
+ +
+<%end%>

These are recent jobs created with the JobWithStatus class

diff --git a/lib/resque/status_server.rb b/lib/resque/status_server.rb index de36a5c..f1892db 100644 --- a/lib/resque/status_server.rb +++ b/lib/resque/status_server.rb @@ -28,6 +28,11 @@ def self.registered(app) redirect '/statuses' end + app.post '/statuses/clear' do + Resque::Status.clear + redirect '/statuses' + end + app.helpers do def status_view(filename, options = {}, locals = {}) erb(File.read(File.join(VIEW_PATH, "#{filename}.erb")), options, locals) diff --git a/resque-status.gemspec b/resque-status.gemspec index f6e4d4c..a1f84c3 100644 --- a/resque-status.gemspec +++ b/resque-status.gemspec @@ -9,7 +9,7 @@ Gem::Specification.new do |s| s.required_rubygems_version = Gem::Requirement.new(">= 0") if s.respond_to? :required_rubygems_version= s.authors = ["Aaron Quint"] - s.date = %q{2010-01-19} + s.date = %q{2010-01-20} s.description = %q{resque-status is an extension to the resque queue system that provides simple trackable jobs. It provides a Resque::Status class which can set/get the statuses of jobs and a Resque::JobWithStatus class that when subclassed provides easily trackable/killable jobs.} s.email = %q{aaron@quirkey.com} s.extra_rdoc_files = [ @@ -58,17 +58,20 @@ Gem::Specification.new do |s| s.add_runtime_dependency(%q, [">= 1.3.1"]) s.add_runtime_dependency(%q, [">= 0.2.0"]) s.add_development_dependency(%q, [">= 2.10.2"]) + s.add_development_dependency(%q, [">= 0.9.8"]) else s.add_dependency(%q, [">= 2.0.2"]) s.add_dependency(%q, [">= 1.3.1"]) s.add_dependency(%q, [">= 0.2.0"]) s.add_dependency(%q, [">= 2.10.2"]) + s.add_dependency(%q, [">= 0.9.8"]) end else s.add_dependency(%q, [">= 2.0.2"]) s.add_dependency(%q, [">= 1.3.1"]) s.add_dependency(%q, [">= 0.2.0"]) s.add_dependency(%q, [">= 2.10.2"]) + s.add_dependency(%q, [">= 0.9.8"]) end end