use audit::new_connection;
use futures::stream::StreamExt;
#[tokio::main]
async fn main() -> Result<(), String> {
let (connection, mut handle, mut messages) =
new_connection().map_err(|e| format!("{e}"))?;
tokio::spawn(connection);
handle.enable_events().await.map_err(|e| format!("{e}"))?;
env_logger::init();
while let Some((msg, _)) = messages.next().await {
println!("{msg:?}");
}
Ok(())
}