Introduce 'shovels list'

for listing only the shovels in a particular
virtual host.

Author: michaelklishin

src/cli.rs

@@ -2861,14 +2861,21 @@ pub fn get_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 1] {
         )].map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
 }
 
-pub fn shovel_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 4] {
+pub fn shovel_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 5] {
     let list_all_cmd = Command::new("list_all")
         .long_about("Lists shovels in all virtual hosts")
         .after_help(color_print::cformat!(
             "<bold>Doc guide</bold>: {}",
             SHOVEL_GUIDE_URL
         ));
 
+    let list_cmd = Command::new("list")
+        .long_about("Lists shovels in a specific virtual host")
+        .after_help(color_print::cformat!(
+            "<bold>Doc guide</bold>: {}",
+            SHOVEL_GUIDE_URL
+        ));
+
     let declare_091_cmd = Command::new("declare_amqp091")
         .long_about(
             "Declares a dynamic shovel that uses AMQP 0-9-1 for both source and destination",
@@ -3003,8 +3010,14 @@ pub fn shovel_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 4
                 .required(true),
         );
 
-    [list_all_cmd, declare_091_cmd, declare_10_cmd, delete_cmd]
-        .map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
+    [
+        list_all_cmd,
+        list_cmd,
+        declare_091_cmd,
+        declare_10_cmd,
+        delete_cmd,
+    ]
+    .map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
 }
 
 fn federation_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 6] {

src/commands.rs

@@ -248,6 +248,10 @@ pub fn list_shovels(client: APIClient) -> ClientResult<Vec<responses::Shovel>> {
     client.list_shovels()
 }
 
+pub fn list_shovels_in(client: APIClient, vhost: &str) -> ClientResult<Vec<responses::Shovel>> {
+    client.list_shovels_in(vhost)
+}
+
 pub fn declare_amqp10_shovel(
     client: APIClient,
     vhost: &str,

src/main.rs

@@ -1035,6 +1035,10 @@ fn dispatch_common_subcommand(
             let result = commands::list_shovels(client);
             res_handler.tabular_result(result)
         }
+        ("shovels", "list") => {
+            let result = commands::list_shovels_in(client, &vhost);
+            res_handler.tabular_result(result)
+        }
         ("streams", "declare") => {
             let result = commands::declare_stream(client, &vhost, second_level_args);
             res_handler.no_output_on_success(result);

tests/shovel_tests.rs

@@ -15,6 +15,7 @@
 mod test_helpers;
 
 use crate::test_helpers::*;
+use predicates::boolean::PredicateBooleanExt;
 use predicates::prelude::predicate;
 
 #[test]
@@ -150,6 +151,23 @@ fn test_amqp091_shovel_declaration_and_deletion() -> Result<(), Box<dyn std::err
         dest_x,
     ]);
 
+    run_succeeds(["-V", vh, "shovels", "list"]).stdout(
+        predicate::str::contains(vh)
+            .and(predicate::str::contains(src_q))
+            .and(predicate::str::contains("dynamic"))
+            .and(predicate::str::contains("node"))
+            .and(predicate::str::contains("state")),
+    );
+
+    run_succeeds(["-V", vh, "shovels", "list_all"]).stdout(
+        predicate::str::contains(vh)
+            .and(predicate::str::contains(src_q))
+            .and(predicate::str::contains("dynamic"))
+            .and(predicate::str::contains("vhost"))
+            .and(predicate::str::contains("node"))
+            .and(predicate::str::contains("state")),
+    );
+
     run_succeeds(["-V", vh, "shovels", "delete", "--name", name]);
     run_succeeds(["-V", vh, "shovels", "delete", "--name", name]);