x3m_rabbit

defmodule X3m.Rabbit.Consumers do
  use Supervisor
  alias X3m.Rabbit

  def start_link([channel_manager, configuration, opts]),
    do: Supervisor.start_link(__MODULE__, {channel_manager, configuration}, opts)

  def init({channel_manager, configuration}) do
    children =
      configuration
      |> Enum.map(&_define_worker(channel_manager, &1))

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

  defp _define_worker(channel_manager, {:publisher, name, targets}) do
    {Rabbit.Publisher, [channel_manager, name, targets, [name: name]]}
    |> Supervisor.child_spec(id: name)
  end

  defp _define_worker(channel_manager, {:listener, name, definition}) do
    {Rabbit.Listener, [channel_manager, name, definition, [name: name]]}
    |> Supervisor.child_spec(id: name)
  end
end