oban_utils.ex

defmodule MyApp.ObanUtils do
  @doc """
  Wait for our Phoenix Endpoint to come online

  Without waiting for the Phoenix Endpoint to start up we have a race condition
  where a job may execute that broadcasts a message (which requires the Endpoint
  to be running). And additionally our Phoenix controller's depend on Oban to be
  running so that `Oban.insert/3` can be used (which gives us guarantees about
  uniqueness).

  So by delaying these jobs until the Endpoint is up we avoid the circular race
  condition.
  """
  def ensure_endpoint_alive(timeout \\ 10_000)

  def ensure_endpoint_alive(timeout) when timeout > 0 do
    if Process.whereis(FeltServerWeb.Endpoint) do
      :ok
    else
      Process.sleep(100)
      ensure_endpoint_alive(timeout - 100)
    end
  end

  def ensure_endpoint_alive(_timeout) do
    raise "Timeout exceeded while waiting for endpoint to be available"
  end
end