refactor(nodedb): propagate StorageEngineSync bound across all NodeDbLite impls

Now that NodeDbLite holds array CRDT sync state that requires synchronous
storage access, every impl block must carry StorageEngine + StorageEngineSync.
Updates all remaining impl blocks (batch, collections, definitions, diagnostic,
graph_rag, health, sync_delegate, trait_impl) to match.

Additional changes bundled with the mechanical bound update:
- health: expose public storage() accessor for benchmark compression-ratio
  measurement via backend-specific methods like db_size_bytes()
- trait_impl: use cfg_attr async_trait / async_trait(?Send) to keep the
  NodeDb trait implementation compiling on WASM targets

Author: farhan-syah

nodedb-lite/src/nodedb/batch.rs

@@ -4,9 +4,9 @@ use nodedb_types::Namespace;
 use nodedb_types::error::{NodeDbError, NodeDbResult};
 
 use super::{LockExt, NodeDbLite};
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Batch insert vectors — O(1) CRDT delta export instead of O(N).
     ///
     /// Use this for bulk loading (cold-start hydration, benchmark setup, imports).

nodedb-lite/src/nodedb/collection/bulk.rs

@@ -10,9 +10,9 @@ use nodedb_types::value::Value;
 
 use super::super::convert::value_to_loro;
 use super::super::{LockExt, NodeDbLite};
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Bulk update documents matching a predicate.
     ///
     /// Scans all documents, evaluates `ScanFilter` predicates, and applies

nodedb-lite/src/nodedb/collection/ddl.rs

@@ -3,7 +3,7 @@
 use nodedb_types::error::{NodeDbError, NodeDbResult};
 
 use super::super::{LockExt, NodeDbLite};
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
 /// Collection metadata stored in redb.
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
@@ -18,7 +18,7 @@ pub struct CollectionMeta {
     pub config_json: Option<String>,
 }
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Create a collection with optional schema.
     ///
     /// If the collection already exists, returns Ok (idempotent).

nodedb-lite/src/nodedb/collection/import.rs

@@ -3,9 +3,9 @@
 use nodedb_types::error::{NodeDbError, NodeDbResult};
 
 use super::super::{LockExt, NodeDbLite};
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Import documents from NDJSON (newline-delimited JSON) text.
     ///
     /// Each line is a JSON object. The "id" field is used as document ID;

nodedb-lite/src/nodedb/collection/transaction.rs

@@ -13,7 +13,7 @@ use nodedb_types::value::Value;
 use super::super::convert::value_to_loro;
 use super::super::{LockExt, NodeDbLite};
 use crate::engine::crdt::engine::{CrdtBatchOp, CrdtField};
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
 /// A single operation in a transaction batch.
 #[derive(Debug, Clone)]
@@ -29,7 +29,7 @@ pub enum TransactionOp {
     },
 }
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Execute a batch of operations atomically.
     ///
     /// **Atomicity model**: all operations are validated upfront. If any

nodedb-lite/src/nodedb/definitions.rs

@@ -12,7 +12,7 @@
 use nodedb_types::error::{NodeDbError, NodeDbResult};
 
 use super::NodeDbLite;
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
 /// A stored function definition (mirrors Origin's StoredFunction).
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
@@ -69,7 +69,7 @@ pub struct LiteProcedureParam {
 
 // ── Generic CRUD helpers ────────────────────────────────────────────────
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Store a definition in the local catalog under `{prefix}:{name}`.
     async fn put_definition(
         &self,
@@ -137,7 +137,7 @@ impl<S: StorageEngine> NodeDbLite<S> {
 
 // ── Type-specific convenience methods ───────────────────────────────────
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Store a function definition in the local catalog.
     pub async fn put_function(&self, func: &LiteStoredFunction) -> NodeDbResult<()> {
         self.put_definition("function", &func.name, func).await

nodedb-lite/src/nodedb/diagnostic.rs

@@ -13,7 +13,7 @@
 
 use serde::Serialize;
 
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
 use super::core::NodeDbLite;
 use super::health::HealthStatus;
@@ -67,7 +67,7 @@ pub struct BuildInfo {
     pub profile: &'static str,
 }
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Generate a diagnostic dump suitable for bug reports.
     ///
     /// Contains NO user data, NO document contents, NO embeddings.

nodedb-lite/src/nodedb/graph_rag.rs

@@ -13,7 +13,7 @@ use nodedb_types::id::NodeId;
 use nodedb_types::result::SearchResult;
 
 use super::{LockExt, NodeDbLite};
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
 /// GraphRAG fusion parameters.
 pub struct GraphRagParams<'a> {
@@ -47,7 +47,7 @@ impl Default for GraphRagParams<'_> {
     }
 }
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// GraphRAG fusion: vector search → graph expansion → RRF merge.
     ///
     /// 1. Vector search returns `vector_k` candidates by embedding similarity.
@@ -189,7 +189,7 @@ fn search_results_to_ranked(
         .collect()
 }
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
     /// Hybrid search: vector similarity + BM25 text relevance fused via RRF.
     ///
     /// 1. Vector search returns `vector_k` candidates by embedding similarity.

nodedb-lite/src/nodedb/health.rs

@@ -11,7 +11,7 @@
 use serde::Serialize;
 
 use crate::memory::{EngineId, PressureLevel};
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
 use super::core::NodeDbLite;
 use super::lock_ext::LockExt;
@@ -115,7 +115,15 @@ fn engine_memory(gov: &crate::memory::MemoryGovernor, id: EngineId) -> EngineMem
     }
 }
 
-impl<S: StorageEngine> NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> NodeDbLite<S> {
+    /// Borrow the underlying storage engine.
+    ///
+    /// Public so benchmark code can call backend-specific methods like
+    /// `RedbStorage::db_size_bytes()` for compression-ratio measurement.
+    pub fn storage(&self) -> &S {
+        &self.storage
+    }
+
     /// Get a structured health report.
     ///
     /// This is a cheap, non-blocking call — reads atomic counters and lock-free state.

nodedb-lite/src/nodedb/sync_delegate.rs

@@ -1,12 +1,12 @@
 //! `SyncDelegate` implementation — bridges the sync transport to NodeDbLite's engines.
 
-use crate::storage::engine::StorageEngine;
+use crate::storage::engine::{StorageEngine, StorageEngineSync};
 
 use super::core::NodeDbLite;
 
 #[cfg(not(target_arch = "wasm32"))]
 #[async_trait::async_trait]
-impl<S: StorageEngine> crate::sync::SyncDelegate for NodeDbLite<S> {
+impl<S: StorageEngine + StorageEngineSync> crate::sync::SyncDelegate for NodeDbLite<S> {
     fn pending_deltas(&self) -> Vec<crate::engine::crdt::engine::PendingDelta> {
         self.pending_crdt_deltas().unwrap_or_default()
     }