From 473bf7f5230349890ced48f4487e1c1883296ab0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jean-S=C3=A9bastien=20P=C3=A9dron?= Date: Wed, 13 Nov 2024 12:08:50 +0100 Subject: [PATCH] rabbitmq_4_0_deprecations_SUITE: Add more assertions to ram node tests --- .../test/rabbitmq_4_0_deprecations_SUITE.erl | 22 +++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/deps/rabbit/test/rabbitmq_4_0_deprecations_SUITE.erl b/deps/rabbit/test/rabbitmq_4_0_deprecations_SUITE.erl index d5f5f147782a..f01fce00baf9 100644 --- a/deps/rabbit/test/rabbitmq_4_0_deprecations_SUITE.erl +++ b/deps/rabbit/test/rabbitmq_4_0_deprecations_SUITE.erl @@ -296,6 +296,11 @@ join_when_ram_node_type_is_permitted_by_default_khepri(Config) -> [NodeA, NodeB] = rabbit_ct_broker_helpers:get_node_configs( Config, nodename), + IsPermitted = rabbit_ct_broker_helpers:rpc( + Config, NodeA, + rabbit_deprecated_features, is_permitted, + [ram_node_type]), + ok = rabbit_control_helper:command(stop_app, NodeA), ?assertMatch( {error, 70, @@ -305,6 +310,12 @@ join_when_ram_node_type_is_permitted_by_default_khepri(Config) -> [atom_to_list(NodeB)], [{"--ram", true}])), ok = rabbit_control_helper:command(start_app, NodeA), + ?assertEqual( + IsPermitted, + rabbit_ct_broker_helpers:rpc( + Config, NodeA, + rabbit_deprecated_features, is_permitted, [ram_node_type])), + ?assertEqual([NodeA], get_all_nodes(Config, NodeA)), ?assertEqual([NodeB], get_all_nodes(Config, NodeB)), ?assertEqual([NodeA], get_disc_nodes(Config, NodeA)), @@ -357,6 +368,11 @@ join_when_ram_node_type_is_not_permitted_from_conf_khepri(Config) -> [NodeA, NodeB] = rabbit_ct_broker_helpers:get_node_configs( Config, nodename), + IsPermitted = rabbit_ct_broker_helpers:rpc( + Config, NodeA, + rabbit_deprecated_features, is_permitted, + [ram_node_type]), + ok = rabbit_control_helper:command(stop_app, NodeA), ?assertMatch( {error, 70, @@ -366,6 +382,12 @@ join_when_ram_node_type_is_not_permitted_from_conf_khepri(Config) -> [atom_to_list(NodeB)], [{"--ram", true}])), ok = rabbit_control_helper:command(start_app, NodeA), + ?assertEqual( + IsPermitted, + rabbit_ct_broker_helpers:rpc( + Config, NodeA, + rabbit_deprecated_features, is_permitted, [ram_node_type])), + ?assertEqual([NodeA], get_all_nodes(Config, NodeA)), ?assertEqual([NodeB], get_all_nodes(Config, NodeB)), ?assertEqual([NodeA], get_disc_nodes(Config, NodeA)),