read_step.ex

defmodule Ash.Reactor.ReadStep do
  @moduledoc """
  The Reactor step which is used to execute read actions.
  """
  use Reactor.Step
  import Ash.Reactor.StepUtils

  alias Ash.Query

  def run(arguments, _context, options) do
    query_options =
      options
      |> maybe_set_kw(:authorize?, options[:authorize?])
      |> maybe_set_kw(:actor, arguments[:actor])
      |> maybe_set_kw(:tenant, arguments[:tenant])

    action_options =
      []
      |> maybe_set_kw(:authorize?, options[:authorize?])

    options[:resource]
    |> Query.for_read(options[:action], arguments[:input], query_options)
    |> options[:domain].read(action_options)
    |> case do
      {:ok, records} -> {:ok, records}
      {:ok, records, _} -> {:ok, records}
      {:error, reason} -> {:error, reason}
    end
  end
end