require_relative '../test_helper'

# Unit Test for RocketJob::Job
class HousekeepingJobTest < Minitest::Test
  class TestJob < RocketJob::Job
    def perform
    end
  end

  describe RocketJob::Jobs::HousekeepingJob do
    before do
      HousekeepingJobTest::TestJob.delete_all
      RocketJob::Jobs::HousekeepingJob.delete_all

      job = HousekeepingJobTest::TestJob.new(created_at: 2.days.ago)
      job.abort!
      job = HousekeepingJobTest::TestJob.new(created_at: 8.days.ago)
      job.abort!

      job = HousekeepingJobTest::TestJob.new(created_at: 2.days.ago)
      job.perform_now
      job.save!
      job = HousekeepingJobTest::TestJob.new(created_at: 8.days.ago)
      job.perform_now
      job.save!

      job = HousekeepingJobTest::TestJob.new(created_at: 2.days.ago)
      job.fail!
      job = HousekeepingJobTest::TestJob.new(created_at: 15.days.ago)
      job.fail!

      job = HousekeepingJobTest::TestJob.new(created_at: 400.days.ago)
      job.pause!
      job = HousekeepingJobTest::TestJob.new
      job.pause!

      HousekeepingJobTest::TestJob.create!(created_at: 15.days.ago)
      HousekeepingJobTest::TestJob.create!

      assert_equal 10, HousekeepingJobTest::TestJob.count, -> { HousekeepingJobTest::TestJob.all.to_a.ai }
    end

    after do
      @job.destroy if @job && !@job.new_record?
    end

    describe 'perform' do
      it 'destroys jobs' do
        @job = RocketJob::Jobs::HousekeepingJob.new
        @job.perform_now
        assert_equal 1, HousekeepingJobTest::TestJob.aborted.count, -> { HousekeepingJobTest::TestJob.aborted.to_a.ai }
        assert_equal 1, HousekeepingJobTest::TestJob.completed.count, -> { HousekeepingJobTest::TestJob.completed.to_a.ai }
        assert_equal 1, HousekeepingJobTest::TestJob.failed.count, -> { HousekeepingJobTest::TestJob.failed.to_a.ai }
        assert_equal 2, HousekeepingJobTest::TestJob.paused.count, -> { HousekeepingJobTest::TestJob.paused.to_a.ai }
        assert_equal 2, HousekeepingJobTest::TestJob.queued.count, -> { HousekeepingJobTest::TestJob.queued.to_a.ai }
      end
    end
  end
end