use std::path::Path;
use miden_node_db::DatabaseError;
use miden_node_utils::tracing::miden_instrument;
use crate::{COMPONENT, LOG_TARGET};
include!(concat!(env!("OUT_DIR"), "/db_migrator.rs"));
#[miden_instrument(
level = "debug",
target = COMPONENT,
skip_all,
err,
)]
pub fn bootstrap_database(database_filepath: &Path) -> std::result::Result<(), DatabaseError> {
let migrator = migrator().map_err(DatabaseError::migration)?;
tracing::info!(
target: LOG_TARGET,
migration_count = migrator.schema_hashes().len(),
"Bootstrapping database schema"
);
migrator.bootstrap(database_filepath).map_err(DatabaseError::migration)?;
Ok(())
}
#[miden_instrument(
level = "debug",
target = COMPONENT,
skip_all,
err,
)]
pub fn migrate_database(database_filepath: &Path) -> std::result::Result<(), DatabaseError> {
let migrator = migrator().map_err(DatabaseError::migration)?;
tracing::info!(
target: LOG_TARGET,
migration_count = migrator.schema_hashes().len(),
"Applying database migrations"
);
migrator.migrate(database_filepath).map_err(DatabaseError::migration)?;
Ok(())
}
#[miden_instrument(
level = "debug",
target = COMPONENT,
skip_all,
err,
)]
pub fn verify_latest_schema(database_filepath: &Path) -> std::result::Result<(), DatabaseError> {
let migrator = migrator().map_err(DatabaseError::migration)?;
tracing::info!(
target: LOG_TARGET,
migration_count = migrator.schema_hashes().len(),
"Verifying database schema"
);
migrator
.verify_latest_schema(database_filepath)
.map_err(DatabaseError::migration)?;
Ok(())
}
#[cfg(test)]
mod tests {
use anyhow::Result;
use miden_node_db::migration::{SchemaHash, SchemaHashes};
use super::*;
const EXPECTED_SCHEMA_HASHES: [SchemaHash; 1] = [SchemaHash::from_hex(
"100025e3daa05c2f7d5be2dc6ff096dbe916f1af4d95ae27cdfb2e23d6f0723a",
)];
#[test]
fn migration_schema_hashes_are_stable() -> Result<()> {
let migrator = migrator()?;
assert_eq!(migrator.schema_hashes(), SchemaHashes(&EXPECTED_SCHEMA_HASHES));
Ok(())
}
}