use gsmtc::{ManagerEvent::*, SessionUpdateEvent::*};
use windows::core::Result;

#[tokio::main]
async fn main() -> Result<()> {
    tracing_subscriber::fmt()
        .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
        .init();

    let mut rx = gsmtc::SessionManager::create().await?;

    while let Some(evt) = rx.recv().await {
        match evt {
            SessionCreated {
                session_id,
                mut rx,
                source,
            } => {
                println!("Created session: {{id={session_id}, source={source}}}");
                tokio::spawn(async move {
                    while let Some(evt) = rx.recv().await {
                        match evt {
                            Model(model) => {
                                println!("[{session_id}/{source}] Model updated: {model:#?}")
                            }
                            Media(model, image) => println!(
                                "[{session_id}/{source}] Media updated: {model:#?} - {image:?}"
                            ),
                        }
                    }
                    println!("[{session_id}/{source}] exited event-loop");
                });
            }
            SessionRemoved { session_id } => println!("Session {{id={session_id}}} was removed"),
            CurrentSessionChanged {
                session_id: Some(id),
            } => println!("Current session: {id}"),
            CurrentSessionChanged { session_id: None } => println!("No more current session"),
        }
    }
    println!("Exited global event-loop");

    Ok(())
}