Update Khepri + New fold option

Author: dumbbell

MODULE.bazel

@@ -287,7 +287,7 @@ erlang_package.hex_package(
 erlang_package.git_package(
     name = "khepri",
     build_file = "@rabbitmq-server//bazel:BUILD.khepri",
-    commit = "cb52d575903ddb0e0f13d2ac9ee819b046f9d598",
+    commit = "a862938bd2927ae9b1580f914af246c3cd302a7e",
     repository = "rabbitmq/khepri",
 )
 

deps/rabbit/Makefile

@@ -151,7 +151,7 @@ dep_syslog = git https://github.com/schlagert/syslog 4.0.0
 dep_osiris = git https://github.com/rabbitmq/osiris v1.6.7
 dep_systemd = hex 0.6.1
 dep_seshat = git https://github.com/rabbitmq/seshat v0.6.1
-dep_khepri = git https://github.com/rabbitmq/khepri cb52d575903ddb0e0f13d2ac9ee819b046f9d598
+dep_khepri = git https://github.com/rabbitmq/khepri a862938bd2927ae9b1580f914af246c3cd302a7e
 dep_khepri_mnesia_migration = hex 0.1.1
 
 define usage_xml_to_erl

deps/rabbit/src/rabbit_db_queue.erl

@@ -994,7 +994,8 @@ delete_transient_in_khepri(FilterFun) ->
                         false ->
                             Acc
                     end
-            end, []),
+            end, [],
+            #{copy_tree_and_run_from_caller => true}),
     case Ret of
         {ok, Items} ->
             {QueueNames, Deletions} = lists:unzip(Items),

deps/rabbit/src/rabbit_khepri.erl

@@ -32,7 +32,7 @@
          adv_create/2,
          update/2,
          cas/3,
-         fold/3,
+         fold/3, fold/4,
          foreach/2,
          filter/2,
 
@@ -668,7 +668,11 @@ cas(Path, Pattern, Data) ->
     khepri:compare_and_swap(
       ?STORE_ID, Path, Pattern, Data, ?DEFAULT_COMMAND_OPTIONS).
 
-fold(Path, Pred, Acc) -> khepri:fold(?STORE_ID, Path, Pred, Acc).
+fold(Path, Pred, Acc) ->
+    khepri:fold(?STORE_ID, Path, Pred, Acc).
+
+fold(Path, Pred, Acc, Options) ->
+    khepri:fold(?STORE_ID, Path, Pred, Acc, Options).
 
 foreach(Path, Pred) -> khepri:foreach(?STORE_ID, Path, Pred).