quantum_startup_test.exs

defmodule QuantumStartupTest do
  @moduledoc false

  use ExUnit.Case

  import ExUnit.CaptureLog

  import Crontab.CronExpression

  defmodule Scheduler do
    @moduledoc false

    use Quantum.Scheduler, otp_app: :quantum_startup_test
  end

  @tag :startup
  test "prevent duplicate job names on startup" do
    capture_log(fn ->
      test_jobs = [
        {:test_job, [schedule: ~e[1 * * * *], task: fn -> :ok end]},
        {:test_job, [schedule: ~e[2 * * * *], task: fn -> :ok end]},
        {"3 * * * *", fn -> :ok end},
        {"4 * * * *", fn -> :ok end}
      ]

      Application.put_env(:quantum_startup_test, QuantumStartupTest.Scheduler, jobs: test_jobs)

      capture_log(fn ->
        {:ok, _pid} = start_supervised(Scheduler)

        assert Enum.count(QuantumStartupTest.Scheduler.jobs()) == 3
        assert QuantumStartupTest.Scheduler.find_job(:test_job).schedule == ~e[1 * * * *]

        :ok = stop_supervised(Scheduler)
      end)
    end)
  end
end