# frozen_string_literal: true

require “rake/testtask”

#TODO: add qu back to the list after it support Quails 5.1 ACTIVEJOB_ADAPTERS = %w(async inline delayed_job que queue_classic resque sidekiq sneakers sucker_punch backburner test) ACTIVEJOB_ADAPTERS.delete(“queue_classic”) if defined?(JRUBY_VERSION)

task default: :test task test: “test:default”

task :package

namespace :test do

desc "Run all adapter tests"
task :default do
  run_without_aborting ACTIVEJOB_ADAPTERS.map { |a| "test:#{a}" }
end

desc "Run all adapter tests in isolation"
task :isolated do
  run_without_aborting ACTIVEJOB_ADAPTERS.map { |a| "test:isolated:#{a}" }
end

desc "Run integration tests for all adapters"
task :integration do
  run_without_aborting (ACTIVEJOB_ADAPTERS - ["test"]).map { |a| "test:integration:#{a}" }
end

task "env:integration" do
  ENV["AJ_INTEGRATION_TESTS"] = "1"
end

ACTIVEJOB_ADAPTERS.each do |adapter|
  task("env:#{adapter}") { ENV["AJ_ADAPTER"] = adapter }

  Rake::TestTask.new(adapter => "test:env:#{adapter}") do |t|
    t.description = "Run adapter tests for #{adapter}"
    t.libs << "test"
    t.test_files = FileList["test/cases/**/*_test.rb"]
    t.verbose = true
    t.warning = false
    t.ruby_opts = ["--dev"] if defined?(JRUBY_VERSION)
  end

  namespace :isolated do
    task adapter => "test:env:#{adapter}" do
      Dir.glob("#{__dir__}/test/cases/**/*_test.rb").all? do |file|
        sh(Gem.ruby, "-w", "-I#{__dir__}/lib", "-I#{__dir__}/test", file)
      end || raise("Failures")
    end
  end

  namespace :integration do
    Rake::TestTask.new(adapter => ["test:env:#{adapter}", "test:env:integration"]) do |t|
      t.description = "Run integration tests for #{adapter}"
      t.libs << "test"
      t.test_files = FileList["test/integration/**/*_test.rb"]
      t.verbose = true
      t.warning = false
      t.ruby_opts = ["--dev"] if defined?(JRUBY_VERSION)
    end
  end
end

end

def run_without_aborting(tasks)

errors = []

tasks.each do |task|
  begin
    Rake::Task[task].invoke
  rescue Exception
    errors << task
  end
end

abort "Errors running #{errors.join(', ')}" if errors.any?

end