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
37
38
39
40
41
42
43
44
45
46
47
|
# File 'lib/sidetiq/web.rb', line 7
def self.registered(app)
app.helpers do
def sidetiq_clock
Sidetiq::Clock.instance
end
def sidetiq_schedules
sidetiq_clock.schedules
end
end
app.get "/sidetiq" do
@schedules = sidetiq_schedules
@time = sidetiq_clock.gettime
slim File.read(File.join(VIEWS, 'sidetiq.slim'))
end
app.get "/sidetiq/:name" do
halt 404 unless (name = params[:name])
@time = sidetiq_clock.gettime
@worker, @schedule = sidetiq_schedules.select do |worker, schedule|
worker.name == name
end.flatten
slim File.read(File.join(VIEWS, 'sidetiq_details.slim'))
end
app.post "/sidetiq/:name/trigger" do
halt 404 unless (name = params[:name])
worker, _ = sidetiq_schedules.select do |worker, schedule|
worker.name == name
end.flatten
worker.perform_async
redirect "#{root_path}sidetiq"
end
end
|