Sha256: 44fe5965a8a221a6d01d1e1067d1807634ac9f39abb596aeee9cd7729468d97c
Contents?: true
Size: 1.82 KB
Versions: 12
Compression:
Stored size: 1.82 KB
Contents
# frozen_string_literal: true
module GoodJob
class BaseFilter
DEFAULT_LIMIT = 25
EMPTY = '[none]'
attr_accessor :params, :base_query
def initialize(params, base_query = nil)
@params = params
@base_query = base_query || default_base_query
end
def records
after_scheduled_at = params[:after_scheduled_at].present? ? Time.zone.parse(params[:after_scheduled_at]) : nil
query_for_records.display_all(
after_scheduled_at: after_scheduled_at,
after_id: params[:after_id]
).limit(params.fetch(:limit, DEFAULT_LIMIT))
end
def last
@_last ||= records.last
end
def queues
base_query.group(:queue_name).count
.sort_by { |name, _count| name.to_s || EMPTY }
.to_h
end
def job_classes
filtered_query(params.slice(:queue_name)).unscope(:select)
.group(GoodJob::BaseExecution.params_job_class).count
.sort_by { |name, _count| name.to_s }
.to_h
end
def states
raise NotImplementedError
end
def state_names
raise NotImplementedError
end
def to_params(override = {})
{
job_class: params[:job_class],
limit: params[:limit],
queue_name: params[:queue_name],
query: params[:query],
state: params[:state],
cron_key: params[:cron_key],
}.merge(override).delete_if { |_, v| v.blank? }
end
def filtered_query(filtered_params = params)
raise NotImplementedError
end
def filtered_count
filtered_query.count
end
private
def query_for_records
raise NotImplementedError
end
def default_base_query
raise NotImplementedError
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems