New command: list user_connections

Author: michaelklishin

CHANGELOG.md

@@ -4,6 +4,14 @@
 
 ### Enhancements
 
+ * `list user_connections` is a new command that lists connections of a specific user:
+
+   ```
+   rabbitmqadmin --vhost="/" list user_connections --username "monitoring.1"
+
+   rabbitmqadmin --vhost="production" list user_connections --username "web.45cf7dc28"
+   ```
+
  * New general option `--table-style`, can be used to change output table styling.
 
    By default, the following style is used:

src/cli.rs

@@ -310,7 +310,7 @@ pub fn parser() -> Command {
         ])
 }
 
-fn list_subcommands() -> [Command; 18] {
+fn list_subcommands() -> [Command; 19] {
     // duplicate this very common global argument so that
     // it can be passed as the end of argument list
     let vhost_arg = Arg::new("vhost")
@@ -343,6 +343,20 @@ fn list_subcommands() -> [Command; 18] {
                 "<bold>Doc guide</bold>: {}",
                 CONNECTION_GUIDE_URL
             )),
+        Command::new("user_connections")
+            .arg(vhost_arg.clone())
+            .arg(
+                Arg::new("username")
+                    .short('u')
+                    .long("username")
+                    .required(true)
+                    .help("Name of the user whose connections to list"),
+            )
+            .long_about("Lists client connections that authenticated with a specific username")
+            .after_long_help(color_print::cformat!(
+                "<bold>Doc guide</bold>: {}",
+                CONNECTION_GUIDE_URL
+            )),
         Command::new("channels")
             .arg(vhost_arg.clone())
             .long_about("Lists AMQP 0-9-1 channels")

src/commands.rs

@@ -80,6 +80,14 @@ pub fn list_connections(client: APIClient) -> ClientResult<Vec<responses::Connec
     client.list_connections()
 }
 
+pub fn list_user_connections(
+    client: APIClient,
+    command_args: &ArgMatches,
+) -> ClientResult<Vec<responses::UserConnection>> {
+    let username = command_args.get_one::<String>("username").cloned().unwrap();
+    client.list_user_connections(&username)
+}
+
 pub fn list_channels(client: APIClient) -> ClientResult<Vec<responses::Channel>> {
     client.list_channels()
 }

src/main.rs

@@ -313,6 +313,10 @@ fn dispatch_common_subcommand(
             let result = commands::list_connections(client);
             res_handler.tabular_result(result)
         }
+        ("list", "user_connections") => {
+            let result = commands::list_user_connections(client, second_level_args);
+            res_handler.tabular_result(result)
+        }
         ("list", "channels") => {
             let result = commands::list_channels(client);
             res_handler.tabular_result(result)

tests/connections_tests.rs

@@ -0,0 +1,44 @@
+// Copyright (C) 2023-2025 RabbitMQ Core Team ([email protected])
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+mod test_helpers;
+use crate::test_helpers::*;
+
+#[test]
+fn test_list_connections() -> Result<(), Box<dyn std::error::Error>> {
+    run_succeeds(["list", "connections"]);
+
+    Ok(())
+}
+
+#[test]
+fn test_list_connections_table_styles() -> Result<(), Box<dyn std::error::Error>> {
+    run_succeeds(["--table-style", "markdown", "list", "connections"]);
+
+    Ok(())
+}
+
+#[test]
+fn test_list_user_connections() -> Result<(), Box<dyn std::error::Error>> {
+    run_succeeds([
+        "--table-style",
+        "markdown",
+        "list",
+        "user_connections",
+        "--username",
+        "monitoring",
+    ]);
+
+    Ok(())
+}