fix: absolutify db path

+ add test

Author: marvin-j97

.gitignore

@@ -21,3 +21,4 @@ Cargo.lock
 .data
 
 /old_*
+.test

Cargo.toml

@@ -2,7 +2,7 @@
 name = "fjall"
 description = "LSM-based key-value storage engine"
 license = "MIT OR Apache-2.0"
-version = "0.6.1"
+version = "0.6.2"
 edition = "2021"
 rust-version = "1.74.0"
 readme = "README.md"
@@ -26,11 +26,12 @@ segment_history = ["lsm-tree/segment_history"]
 [dependencies]
 byteorder = "1.5.0"
 crc32fast = "1.3.2"
-lsm-tree = { version = "0.6.1", default-features = false }
+lsm-tree = { version = "0.6.2", default-features = false }
 log = "0.4.20"
 std-semaphore = "0.1.0"
 tempfile = "3.9.0"
 fs_extra = "1.3.0"
+path-absolutize = "3.1.1"
 
 [dev-dependencies]
 criterion = { version = "0.5.1", features = ["html_reports"] }

src/config.rs

@@ -1,10 +1,19 @@
 use crate::{journal::shard::RecoveryMode, Keyspace};
 use lsm_tree::{descriptor_table::FileDescriptorTable, BlockCache};
+use path_absolutize::Absolutize;
 use std::{
     path::{Path, PathBuf},
     sync::Arc,
 };
 
+fn absolute_path<P: AsRef<Path>>(path: P) -> PathBuf {
+    // TODO: replace with https://doc.rust-lang.org/std/path/fn.absolute.html once stable
+    path.as_ref()
+        .absolutize()
+        .expect("should be absolute path")
+        .into()
+}
+
 /// Global keyspace configuration
 #[derive(Clone)]
 pub struct Config {
@@ -50,7 +59,7 @@ impl Default for Config {
             .max(1);
 
         Self {
-            path: ".fjall_data".into(),
+            path: absolute_path (".fjall_data"),
             block_cache: Arc::new(BlockCache::with_capacity_bytes(/* 16 MiB */ 16 * 1_024 * 1_024)),
             descriptor_table: Arc::new(FileDescriptorTable::new(960, 4)),
             max_write_buffer_size_in_bytes: 64 * 1_024 * 1_024,
@@ -67,7 +76,7 @@ impl Config {
     /// Creates a new configuration
     pub fn new<P: AsRef<Path>>(path: P) -> Self {
         Self {
-            path: path.as_ref().into(),
+            path: absolute_path(path),
             ..Default::default()
         }
     }

tests/recover_from_different_folder.rs

@@ -0,0 +1,39 @@
+use fjall::Config;
+use std::time::Duration;
+use test_log::test;
+
+#[test]
+fn recover_from_different_folder() -> fjall::Result<()> {
+    if std::path::Path::new(".test").try_exists()? {
+        std::fs::remove_dir_all(".test")?;
+    }
+
+    let folder = ".test/asd";
+
+    {
+        let keyspace = Config::new(folder).open()?;
+        let partition = keyspace.open_partition("default", Default::default())?;
+
+        partition.insert("abc", "def")?;
+        partition.insert("wqewe", "def")?;
+        partition.insert("ewewq", "def")?;
+        partition.insert("asddas", "def")?;
+        partition.insert("ycxycx", "def")?;
+        partition.insert("asdsda", "def")?;
+        partition.insert("wewqe", "def")?;
+    }
+
+    let absolute_folder = std::path::Path::new(folder).canonicalize()?;
+
+    std::fs::create_dir_all(".test/def")?;
+    std::env::set_current_dir(".test/def")?;
+
+    for _ in 0..10 {
+        let _keyspace = Config::new(&absolute_folder)
+            .max_write_buffer_size(1)
+            .open()?;
+        std::thread::sleep(Duration::from_secs(1));
+    }
+
+    Ok(())
+}