use certstreamrs::CertstreamClient;
use futures_util::{pin_mut, StreamExt};

#[tokio::main]
async fn main() {
    // Create the client and open the connection/stream.
    let client = CertstreamClient::default();
    let stream = client.watch_certs();
    pin_mut!(stream);

    // Read from the stream and print the certificate message.
    loop {
        let msg = stream.next().await.unwrap().unwrap();

        println!(
            "Source: {} | First Hostname: {}",
            msg.data.source.name,
            msg.data.leaf_cert.all_domains.first().unwrap()
        );
    }
}