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
|
# File 'lib/sidekiq/priority_queue/web.rb', line 9
def self.registered(app)
app.tabs['Priority Queues'] = 'priority_queues'
app.get '/priority_queues' do
@queues = Queue.all
render(:erb, File.read("#{ROOT}/views/priority_queues.erb"))
end
app.get '/priority_queues/:name' do
@name = route_params[:name]
halt(404) unless @name
@count = (params['count'] || 25).to_i
@queue = Sidekiq::Queue.new(@name)
(@current_page, @total_size, @messages) = page("priority-queue:#{@name}", params['page'], @count)
@subqueue_counts = Sidekiq.redis do |con|
con.zrevrange("priority-queue-counts:#{@name}", 0, params['subqueue_count'] || 10, withscores: true)
end.map { |name, count| SubqueueCount.new(name, count) }
@messages = @messages.map{ |msg| Job.new(msg.first, @name, msg.last) }
render(:erb, File.read("#{ROOT}/views/priority_queue.erb"))
end
app.post "/priority_queues/:name/delete" do
name = route_params[:name]
Job.new(params['key_val'], name).delete
redirect_with_query("#{root_path}priority_queues/#{CGI.escape(name)}")
end
end
|