module Sidekiq::PriorityQueue::Web

Constants

ROOT

Public Class Methods

registered(app) click to toggle source
# 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