carguero_task_bunny

defmodule Mix.Tasks.TaskBunny.Queue.Reset do
  use Mix.Task

  @shortdoc "Reset all queues in config files"

  @moduledoc """
  Mix task to reset all queues.

  It deletes the queues and creates them again.
  Therefore all messages in the queues are removed.
  """

  alias TaskBunny.{Connection, Config, Queue}

  @doc false
  @spec run(list) :: any
  def run(_args) do
    Config.disable_auto_start()
    Mix.Task.run("app.start")

    _connections =
      Enum.map(Config.hosts(), fn host ->
        Connection.start_link(host)
      end)

    Config.queues()
    |> Enum.each(fn queue -> reset_queue(queue) end)
  end

  defp reset_queue(queue) do
    Mix.shell().info("Resetting queues for #{inspect(queue)}")
    host = queue[:host] || :default

    Queue.delete_with_subqueues(host, queue[:name])
    Queue.declare_with_subqueues(host, queue[:name])
  end
end