module MissionControl::Jobs::NavigationHelper
def jobs_count_with_status(status)
def jobs_count_with_status(status) count = ActiveJob.jobs.with_status(status).count count.infinite? ? "..." : number_to_human(count) end
def jobs_filter_param
def jobs_filter_param if @job_filters&.any? { filter: @job_filters } else {} end end
def navigation(title: nil, section: nil)
def navigation(title: nil, section: nil) @page_title = title @current_section = section end
def navigation_section_for_status(status)
def navigation_section_for_status(status) if status.nil? || status == :pending :queues else "#{status}_jobs".to_sym end end
def navigation_sections
def navigation_sections { queues: [ "Queues", application_queues_path(@application) ] }.tap do |sections| supported_job_statuses.without(:pending).each do |status| sections[navigation_section_for_status(status)] = [ "#{status.to_s.titleize} jobs (#{jobs_count_with_status(status)})", application_jobs_path(@application, status) ] end sections[:workers] = [ "Workers", application_workers_path(@application) ] if workers_exposed? sections[:recurring_tasks] = [ "Recurring tasks", application_recurring_tasks_path(@application) ] if recurring_tasks_supported? end end
def selectable_applications
def selectable_applications MissionControl::Jobs.applications.reject { |app| selected_application?(app) } end
def selected_application?(application)
def selected_application?(application) MissionControl::Jobs::Current.application.name == application.name end
def selected_server?(server)
def selected_server?(server) MissionControl::Jobs::Current.server.name == server.name end