test(dssubs): adapt `t_lease_reconnect` testcase

apps/emqx_ds_shared_sub/src/emqx_ds_shared_sub_registry.erl

@@ -4,8 +4,6 @@
 
 -module(emqx_ds_shared_sub_registry).
 
--behaviour(supervisor).
-
 %% API
 -export([
     start_link/0,
@@ -17,7 +15,7 @@
     start_elector/2
 ]).
 
-%% supervisor behaviour callbacks
+-behaviour(supervisor).
 -export([init/1]).
 
 %%------------------------------------------------------------------------------
@@ -76,7 +74,7 @@ init([]) ->
     SupFlags = #{
         strategy => one_for_one,
         intensity => 10,
-        period => 10
+        period => 1
     },
     ChildSpecs = [],
     {ok, {SupFlags, ChildSpecs}}.

apps/emqx_ds_shared_sub/test/emqx_ds_shared_sub_SUITE.erl

@@ -417,8 +417,8 @@ t_lease_reconnect(_Config) ->
 
     ConnShared = emqtt_connect_sub(<<"client_shared">>),
 
-    %% Stop registry to simulate unability to find leader.
-    ok = supervisor:terminate_child(emqx_ds_shared_sub_sup, emqx_ds_shared_sub_registry),
+    %% Simulate unability to find leader.
+    ok = emqx_ds_shared_sub_leader_store:close(),
 
     ?assertWaitEvent(
         {ok, _, _} = emqtt:subscribe(ConnShared, <<"$share/gr2/topic2/#">>, 1),
@@ -426,9 +426,9 @@ t_lease_reconnect(_Config) ->
         5_000
     ),
 
-    %% Start registry, agent should retry after some time and find the leader.
+    %% Agent should retry after some time and find the leader.
     ?assertWaitEvent(
-        {ok, _} = supervisor:restart_child(emqx_ds_shared_sub_sup, emqx_ds_shared_sub_registry),
+        ok = emqx_ds_shared_sub_leader_store:open(),
         #{?snk_kind := leader_lease_streams},
         5_000
     ),