Class: Que::Web

Inherits:
Sinatra::Base
  • Object
show all
Defined in:
lib/que/web.rb

Defined Under Namespace

Modules: Viewmodels Classes: Pager

Constant Summary collapse

PAGE_SIZE = 
10
FLASH_KEY = 
'que.web.flash'.freeze
SQL = 
{
  dashboard_stats: <<-SQL.freeze,
  failing_jobs: <<-SQL.freeze,
  scheduled_jobs: <<-SQL.freeze,
  delete_job: delete_jobs_query(lock_job_sql),
  delete_all_scheduled_jobs: delete_jobs_query(lock_all_scheduled_jobs_sql),
  delete_all_failing_jobs: delete_jobs_query(lock_all_failing_jobs_sql),
  reschedule_job: <<-SQL.freeze,
  reschedule_all_scheduled_jobs: reschedule_all_jobs_query(lock_all_scheduled_jobs_sql),
  reschedule_all_failing_jobs: reschedule_all_jobs_query(lock_all_failing_jobs_sql),
  fetch_job: <<-SQL.freeze,
}.freeze

Instance Method Summary collapse

Instance Method Details

#get_pager(record_count) ⇒ Object 



138
139
140
141
 
# File 'lib/que/web.rb', line 138

def get_pager(record_count)
  page = (params[:page] || 1).to_i
  Pager.new(page, PAGE_SIZE, record_count)
end

#search ⇒ Object 



143
144
145
146
 
# File 'lib/que/web.rb', line 143

def search
  return '%' unless search_param.present?
  "%#{search_param}%"
end

#search_param ⇒ Object 



153
154
155
156
 
# File 'lib/que/web.rb', line 153

def search_param
  return unless params['search'].present?
  params['search'].gsub(/[^0-9A-Za-z:]/, '')
end

#search_running(jobs) ⇒ Object 



148
149
150
151
 
# File 'lib/que/web.rb', line 148

def search_running(jobs)
  return jobs unless search_param.present?
  jobs.select { |job| job.job_class.include? search_param }
end