require 'minitest'
require "minitest/autorun"
require 'pry'


$:.unshift(".")
require 'resque_stuck_queue'
require File.join(File.expand_path(File.dirname(__FILE__)), "resque", "set_redis_key")
require File.join(File.expand_path(File.dirname(__FILE__)), "test_helper")

class TestIntegration < Minitest::Test

  include TestHelper

  # UBER HAXING no after(:all) or before(:all)
  class << self
    def tests_running?
      test_count = public_instance_methods.select{|m| m.to_s.match(/^test_/)}.size
      true if tests_ran != test_count
    end

    def tests_done?
      !tests_running?
    end

    attr_accessor :tests_ran, :resque_pid
    def tests_ran
      @tests_ran ||= 0
    end

    def run_resque_before_all
      return if @running_resque
      @running_resque = true

      @resque_pid = TestHelper.run_resque
    end
  end

  def setup
    Resque::StuckQueue.config[:redis] = Redis.new
    Resque::StuckQueue.redis.flushall
    Resque::StuckQueue.config[:watcher_interval] = 1
    Resque::StuckQueue.config[:abort_on_exception] = true
    self.class.run_resque_before_all
    self.class.tests_ran += 1
  end

  def teardown
    Resque::StuckQueue.reset!
    if self.class.tests_done?
      hax_kill_resque
      Process.waitall
    end
  end

  def test_resque_enqueues_a_job_does_not_trigger
    puts "#{__method__}"

    with_no_resque_failures do
      Resque::StuckQueue.config[:trigger_timeout] = 10
      Resque::StuckQueue.config[:heartbeat_interval] = 1
      Resque::StuckQueue.config[:redis] = Redis.new

      @triggered = false
      Resque::StuckQueue.config[:triggered_handler] = proc { @triggered = true }
      start_and_stop_loops_after(5)
      sleep 3 # job ran successfully, so don't trigger
      assert_equal @triggered, false
    end
  end

  def test_resque_does_not_enqueues_a_job_does_trigger
    puts "#{__method__}"

    with_no_resque_failures do
      Resque::StuckQueue.config[:trigger_timeout] = 0
      Resque::StuckQueue.config[:heartbeat_interval] = 1
      Resque::StuckQueue.config[:redis] = Redis.new

      @triggered = false
      Resque::StuckQueue.config[:triggered_handler] = proc { @triggered = true }
      start_and_stop_loops_after(2)
      # check handler did get called
      assert_equal @triggered, true
    end
  end

  def test_has_settable_custom_hearbeat_job
    puts "#{__method__}"

    with_no_resque_failures do
      Resque::StuckQueue.config[:trigger_timeout] = 2 # won't allow waiting too much and will complain (eg trigger) sooner than later
      Resque::StuckQueue.config[:heartbeat_interval] = 1
      Resque::StuckQueue.config[:redis] = Redis.new

      begin
        Resque::StuckQueue.config[:heartbeat_job] = proc { Resque.enqueue_to(:app, Resque::StuckQueue::HeartbeatJob, Resque::StuckQueue.heartbeat_key_for(:app)) }
        @triggered = false
        Resque::StuckQueue.config[:triggered_handler] = proc { @triggered = true }
        start_and_stop_loops_after(4)

        sleep 3 # allow trigger
        assert true, "should not have raised"
        assert @triggered, "should have triggered"
      rescue => e
        assert false, "should have succeeded with good refresh_job.\n #{e.inspect}"
      end
    end
  end

end