chore: cargo format

eventstore/src/grpc.rs

@@ -840,7 +840,8 @@ impl NodeConnection {
                 roots.add(cert).unwrap();
             }
         } else {
-            for cert in rustls_native_certs::load_native_certs().expect("could not load platform certs")
+            for cert in
+                rustls_native_certs::load_native_certs().expect("could not load platform certs")
             {
                 roots.add(cert).unwrap();
             }

eventstore/tests/integration.rs

@@ -1,8 +1,8 @@
 mod api;
 mod common;
 mod images;
-mod plugins;
 mod misc;
+mod plugins;
 
 use crate::common::{fresh_stream_id, generate_events};
 use eventstore::{Client, ClientSettings};
@@ -161,7 +161,7 @@ async fn wait_for_admin_to_be_available(client: &Client) -> eventstore::Result<(
 enum Tests {
     Api(ApiTests),
     Plugins(PluginTests),
-    Misc(MiscTests)
+    Misc(MiscTests),
 }
 
 impl Tests {
@@ -198,7 +198,9 @@ enum MiscTests {
 }
 
 impl From<MiscTests> for Tests {
-    fn from(test: MiscTests) -> Self { Tests::Misc(test) }
+    fn from(test: MiscTests) -> Self {
+        Tests::Misc(test)
+    }
 }
 
 enum Topologies {
@@ -278,7 +280,7 @@ async fn run_test(test: impl Into<Tests>, topology: Topologies) -> eyre::Result<
         },
 
         Tests::Misc(test) => match test {
-            MiscTests::RootCertificates => misc::root_certificates::tests(container_port).await
+            MiscTests::RootCertificates => misc::root_certificates::tests(container_port).await,
         },
     };
 

eventstore/tests/misc/root_certificates.rs

@@ -1,17 +1,51 @@
-pub async fn tests(port: u16) -> eyre::Result<()> {
-    let root_cert = "certs/ca/ca.crt";
-
-    let setts = format!(
-        "esdb://admin:changeit@localhost:{}?tlsVerifyCert=true&tls=true&tlsCaFile={}",
-        port,
-        root_cert
-    )
-    .parse()?;
-    let client = eventstore::Client::new(setts)?;
-
-    let mut streams = client.read_all(&Default::default()).await?;
-
-    streams.next().await?;
-
-    Ok(())
-}
+use tracing::debug;
+
+async fn test_with_valid_root_certificate(port: u16) -> eyre::Result<()> {
+    let root_cert = "certs/ca/ca.crt";
+
+    let setts = format!(
+        "esdb://admin:changeit@localhost:{}?tlsVerifyCert=true&tls=true&tlsCaFile={}",
+        port, root_cert
+    )
+    .parse()?;
+    let client = eventstore::Client::new(setts)?;
+
+    let mut streams = client.read_all(&Default::default()).await?;
+
+    streams.next().await?;
+
+    Ok(())
+}
+
+async fn test_with_invalid_certificate(port: u16) -> eyre::Result<()> {
+    // invalid root certificate
+    let root_cert = "certs/node1/node.crt";
+
+    let setts = format!(
+        "esdb://admin:changeit@localhost:{}?tlsVerifyCert=true&tls=true&tlsCaFile={}",
+        port, root_cert
+    )
+    .parse()?;
+    let client = eventstore::Client::new(setts)?;
+
+    let result = client.read_all(&Default::default()).await;
+
+    assert!(
+        result.is_err(),
+        "Expected an error due to invalid certificate"
+    );
+
+    Ok(())
+}
+
+pub async fn tests(port: u16) -> eyre::Result<()> {
+    debug!("Before test_with_valid_root_certificate…");
+    test_with_valid_root_certificate(port).await?;
+    debug!("Complete");
+
+    debug!("Before test_with_invalid_certificate…");
+    test_with_invalid_certificate(port).await?;
+    debug!("Complete");
+
+    Ok(())
+}