Storage case to base tests for eventstore on

storage_case.ex

defmodule MyApp.StorageCase do
  use ExUnit.CaseTemplate

  setup do
    Application.stop(:myapp)
    Application.stop(:commanded)
    Application.stop(:eventstore)

    reset_eventstore()
    reset_readstore()

    Application.ensure_all_started(:myapp)

    :ok
  end

  defp reset_eventstore do
    eventstore_config = 
      Application.get_env(:eventstore, EventStore.Storage) 
      |> Keyword.merge(pool: DBConnection.Poolboy)

    {:ok, conn} = Postgrex.start_link(eventstore_config)

    EventStore.Storage.Initializer.reset!(conn)
  end

  defp reset_readstore do
    readstore_config = Application.get_env(:myapp, MyApp.Repo)

    {:ok, conn} = Postgrex.start_link(readstore_config)

    Postgrex.query!(conn, truncate_readstore_tables(), [])
  end

  defp truncate_readstore_tables do
"""
TRUNCATE TABLE
  projection_versions,
  -- ... additional read model tables
RESTART IDENTITY;
"""
  end
end