ash_postgres_belongs_to_index

defmodule AshPostgresBelongsToIndex.Transformer do
  use Spark.Dsl.Transformer

  alias Spark.Dsl.Transformer
  alias Ash.Resource.Relationships.BelongsTo

  def after?(Ash.Resource.Transformers.BelongsToAttribute), do: true
  def after?(_), do: false

  def transform(dsl_state) do
    except_list = Transformer.get_option(dsl_state, [:postgres_belongs_to_index], :except, [])

    manual_references =
      Transformer.get_entities(dsl_state, [:postgres, :references])
      |> Enum.map(& &1.relationship)

    dsl_state
    |> get_belongs_toes()
    |> Enum.reject(fn %BelongsTo{name: name} -> name in except_list end)
    |> Enum.reject(fn %BelongsTo{name: name} -> name in manual_references end)
    |> Enum.reduce(dsl_state, fn %BelongsTo{name: name}, dsl_state ->
      {:ok, reference} =
        Transformer.build_entity(AshPostgres.DataLayer, [:postgres, :references], :reference,
          relationship: name,
          index?: true
        )

      dsl_state |> Transformer.add_entity([:postgres, :references], reference, type: :append)
    end)
    |> then(fn dsl_state -> {:ok, dsl_state} end)
  end

  def get_belongs_toes(dsl_state) do
    multitenant_attr = dsl_state |> Transformer.get_option([:multitenancy], :attribute)

    dsl_state
    |> Transformer.get_entities([:relationships])
    |> Enum.filter(fn
      %BelongsTo{source_attribute: source_attribute} -> source_attribute != multitenant_attr
      %{} -> false
    end)
  end
end