use std::net::{TcpListener, TcpStream};
use anyhow::Result;
use async_native_tls::{Identity, TlsAcceptor, TlsStream};
use smol::{io, Async};
async fn echo(stream: TlsStream<Async<TcpStream>>) -> Result<()> {
let stream = async_dup::Mutex::new(stream);
io::copy(&stream, &mut &stream).await?;
Ok(())
}
fn main() -> Result<()> {
let identity = Identity::from_pkcs12(include_bytes!("identity.pfx"), "password")?;
let tls = TlsAcceptor::from(native_tls::TlsAcceptor::new(identity)?);
smol::block_on(async {
let listener = Async::<TcpListener>::bind(([127, 0, 0, 1], 7001))?;
println!("Listening on {}", listener.get_ref().local_addr()?);
println!("Now start a TLS client.");
loop {
let (stream, _) = listener.accept().await?;
let stream = tls.accept(stream).await?;
println!(
"Accepted client: {}",
stream.get_ref().get_ref().peer_addr()?
);
smol::spawn(echo(stream)).detach();
}
})
}