update tests

diff --git a/test/cluster_kv_test.exs b/test/cluster_kv_test.exs
index 05b9e937d7854887b3b30fc7a327bbb63cc04ff3..d62e780a87f11aee648d0f14bb4bba666c2bda60 100644 (file)
--- a/test/cluster_kv_test.exs
+++ b/test/cluster_kv_test.exs
@@ -17,10 +17,11 @@ defmodule ClusterKVTest do
   end
 
   test "test", %{db: db} do
-    me = {self(), self()}
+    me = {self(), Node.self()}
     ClusterKV.put(db, @keyspace, "test1:test", :hello)
     ClusterKV.put(db, @keyspace, "test1:test", :cruel)
     ClusterKV.put(db, @keyspace, "test1:test", :world)
+    ClusterKV.put(db, @keyspace, "test1:test", me)
 
     assert "test:1" = ClusterKV.get_wildcard_key(".test.light..status", ".", ":", "")
 
@@ -34,7 +35,8 @@ defmodule ClusterKVTest do
       ""
     )
 
-    assert {"test1:test", [:world, :cruel, :hello]} = ClusterKV.get(db, @keyspace, "test1:test")
+    assert {"test1:test", [^me, :world, :cruel, :hello]} =
+             ClusterKV.get(db, @keyspace, "test1:test")
 
     assert [{["com", "test", "", "temp"], {1_003_039_494, me}}] =
              ClusterKV.wildcard(
@@ -48,6 +50,10 @@ defmodule ClusterKVTest do
 
     ClusterKV.update(db, @keyspace, "test1:test", :cruel, :remove)
 
+    assert {"test1:test", [^me, :world, :hello]} = ClusterKV.get(db, @keyspace, "test1:test")
+
+    ClusterKV.update(db, @keyspace, "test1:test", me, :remove)
+
     assert {"test1:test", [:world, :hello]} = ClusterKV.get(db, @keyspace, "test1:test")
 
     ClusterKV.update(db, @keyspace, "test1:test", :hi, :replace)