use clap::Parser;
use rustls_acme::caches::DirCache;
use rustls_acme::AcmeConfig;
use std::net::Ipv6Addr;
use std::path::PathBuf;
use tokio_stream::wrappers::TcpListenerStream;
use warp::Filter;
#[derive(Parser, Debug)]
struct Args {
#[clap(short, required = true)]
domains: Vec<String>,
#[clap(short)]
email: Vec<String>,
#[clap(short)]
cache: Option<PathBuf>,
#[clap(long)]
prod: bool,
#[clap(short, long, default_value = "443")]
port: u16,
}
#[tokio::main]
async fn main() {
simple_logger::init_with_level(log::Level::Info).unwrap();
let args = Args::parse();
let tcp_listener = tokio::net::TcpListener::bind((Ipv6Addr::UNSPECIFIED, args.port)).await.unwrap();
let tcp_incoming = TcpListenerStream::new(tcp_listener);
let tls_incoming = AcmeConfig::new(args.domains)
.contact(args.email.iter().map(|e| format!("mailto:{}", e)))
.cache_option(args.cache.clone().map(DirCache::new))
.directory_lets_encrypt(args.prod)
.tokio_incoming(tcp_incoming, Vec::new());
let route = warp::any().map(|| "Hello Tls!");
warp::serve(route).run_incoming(tls_incoming).await;
unreachable!()
}