Two more policies commands

That seek to help troubleshooting policies
more efficient.

As a drive-by change this makes sure that --apply-to
values are fetched correctly and actually used.

Author: michaelklishin

CHANGELOG.md

@@ -20,6 +20,28 @@
    # an equivalent of 'delete policy'
    rabbitmqadmin policies delete --name "policy-name"
    ```
+ * `policies list_in` is a new command that lists policies in a specific virtual host:
+
+   ```shell
+   rabbitmqadmin --vhost "a.vhost" policies list_in
+   ```
+
+   ```shell
+   rabbitmqadmin --vhost "streams.vhost" policies list_in --apply-to "streams"
+   ```
+
+ * `policies list_matching_object` is a new command that lists all policies that 
+   would match an object (a queue, a stream, an exchange)
+   with a given name:
+
+   ```shell
+   rabbitmqadmin --vhost "a.vhost" policies list_matching_object --name 'audit.events' --type queues
+   ```
+
+### Bug Fixes
+
+ * `declare policy`'s `--apply-to` argument value was ignored 
+
 
 
 ## v0.25.0 (Mar 2, 2025)

Cargo.lock

@@ -734,6 +734,7 @@ fn declare_subcommands() -> [Command; 12] {
                 Arg::new("apply_to")
                     .long("apply-to")
                     .help("entities to apply to (queues, classic_queues, quorum_queues, streams, exchanges, all)")
+                    .value_parser(value_parser!(PolicyTarget))
                     .required(true),
             )
             .arg(
@@ -1070,7 +1071,8 @@ fn policies_subcommands() -> [Command; 5] {
             Arg::new("type")
                 .long("type")
                 .value_parser(value_parser!(PolicyTarget))
-                .required(true),
+                .required(true)
+                .help("target type, one of 'queues', 'streams', 'exchanges'"),
         );
 
     [

src/cli.rs

@@ -691,7 +691,10 @@ pub fn declare_policy(
 ) -> ClientResult<()> {
     let name = command_args.get_one::<String>("name").unwrap();
     let pattern = command_args.get_one::<String>("pattern").unwrap();
-    let apply_to = command_args.get_one::<String>("pattern").unwrap();
+    let apply_to = command_args
+        .get_one::<PolicyTarget>("apply_to")
+        .cloned()
+        .unwrap();
     let priority = command_args.get_one::<String>("priority").unwrap();
     let definition = command_args.get_one::<String>("definition").unwrap();
 
@@ -705,7 +708,7 @@ pub fn declare_policy(
         vhost,
         name,
         pattern,
-        apply_to: commons::PolicyTarget::from(apply_to.as_str()),
+        apply_to: apply_to.clone(),
         priority: priority.parse::<i32>().unwrap(),
         definition: parsed_definition,
     };
@@ -720,7 +723,10 @@ pub fn declare_operator_policy(
 ) -> ClientResult<()> {
     let name = command_args.get_one::<String>("name").unwrap();
     let pattern = command_args.get_one::<String>("pattern").unwrap();
-    let apply_to = command_args.get_one::<String>("pattern").unwrap();
+    let apply_to = command_args
+        .get_one::<PolicyTarget>("apply_to")
+        .cloned()
+        .unwrap();
     let priority = command_args.get_one::<String>("priority").unwrap();
     let definition = command_args.get_one::<String>("definition").unwrap();
 
@@ -734,7 +740,7 @@ pub fn declare_operator_policy(
         vhost,
         name,
         pattern,
-        apply_to: commons::PolicyTarget::from(apply_to.as_str()),
+        apply_to: apply_to.clone(),
         priority: priority.parse::<i32>().unwrap(),
         definition: parsed_definition,
     };

src/commands.rs

@@ -197,3 +197,146 @@ fn test_policies_in_with_entity_type() -> Result<(), Box<dyn std::error::Error>>
 
     Ok(())
 }
+
+#[test]
+fn test_policies_matching_objects() -> Result<(), Box<dyn std::error::Error>> {
+    let vh1 = "rabbitmqadmin.vh.policies.11";
+    let vh2 = "rabbitmqadmin.vh.policies.12";
+    let vh3 = "rabbitmqadmin.vh.policies.13";
+
+    run_succeeds(["delete", "vhost", "--name", vh1, "--idempotently"]);
+    run_succeeds(["declare", "vhost", "--name", vh1]);
+    run_succeeds(["delete", "vhost", "--name", vh2, "--idempotently"]);
+    run_succeeds(["declare", "vhost", "--name", vh2]);
+    run_succeeds(["delete", "vhost", "--name", vh3, "--idempotently"]);
+    run_succeeds(["declare", "vhost", "--name", vh3]);
+
+    let policy1 = "rabbitmqadmin.policies.11";
+    run_succeeds([
+        "--vhost",
+        vh1,
+        "policies",
+        "declare",
+        "--name",
+        policy1,
+        "--pattern",
+        "^q-.*",
+        "--apply-to",
+        "queues",
+        "--priority",
+        "47",
+        "--definition",
+        "{\"max-length\": 20}",
+    ]);
+
+    let policy2 = "rabbitmqadmin.policies.12";
+    run_succeeds([
+        "--vhost",
+        vh2,
+        "policies",
+        "declare",
+        "--name",
+        policy2,
+        "--pattern",
+        "^x-.*",
+        "--apply-to",
+        "exchanges",
+        "--priority",
+        "17",
+        "--definition",
+        "{\"alternate-exchange\": \"amq.fanout\"}",
+    ]);
+
+    let policy3 = "rabbitmqadmin.policies.13";
+    run_succeeds([
+        "--vhost",
+        vh3,
+        "policies",
+        "declare",
+        "--name",
+        policy3,
+        "--pattern",
+        "^s-.*",
+        "--apply-to",
+        "streams",
+        "--priority",
+        "15",
+        "--definition",
+        "{\"max-age\": \"1D\"}",
+    ]);
+
+    run_succeeds([
+        "--vhost",
+        vh1,
+        "policies",
+        "list_matching_object",
+        "--name",
+        "q-abc",
+        "--type",
+        "queues",
+    ])
+    .stdout(predicate::str::contains(policy1).and(predicate::str::contains("20")));
+    run_succeeds([
+        "--vhost",
+        vh1,
+        "policies",
+        "list_matching_object",
+        "--name",
+        "q-abc",
+        "--type",
+        "exchanges",
+    ])
+    .stdout(predicate::str::contains(policy1).not());
+
+    run_succeeds([
+        "--vhost",
+        vh2,
+        "policies",
+        "list_matching_object",
+        "--name",
+        "x-abc",
+        "--type",
+        "exchanges",
+    ])
+    .stdout(predicate::str::contains(policy2));
+    run_succeeds([
+        "--vhost",
+        vh2,
+        "policies",
+        "list_matching_object",
+        "--name",
+        "x-abc",
+        "--type",
+        "streams",
+    ])
+    .stdout(predicate::str::contains(policy2).not());
+
+    run_succeeds([
+        "--vhost",
+        vh3,
+        "policies",
+        "list_matching_object",
+        "--name",
+        "s-abc",
+        "--type",
+        "streams",
+    ])
+    .stdout(predicate::str::contains(policy3).and(predicate::str::contains("1D")));
+    run_succeeds([
+        "--vhost",
+        vh3,
+        "policies",
+        "list_matching_object",
+        "--name",
+        "s-abc",
+        "--type",
+        "exchanges",
+    ])
+    .stdout(predicate::str::contains(policy3).not());
+
+    run_succeeds(["delete", "vhost", "--name", vh1, "--idempotently"]);
+    run_succeeds(["delete", "vhost", "--name", vh2, "--idempotently"]);
+    run_succeeds(["delete", "vhost", "--name", vh3, "--idempotently"]);
+
+    Ok(())
+}