issues #28, #30: add cache manager tests

Signed-off-by: Matteo Cafasso <[email protected]>

Author: noxdafox

test/cache_manager_test.exs

@@ -0,0 +1,58 @@
+# This Source Code Form is subject to the terms of the Mozilla Public
+# License, v. 2.0. If a copy of the MPL was not distributed with this
+# file, You can obtain one at http://mozilla.org/MPL/2.0/.
+#
+# Copyright (c) 2017-2019, Matteo Cafasso.
+# All rights reserved.
+
+defmodule RabbitMQ.MessageDeduplicationPlugin.CacheManager.Test do
+  use ExUnit.Case
+
+  alias :timer, as: Timer
+  alias :mnesia, as: Mnesia
+  alias RabbitMQ.MessageDeduplicationPlugin.Cache, as: Cache
+  alias RabbitMQ.MessageDeduplicationPlugin.CacheManager, as: CacheManager
+
+  @caches :message_deduplication_caches
+
+  setup do
+    start_supervised!(%{id: :cache_manager,
+                        start: {CacheManager,
+                                :start_link,
+                                []}})
+
+    %{}
+  end
+
+  test "cache creation", %{} do
+    options = [persistence: :memory]
+
+    CacheManager.create(:cache, options)
+    {:atomic, [:cache]} = Mnesia.transaction(fn -> Mnesia.all_keys(@caches) end)
+    CacheManager.destroy(:cache)
+  end
+
+  test "cache deletion", %{} do
+    options = [persistence: :memory]
+
+    :ok = CacheManager.create(:cache, options)
+    {:atomic, [:cache]} = Mnesia.transaction(fn -> Mnesia.all_keys(@caches) end)
+    :ok = CacheManager.destroy(:cache)
+    {:atomic, []} = Mnesia.transaction(fn -> Mnesia.all_keys(@caches) end)
+  end
+
+  test "cache cleanup routine", %{} do
+    options = [persistence: :memory]
+
+    :ok = CacheManager.create(:cache, options)
+
+    {:ok, :inserted} = Cache.insert(:cache, "foo", 1000)
+
+    Timer.sleep(3200)
+
+    {:atomic, []} = Mnesia.transaction(fn -> Mnesia.all_keys(:cache) end)
+
+    :ok = CacheManager.destroy(:cache)
+  end
+
+end

test/cache_test.exs

@@ -2,7 +2,7 @@
 # License, v. 2.0. If a copy of the MPL was not distributed with this
 # file, You can obtain one at http://mozilla.org/MPL/2.0/.
 #
-# Copyright (c) 2017-2018, Matteo Cafasso.
+# Copyright (c) 2017-2019, Matteo Cafasso.
 # All rights reserved.
 
 defmodule RabbitMQ.MessageDeduplicationPlugin.Cache.Test do
@@ -69,7 +69,7 @@ defmodule RabbitMQ.MessageDeduplicationPlugin.Cache.Test do
     {:ok, :inserted} = Cache.insert(cache, "foo", Timer.seconds(1))
     {:ok, :exists} = Cache.insert(cache, "foo")
 
-    Timer.sleep(3200)
+    Timer.sleep(1200)
 
     :ok = Cache.delete_expired_entries(cache)