Class: GoodJob::JobsFilter

Inherits:
BaseFilter show all
Defined in:
app/filters/good_job/jobs_filter.rb

Constant Summary collapse

UUID_REGEX = 
/\A[0-9a-f]{8}(?:-[0-9a-f]{4}){3}-[0-9a-f]{12}\z/i

Constants inherited from BaseFilter

BaseFilter::DEFAULT_LIMIT, BaseFilter::EMPTY

Instance Attribute Summary

Attributes inherited from BaseFilter

#base_query, #params

Instance Method Summary collapse

Methods inherited from BaseFilter

#initialize, #job_classes, #last, #next_page_params, #queues, #records, #to_params

Constructor Details

This class inherits a constructor from GoodJob::BaseFilter

Instance Method Details

#filtered_count ⇒ Object 



36
37
38
 
# File 'app/filters/good_job/jobs_filter.rb', line 36

def filtered_count
  @_filtered_count ||= filtered_query.unscope(:select).count
end

#filtered_query(filter_params = params) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
 
# File 'app/filters/good_job/jobs_filter.rb', line 25

def filtered_query(filter_params = params)
  base_query
    .merge(filter_by_job_class(filter_params[:job_class]))
    .merge(filter_by_queue_name(filter_params[:queue_name]))
    .merge(filter_by_label(filter_params[:label]))
    .merge(filter_by_search_query(filter_params[:query]))
    .merge(filter_by_cron_key(filter_params[:cron_key]))
    .merge(filter_by_finished_since(filter_params[:finished_since]))
    .merge(filter_by_state(filter_params[:state]))
end

#ordered_by ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'app/filters/good_job/jobs_filter.rb', line 40

def ordered_by
  case params[:state]
  when "scheduled", "retried", "pending", "queued"
    %w[scheduled_at asc]
  when "running"
    %w[performed_at desc]
  when "finished", "discarded"
    %w[finished_at desc]
  else
    %w[created_at desc]
  end
end

#state_names ⇒ Object 



7
8
9
 
# File 'app/filters/good_job/jobs_filter.rb', line 7

def state_names
  %w[scheduled retried queued running succeeded discarded]
end

#states ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'app/filters/good_job/jobs_filter.rb', line 11

def states
  @_states ||= begin
    query = filtered_query(params.except(:state))
    {
      'scheduled' =>  query.scheduled.count,
      'retried' => query.retried.count,
      'queued' => query.queued.count,
      'running' => query.running.count,
      'succeeded' => query.succeeded.count,
      'discarded' => query.discarded.count,
    }
  end
end