compio-tls 0.9.1

TLS adaptor with compio
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

use compio_io::{AsyncReadExt, AsyncWrite, AsyncWriteExt};
use compio_net::TcpStream;
use compio_tls::TlsConnector;

async fn connect(connector: TlsConnector) {
    let stream = TcpStream::connect("www.example.com:443").await.unwrap();
    let mut stream = connector.connect("www.example.com", stream).await.unwrap();

    stream
        .write_all("GET / HTTP/1.1\r\nHost:www.example.com\r\nConnection: close\r\n\r\n")
        .await
        .unwrap();
    stream.flush().await.unwrap();
    let (_, res) = stream.read_to_end(vec![]).await.unwrap();
    println!("{}", String::from_utf8_lossy(&res));
}

#[cfg(feature = "native-tls")]
#[compio_macros::test]
async fn native() {
    let connector = TlsConnector::from(native_tls::TlsConnector::new().unwrap());

    connect(connector).await;
}

#[cfg(feature = "rustls")]
#[compio_macros::test]
async fn rtls() {
    let mut store = rustls::RootCertStore::empty();
    for cert in rustls_native_certs::load_native_certs().unwrap() {
        store.add(cert).unwrap();
    }

    let connector = TlsConnector::from(std::sync::Arc::new(
        rustls::ClientConfig::builder()
            .with_root_certificates(store)
            .with_no_client_auth(),
    ));

    connect(connector).await;
}