cargo fmt

Author: michaelklishin

src/commands.rs

@@ -27,14 +27,14 @@ use rabbitmq_http_client::commons::{ExchangeType, SupportedProtocol};
 use rabbitmq_http_client::commons::{MessageTransferAcknowledgementMode, UserLimitTarget};
 use rabbitmq_http_client::commons::{PolicyTarget, VirtualHostLimitTarget};
 use rabbitmq_http_client::password_hashing::{HashingAlgorithm, HashingError};
+use rabbitmq_http_client::requests::shovels::OwnedShovelParams;
 use rabbitmq_http_client::requests::{
     Amqp10ShovelDestinationParams, Amqp10ShovelParams, Amqp10ShovelSourceParams,
     Amqp091ShovelDestinationParams, Amqp091ShovelParams, Amqp091ShovelSourceParams,
     DEFAULT_FEDERATION_PREFETCH, EnforcedLimitParams, ExchangeFederationParams,
     FEDERATION_UPSTREAM_COMPONENT, FederationResourceCleanupMode, FederationUpstreamParams,
     PolicyParams, QueueFederationParams, RuntimeParameterDefinition,
 };
-use rabbitmq_http_client::requests::shovels::OwnedShovelParams;
 
 use rabbitmq_http_client::transformers::{TransformationChain, VirtualHostTransformationChain};
 use rabbitmq_http_client::{password_hashing, requests, responses};

tests/shovel_destination_uri_modification_tests.rs

@@ -19,7 +19,8 @@ use predicates::prelude::*;
 use std::str;
 
 #[test]
-fn test_disable_tls_peer_verification_for_all_destination_uris_basic() -> Result<(), Box<dyn std::error::Error>> {
+fn test_disable_tls_peer_verification_for_all_destination_uris_basic()
+-> Result<(), Box<dyn std::error::Error>> {
     let vh = "test_disable_tls_peer_verification_for_all_destination_uris_basic";
     let shovel_name = "test_basic_dest_shovel";
 
@@ -67,7 +68,8 @@ fn test_disable_tls_peer_verification_for_all_destination_uris_basic() -> Result
 #[test]
 fn test_disable_tls_peer_verification_for_all_destination_uris_with_existing_verify_param()
 -> Result<(), Box<dyn std::error::Error>> {
-    let vh = "test_disable_tls_peer_verification_for_all_destination_uris_with_existing_verify_param";
+    let vh =
+        "test_disable_tls_peer_verification_for_all_destination_uris_with_existing_verify_param";
     let shovel_name = "test_existing_dest_shovel";
 
     delete_vhost(vh).ok();
@@ -106,14 +108,19 @@ fn test_disable_tls_peer_verification_for_all_destination_uris_with_existing_ver
     ]);
 
     let output = run_succeeds(["parameters", "list_all"]);
-    let stdout = output.stdout(predicate::str::contains(shovel_name))
+    let stdout = output
+        .stdout(predicate::str::contains(shovel_name))
         .stdout(predicate::str::contains("verify=verify_none"))
         .stdout(predicate::str::contains("dest_key1=xyz"))
         .stdout(predicate::str::contains("dest_key2=abc"))
         .stdout(predicate::str::contains("cacertfile=/path/to/dest_ca.pem"))
-        .stdout(predicate::str::contains("certfile=/path/to/dest_client.pem"))
+        .stdout(predicate::str::contains(
+            "certfile=/path/to/dest_client.pem",
+        ))
         .stdout(predicate::str::contains("keyfile=/path/to/dest_client.key"))
-        .stdout(predicate::str::contains("server_name_indication=dest.example.com"))
+        .stdout(predicate::str::contains(
+            "server_name_indication=dest.example.com",
+        ))
         .stdout(predicate::str::contains("dest_param=value456"))
         .stdout(predicate::str::contains("another_dest_param=def"))
         .stdout(predicate::str::contains("heartbeat=30"));
@@ -130,39 +137,59 @@ fn test_disable_tls_peer_verification_for_all_destination_uris_with_existing_ver
         if in_our_shovel {
             shovel_section.push_str(line);
             shovel_section.push('\n');
-            if line.contains("└─") || (in_our_shovel && line.contains("├─") && !line.contains(&shovel_name)) {
+            if line.contains("└─")
+                || (in_our_shovel && line.contains("├─") && !line.contains(&shovel_name))
+            {
                 break;
             }
         }
     }
 
-    let dest_uri_lines: Vec<&str> = shovel_section.lines()
+    let dest_uri_lines: Vec<&str> = shovel_section
+        .lines()
         .filter(|line| line.contains("dest-uri"))
         .collect();
-    assert!(!dest_uri_lines.is_empty(), "Could not find dest-uri in shovel section");
+    assert!(
+        !dest_uri_lines.is_empty(),
+        "Could not find dest-uri in shovel section"
+    );
 
     let dest_uri_content = dest_uri_lines[0];
     let dest_verify_count = dest_uri_content.matches("verify=").count();
-    assert_eq!(dest_verify_count, 1, "Expected exactly 1 verify parameter in destination URI, found {}", dest_verify_count);
+    assert_eq!(
+        dest_verify_count, 1,
+        "Expected exactly 1 verify parameter in destination URI, found {}",
+        dest_verify_count
+    );
 
-    assert!(dest_uri_content.contains("verify=verify_none"), "Destination URI should contain verify=verify_none");
-    assert!(!dest_uri_content.contains("verify=verify_peer"), "Destination URI should not contain verify=verify_peer");
+    assert!(
+        dest_uri_content.contains("verify=verify_none"),
+        "Destination URI should contain verify=verify_none"
+    );
+    assert!(
+        !dest_uri_content.contains("verify=verify_peer"),
+        "Destination URI should not contain verify=verify_peer"
+    );
 
     delete_vhost(vh).expect("failed to delete a virtual host");
 
     Ok(())
 }
 
 #[test]
