eidetic_eventstore_mongodb

defmodule Eidetic.EventStore.MongoDB do
  @moduledoc """
  MongoDB Adapter for Eidetic
  """
  use GenServer

  @doc false
  def start_link(options \\ []) do
    GenServer.start_link(__MODULE__, %{}, options)
  end

  @doc false
  def handle_call({:record, event = %Eidetic.Event{}}, _from, _state) do
    {:ok, %Mongo.InsertOneResult{inserted_id: object_identifier}} = event
    |> transform_in
    |> insert

    {:reply, {:ok, [object_identifier: object_identifier]}, %{}}
  end

  @doc false
  def handle_call({:fetch, identifier}, _from, _state) do
    events = identifier
    |> select
    |> transform_out

    {:reply, {:ok, events}, %{}}
  end

  @doc false
  defp insert(document) do
    Mongo.insert_one(:mongo, "events", document, pool: DBConnection.Poolboy)
  end

  @doc false
  defp select(identifier) do
    Mongo.find(:mongo, "events", %{"$query": %{identifier: identifier}}, pool: DBConnection.Poolboy)
    |> Enum.to_list()
  end

  @doc false
  defp transform_in(event = %Eidetic.Event{}) do
    %{event | datetime: DateTime.to_iso8601(event.datetime)}
  end

  @doc false
  defp transform_out(events) when is_list(events) do
    Enum.reduce(events, [], fn(event, list) ->
      list ++ [transform_to_eidetic_event(event)]
    end)
  end

  @doc false
  # TODO: Move this to Eidetic, and not the adapter
  defp transform_to_eidetic_event(event) when is_map(event) do
    {:ok, datetime, seconds} = DateTime.from_iso8601(event["datetime"])

    event = Map.update!(event, "payload", fn(payload) -> Map.new(payload, fn {k, v} -> {String.to_atom(k), v} end) end)

    %Eidetic.Event{}
    |> Map.merge(Map.new(event, fn {k, v} -> {String.to_atom(k), v} end))
    |> Map.delete(:_id)
    |> Map.put(:datetime, datetime)
  end
end