resque/resque-web

require 'resque/failure/redis_multi_queue'

module ResqueWeb
  module QueuesHelper
    def queues_partial_name
      if Resque::Failure.backend == Resque::Failure::RedisMultiQueue
        'resque_web/queues/queues_advanced'
      else
        'resque_web/queues/queues_basic'
      end
    end

    def queue_names
      Resque.queues.sort_by(&:to_s)
    end

    def queue_start_at
      params[:start].to_i
    end

    def queue_end_at
      if queue_start_at + queue_per_page > queue_size
        queue_size
      else
        queue_start_at + queue_per_page
      end
    end

    def queue_per_page
      20
    end

    def queue_size(queue_name = params[:id])
      Resque.size queue_name
    end

    def queue_jobs
      @queue_jobs ||= Resque.peek(params[:id], queue_start_at, queue_per_page)
    end

    def failed_queue_names
      Resque::Failure.queues.sort_by(&:to_s)
    end

    def failed_queue_name(original_queue_name)
      "#{original_queue_name}_failed"
    end

    def failed_queue_class(queue_name)
      Resque::Failure.count(queue_name).zero? ? "failed" : "failure"
    end

    def failed_queue_size(queue_name)
      Resque::Failure.count(queue_name)
    end

    def failed_queue_info(queue_name)
      failed_queue = failed_queue_name(queue_name)
      size = failed_queue_size(failed_queue)

      if size > 0
        css_class = "badge badge-important"
        badge = link_to(size, failure_path(failed_queue))
      else
        css_class = "badge"
        badge = size.to_s
      end

      raw "<span class=\"#{css_class}\">#{badge}</span>"
    end
  end
end