feat: migrate from ffi-napi to native Rust addon (napi-rs)

- Add native/ directory with Rust bindings using napi-rs
- Update GitHub Actions to build native addon with Rust toolchain
- Remove unstable ffi-napi dependencies from optionalDependencies
- Simplify build process: cargo build + tsc
- Fixes CI build failures with Node.js 20.x

Author: sushanthpy

native/Cargo.lock

@@ -0,0 +1,17 @@
+[package]
+name = "toondb-nodejs-native"
+version = "0.3.6"
+edition = "2021"
+
+[lib]
+crate-type = ["cdylib"]
+
+[dependencies]
+napi = { version = "2", features = ["async"] }
+napi-derive = "2"
+
+[dependencies.toondb-storage]
+path = "../../toondb/toondb-storage"
+
+[build-dependencies]
+napi-build = "2"

native/Cargo.toml

@@ -0,0 +1,3 @@
+fn main() {
+    napi_build::setup();
+}

native/build.rs

@@ -0,0 +1,164 @@
+#![deny(clippy::all)]
+
+use napi::bindgen_prelude::*;
+use napi_derive::napi;
+use toondb_storage as storage;
+
+#[napi]
+pub struct Database {
+    inner: storage::Database,
+}
+
+#[napi]
+impl Database {
+    #[napi(factory)]
+    pub fn open(path: String) -> Result<Self> {
+        let inner = storage::Database::open(&path)
+            .map_err(|e| Error::from_reason(e.to_string()))?;
+        Ok(Self { inner })
+    }
+    
+    #[napi]
+    pub fn put(&self, key: Buffer, value: Buffer) -> Result<()> {
+        self.inner.put(&key, &value)
+            .map_err(|e| Error::from_reason(e.to_string()))
+    }
+    
+    #[napi]
+    pub fn get(&self, key: Buffer) -> Result<Option<Buffer>> {
+        let result = self.inner.get(&key)
+            .map_err(|e| Error::from_reason(e.to_string()))?;
+        Ok(result.map(|v| v.into()))
+    }
+    
+    #[napi]
+    pub fn delete(&self, key: Buffer) -> Result<()> {
+        self.inner.delete(&key)
+            .map_err(|e| Error::from_reason(e.to_string()))
+    }
+    
+    #[napi]
+    pub fn put_path(&self, path: String, value: Buffer) -> Result<()> {
+        self.inner.put_path(&path, &value)
+            .map_err(|e| Error::from_reason(e.to_string()))
+    }
+    
+    #[napi]
+    pub fn get_path(&self, path: String) -> Result<Option<Buffer>> {
+        let result = self.inner.get_path(&path)
+            .map_err(|e| Error::from_reason(e.to_string()))?;
+        Ok(result.map(|v| v.into()))
+    }
+    
+    #[napi]
+    pub fn delete_path(&self, path: String) -> Result<()> {
+        self.inner.delete_path(&path)
+            .map_err(|e| Error::from_reason(e.to_string()))
+    }
+    
+    #[napi]
+    pub fn begin_transaction(&self) -> Result<Transaction> {
+        let txn = self.inner.begin_txn()
+            .map_err(|e| Error::from_reason(e.to_string()))?;
+        Ok(Transaction { inner: Some(txn) })
+    }
+    
+    #[napi]
+    pub fn checkpoint(&self) -> Result<i64> {
+        self.inner.checkpoint()
+            .map_err(|e| Error::from_reason(e.to_string()))
+    }
+    
+    #[napi]
+    pub fn stats(&self) -> Result<Stats> {
+        let stats = self.inner.stats()
+            .map_err(|e| Error::from_reason(e.to_string()))?;
+        Ok(Stats {
+            memtable_size_bytes: stats.memtable_size_bytes as i64,
+            wal_size_bytes: stats.wal_size_bytes as i64,
+            active_transactions: stats.active_transactions as i32,
+            min_active_snapshot: stats.min_active_snapshot as i64,
+            last_checkpoint_lsn: stats.last_checkpoint_lsn as i64,
+        })
+    }
+    
+    #[napi]
+    pub fn close(&mut self) {
+        // Rust Drop handles cleanup
+    }
+}
+
+#[napi(object)]
+pub struct Stats {
+    pub memtable_size_bytes: i64,
+    pub wal_size_bytes: i64,
+    pub active_transactions: i32,
+    pub min_active_snapshot: i64,
+    pub last_checkpoint_lsn: i64,
+}
+
+#[napi]
+pub struct Transaction {
+    inner: Option<storage::Transaction>,
+}
+
+#[napi]
+impl Transaction {
+    #[napi]
+    pub fn put(&mut self, key: Buffer, value: Buffer) -> Result<()> {
+        self.inner.as_mut()
+            .ok_or_else(|| Error::from_reason("Transaction already committed or aborted"))?
+            .put(&key, &value)
+            .map_err(|e| Error::from_reason(e.to_string()))
+    }
+    
+    #[napi]
+    pub fn get(&self, key: Buffer) -> Result<Option<Buffer>> {
+        let txn = self.inner.as_ref()
+            .ok_or_else(|| Error::from_reason("Transaction already committed or aborted"))?;
+        let result = txn.get(&key)
+            .map_err(|e| Error::from_reason(e.to_string()))?;
+        Ok(result.map(|v| v.into()))
+    }
+    
+    #[napi]
+    pub fn delete(&mut self, key: Buffer) -> Result<()> {
+        self.inner.as_mut()
+            .ok_or_else(|| Error::from_reason("Transaction already committed or aborted"))?
+            .delete(&key)
+            .map_err(|e| Error::from_reason(e.to_string()))
+    }
+    
+    #[napi]
+    pub fn put_path(&mut self, path: String, value: Buffer) -> Result<()> {
+        self.inner.as_mut()
+            .ok_or_else(|| Error::from_reason("Transaction already committed or aborted"))?
+            .put_path(&path, &value)
+            .map_err(|e| Error::from_reason(e.to_string()))
+    }
+    
+    #[napi]
+    pub fn get_path(&self, path: String) -> Result<Option<Buffer>> {
+        let txn = self.inner.as_ref()
+            .ok_or_else(|| Error::from_reason("Transaction already committed or aborted"))?;
+        let result = txn.get_path(&path)
+            .map_err(|e| Error::from_reason(e.to_string()))?;
+        Ok(result.map(|v| v.into()))
+    }
+    
+    #[napi]
+    pub fn commit(&mut self) -> Result<()> {
+        let txn = self.inner.take()
+            .ok_or_else(|| Error::from_reason("Transaction already committed or aborted"))?;
+        txn.commit()
+            .map_err(|e| Error::from_reason(e.to_string()))?;
+        Ok(())
+    }
+    
+    #[napi]
+    pub fn abort(&mut self) {
+        if let Some(txn) = self.inner.take() {
+            txn.abort();
+        }
+    }
+}

