0.27.0

Author: michaelklishin

CHANGELOG.md

@@ -1,10 +1,33 @@
 # rabbitmqadmin-ng Change Log
 
-## v0.27.0 (in development)
+## v0.28.0 (in development)
 
 No changes yet.
 
 
+## v0.27.0 (Mar 10, 2025)
+
+### Enhancements
+
+ * `definitions export` now supports a new flag, `--transformations`, a comma-separated list of
+   supported operations to apply to the definitions.
+
+   ```shell
+   rabbitmqadmin definitions export --transformations strip_cmq_keys_from_policies,drop_empty_policies
+   ```
+
+   The command above applies two transformations named `strip_cmq_keys_from_policies` and `drop_empty_policies`
+   that will strip all classic queue mirroring-related policy keys that RabbitMQ 3.13 nodes supported,
+   then removes policies that did not have any other keys (ended up having an empty definition).
+
+ * When `--non-interactive` mode is used, newlines in table cells are now replaced with comma-separated lists
+
+### Bug Fixes
+
+ * 'declare queue's `--type` flag value that the tool does not recognize are now passed as is to
+   the HTTP API
+
+
 ## v0.26.0 (Mar 3, 2025)
 
 ### Enhancements

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "rabbitmqadmin"
-version = "0.26.0"
+version = "0.27.0"
 edition = "2024"
 
 description = "rabbitmqadmin v2 is a major revision of rabbitmqadmin, one of the RabbitMQ CLI tools that target the HTTP API"

Cargo.toml

@@ -1271,12 +1271,13 @@ fn export_subcommands() -> [Command; 1] {
                 .help("output path")
                 .required(false)
                 .default_value("-"),
-        ).arg(
-        Arg::new("transformations")
-            .long("transformations")
-            .short('t')
-            .long_help(
-                r#"
+        )
+        .arg(
+            Arg::new("transformations")
+                .long("transformations")
+                .short('t')
+                .long_help(
+                    r#"
 A comma-separated list of names of the definition transformations to apply.
 
 Supported transformations:
@@ -1286,12 +1287,12 @@ Supported transformations:
 
 Example use: --transformations strip_cmq_keys_from_policies,drop_empty_policies
                 "#,
-            )
-            .num_args(1..)
-            .value_delimiter(',')
-            .action(ArgAction::Append)
-            .required(false),
-    );
+                )
+                .num_args(1..)
+                .value_delimiter(',')
+                .action(ArgAction::Append)
+                .required(false),
+        );
     [definitions]
 }
 

src/cli.rs

@@ -21,8 +21,8 @@ use rabbitmq_http_client::commons::{ExchangeType, SupportedProtocol};
 use rabbitmq_http_client::commons::{PolicyTarget, VirtualHostLimitTarget};
 use rabbitmq_http_client::commons::{ShovelAcknowledgementMode, UserLimitTarget};
 use rabbitmq_http_client::requests::{
-    Amqp091ShovelDestinationParams, Amqp091ShovelParams, Amqp091ShovelSourceParams,
     Amqp10ShovelDestinationParams, Amqp10ShovelParams, Amqp10ShovelSourceParams,
+    Amqp091ShovelDestinationParams, Amqp091ShovelParams, Amqp091ShovelSourceParams,
     EnforcedLimitParams,
 };
 use std::fs;

src/commands.rs

@@ -47,31 +47,48 @@ fn test_export_vhost_definitions() -> Result<(), Box<dyn std::error::Error>> {
 }
 
 #[test]
-fn test_export_cluster_wide_definitions_with_transformations_case1() -> Result<(), Box<dyn std::error::Error>> {
+fn test_export_cluster_wide_definitions_with_transformations_case1()
+-> Result<(), Box<dyn std::error::Error>> {
     let vh = "test_export_cluster_definitions.transformations.1";
     delete_vhost(vh).expect("failed to delete a virtual host");
     run_succeeds(["declare", "vhost", "--name", vh]);
 
     let p1 = "test_export_cluster_definitions.1";
     run_succeeds([
-        "--vhost", vh,
-        "declare", "policy",
-        "--name", p1,
-        "--pattern", "^matching\\..+", "--apply-to", "classic_queues", "--priority", "10",
-        "--definition", "{\"max-length\": 10}"]);
+        "--vhost",
+        vh,
+        "declare",
+        "policy",
+        "--name",
+        p1,
+        "--pattern",
+        "^matching\\..+",
+        "--apply-to",
+        "classic_queues",
+        "--priority",
+        "10",
+        "--definition",
+        "{\"max-length\": 10}",
+    ]);
 
     let q = "qq.test_export_cluster_definitions.1";
     run_succeeds([
         "-V", vh, "declare", "queue", "--name", q, "--type", "quorum",
     ]);
 
-    run_succeeds(["--vhost", vh, "definitions", "export"])
-        .stdout(predicate::str::contains(p1));
+    run_succeeds(["--vhost", vh, "definitions", "export"]).stdout(predicate::str::contains(p1));
     // These two cannot be tested on 4.x: empty definitions will be rejected
     // by validation and CMQ keys are no longer recognized as known/valid.
     // But at least we can test the code path this way.
-    run_succeeds(["--vhost", vh, "definitions", "export", "--transformations", "strip_cmq_keys_from_policies,drop_empty_policies"])
-        .stdout(predicate::str::contains(p1));
+    run_succeeds([
+        "--vhost",
+        vh,
+        "definitions",
+        "export",
+        "--transformations",
+        "strip_cmq_keys_from_policies,drop_empty_policies",
+    ])
+    .stdout(predicate::str::contains(p1));
 
     delete_vhost(vh).expect("failed to delete a virtual host");