defmodule Commanded.Helpers.Process do
  import ExUnit.Assertions

  @doc """
  Stop the given process with a non-normal exit reason
  """
  def shutdown(pid) when is_pid(pid) do
    Process.unlink(pid)
    Process.exit(pid, :shutdown)

    ref = Process.monitor(pid)
    assert_receive {:DOWN, ^ref, _, _, _}, 5_000
  end
  
  def shutdown(aggregate_uuid) do
    [{pid, _}] = Registry.lookup(:aggregate_registry, aggregate_uuid)
    shutdown(pid)
  end
end