'definitions export': introduce --transformations

these named functions can help a variety
of RabbitMQ operation tasks, from obfuscating
values to stripping off deprecated or removed
keys from policies, to enforcing a default
queue type during upgrades from older series
that do not support DQT.

Author: michaelklishin

Cargo.lock

@@ -17,7 +17,7 @@ reqwest = { version = "0.12.12", features = [
     "__rustls",
     "rustls-tls-native-roots"
 ]}
-rabbitmq_http_client = { git = "https://github.com/michaelklishin/rabbitmq-http-api-rs.git", features = [
+rabbitmq_http_client = { path = "/Users/antares/Development/RabbitMQ/rabbitmq-http-api-client-rs.git", features = [
     "core",
     "blocking",
     "tabled"

Cargo.toml

@@ -17,7 +17,7 @@ use super::constants::*;
 use super::static_urls::*;
 use super::tanzu_cli::tanzu_subcommands;
 use crate::output::TableStyle;
-use clap::{Arg, ArgAction, ArgGroup, Command, value_parser};
+use clap::{value_parser, Arg, ArgAction, ArgGroup, Command};
 use rabbitmq_http_client::commons::{
     BindingDestinationType, ExchangeType, PolicyTarget, QueueType, ShovelAcknowledgementMode,
     SupportedProtocol,
@@ -1187,6 +1187,20 @@ fn definitions_subcommands() -> [Command; 4] {
                 .help("output file path or '-' for standard output")
                 .required(false)
                 .default_value("-"),
+        )
+        .arg(
+            Arg::new("transformations")
+                .long("transformations")
+                .short('t')
+                .long_help(r#"
+Comma-separated names of the transformations to apply to the definitions.
+
+Supported names: strip_cmq_policies"
+                "#)
+                .num_args(1..)
+                .value_delimiter(',')
+                .action(ArgAction::Append)
+                .required(false),
         );
 
     let export_from_vhost_cmd = Command::new("export_from_vhost")

src/cli.rs

@@ -21,15 +21,16 @@ 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::{
-    Amqp10ShovelDestinationParams, Amqp10ShovelParams, Amqp10ShovelSourceParams,
     Amqp091ShovelDestinationParams, Amqp091ShovelParams, Amqp091ShovelSourceParams,
+    Amqp10ShovelDestinationParams, Amqp10ShovelParams, Amqp10ShovelSourceParams,
     EnforcedLimitParams,
 };
 use std::fs;
 use std::process;
 
 use rabbitmq_http_client::commons::BindingDestinationType;
 use rabbitmq_http_client::commons::QueueType;
+use rabbitmq_http_client::transformers::TransformationChain;
 use rabbitmq_http_client::{password_hashing, requests, responses};
 
 type APIClient<'a> = Client<&'a str, &'a str, &'a str>;
@@ -907,6 +908,52 @@ pub fn rebalance_queues(client: APIClient) -> ClientResult<()> {
 pub fn export_cluster_wide_definitions(
     client: APIClient,
     command_args: &ArgMatches,
+) -> ClientResult<()> {
+    let transformations = command_args
+        .get_many::<String>("transformations")
+        .unwrap_or_default();
+
+    if transformations.len() == 0 {
+        export_cluster_wide_definitions_without_transformations(client, command_args)
+    } else {
+        let transformations = transformations
+            .into_iter()
+            .map(|t| String::from(t))
+            .collect::<Vec<_>>();
+        export_and_transform_cluster_wide_definitions(client, command_args, transformations)
+    }
+}
+
+fn export_and_transform_cluster_wide_definitions(
+    client: APIClient,
+    command_args: &ArgMatches,
+    transformations: Vec<String>,
+) -> ClientResult<()> {
+    match client.export_cluster_wide_definitions_as_data() {
+        Ok(mut defs0) => {
+            let chain = TransformationChain::from(transformations);
+            let defs1 = chain.apply(&mut defs0);
+            let json = serde_json::to_string_pretty(&defs1).unwrap();
+
+            let path = command_args.get_one::<String>("file").unwrap();
+            match path.as_str() {
+                "-" => {
+                    println!("{}", &json);
+                    Ok(())
+                }
+                file => {
+                    _ = fs::write(file, &json);
+                    Ok(())
+                }
+            }
+        }
+        Err(err) => Err(err),
+    }
+}
+
+fn export_cluster_wide_definitions_without_transformations(
+    client: APIClient,
+    command_args: &ArgMatches,
 ) -> ClientResult<()> {
     match client.export_cluster_wide_definitions() {
         Ok(definitions) => {