5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
# File 'lib/attentive_sidekiq/web.rb', line 5
def self.registered(app)
app.get("/disappeared-jobs") do
@disappeared_jobs = AttentiveSidekiq::Disappeared.jobs
erb File.read(File.join(VIEW_PATH, 'disappeared-list.erb'))
end
app.post("/disappeared-jobs/requeue-all") do
AttentiveSidekiq::Disappeared.jobs.each do |job|
if job['status'] == 'detected'
AttentiveSidekiq::Disappeared.requeue(job['jid'])
end
end
redirect "#{root_path}disappeared-jobs"
end
app.post("/disappeared-jobs/delete-all") do
AttentiveSidekiq::Disappeared.jobs.each do |job|
AttentiveSidekiq::Disappeared.remove(job['jid'])
end
redirect "#{root_path}disappeared-jobs"
end
app.post("/disappeared-jobs/:jid/delete") do
AttentiveSidekiq::Disappeared.remove(params['jid'])
redirect "#{root_path}disappeared-jobs"
end
app.post("/disappeared-jobs/:jid/requeue") do
AttentiveSidekiq::Disappeared.requeue(params['jid'])
redirect "#{root_path}disappeared-jobs"
end
end
|