Sha256: 1c15a7df66e0552db6c676e262d9ec96f4a03d263e25a1f8d1237d155143c88d
Contents?: true
Size: 1.53 KB
Versions: 7
Compression:
Stored size: 1.53 KB
Contents
module MissionControl::Jobs::NavigationHelper
attr_reader :page_title, :current_section
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 navigation_section_for_status(status)
if status.nil? || status == :pending
:queues
else
"#{status}_jobs".to_sym
end
end
def navigation(title: nil, section: nil)
@page_title = title
@current_section = section
end
def selected_application?(application)
MissionControl::Jobs::Current.application.name == application.name
end
def selectable_applications
MissionControl::Jobs.applications.reject { |app| selected_application?(app) }
end
def selected_server?(server)
MissionControl::Jobs::Current.server.name == server.name
end
def jobs_filter_param
if @job_filters&.any?
{ filter: @job_filters }
else
{}
end
end
def jobs_count_with_status(status)
count = ActiveJob.jobs.with_status(status).count
count.infinite? ? "..." : number_to_human(count)
end
end
Version data entries
7 entries across 7 versions & 1 rubygems