Summary: Rebase onto upstream v0.2.0 (database-primitive merge) + fix loro 1.12.0 API

- Rebase onto upstream/main ea1cbc6 (v0.2.0 tag, PR NodeDB-Lab#102 merge)
- Resolve pool.rs conflict: keep database-aware authenticate() signature
- Bump loro workspace dep =1.10.8 → =1.12.0 (loro-internal now at 1.12.0)
- Add From<loro::LoroError> for CrdtError to support ? on fork_at() Result
- Fix nodedb-crdt history.rs: fork_at() now returns Result in loro 1.12.0
- Regenerate Cargo.lock

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: leowmjw

Cargo.lock

@@ -131,7 +131,7 @@ bytes = "1"
 io-uring = "0.7"
 
 # CRDTs
-loro = "=1.10.8"
+loro = "=1.12.0"
 
 # Kafka bridge
 rdkafka = { version = "0.36", features = ["cmake-build"] }

Cargo.toml

@@ -53,4 +53,10 @@ pub enum CrdtError {
     },
 }
 
+impl From<loro::LoroError> for CrdtError {
+    fn from(e: loro::LoroError) -> Self {
+        CrdtError::Loro(e.to_string())
+    }
+}
+
 pub type Result<T> = std::result::Result<T, CrdtError>;

nodedb-crdt/src/error.rs

@@ -27,7 +27,7 @@ impl CrdtState {
         version: &loro::VersionVector,
     ) -> Result<Option<LoroValue>> {
         let frontiers = self.doc.vv_to_frontiers(version);
-        let forked = self.doc.fork_at(&frontiers);
+        let forked = self.doc.fork_at(&frontiers)?;
 
         let coll = forked.get_map(collection);
         match coll.get(row_id) {