Upgrade Khepri to the latest main

The latest changes on Khepri main fix some issues:

* Projections are re-initialized when khepri_machine restarts, even if
  the register_projection commands have been snapshotted. This fixes
  ETS errors and shutdowns that could happen if the rabbit was
  restarted after performing many (4096+) database operations.
* Deleting a subtree in the store by deleting the root of the subtree
  now correctly recursively deletes records out of any projections
  register to watch the deleted nodes. In the rabbit app, this fixes
  some failing cases in the bindings_SUITE and resolves a TODO in
  rabbit_db_binding.

Author: the-mikedavis

MODULE.bazel

@@ -228,11 +228,11 @@ erlang_package.git_package(
     repository = "michaelklishin/erlang-jose",
 )
 
-erlang_package.hex_package(
+erlang_package.git_package(
     name = "khepri",
     build_file = "@rabbitmq-server//bazel:BUILD.khepri",
-    # sha256 = "7fae3112cea737bc64d5ff51c1b79a7f30f13ed3d11c565d2a6966ea5aa40473",
-    version = "0.6.0",
+    commit = "e8f38b60e28a3e31af2b7dd5248514c508af7d0a",
+    repository = "rabbitmq/khepri",
 )
 
 erlang_package.hex_package(

bazel/BUILD.khepri

@@ -82,6 +82,7 @@ erlang_bytecode(
         "include/khepri.hrl",
         "src/khepri_machine.hrl",
         "src/khepri_payload.hrl",
+        "src/khepri_tree.hrl",
     ],
     app_name = "khepri",
     erlc_opts = "//:erlc_opts",
@@ -95,6 +96,7 @@ erlang_bytecode(
         "include/khepri.hrl",
         "src/khepri_machine.hrl",
         "src/khepri_payload.hrl",
+        "src/khepri_tree.hrl",
     ],
     app_name = "khepri",
     erlc_opts = "//:erlc_opts",
@@ -135,6 +137,7 @@ erlang_bytecode(
         "src/khepri_cluster.hrl",
         "src/khepri_machine.hrl",
         "src/khepri_payload.hrl",
+        "src/khepri_tree.hrl",
     ],
     app_name = "khepri",
     erlc_opts = "//:erlc_opts",
@@ -154,6 +157,7 @@ erlang_bytecode(
         "src/khepri_payload.hrl",
         "src/khepri_projection.hrl",
         "src/khepri_ret.hrl",
+        "src/khepri_tree.hrl",
         "src/khepri_tx.hrl",
     ],
     app_name = "khepri",
@@ -195,6 +199,7 @@ erlang_bytecode(
         "src/khepri_machine.hrl",
         "src/khepri_payload.hrl",
         "src/khepri_projection.hrl",
+        "src/khepri_tree.hrl",
     ],
     app_name = "khepri",
     erlc_opts = "//:erlc_opts",
@@ -232,6 +237,7 @@ erlang_bytecode(
         "src/khepri_machine.hrl",
         "src/khepri_payload.hrl",
         "src/khepri_ret.hrl",
+        "src/khepri_tree.hrl",
         "src/khepri_tx.hrl",
     ],
     app_name = "khepri",
@@ -249,6 +255,7 @@ erlang_bytecode(
         "src/khepri_machine.hrl",
         "src/khepri_payload.hrl",
         "src/khepri_ret.hrl",
+        "src/khepri_tree.hrl",
         "src/khepri_tx.hrl",
     ],
     app_name = "khepri",
@@ -330,6 +337,7 @@ filegroup(
         "src/khepri_payload.hrl",
         "src/khepri_projection.hrl",
         "src/khepri_ret.hrl",
+        "src/khepri_tree.hrl",
         "src/khepri_tx.hrl",
     ],
 )
@@ -346,7 +354,10 @@ filegroup(
 
 filegroup(
     name = "licenses",
-    srcs = [],
+    srcs = [
+        "LICENSE-Apache-2.0",
+        "LICENSE-MPL-2.0",
+    ],
 )
 
 filegroup(

deps/rabbit/src/rabbit_db_binding.erl

@@ -775,11 +775,8 @@ delete_all_for_exchange_in_khepri(X = #exchange{name = XName}, OnlyDurable, Remo
 delete_for_source_in_khepri(#resource{virtual_host = VHost, name = Name}) ->
     Path = khepri_routes_path() ++ [VHost, Name],
     {ok, Bindings} = khepri_tx:get_many(Path ++ [rabbit_khepri:if_has_data_wildcard()]),
-    %% ok = khepri_tx:delete(Path),
-    maps:fold(fun(P, Set, Acc) ->
-                      %% TODO projections are not updated if we just use the previous
-                      %% delete of the root path. Let's keep it like this for now...
-                      ok = khepri_tx:delete(P),
+    ok = khepri_tx:delete(Path),
+    maps:fold(fun(_P, Set, Acc) ->
                       sets:to_list(Set) ++ Acc
               end, [], Bindings).