require File.dirname(__FILE__) + '/test_helper'

# Pull in the server test_helper from resque
require 'resque/server/test_helper.rb'

context "on GET to /schedule" do
  setup { get "/schedule" }

  should_respond_with_success
end

context "on GET to /schedule with scheduled jobs" do
  setup do
    Resque::Scheduler.env = 'production'
    Resque.schedule = {
      'some_ivar_job' => {
        'cron' => "* * * * *",
        'class' => 'SomeIvarJob',
        'args' => "/tmp",
        'rails_env' => 'production'
      },
      'some_other_job' => {
        'every' => ['5m'],
        'queue' => 'high',
        'class' => 'SomeOtherJob',
        'args' => {
          'b' => 'blah'
        }
      },
      'some_fancy_job' => {
        'every' => ['1m'],
        'queue' => 'fancy',
        'class' => 'SomeFancyJob',
        'args' => 'sparkles',
        'rails_env' => 'fancy'
      }
    }
    Resque::Scheduler.load_schedule!
    get "/schedule"
  end

  should_respond_with_success

  test 'see the scheduled job' do
    assert last_response.body.include?('SomeIvarJob')
  end

  test 'excludes jobs for other envs' do
    assert !last_response.body.include?('SomeFancyJob')
  end
end

context "on GET to /delayed" do
  setup { get "/delayed" }

  should_respond_with_success
end

context "on GET to /delayed/jobs/:klass" do
  setup do
    @t = Time.now + 3600
    Resque.enqueue_at(@t, SomeIvarJob, 'foo', 'bar')
    get URI("/delayed/jobs/SomeIvarJob?args=" + URI.encode(%w{foo bar}.to_json)).to_s
  end

  should_respond_with_success

  test 'see the scheduled job' do
    assert last_response.body.include?(@t.to_s)
  end

  context 'with a namespaced class' do
    setup do
      @t = Time.now + 3600
      module Foo
        class Bar
          def self.queue
            'bar'
          end
        end
      end
      Resque.enqueue_at(@t, Foo::Bar, 'foo', 'bar')
      get URI("/delayed/jobs/Foo::Bar?args=" + URI.encode(%w{foo bar}.to_json)).to_s
    end

    should_respond_with_success

    test 'see the scheduled job' do
      assert last_response.body.include?(@t.to_s)
    end
  end
end

def resque_schedule
  {
    'job_without_params' => {
      'cron' => '* * * * *',
      'class' => 'JobWithoutParams',
      'args' => {
        'host' => 'localhost'
      },
      'rails_env' => 'production'},
    'job_with_params' => {
      'cron' => '* * * * *',
      'class' => 'JobWithParams',
      'args' => {
        'host' => 'localhost'
      },
      'parameters' => {
        'log_level' => {
          'description' => 'The level of logging',
          'default' => 'warn'
        }
      }
    }
  }
end

context "POST /schedule/requeue" do
  setup do
    Resque.schedule = resque_schedule
    Resque::Scheduler.load_schedule!
  end

  test 'job without params' do
    # Regular jobs without params should redirect to /overview
    job_name = 'job_without_params'
    Resque::Scheduler.stubs(:enqueue_from_config).once.with(Resque.schedule[job_name])

    post '/schedule/requeue', {'job_name' => job_name}
    follow_redirect!
    assert_equal "http://example.org/overview", last_request.url
    assert last_response.ok?
  end

  test 'job with params' do
    # If a job has params defined,
    # it should render the template with a form for the job params
    job_name = 'job_with_params'
    post '/schedule/requeue', {'job_name' => job_name}

    assert last_response.ok?, last_response.errors
    assert last_response.body.include?("This job requires parameters")
    assert last_response.body.include?("<input type=\"hidden\" name=\"job_name\" value=\"#{job_name}\">")

    Resque.schedule[job_name]['parameters'].each do |param_name, param_config|
      assert last_response.body.include?(
        "<span style=\"border-bottom:1px dotted;\" title=\"#{param_config['description']}\">(?)</span>")
      assert last_response.body.include?(
        "<input type=\"text\" name=\"log_level\" value=\"#{param_config['default']}\">")
    end
  end
end

context "POST /schedule/requeue_with_params" do
  setup do
    Resque.schedule = resque_schedule
    Resque::Scheduler.load_schedule!
  end

  test 'job with params' do
    job_name = 'job_with_params'
    log_level = 'error'

    job_config = Resque.schedule[job_name]
    args = job_config['args'].merge('log_level' => log_level)
    job_config = job_config.merge('args' => args)

    Resque::Scheduler.stubs(:enqueue_from_config).once.with(job_config)

    post '/schedule/requeue_with_params', {
      'job_name' => job_name,
      'log_level' => log_level
    }
    follow_redirect!
    assert_equal "http://example.org/overview", last_request.url

    assert last_response.ok?, last_response.errors
  end
end

context "on POST to /delayed/search" do
  setup do
    t = Time.now + 60
    Resque.enqueue_at(t, SomeIvarJob)
    Resque.enqueue(SomeQuickJob)
  end

  test 'should find matching scheduled job' do
    post "/delayed/search" , 'search' => 'ivar'
    assert last_response.status == 200
    assert last_response.body.include?('SomeIvarJob')
  end

  test 'should find matching queued job' do
    post "/delayed/search" , 'search' => 'quick'
    assert last_response.status == 200
    assert last_response.body.include?('SomeQuickJob')
  end
end

context "on POST to /delayed/cancel_now" do
  setup { post "/delayed/cancel_now" }

  test 'redirects to overview' do
    assert last_response.status == 302
    assert last_response.header['Location'].include? '/delayed'
  end

end