From c393c2e091aca847a9473ff848cf8f8d15f6c96f Mon Sep 17 00:00:00 2001
From: JimMoen <LnJimMoen@outlook.com>
Date: Fri, 21 Jul 2023 19:42:02 +0800
Subject: [PATCH] test: ets table cleanup after cases

---
 .../test/emqx_rule_index_SUITE.erl            | 24 ++++++++++++-------
 1 file changed, 16 insertions(+), 8 deletions(-)

diff --git a/apps/emqx_rule_engine/test/emqx_rule_index_SUITE.erl b/apps/emqx_rule_engine/test/emqx_rule_index_SUITE.erl
index c4b1b4848..cf4b67cd4 100644
--- a/apps/emqx_rule_engine/test/emqx_rule_index_SUITE.erl
+++ b/apps/emqx_rule_engine/test/emqx_rule_index_SUITE.erl
@@ -30,7 +30,8 @@ t_insert(_) ->
     true = emqx_rule_index:insert(<<"sensor/+/#">>, t_insert_2, <<>>, Tab),
     true = emqx_rule_index:insert(<<"sensor/#">>, t_insert_3, <<>>, Tab),
     ?assertEqual(<<"sensor/#">>, get_topic(match(<<"sensor">>, Tab))),
-    ?assertEqual(t_insert_3, get_id(match(<<"sensor">>, Tab))).
+    ?assertEqual(t_insert_3, get_id(match(<<"sensor">>, Tab))),
+    true = ets:delete(Tab).
 
 t_match(_) ->
     Tab = new(),
@@ -40,7 +41,8 @@ t_match(_) ->
     ?assertMatch(
         [<<"sensor/#">>, <<"sensor/+/#">>],
         [get_topic(M) || M <- matches(<<"sensor/1">>, Tab)]
-    ).
+    ),
+    true = ets:delete(Tab).
 
 t_match2(_) ->
     Tab = new(),
@@ -54,7 +56,8 @@ t_match2(_) ->
     ?assertEqual(
         false,
         emqx_rule_index:match(<<"$SYS/broker/zenmq">>, Tab)
-    ).
+    ),
+    true = ets:delete(Tab).
 
 t_match3(_) ->
     Tab = new(),
@@ -77,7 +80,8 @@ t_match3(_) ->
     ?assertEqual(
         t_match3_sys,
         get_id(match(<<"$SYS/a/b/c">>, Tab))
-    ).
+    ),
+    true = ets:delete(Tab).
 
 t_match4(_) ->
     Tab = new(),
@@ -93,7 +97,8 @@ t_match4(_) ->
     ?assertEqual(
         [<<"/#">>, <<"/+/a/b/c">>],
         [get_topic(M) || M <- matches(<<"/0/a/b/c">>, Tab)]
-    ).
+    ),
+    true = ets:delete(Tab).
 
 t_match5(_) ->
     Tab = new(),
@@ -114,21 +119,24 @@ t_match5(_) ->
     ?assertEqual(
         [<<"#">>, <<T/binary, "/#">>, <<T/binary, "/+">>],
         [get_topic(M) || M <- matches(<<T/binary, "/1">>, Tab)]
-    ).
+    ),
+    true = ets:delete(Tab).
 
 t_match6(_) ->
     Tab = new(),
     T = <<"a/b/c/d/e/f/g/h/i/j/k/l/m/n/o/p/q/r/s/t/u/v/w/x/y/z">>,
     W = <<"+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/+/#">>,
     emqx_rule_index:insert(W, ID = t_match6, <<>>, Tab),
-    ?assertEqual(ID, get_id(match(T, Tab))).
+    ?assertEqual(ID, get_id(match(T, Tab))),
+    true = ets:delete(Tab).
 
 t_match7(_) ->
     Tab = new(),
     T = <<"a/b/c/d/e/f/g/h/i/j/k/l/m/n/o/p/q/r/s/t/u/v/w/x/y/z">>,
     W = <<"a/+/c/+/e/+/g/+/i/+/k/+/m/+/o/+/q/+/s/+/u/+/w/+/y/+/#">>,
     emqx_rule_index:insert(W, t_match7, <<>>, Tab),
-    ?assertEqual(W, get_topic(match(T, Tab))).
+    ?assertEqual(W, get_topic(match(T, Tab))),
+    true = ets:delete(Tab).
 
 new() ->
     ets:new(?MODULE, [public, ordered_set, {write_concurrency, true}]).