rants 0.6.0

An async NATS client library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

#[cfg(feature = "rustls-tls")]
mod common;

#[cfg(feature = "rustls-tls")]
mod test {
    use super::common::{self, NatsServer};
    use rants::{
        rustls::{Certificate, ClientConfig, RootCertStore},
        Client,
    };
    use std::{fs::File, io::BufReader};

    #[tokio::test(flavor = "multi_thread")]
    async fn rustls_tls_connection() {
        common::init();
        let _nats_server = NatsServer::new(&[
            "--tlscert=tests/certs/server-crt.pem",
            "--tlskey=tests/certs/server-key.pem",
        ])
        .await;

        let address = "127.0.0.1".parse().unwrap();
        let mut client = Client::new(vec![address]);

        // Load the server root certificate
        let file = File::open("tests/certs/ca.pem").unwrap();
        let mut file = BufReader::new(file);

        // Set the TLS config
        let certs = rustls_pemfile::certs(&mut file).unwrap();
        let mut root_certs = RootCertStore::empty();
        for cert in certs {
            root_certs.add(&Certificate(cert)).unwrap();
        }
        let tls_config = ClientConfig::builder()
            .with_safe_defaults()
            .with_root_certificates(root_certs)
            .with_no_client_auth();
        client.set_tls_config(tls_config).await;
        client.set_tls_domain(String::from("example.com")).await;

        client.connect().await;
        client.disconnect().await;
    }
}