cqrs_events

defmodule Cqrs.Events.Server do
  use GenServer
  require Logger
  alias Cqrs.Events.Handlers
  alias Cqrs.Events.Db

  import Moebius.DocumentQuery, only: [db: 1, insert: 2]

  # GenServer API
  def start_link(name) do
    GenServer.start_link(__MODULE__, %{}, [name: name])
  end

  # Public API

  def trigger(event, payload \\ %{}) do
    GenServer.call(__MODULE__, {event, payload})
  end

  # Private API

  def handle_call({event, payload}, _from, state) do
    db(:cqrs_events)
    |> insert(%{event: event, payload: payload})
    |> Db.run

    :syn.multi_call({event, false}, %{payload: payload})
    :syn.publish({event, true}, %{payload: payload})

    {:reply, :ok, state}
  end
end