Resque::Server.helpers do #################### #failed.erb helpers# #################### def failed_date_format "%Y/%m/%d %T %z" end def failed_multiple_queues? return @multiple_failed_queues if defined?(@multiple_failed_queues) @multiple_failed_queues = Resque::Failure.queues.size > 1 || (defined?(Resque::Failure::RedisMultiQueue) && Resque::Failure.backend == Resque::Failure::RedisMultiQueue) end def failed_size @failed_size ||= Resque::Failure.count(params[:queue], params[:class]) end def failed_per_page @failed_per_page = if params[:class] failed_size else 20 end end def failed_start_at params[:start].to_i end def failed_end_at if failed_start_at + failed_per_page > failed_size failed_size else failed_start_at + failed_per_page - 1 end end def failed_order params[:order] || 'desc' end def failed_class_counts(queue = params[:queue]) classes = Hash.new(0) Resque::Failure.each(0, Resque::Failure.count(queue), queue) do |_, item| class_name = item['payload']['class'] if item['payload'] class_name ||= "nil" classes[class_name] += 1 end classes end def page_entries_info(start, stop, size, name = nil) if size == 0 name ? "No #{name}s" : '0' elsif size == 1 'Showing 1' + (name ? " #{name}" : '') elsif size > failed_per_page "Showing #{start}-#{stop} of #{size}" + (name ? " #{name}s" : '') else "Showing #{start} to #{size - 1}" + (name ? " #{name}s" : '') end end end