New command group: exchanges, closes #63

Author: michaelklishin

CHANGELOG.md

@@ -4,6 +4,7 @@
 
 ### Enhancements
 
+ * `exchanges` is a new command group for operations on exchanges
  * `global_parameters` is a new command group for operations on [global runtime parameters](https://www.rabbitmq.com/docs/parameters)
  * `nodes` is a new command group for operations on nodes
  * `parameters` is a new command group for operations on [runtime parameters](https://www.rabbitmq.com/docs/parameters)

src/cli.rs

@@ -80,6 +80,12 @@ pub fn parser(pre_flight_settings: PreFlightSettings) -> Command {
         ))
         .subcommand_value_name("deprecated feature")
         .subcommands(deprecated_features_subcommands(pre_flight_settings.clone()));
+    let exchanges_group = Command::new("exchanges")
+        .about("Operations on exchanges")
+        .infer_subcommands(pre_flight_settings.infer_subcommands)
+        .infer_long_args(pre_flight_settings.infer_long_options)
+        .subcommand_value_name("exchange")
+        .subcommands(exchanges_subcommands(pre_flight_settings.clone()));
     let export_group = Command::new("export")
         .about("See 'definitions export'")
         .infer_subcommands(pre_flight_settings.infer_subcommands)
@@ -274,6 +280,7 @@ pub fn parser(pre_flight_settings: PreFlightSettings) -> Command {
         definitions_group,
         delete_group,
         deprecated_features_group,
+        exchanges_group,
         export_group,
         feature_flags_group,
         federation_group,
@@ -1801,6 +1808,132 @@ Examples:
     .map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
 }
 
+fn exchanges_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 5] {
+    let bind_cmd = Command::new("bind")
+        .about("Creates a binding between a source exchange and a destination (a queue or an exchange)")
+        .arg(
+            Arg::new("source")
+                .long("source")
+                .help("source exchange")
+                .required(true),
+        )
+        .arg(
+            Arg::new("destination_type")
+                .long("destination-type")
+                .help("destination type: exchange or queue")
+                .required(true)
+                .value_parser(value_parser!(BindingDestinationType)),
+        )
+        .arg(
+            Arg::new("destination")
+                .long("destination")
+                .help("destination exchange/queue name")
+                .required(true),
+        )
+        .arg(
+            Arg::new("routing_key")
+                .long("routing-key")
+                .help("routing key")
+                .required(true),
+        )
+        .arg(
+            Arg::new("arguments")
+                .long("arguments")
+                .help("additional arguments")
+                .required(false)
+                .default_value("{}")
+                .value_parser(value_parser!(String)),
+        );
+    let declare_cmd = Command::new("declare")
+        .about("Declares an exchange")
+        .arg(
+            Arg::new("name")
+                .long("name")
+                .help("exchange name")
+                .required(true),
+        )
+        .arg(
+            Arg::new("type")
+                .long("type")
+                .help("exchange type")
+                .value_parser(value_parser!(ExchangeType))
+                .required(false),
+        )
+        .arg(
+            Arg::new("durable")
+                .long("durable")
+                .help("should it persist after a restart")
+                .required(false)
+                .value_parser(value_parser!(bool)),
+        )
+        .arg(
+            Arg::new("auto_delete")
+                .long("auto-delete")
+                .help("should it be deleted when the last queue is unbound")
+                .required(false)
+                .value_parser(value_parser!(bool)),
+        )
+        .arg(
+            Arg::new("arguments")
+                .long("arguments")
+                .help("additional exchange arguments")
+                .required(false)
+                .default_value("{}")
+                .value_parser(value_parser!(String)),
+        );
+    let idempotently_arg = Arg::new("idempotently")
+        .long("idempotently")
+        .value_parser(value_parser!(bool))
+        .action(ArgAction::SetTrue)
+        .help("do not consider 404 Not Found API responses to be errors")
+        .required(false);
+    let delete_cmd = Command::new("delete")
+        .about("Deletes an exchange")
+        .arg(
+            Arg::new("name")
+                .long("name")
+                .help("exchange name")
+                .required(true),
+        )
+        .arg(idempotently_arg.clone());
+    let list_cmd = Command::new("list").long_about("Lists exchanges");
+    let unbind_cmd = Command::new("unbind")
+        .about("Deletes a binding")
+        .arg(
+            Arg::new("source")
+                .long("source")
+                .help("source exchange")
+                .required(true),
+        )
+        .arg(
+            Arg::new("destination_type")
+                .long("destination-type")
+                .help("destination type: exchange or queue")
+                .required(true),
+        )
+        .arg(
+            Arg::new("destination")
+                .long("destination")
+                .help("destination exchange/queue name")
+                .required(true),
+        )
+        .arg(
+            Arg::new("routing_key")
+                .long("routing-key")
+                .help("routing key")
+                .required(true),
+        )
+        .arg(
+            Arg::new("arguments")
+                .long("arguments")
+                .help("additional arguments")
+                .required(false)
+                .default_value("{}")
+                .value_parser(value_parser!(String)),
+        );
+    [bind_cmd, declare_cmd, delete_cmd, list_cmd, unbind_cmd]
+        .map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
+}
 fn export_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 1] {
     let definitions = Command::new("definitions")
         .about("Prefer 'definitions export'")

src/main.rs

@@ -415,6 +415,26 @@ fn dispatch_common_subcommand(
             let result = commands::export_cluster_wide_definitions(client, second_level_args);
             res_handler.no_output_on_success(result);
         }
+        ("exchanges", "bind") => {
+            let result = commands::declare_binding(client, &vhost, second_level_args);
+            res_handler.no_output_on_success(result);
+        }
+        ("exchanges", "declare") => {
+            let result = commands::declare_exchange(client, &vhost, second_level_args);
+            res_handler.no_output_on_success(result);
+        }
+        ("exchanges", "delete") => {
+            let result = commands::delete_exchange(client, &vhost, second_level_args);
+            res_handler.delete_operation_result(result);
+        }
+        ("exchanges", "list") => {
+            let result = commands::list_exchanges(client, &vhost);
+            res_handler.tabular_result(result)
+        }
+        ("exchanges", "unbind") => {
+            let result = commands::delete_binding(client, &vhost, second_level_args);
+            res_handler.no_output_on_success(result);
+        }
         ("feature_flags", "enable") => {
             let result = commands::enable_feature_flag(client, second_level_args);
             res_handler.no_output_on_success(result);

tests/bindings_tests.rs

@@ -84,7 +84,7 @@ fn test_list_bindings() -> Result<(), Box<dyn std::error::Error>> {
     );
 
     // delete the queue from vhost 1
-    run_succeeds(["-V", vh1, "delete", "queue", "--name", q1]);
+    run_succeeds(["-V", vh1, "queues", "delete", "--name", q1]);
 
     // these bindings were deleted with the queue
     run_succeeds(["-V", "bindings_vhost_1", "list", "bindings"]).stdout(