conduit_nsq

defmodule ConduitNSQ.ConsumerGroup do
  @moduledoc """
  Manages consumers
  """

  use Supervisor

  def start_link(broker, subscribers, opts) do
    Supervisor.start_link(
      __MODULE__,
      [broker, subscribers, opts],
      name: name(broker)
    )
  end

  def child_spec([broker, _, _] = args) do
    %{
      id: name(broker),
      start: {__MODULE__, :start_link, args},
      type: :supervisor
    }
  end

  @impl true
  def init([broker, subscribers, opts]) do
    children =
      subscribers
      |> Enum.map(fn {name, sub_opts} ->
        {ConduitNSQ.Consumer, [broker, name, sub_opts, opts]}
      end)

    Supervisor.init(children, strategy: :one_for_one)
  end

  defp name(broker) do
    Module.concat(broker, ConsumerGroup)
  end
end