defmodule CTE.Supervisor do
  @moduledoc false
  use Supervisor

  def start_link(repo, otp_app, adapter, cte_config) do
    Supervisor.start_link(__MODULE__, {repo, otp_app, adapter, cte_config}, name: repo)
  end

  def init({repo, _otp_app, adapter, cte_config}) do
    # the otp_app here can be used for grabbing user definitions at runtime
    args = [repo: repo] ++ [config: cte_config]

    child_spec =
      %{
        id: repo,
        start: {adapter, :start_link, [args]}
      }
      |> wrap_child_spec(args)

    Supervisor.init([child_spec], strategy: :one_for_one, max_restarts: 0)
  end

  def start_child({mod, fun, args}, adapter, _meta) do
    case apply(mod, fun, args) do
      {:ok, pid} ->
        CTE.Registry.associate(self(), {adapter, %{pid: pid}})
        {:ok, pid}

      other ->
        other
    end
  end

  defp wrap_child_spec(%{start: start} = spec, args) do
    %{spec | start: {__MODULE__, :start_child, [start | args]}}
  end
end