leap_client_rs 0.1.5

use std::time::{Duration, SystemTime, UNIX_EPOCH};

use leap_client_rs::{LeapEdge, LeapOptions};
use tokio::time::sleep;

#[tokio::main]
async fn main() -> Result<(), std::io::Error> {
    fern::Dispatch::new()
        .format(|out, message, _| {
            out.finish(format_args!(
                "{} - {}",
                SystemTime::now()
                    .duration_since(UNIX_EPOCH)
                    .unwrap()
                    .as_millis(),
                message
            ))
        })
        .level(log::LevelFilter::Debug)
        .chain(std::io::stdout())
        .apply()
        .ok();

    let mut manager = LeapEdge::new(LeapOptions {
        project: &std::env::var("PROJECT").unwrap(),
        token: std::env::var("TOKEN").ok().as_deref(),
        ..Default::default()
    })
    .await?;

    if let Ok(channel) = std::env::var("CHANNEL") {
        manager.channel_subscribe(&channel).await?;
    }

    while (manager.listen().await).is_some() {}

    sleep(Duration::from_secs(5)).await;

    log::debug!("Done :D");

    Ok(())
}