feat(moon): bootstrap encoding codec primitives #903

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged

zxch3n merged 89 commits into main from feat/moonbit-encoding-plan

Jan 16, 2026

.gitignore

-Original file line number
+Diff line change
@@ Expand Up / @@ -3,6 +3,8 @@ @@
     *.ipynb
     flamegraph.svg
     target
+    moon/_build/
+    moon_*_fuzz_artifacts*/
     dhat-heap.json
     .DS_Store
     node_modules/
@@ Expand Down @@

Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

crates/kv-store/tests/moon_sstable_fixture.rs

-Original file line number
+Diff line change
@@ -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"")),
+            ]
+        );
+    }

crates/kv-store/tests/testdata/moon_sstable_simple.bin

Binary file not shown.

crates/loro-internal/src/state/dead_containers_cache.rs

-Original file line number
+Diff line change
@@ Expand Up / @@ -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;
                 }
             }
@@ Expand Down Expand Up / @@ -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
@@ Expand Down @@

crates/loro/Cargo.toml

-Original file line number
+Diff line change
@@ Expand Up / @@ -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" }
@@ Expand All / @@ -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"]
@@ Expand Down @@

Provide feedback