class DelayedJobWeb

# File lib/delayed_job_web/application/app.rb, line 95
def csrf_token
  # Set up by Rack::Protection
  session[:csrf]
end

# File lib/delayed_job_web/application/app.rb, line 100
def csrf_token_tag
  # If csrf_token is nil, and we submit a blank string authenticity_token
  # param, Rack::Protection will fail.
  if csrf_token
    "<input type='hidden' name='authenticity_token' value='#{h csrf_token}'>"
  end
end

# File lib/delayed_job_web/application/app.rb, line 34
def current_page
  url_path request.path_info.sub('/','')
end

# File lib/delayed_job_web/application/app.rb, line 87
def delayed_job
  begin
    Delayed::Job
  rescue
    false
  end
end

# File lib/delayed_job_web/application/app.rb, line 164
def delayed_jobs(type, queues = [])
  rel = delayed_job

  rel =
    case type
    when :working
      rel.where('locked_at IS NOT NULL AND failed_at IS NULL')
    when :failed
      rel.where('last_error IS NOT NULL')
    when :pending
      rel.where(:attempts => 0, :locked_at => nil)
    else
      rel
    end

  rel = rel.where(:queue => queues) unless queues.empty?

  rel
end

# File lib/delayed_job_web/application/app.rb, line 68
def h(text)
  Rack::Utils.escape_html(text)
end

# File lib/delayed_job_web/application/app.rb, line 188
def partial(template, local_vars = {})
  @partial = true
  erb(template.to_sym, {:layout => false}, local_vars)
ensure
  @partial = false
end

# File lib/delayed_job_web/application/app.rb, line 72
def path_prefix
  request.env['SCRIPT_NAME']
end

# File lib/delayed_job_web/application/app.rb, line 42
def per_page
  params[:per_page].to_i > 0 ? params[:per_page].to_i : 20
end

# File lib/delayed_job_web/application/app.rb, line 205
def poll
  if @polling
    text = "Last Updated: #{Time.now.strftime("%H:%M:%S")}"
  else
    text = "<a href='#{u(request.path_info + ".poll")}' rel='poll'>Live Poll</a>"
  end
  "<p class='poll'>#{text}</p>"
end

# File lib/delayed_job_web/application/app.rb, line 54
def queue_path(queue)
  with_queue(queue) do
    url_path(:overview)
  end
end

# File lib/delayed_job_web/application/app.rb, line 214
def show_for_polling(page)
  content_type "text/html"
  @polling = true
  # show(page.to_sym, false).gsub(/\s{1,}/, ' ')
  @jobs = delayed_jobs(page.to_sym, @queues)
  erb(page.to_sym, {:layout => false})
end

# File lib/delayed_job_web/application/app.rb, line 38
def start
  params[:start].to_i
end

# File lib/delayed_job_web/application/app.rb, line 76
def tabs
  [
    {:name => 'Overview', :path => '/overview'},
    {:name => 'Enqueued', :path => '/enqueued'},
    {:name => 'Working', :path => '/working'},
    {:name => 'Pending', :path => '/pending'},
    {:name => 'Failed', :path => '/failed'},
    {:name => 'Stats', :path => '/stats'}
  ]
end

# File lib/delayed_job_web/application/app.rb, line 46
def url_path(*path_parts)
  url = [ path_prefix, path_parts ].join("/").squeeze('/')
  url += "?queues=#{CGI.escape(@queues.join(","))}" unless @queues.empty?
  url
end

# File lib/delayed_job_web/application/app.rb, line 60
def with_queue(queue, &block)
  aux_queues = @queues
  @queues = Array(queue)
  result  = block.call
  @queues = aux_queues
  result
end