//! DataFusion SQL over netsky observability tables.
use netsky_db::Db;
pub fn run(sql: &str) -> netsky_core::Result<()> {
let db = Db::open().map_err(|e| netsky_core::anyhow!("open netsky-db: {e}"))?;
db.migrate()
.map_err(|e| netsky_core::anyhow!("migrate netsky-db: {e}"))?;
let output = db
.query(sql)
.map_err(|e| netsky_core::anyhow!("query netsky-db: {e}"))?;
println!("{output}");
Ok(())
}