-fn test_disable_tls_peer_verification_for_all_destination_uris_amqp10() -> Result<(), Box<dyn std::error::Error>> {
+fn test_disable_tls_peer_verification_for_all_destination_uris_amqp10()
+-> Result<(), Box<dyn std::error::Error>> {
     let vh = "test_disable_tls_peer_verification_for_all_destination_uris_amqp10";
     let shovel_name = "test_amqp10_dest_shovel";
 
     delete_vhost(vh).ok();
     run_succeeds(["declare", "vhost", "--name", vh]);
 
     let amqps_source = format!("amqps://localhost:5671/{}", vh);
-    let amqps_destination = format!("amqps://localhost:5671/{}?verify=verify_peer&certfile=/path/to/client.pem", vh);
+    let amqps_destination = format!(
+        "amqps://localhost:5671/{}?verify=verify_peer&certfile=/path/to/client.pem",
+        vh
+    );
 
     run_succeeds([
         "-V",
@@ -211,7 +238,10 @@ fn test_disable_tls_peer_verification_for_all_destination_uris_with_dummy_query_
 
     let amqps_base = format!("amqps://localhost:5671/{}", vh);
     let source_uri = format!("{}?source_abc=123&source_heartbeat=5", amqps_base);
-    let dest_uri = format!("{}?dest_xyz=456&dest_heartbeat=10&channel_max=100&another_dummy=example", amqps_base);
+    let dest_uri = format!(
+        "{}?dest_xyz=456&dest_heartbeat=10&channel_max=100&another_dummy=example",
+        amqps_base
+    );
 
     run_succeeds([
         "-V",
@@ -239,7 +269,8 @@ fn test_disable_tls_peer_verification_for_all_destination_uris_with_dummy_query_
     ]);
 
     let output = run_succeeds(["parameters", "list_all"]);
-    let stdout = output.stdout(predicate::str::contains(shovel_name))
+    let stdout = output
+        .stdout(predicate::str::contains(shovel_name))
         .stdout(predicate::str::contains("verify=verify_none"))
         .stdout(predicate::str::contains("dest_xyz=456"))
         .stdout(predicate::str::contains("dest_heartbeat=10"))
@@ -258,23 +289,39 @@ fn test_disable_tls_peer_verification_for_all_destination_uris_with_dummy_query_
         if in_our_shovel {
             shovel_section.push_str(line);
             shovel_section.push('\n');
-            if line.contains("└─") || (in_our_shovel && line.contains("├─") && !line.contains(&shovel_name)) {
+            if line.contains("└─")
+                || (in_our_shovel && line.contains("├─") && !line.contains(&shovel_name))
+            {
                 break;
             }
         }
     }
 
-    let dest_uri_lines: Vec<&str> = shovel_section.lines()
+    let dest_uri_lines: Vec<&str> = shovel_section
+        .lines()
         .filter(|line| line.contains("dest-uri"))
         .collect();
-    assert!(!dest_uri_lines.is_empty(), "Could not find dest-uri in shovel section");
+    assert!(
+        !dest_uri_lines.is_empty(),
+        "Could not find dest-uri in shovel section"
+    );
 
     let dest_uri_content = dest_uri_lines[0];
     let dest_verify_count = dest_uri_content.matches("verify=").count();
-    assert_eq!(dest_verify_count, 1, "Expected exactly 1 verify parameter in destination URI, found {}", dest_verify_count);
+    assert_eq!(
+        dest_verify_count, 1,
+        "Expected exactly 1 verify parameter in destination URI, found {}",
+        dest_verify_count
+    );
 
-    assert!(dest_uri_content.contains("verify=verify_none"), "Destination URI should contain verify=verify_none");
-    assert!(!dest_uri_content.contains("verify=verify_peer"), "Destination URI should not contain verify=verify_peer");
+    assert!(
+        dest_uri_content.contains("verify=verify_none"),
+        "Destination URI should contain verify=verify_none"
+    );
+    assert!(
+        !dest_uri_content.contains("verify=verify_peer"),
+        "Destination URI should not contain verify=verify_peer"
+    );
 
     delete_vhost(vh).expect("failed to delete a virtual host");
 
@@ -297,4 +344,4 @@ fn test_disable_tls_peer_verification_for_all_destination_uris_no_shovels()
     delete_vhost(vh).expect("failed to delete a virtual host");
 
     Ok(())
-}
+}