defmodule SPARQL.Processor do
  @moduledoc """
  Context module for the SPARQL processor executing SPARQL queries and updates.
  """

  alias SPARQL.{Query, Algebra}

  @doc """
  Executes a `SPARQL.Query` or string with a SPARQL string against a `RDF.Data` structure.
  """
  def query(data, query, options \\ [])

  def query(data, query_string, options) when is_binary(query_string) do
    with %Query{} = query <- Query.new(query_string, options) do
      query(data, query, options)
    end
  end

  def query(data, %Query{expr: expr, base: base, prefixes: prefixes}, _options) do
    {:ok, generator} =
      RDF.BlankNode.Generator.start_link(algorithm: RDF.BlankNode.Generator.Increment, prefix: "b")

    try do
      Algebra.Expression.evaluate(expr, data, execution_context(base, prefixes, generator))
      |> query_post_processing()
    after
      RDF.BlankNode.Generator.stop(generator)
    end
  end

  def query_post_processing(%Query.Result{} = result) do
    Query.Result.remove_identity(result)
  end

  def query_post_processing(result), do: result

  defp execution_context(base, prefixes, generator) do
    %{
      base: base,
      prefixes: prefixes,
      time: DateTime.utc_now(),
      bnode_generator: generator
    }
  end

end