native/src/lib.rs

@@ -0,0 +1 @@
+{"rustc_fingerprint":9616641580413405637,"outputs":{"17747080675513052775":{"success":true,"status":"","code":0,"stdout":"rustc 1.92.0 (ded5c06cf 2025-12-08)\nbinary: rustc\ncommit-hash: ded5c06cf21d2b93bffd5d884aa6e96934ee4234\ncommit-date: 2025-12-08\nhost: aarch64-apple-darwin\nrelease: 1.92.0\nLLVM version: 21.1.3\n","stderr":""},"7971740275564407648":{"success":true,"status":"","code":0,"stdout":"___\nlib___.rlib\nlib___.dylib\nlib___.dylib\nlib___.a\nlib___.dylib\n/Users/sushanth/.rustup/toolchains/stable-aarch64-apple-darwin\noff\npacked\nunpacked\n___\ndebug_assertions\npanic=\"unwind\"\nproc_macro\ntarget_abi=\"\"\ntarget_arch=\"aarch64\"\ntarget_endian=\"little\"\ntarget_env=\"\"\ntarget_family=\"unix\"\ntarget_feature=\"aes\"\ntarget_feature=\"crc\"\ntarget_feature=\"dit\"\ntarget_feature=\"dotprod\"\ntarget_feature=\"dpb\"\ntarget_feature=\"dpb2\"\ntarget_feature=\"fcma\"\ntarget_feature=\"fhm\"\ntarget_feature=\"flagm\"\ntarget_feature=\"fp16\"\ntarget_feature=\"frintts\"\ntarget_feature=\"jsconv\"\ntarget_feature=\"lor\"\ntarget_feature=\"lse\"\ntarget_feature=\"neon\"\ntarget_feature=\"paca\"\ntarget_feature=\"pacg\"\ntarget_feature=\"pan\"\ntarget_feature=\"pmuv3\"\ntarget_feature=\"ras\"\ntarget_feature=\"rcpc\"\ntarget_feature=\"rcpc2\"\ntarget_feature=\"rdm\"\ntarget_feature=\"sb\"\ntarget_feature=\"sha2\"\ntarget_feature=\"sha3\"\ntarget_feature=\"ssbs\"\ntarget_feature=\"vh\"\ntarget_has_atomic=\"128\"\ntarget_has_atomic=\"16\"\ntarget_has_atomic=\"32\"\ntarget_has_atomic=\"64\"\ntarget_has_atomic=\"8\"\ntarget_has_atomic=\"ptr\"\ntarget_os=\"macos\"\ntarget_pointer_width=\"64\"\ntarget_vendor=\"apple\"\nunix\n","stderr":""}},"successes":{}}

native/target/.rustc_info.json

@@ -0,0 +1,3 @@
+Signature: 8a477f597d28d172789f06886806bc55
+# This file is a cache directory tag created by cargo.
+# For information about cache directory tags see https://bford.info/cachedir/

native/target/CACHEDIR.TAG

@@ -0,0 +1 @@
+This file has an mtime of when this was started.

native/target/release/.cargo-lock

@@ -0,0 +1 @@
+95625d7fe2b3bfb0