lib/rdf/query/bgp.ex

defmodule RDF.Query.BGP do
  @moduledoc """
  A struct for Basic Graph Pattern queries.

  See `RDF.Query` and its functions on how to construct this query struct and
  apply it on `RDF.Graph`s.
  """

  @enforce_keys [:triple_patterns]
  defstruct [:triple_patterns]

  alias RDF.Star.Statement

  @type variable :: String.t()
  @type triple_pattern :: {
          subject :: variable | Statement.subject(),
          predicate :: variable | Statement.predicate(),
          object :: variable | Statement.object()
        }
  @type triple_patterns :: list(triple_pattern)

  @type t :: %__MODULE__{triple_patterns: triple_patterns}

  @doc """
  Return a list of all variables in a BGP.
  """
  @spec variables(any) :: [atom]
  def variables(bgp)

  def variables(%__MODULE__{triple_patterns: triple_patterns}), do: variables(triple_patterns)

  def variables(triple_patterns) when is_list(triple_patterns) do
    triple_patterns
    |> Enum.flat_map(&variables/1)
    |> Enum.uniq()
  end

  def variables({quoted, p, o}) when is_tuple(quoted),
    do: variables(quoted) ++ variables({"", p, o})

  def variables({s, p, quoted}) when is_tuple(quoted),
    do: variables(quoted) ++ variables({s, p, ""})

  def variables({s, p, o}) when is_atom(s) and is_atom(p) and is_atom(o), do: [s, p, o]
  def variables({s, p, _}) when is_atom(s) and is_atom(p), do: [s, p]
  def variables({s, _, o}) when is_atom(s) and is_atom(o), do: [s, o]
  def variables({_, p, o}) when is_atom(p) and is_atom(o), do: [p, o]
  def variables({s, _, _}) when is_atom(s), do: [s]
  def variables({_, p, _}) when is_atom(p), do: [p]
  def variables({_, _, o}) when is_atom(o), do: [o]

  def variables(_), do: []
end