kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

Merge pull request #1702 from lucianosousa/patch-2

Browse source 
removing duplicated code
This commit is contained in:
Mike Perham 2014-05-13 13:36:17 -07:00
commit 4731272fc2
1 changed files with 23 additions and 40 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

63
lib/sidekiq/web.rb
View file

@ -86,12 +86,7 @@ module Sidekiq
params['key'].each do |key|
job = Sidekiq::DeadSet.new.fetch(*parse_params(key)).first
next unless job
if params['retry']
job.retry
elsif params['delete']
job.delete
end
retry_or_delete job, params if job
end
redirect_with_query("#{root_path}morgue")
end
@ -109,13 +104,7 @@ module Sidekiq
post "/morgue/:key" do
halt 404 unless params['key']
job = Sidekiq::DeadSet.new.fetch(*parse_params(params['key'])).first
if job
if params['retry']
job.retry
elsif params['delete']
job.delete
end
end
retry_or_delete job, params if job
redirect_with_query("#{root_path}morgue")
end
@ -139,12 +128,7 @@ module Sidekiq
params['key'].each do |key|
job = Sidekiq::RetrySet.new.fetch(*parse_params(key)).first
next unless job
if params['retry']
job.retry
elsif params['delete']
job.delete
end
retry_or_delete job, params if job
end
redirect_with_query("#{root_path}retries")
end
@ -162,13 +146,7 @@ module Sidekiq
post "/retries/:key" do
halt 404 unless params['key']
job = Sidekiq::RetrySet.new.fetch(*parse_params(params['key'])).first
if job
if params['retry']
job.retry
elsif params['delete']
job.delete
end
end
retry_or_delete job, params if job
redirect_with_query("#{root_path}retries")
end
@ -191,13 +169,7 @@ module Sidekiq
params['key'].each do |key|
job = Sidekiq::ScheduledSet.new.fetch(*parse_params(key)).first
if job
if params['delete']
job.delete
elsif params['add_to_queue']
job.add_to_queue
end
end
delete_or_add_queue job, params if job
end
redirect_with_query("#{root_path}scheduled")
end
@ -205,13 +177,7 @@ module Sidekiq
post "/scheduled/:key" do
halt 404 unless params['key']
job = Sidekiq::ScheduledSet.new.fetch(*parse_params(params['key'])).first
if job
if params['add_to_queue']
job.add_to_queue
elsif params['delete']
job.delete
end
end
delete_or_add_queue job, params if job
redirect_with_query("#{root_path}scheduled")
end
@ -245,5 +211,22 @@ module Sidekiq
})
end
private
def retry_or_delete job, params
if params['retry']
job.retry
elsif params['delete']
job.delete
end
end
def delete_or_add_queue job, params
if params['delete']
job.delete
elsif params['add_to_queue']
job.add_to_queue
end
end
end
end