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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
# File 'lib/sidekiq/expected_failures/web.rb', line 5
def self.registered(app)
web_dir = File.expand_path("../../../../web", __FILE__)
app.helpers do
def link_to_details(job)
data = []
job["args"].each_with_index { |argument, index| data << "data-#{index+1}='#{h argument.inspect}'" }
"<a href='#' #{data.join(' ')} title='#{job["worker"]}'>Details</a>"
end
end
app.post "/expected_failures/clear" do
if %w(old all counters).include?(params[:what])
Sidekiq::ExpectedFailures.send("clear_#{params[:what]}")
end
redirect "#{root_path}expected_failures"
end
app.get "/expected_failures/stats" do
@counters = Sidekiq::ExpectedFailures.counters
content_type :json
Sidekiq.dump_json({
failures: @counters
})
end
app.get "/expected_failures/?:date?" do
@dates = Sidekiq::ExpectedFailures.dates
@count = (params[:count] || 50).to_i
if @dates
@date = params[:date] || @dates.keys[0]
(@current_page, @total_size, @jobs) = page("expected:#{@date}", params[:page], @count)
@jobs = @jobs.map { |msg| Sidekiq.load_json(msg) }
@counters = Sidekiq::ExpectedFailures.counters
end
@javascript = %w(expected bootstrap).map do |file|
File.read(File.join(web_dir, "assets/#{file}.js"))
end.join
erb File.read(File.join(web_dir, "views/expected_failures.erb"))
end
end
|