clean up between tests

Author: drteeth

config/test.exs

@@ -6,7 +6,7 @@ config :coffee_shop, CoffeeShop.Repo,
   password: "postgres",
   database: "coffee_shop_test",
   hostname: "localhost",
-  pool: Ecto.Adapters.SQL.Sandbox
+  pool_size: 1
 
 # We don't run a server during test. If one is required,
 # you can enable the server option below.

test/support/conn_case.ex

@@ -6,13 +6,6 @@ defmodule CoffeeShopWeb.ConnCase do
   Such tests rely on `Phoenix.ConnTest` and also
   import other functionality to make it easier
   to build common data structures and query the data layer.
-
-  Finally, if the test case interacts with the database,
-  we enable the SQL sandbox, so changes done to the database
-  are reverted at the end of every test. If you are using
-  PostgreSQL, you can even run database tests asynchronously
-  by setting `use CoffeeShopWeb.ConnCase, async: true`, although
-  this option is not recommended for other databases.
   """
 
   use ExUnit.CaseTemplate
@@ -28,12 +21,8 @@ defmodule CoffeeShopWeb.ConnCase do
     end
   end
 
-  setup tags do
-    :ok = Ecto.Adapters.SQL.Sandbox.checkout(CoffeeShop.Repo)
-
-    unless tags[:async] do
-      Ecto.Adapters.SQL.Sandbox.mode(CoffeeShop.Repo, {:shared, self()})
-    end
+  setup _tags do
+    CoffeeShop.Storage.reset!()
 
     {:ok, conn: Phoenix.ConnTest.build_conn()}
   end

test/support/storage.ex

@@ -0,0 +1,39 @@
+defmodule CoffeeShop.Storage do
+  @doc """
+  Reset the event store and read store databases.
+  """
+  def reset! do
+    :ok = Application.stop(:coffee_shop)
+
+    reset_eventstore!()
+
+    # reset_readstore!() # This will come in handy once we add a readstore
+
+    {:ok, _} = Application.ensure_all_started(:coffee_shop)
+  end
+
+  defp reset_eventstore! do
+    {:ok, conn} =
+      CoffeeShop.EventStore.config()
+      |> EventStore.Config.default_postgrex_opts()
+      |> Postgrex.start_link()
+
+    EventStore.Storage.Initializer.reset!(conn)
+  end
+
+  defp reset_readstore! do
+    readstore_config = Application.get_env(:coffee_shop, CoffeeShop.Repo)
+
+    {:ok, conn} = Postgrex.start_link(readstore_config)
+
+    Postgrex.query!(conn, truncate_readstore_tables(), [])
+  end
+
+  defp truncate_readstore_tables do
+    """
+    TRUNCATE TABLE
+      projection_versions
+    RESTART IDENTITY;
+    """
+  end
+end

test/test_helper.exs

@@ -1,2 +1,2 @@
+ExUnit.configure(exclude: [:pending])
 ExUnit.start()
-Ecto.Adapters.SQL.Sandbox.mode(CoffeeShop.Repo, :manual)