diff --git a/markbase-core/src/server.rs b/markbase-core/src/server.rs index 299b5f0..01946b8 100644 --- a/markbase-core/src/server.rs +++ b/markbase-core/src/server.rs @@ -942,8 +942,7 @@ fn extract_and_register_archive( result.success_files, result.total_bytes); // Register extracted files to database - let db_path = FileTree::user_db_path(user_id); - let conn = FileTree::open_user_db(&db_path)?; + let conn = FileTree::init_user_db(user_id)?; let now = std::time::SystemTime::now() .duration_since(std::time::UNIX_EPOCH) @@ -1196,15 +1195,15 @@ async fn upload_file( let hex = format!("{:x}", hash); let file_uuid = hex[0..32].to_string(); - // Save to database (user-specific SQLite) - let db_path = filetree::FileTree::user_db_path(&user_id); +// Save to database (user-specific SQLite) let file_uuid_clone = file_uuid.clone(); let file_hash_clone = file_hash.clone(); let filename_clone = filename.clone(); let file_path_clone = file_path.clone(); - + let user_id_clone = user_id.clone(); + let db_result = tokio::task::spawn_blocking(move || -> anyhow::Result<()> { - let conn = filetree::FileTree::open_user_db(&db_path)?; + let conn = filetree::FileTree::init_user_db(&user_id_clone)?; // Register file let now = std::time::SystemTime::now()