Gittes-archive/spacedrive
2
0
Fork 0
mirror of https://github.com/spacedriveapp/spacedrive.git synced 2025-12-11 20:15:30 +01:00
Code Issues Packages Projects Releases Wiki Activity

Rename database.db to library.db with automatic migration

Browse Source
This commit is contained in:
Jamie Pine 2025-12-01 14:44:09 -08:00
parent 60a96b31ed
commit 4a314fadb2
2 changed files with 38 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
core/src/library/manager.rs
View File

@ -6,6 +6,11 @@ use super::{
lock::LibraryLock, lock::LibraryLock,
Library, LIBRARY_CONFIG_VERSION, LIBRARY_EXTENSION, Library, LIBRARY_CONFIG_VERSION, LIBRARY_EXTENSION,
}; };
/// Legacy database filename (for migration)
const LEGACY_DB_FILENAME: &str = "database.db";
use super::LIBRARY_DB_FILENAME;
use crate::{ use crate::{
context::CoreContext, context::CoreContext,
device::DeviceManager, device::DeviceManager,
@ -272,7 +277,7 @@ impl LibraryManager {
// Pre-register the initial device BEFORE opening the library // Pre-register the initial device BEFORE opening the library
// This ensures when ensure_device_registered runs, it detects the collision // This ensures when ensure_device_registered runs, it detects the collision
let db_path = library_path.join("database.db"); let db_path = library_path.join(LIBRARY_DB_FILENAME);
let db_url = format!("sqlite://{}?mode=rwc", db_path.display()); let db_url = format!("sqlite://{}?mode=rwc", db_path.display());
let db_conn = sea_orm::Database::connect(&db_url) let db_conn = sea_orm::Database::connect(&db_url)
.await .await
@ -431,8 +436,32 @@ impl LibraryManager {
} }
} }
// Migrate old database.db to library.db if needed
let old_db_path = path.join(LEGACY_DB_FILENAME);
let new_db_path = path.join(LIBRARY_DB_FILENAME);
if old_db_path.exists() && !new_db_path.exists() {
info!("Migrating database.db to library.db");
tokio::fs::rename(&old_db_path, &new_db_path)
.await
.map_err(|e| LibraryError::Other(format!("Failed to rename database: {}", e)))?;
// Also rename WAL and SHM files if they exist
let old_wal = path.join("database.db-wal");
let new_wal = path.join("library.db-wal");
if old_wal.exists() {
let _ = tokio::fs::rename(&old_wal, &new_wal).await;
}
let old_shm = path.join("database.db-shm");
let new_shm = path.join("library.db-shm");
if old_shm.exists() {
let _ = tokio::fs::rename(&old_shm, &new_shm).await;
}
}
// Open database // Open database
let db_path = path.join("database.db"); let db_path = new_db_path;
let db = Arc::new(Database::open(&db_path).await?); let db = Arc::new(Database::open(&db_path).await?);
// Run migrations to ensure schema is up to date // Run migrations to ensure schema is up to date
@ -767,7 +796,7 @@ impl LibraryManager {
tokio::fs::write(config_path, json).await?; tokio::fs::write(config_path, json).await?;
// Initialize database // Initialize database
let db_path = path.join("database.db"); let db_path = path.join(LIBRARY_DB_FILENAME);
let db = Database::create(&db_path).await?; let db = Database::create(&db_path).await?;
// Run initial migrations // Run initial migrations
@ -826,7 +855,7 @@ impl LibraryManager {
tokio::fs::write(config_path, json).await?; tokio::fs::write(config_path, json).await?;
// Initialize database // Initialize database
let db_path = path.join("database.db"); let db_path = path.join(LIBRARY_DB_FILENAME);
let db = Database::create(&db_path).await?; let db = Database::create(&db_path).await?;
// Run initial migrations // Run initial migrations

7
core/src/library/mod.rs
View File

@ -16,6 +16,9 @@ pub use error::{LibraryError, Result};
pub use lock::LibraryLock; pub use lock::LibraryLock;
pub use manager::{DiscoveredLibrary, LibraryManager}; pub use manager::{DiscoveredLibrary, LibraryManager};
/// Filename for the library database
pub(crate) const LIBRARY_DB_FILENAME: &str = "library.db";
use crate::infra::{ use crate::infra::{
db::Database, db::Database,
event::EventBus, event::EventBus,
@ -1270,7 +1273,7 @@ impl Library {
/// Calculate database file size /// Calculate database file size
async fn calculate_database_size(&self) -> Result<u64> { async fn calculate_database_size(&self) -> Result<u64> {
let db_path = self.path().join("database.db"); let db_path = self.path().join(LIBRARY_DB_FILENAME);
debug!( debug!(
db_path = %db_path.display(), db_path = %db_path.display(),
@ -1544,7 +1547,7 @@ impl Library {
/// Calculate database file size (static version) /// Calculate database file size (static version)
async fn calculate_database_size_static(path: &PathBuf) -> Result<u64> { async fn calculate_database_size_static(path: &PathBuf) -> Result<u64> {
let db_path = path.join("database.db"); let db_path = path.join(LIBRARY_DB_FILENAME);
if db_path.exists() { if db_path.exists() {
let metadata = tokio::fs::metadata(&db_path).await?; let metadata = tokio::fs::metadata(&db_path).await?;
Ok(metadata.len()) Ok(metadata.len())