From 5ec4ae14d67e203720017e501e9d9c03309fa923 Mon Sep 17 00:00:00 2001
From: Diana Parra Corbacho <dparracorbac@vmware.com>
Date: Tue, 9 May 2023 16:30:03 +0200
Subject: [PATCH] Khepri: force shrink member to current member

Ra PR pending: https://github.com/rabbitmq/ra/pull/306
---
 deps/rabbit/src/rabbit_khepri.erl | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/deps/rabbit/src/rabbit_khepri.erl b/deps/rabbit/src/rabbit_khepri.erl
index ae5d9c920d04..a09f14fd3031 100644
--- a/deps/rabbit/src/rabbit_khepri.erl
+++ b/deps/rabbit/src/rabbit_khepri.erl
@@ -86,6 +86,8 @@
 -export([if_has_data/1,
          if_has_data_wildcard/0]).
 
+-export([force_shrink_member_to_current_member/0]).
+
 -ifdef(TEST).
 -export([force_metadata_store/1,
          clear_forced_metadata_store/0]).
@@ -372,6 +374,10 @@ force_reset() ->
     DataDir = maps:get(data_dir, ra_system:fetch(coordination)),
     ok = rabbit_file:recursive_delete(filelib:wildcard(DataDir ++ "/*")).
 
+force_shrink_member_to_current_member() ->
+    ok = ra_server_proc:force_shrink_members_to_current_member(
+           {?RA_CLUSTER_NAME, node()}).
+
 ensure_ra_system_started() ->
     {ok, _} = application:ensure_all_started(khepri),
     ok = rabbit_ra_systems:ensure_ra_system_started(?RA_SYSTEM).