lib/memento/memento.ex

defmodule Memento do
  require Memento.Mnesia
  require Memento.Error


  @moduledoc """
  Simple + Powerful interface to the Erlang Mnesia Database.


  See the [README](https://github.com/sheharyarn/memento) to get
  started.
  """




  # Public API
  # ----------


  @doc """
  Start the Memento Application.

  This starts Memento and `:mnesia` along with some sane application
  defaults. See `:mnesia.start/0` for more details.
  """
  @spec start() :: :ok | {:error, any}
  def start do
    Application.start(:mnesia)
  end




  @doc """
  Stop the Memento Application.
  """
  @spec stop() :: :ok | {:error, any}
  def stop do
    Application.stop(:mnesia)
  end




  @doc """
  Tells Memento about other nodes running Memento/Mnesia.

  You can use this to connect to and synchronize with other
  nodes at runtime and/or on discovery, to take full advantage
  of the distribution mode of Memento and Mnesia.

  This is a wrapper method around `:mnesia.change_config/2`.


  ## Example

  ```
  # Connect to Memento running on a specific node
  Memento.add_nodes(:node_xyz@some_host)

  # Add all connected nodes to Memento distributed database
  Memento.add_nodes(Node.list())
  ```
  """
  @spec add_nodes(node | list(node)) :: {:ok, list(node)} | {:error, any}
  def add_nodes(nodes) do
    nodes = List.wrap(nodes)

    if Enum.any?(nodes, & !is_atom(&1)) do
      Memento.Error.raise("Invalid Node list passed")
    end

    Memento.Mnesia.call(:change_config, [:extra_db_nodes, nodes])
  end




  @doc """
  Prints `:mnesia` information to console.
  """
  @spec info() :: :ok
  def info do
    Memento.Mnesia.call(:info, [])
  end




  @doc """
  Returns all information about the Mnesia system.

  Optionally accepts a `key` atom argument which returns result for
  only that key. Will throw an exception if that key is invalid. See
  `:mnesia.system_info/0` for more information and a full list of
  allowed keys.
  """
  @spec system(atom) :: any
  def system(key \\ :all) do
    Memento.Mnesia.call(:system_info, [key])
  end




  # Delegates

  defdelegate wait(tables),          to: Memento.Table
  defdelegate wait(tables, timeout), to: Memento.Table

  defdelegate transaction(fun),      to: Memento.Transaction,  as: :execute
  defdelegate transaction!(fun),     to: Memento.Transaction,  as: :execute!

end