103 lines
3.4 KiB
Rust
103 lines
3.4 KiB
Rust
use bzod::config::Config;
|
|
use bzod::db::Db;
|
|
use std::fs;
|
|
use std::path::PathBuf;
|
|
|
|
fn create_temp_config(temp_dir: PathBuf) -> Config {
|
|
let mut config = Config::load_with_cli(Some(&temp_dir)).unwrap();
|
|
config.backup_dir = temp_dir.clone();
|
|
config.base_url = Some("http://bzo.in".to_string());
|
|
config
|
|
}
|
|
|
|
#[tokio::test]
|
|
async fn test_legacy_migration() {
|
|
let temp_dir =
|
|
std::env::temp_dir().join(format!("bzod_test_migration_{}", uuid::Uuid::new_v4()));
|
|
fs::create_dir_all(&temp_dir).unwrap();
|
|
let config = create_temp_config(temp_dir.clone());
|
|
|
|
// Create legacy files at the root of temp_dir
|
|
let legacy_admin_path = temp_dir.join("admin.db");
|
|
let legacy_system_path = temp_dir.join("system.db");
|
|
let legacy_content_path = temp_dir.join("content.db");
|
|
let legacy_analytics_path = temp_dir.join("analytics.db");
|
|
|
|
// Apply old schemas/migrations
|
|
{
|
|
let mut admin_conn = rusqlite::Connection::open(&legacy_admin_path).unwrap();
|
|
bzod::db::migrations::run_migrations(
|
|
&mut admin_conn,
|
|
"admin",
|
|
bzod::db::migrations::ADMIN_MIGRATIONS,
|
|
None,
|
|
)
|
|
.unwrap();
|
|
// Insert admin user
|
|
let hash = bzod::auth::hash_password("admin_pass").unwrap();
|
|
bzod::db::admin::create_user(&admin_conn, "admin", &hash).unwrap();
|
|
|
|
let mut system_conn = rusqlite::Connection::open(&legacy_system_path).unwrap();
|
|
bzod::db::migrations::run_migrations(
|
|
&mut system_conn,
|
|
"system",
|
|
bzod::db::migrations::SYSTEM_MIGRATIONS,
|
|
None,
|
|
)
|
|
.unwrap();
|
|
|
|
let mut content_conn = rusqlite::Connection::open(&legacy_content_path).unwrap();
|
|
bzod::db::migrations::run_migrations(
|
|
&mut content_conn,
|
|
"content",
|
|
bzod::db::migrations::CONTENT_MIGRATIONS,
|
|
None,
|
|
)
|
|
.unwrap();
|
|
// Insert a link in legacy content
|
|
bzod::db::content::create_url_extended(
|
|
&content_conn,
|
|
"!legacy-slug",
|
|
"https://legacy.com",
|
|
None,
|
|
None,
|
|
&[],
|
|
None,
|
|
None,
|
|
None,
|
|
)
|
|
.unwrap();
|
|
|
|
let mut analytics_conn = rusqlite::Connection::open(&legacy_analytics_path).unwrap();
|
|
bzod::db::migrations::run_migrations(
|
|
&mut analytics_conn,
|
|
"analytics",
|
|
bzod::db::migrations::ANALYTICS_MIGRATIONS,
|
|
None,
|
|
)
|
|
.unwrap();
|
|
}
|
|
|
|
// Call normalize_restored_layout to move legacy flat files into multi-tenant paths
|
|
bzod::services::backup_layout::normalize_restored_layout(&temp_dir).unwrap();
|
|
|
|
// Call Db::init
|
|
let _db = Db::init(&config).expect("Failed to init Db and run legacy migration");
|
|
|
|
// Verify files moved to correct directories
|
|
assert!(!legacy_admin_path.exists());
|
|
assert!(!legacy_content_path.exists());
|
|
assert!(temp_dir.join("admin/admin.db").exists());
|
|
assert!(temp_dir.join("users/1/content.db").exists());
|
|
|
|
// Verify legacy content is preserved in users/1/content.db
|
|
{
|
|
let conn = rusqlite::Connection::open(temp_dir.join("users/1/content.db")).unwrap();
|
|
let url = bzod::db::content::get_url_by_code(&conn, "!legacy-slug").unwrap();
|
|
assert!(url.is_some());
|
|
assert_eq!(url.unwrap().destination, "https://legacy.com");
|
|
}
|
|
|
|
let _ = fs::remove_dir_all(&temp_dir);
|
|
}
|