defmodule Extreme.System.AggregatePidManager do
  use Supervisor
  alias Extreme.System.AggregateRegistry, as: Registry
  alias Extreme.System.AggregateSup

  def start_link(prefix, aggregate_mod),
    do: Supervisor.start_link(__MODULE__, {prefix, aggregate_mod}, name: name(aggregate_mod))

  def init({prefix, aggregate_mod}) do
    children = [
      worker(Registry, [Registry.name(aggregate_mod)]),
      supervisor(AggregateSup, [prefix, aggregate_mod])
    ]

    supervise(children, strategy: :one_for_all)
  end

  def name(aggregate_mod), do: "#{aggregate_mod}.PidManager" |> String.to_atom()
end