rdb_helpers.ex

defmodule MyApp.RethinkDB.Helpers do

  def run(query, opts) do
    query
    |> MyApp.Database.run(opts)
    |> handle_response
  end

  def run(query) do
    run(query, [])
  end

  defp handle_response(%{data: data}) do
    case data do
      # Errors
      %{"first_error" => error} -> {:error, error}
      %{"r" => errors} -> raise List.first errors # always db error
      _ ->
        {:ok, data}
    end
  end

  defp handle_response(%RethinkDB.Exception.ConnectionClosed{}) do
    raise "Cannot connect to RethinkDB"
  end
end