Merge pull request #301 from EnRaiha/fix/fuzz-wasm-builds

fix(build): repair fuzz target and wasm decoder after upstream refactors

Author: farhan-syah

fuzz/Cargo.lock

@@ -16,6 +16,7 @@ libfuzzer-sys = { version = "0.4", optional = true }
 tempfile = "3"
 nodedb-codec = { path = "../nodedb-codec" }
 nodedb-columnar = { path = "../nodedb-columnar" }
+nodedb-mem = { path = "../nodedb-mem" }
 nodedb-strict = { path = "../nodedb-strict" }
 nodedb-types = { path = "../nodedb-types" }
 nodedb-wal = { path = "../nodedb-wal" }

fuzz/Cargo.toml

@@ -1,8 +1,13 @@
+use std::sync::Arc;
+
 use nodedb_columnar::memtable::ColumnData;
+use nodedb_columnar::writer::PROFILE_PLAIN;
 use nodedb_columnar::{
     DeleteBitmap, OwnedSegmentReader, ScanPredicate, SegmentReader, SegmentWriter,
 };
+use nodedb_mem::{EngineId, EngineLimits, GovernorConfig, MemoryGovernor, ScopedMemory};
 use nodedb_types::columnar::{ColumnDef, ColumnType, ColumnarSchema};
+use nodedb_types::{DatabaseId, TenantId};
 use nodedb_wal::crypto::WalEncryptionKey;
 
 const INPUT_PREFIX_BYTES: usize = 64;
@@ -17,6 +22,26 @@ const COLUMN_COUNT: usize = 5;
 const FUZZ_KEK_BYTES: [u8; 32] = [0x5a; 32];
 const FUZZ_KEK_EPOCH: [u8; 4] = [0; 4];
 
+/// A memory scope whose governor ceiling covers every engine's limit — the
+/// same shape the integration tests use. Segment writes now take mandatory
+/// ScopedMemory (refactor(mem): make ScopedMemory budgeting mandatory).
+fn fuzz_memory() -> ScopedMemory {
+    let per_engine = usize::MAX / EngineId::ALL.len();
+    let governor = Arc::new(
+        MemoryGovernor::new(GovernorConfig {
+            global_ceiling: per_engine * EngineId::ALL.len(),
+            engine_limits: EngineLimits::uniform(per_engine),
+        })
+        .expect("fuzz governor"),
+    );
+    ScopedMemory::new(
+        governor,
+        DatabaseId::DEFAULT,
+        TenantId::new(0),
+        EngineId::Columnar,
+    )
+}
+
 fn exercise_reader(reader: &SegmentReader<'_>) {
     let count = reader.column_count().min(COLUMN_COUNT);
     for index in 0..count {
@@ -169,7 +194,7 @@ fn generated_segment(seed: &[u8], kek: Option<&WalEncryptionKey>) -> Option<Vec<
         },
     ];
 
-    SegmentWriter::plain()
+    SegmentWriter::new(PROFILE_PLAIN, fuzz_memory())
         .write_segment(&schema, &columns, ROW_COUNT, kek)
         .ok()
 }

fuzz/src/targets/columnar_segment.rs

@@ -321,7 +321,7 @@ fn compress_native(_data: &[u8], _level: i32) -> Result<Vec<u8>, CodecError> {
 
 #[cfg(target_arch = "wasm32")]
 fn decompress_native(frame: &[u8], expected_size: usize) -> Result<Vec<u8>, CodecError> {
-    use ruzstd::StreamingDecoder;
+    use ruzstd::decoding::StreamingDecoder;
 
     let mut decoder = StreamingDecoder::new(std::io::Cursor::new(frame)).map_err(|e| {
         CodecError::DecompressFailed {