loro-dev
diff --git a/‎.gitignore‎
Lines changed: 2 additions & 0 deletions b/‎.gitignore‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎Cargo.lock‎
Lines changed: 91 additions & 1 deletion b/‎Cargo.lock‎
Lines changed: 91 additions & 1 deletion
diff --git a/‎crates/kv-store/tests/moon_sstable_fixture.rs‎
Lines changed: 19 additions & 0 deletions b/‎crates/kv-store/tests/moon_sstable_fixture.rs‎
Lines changed: 19 additions & 0 deletions
diff --git a/‎crates/kv-store/tests/testdata/moon_sstable_simple.bin‎
50 Bytes b/‎crates/kv-store/tests/testdata/moon_sstable_simple.bin‎
50 Bytes
diff --git a/‎crates/loro-internal/src/state/dead_containers_cache.rs‎
Lines changed: 11 additions & 4 deletions b/‎crates/loro-internal/src/state/dead_containers_cache.rs‎
Lines changed: 11 additions & 4 deletions
diff --git a/‎crates/loro/Cargo.toml‎
Lines changed: 2 additions & 1 deletion b/‎crates/loro/Cargo.toml‎
Lines changed: 2 additions & 1 deletion
@@ -3,6 +3,8 @@
 *.ipynb
 flamegraph.svg
 target
+moon/_build/
+moon_*_fuzz_artifacts*/
 dhat-heap.json
 .DS_Store
 node_modules/
 
@@ -0,0 +1,19 @@
+use bytes::Bytes;
+use loro_kv_store::sstable::SsTable;
+
+#[test]
+fn import_moon_encoded_sstable() {
+    let bytes = Bytes::from_static(include_bytes!("testdata/moon_sstable_simple.bin"));
+    let table = SsTable::import_all(bytes, true).unwrap();
+    let kvs: Vec<(Bytes, Bytes)> = table.iter().collect();
+
+    assert_eq!(
+        kvs,
+        vec![
+            (Bytes::from_static(b"a"), Bytes::from_static(b"1")),
+            (Bytes::from_static(b"ab"), Bytes::from_static(b"2")),
+            (Bytes::from_static(b"z"), Bytes::from_static(b"")),
+        ]
+    );
+}
+
@@ -21,8 +21,9 @@ impl DocState {
     pub(crate) fn is_deleted(&mut self, idx: ContainerIdx) -> bool {
         #[cfg(not(debug_assertions))]
         {
-            if let Some(is_deleted) = self.dead_containers_cache.cache.get(&idx) {
-                return *is_deleted;
+            // Cache stores only deleted containers.
+            if self.dead_containers_cache.cache.contains_key(&idx) {
+                return true;
             }
         }
 
@@ -52,8 +53,14 @@ impl DocState {
             }
         }
 
-        for idx in visited {
-            self.dead_containers_cache.cache.insert(idx, is_deleted);
+        if is_deleted {
+            for idx in visited {
+                self.dead_containers_cache.cache.insert(idx, true);
+            }
+        } else {
+            for idx in visited {
+                self.dead_containers_cache.cache.remove(&idx);
+            }
         }
 
         is_deleted
 
@@ -26,7 +26,7 @@ tracing = { workspace = true }
 rustc-hash = { workspace = true }
 
 [dev-dependencies]
-serde_json = "1.0.87"
+serde_json = { version = "1.0.87", features = ["float_roundtrip"] }
 anyhow = "1.0.83"
 ctor = "0.2"
 dev-utils = { path = "../dev-utils" }
@@ -37,6 +37,7 @@ base64 = "0.22.1"
 serial_test = "3"
 
 [features]
+default = ["counter"]
 counter = ["loro-internal/counter"]
 jsonpath = ["loro-internal/jsonpath"]
 logging = ["loro-internal/logging"]
Original file line number	Diff line number	Diff line change
`@@ -21,8 +21,9 @@ impl DocState {`
`21`	`21`	`pub(crate) fn is_deleted(&mut self, idx: ContainerIdx) -> bool {`
`22`	`22`	`#[cfg(not(debug_assertions))]`
`23`	`23`	`{`
`24`		`- if let Some(is_deleted) = self.dead_containers_cache.cache.get(&idx) {`
`25`		`- return *is_deleted;`
	`24`	`+ // Cache stores only deleted containers.`
	`25`	`+ if self.dead_containers_cache.cache.contains_key(&idx) {`
	`26`	`+ return true;`
`26`	`27`	`}`
`27`	`28`	`}`
`28`	`29`
`@@ -52,8 +53,14 @@ impl DocState {`
`52`	`53`	`}`
`53`	`54`	`}`
`54`	`55`
`55`		`- for idx in visited {`
`56`		`- self.dead_containers_cache.cache.insert(idx, is_deleted);`
	`56`	`+ if is_deleted {`
	`57`	`+ for idx in visited {`
	`58`	`+ self.dead_containers_cache.cache.insert(idx, true);`
	`59`	`+ }`
	`60`	`+ } else {`
	`61`	`+ for idx in visited {`
	`62`	`+ self.dead_containers_cache.cache.remove(&idx);`
	`63`	`+ }`
`57`	`64`	`}`
`58`	`65`
`59`	`66`	`is_deleted`