feat: node updates

Signed-off-by: Janos Sarusi-Kis <janossk@cisco.com>

Author: janosSarusiKis

data-plane/bindings/node/README.md

@@ -1,6 +1,7 @@
 # SLIM Node.js Bindings
 
 Node.js bindings for SLIM using UniFFI.
+Bindings generated with [uniffi-bindgen-node](https://github.com/livekit/uniffi-bindgen-node).
 
 ## Prerequisites
 
@@ -39,6 +40,36 @@ task example:alice    # Run Alice receiver
 task example:bob      # Run Bob sender
 ```
 
+## Build Process
+
+The bindings generation includes patching to fix compatibility issues between `uniffi-bindgen-node` (code generator) and `uniffi-bindgen-react-native` (runtime library):
+
+- **Naming fixes**: `FfiConverterBytes` → `FfiConverterArrayBuffer`
+- **Buffer wrapping**: Proper RustBuffer allocation for byte arrays
+- **Pointer conversions**: BigInt → Number for FFI calls
+- **Error handling**: Enhanced error extraction from Rust
+
+## FFI Type Conversions
+
+The generated bindings use `bigint` in TypeScript signatures for u64 types, but the underlying FFI layer returns JavaScript `number` types at runtime. Application code handles conversions at API boundaries:
+
+```typescript
+// connectAsync returns a number at runtime, despite bigint type signature
+const connId = await service.connectAsync(config);
+
+// Convert to BigInt when passing to methods expecting bigint
+await app.subscribeAsync(name, BigInt(connId));
+
+// When using with methods that need number (for direct FFI calls)
+app.setRoute(name, Number(connId));
+```
+
+**Key conversions:**
+- `connectAsync` returns `number` → convert to `BigInt()` for TypeScript bigint parameters
+- When calling FFI methods with u64 params → convert to `Number()` if passing bigint
+
+This explicit conversion at API boundaries ensures type safety and makes FFI requirements visible.
+
 
 ## Resources
 

data-plane/bindings/node/examples/README.md

@@ -69,10 +69,12 @@ export async function createAndConnectApp(
     console.log(`[${app.id()}] 🔌 Connected to ${serverAddr} (conn ID: ${connId})`);
 
     // Forward subscription to next node
-    // Note: connId must be converted to BigInt for subscribeAsync
+    // Note: Generated bindings expect bigint, but connectAsync returns number
+    // Convert number -> bigint for the subscription call
     await app.subscribeAsync(appName, BigInt(connId));
     console.log(`[${app.id()}] ✅ Subscribed to sessions`);
 
+    // Return connId as bigint for consistency with TypeScript signatures
     return { app, connId: BigInt(connId), service };
   } catch (error: any) {
     let errorMsg = 'Unknown error';

data-plane/bindings/node/examples/common.ts

@@ -7,7 +7,6 @@
  * This example demonstrates the receiver side of a point-to-point messaging scenario.
  * Alice listens for incoming sessions and receives messages from Bob.
  * 
- * Note: Sending replies is currently blocked by uniffi-bindgen-node limitations.
  */
 
 import { createAndConnectApp, logMessage, sleep, DEFAULT_SERVER_ENDPOINT, DEFAULT_SHARED_SECRET } from './common.js';
@@ -61,8 +60,7 @@ function parseArgs(): CliArgs {
 /**
  * Handle an incoming session
  * Receives messages until the session closes
- * 
- * Note: Sending replies is blocked by uniffi-bindgen-node limitations
+
  */
 async function handleSession(app: any, session: any, instance: bigint): Promise<void> {
   const sessionId = session.sessionId();
@@ -79,29 +77,17 @@ async function handleSession(app: any, session: any, instance: bigint): Promise<
         const text = Buffer.from(payload).toString('utf-8');
         logMessage(instance, `📨 Received: ${text}`);
 
-        // try to send a reply using synchronous call
+        // Send a reply
         try {
           session.publishToAndWait(receivedMsg.context, Buffer.from('Hello from Alice'), undefined, undefined);
           logMessage(instance, '📤 Sent reply: Hello from Alice');
         } catch (error: any) {
-          // Debug: log the raw error structure to understand what we're getting
-          console.log('[DEBUG] Raw error:', error);
-          console.log('[DEBUG] Error type:', typeof error);
-          console.log('[DEBUG] Error constructor:', error?.constructor?.name);
-          console.log('[DEBUG] Is array:', Array.isArray(error));
-          if (Array.isArray(error)) {
-            console.log('[DEBUG] Array length:', error.length);
-            console.log('[DEBUG] Array[0]:', error[0]);
-            console.log('[DEBUG] Array[1]:', error[1]);
-          }
-          
           // Error is returned as a tuple: ["SlimError", SlimError]
           // SlimError is a tagged union with different error types
           let errorMessage = 'Unknown error';
 
           if (Array.isArray(error) && error.length === 2 && error[0] === 'SlimError' && error[1]) {
             const slimError = error[1];
-            console.log('[DEBUG] SlimError object:', JSON.stringify(slimError, null, 2));
 
             // Extract message based on error tag
             switch (slimError.tag) {
@@ -136,12 +122,9 @@ async function handleSession(app: any, session: any, instance: bigint): Promise<
                 errorMessage = `${slimError.tag}: ${JSON.stringify(slimError)}`;
             }
           } else if (error?.message) {
-            errorMessage = error.message;
+            errorMessage = error.message || '(empty error message)';
           } else if (error instanceof Error) {
             errorMessage = `${error.name}: ${error.message}`;
-            if (error.stack) {
-              console.log('[DEBUG] Error stack:', error.stack);
-            }
           } else {
             errorMessage = String(error);
           }

data-plane/bindings/node/examples/point-to-point-alice.ts

@@ -104,14 +104,8 @@ async function runSender(args: CliArgs): Promise<void> {
     // Parse remote name
     const remoteName = splitId(args.remote);
 
-    // Debug connId type
-    console.log('[DEBUG] connId value:', connId);
-    console.log('[DEBUG] connId type:', typeof connId);
-    
-    // Convert connId to number for FFI (ffi-rs expects number, not bigint)
+    // Convert bigint -> number for FFI compatibility (ffi-rs requires number type)
     const connIdNum = Number(connId);
-    console.log('[DEBUG] connIdNum value:', connIdNum);
-    console.log('[DEBUG] connIdNum type:', typeof connIdNum);
 
     logMessage(instance, '📍 Setting route to remote peer...');
 
@@ -120,25 +114,10 @@ async function runSender(args: CliArgs): Promise<void> {
       app.setRoute(remoteName, connIdNum);
       logMessage(instance, '✅ Route established');
     } catch (error: any) {
-      // Debug: log the raw error structure
-      console.log('[DEBUG] setRoute error - raw:', error);
-      console.log('[DEBUG] setRoute error - type:', typeof error);
-      console.log('[DEBUG] setRoute error - constructor:', error?.constructor?.name);
-      console.log('[DEBUG] setRoute error - is array:', Array.isArray(error));
-      if (Array.isArray(error)) {
-        console.log('[DEBUG] setRoute error - array length:', error.length);
-        console.log('[DEBUG] setRoute error - array[0]:', error[0]);
-        console.log('[DEBUG] setRoute error - array[1]:', error[1]);
-        if (error[1]) {
-          console.log('[DEBUG] setRoute error - SlimError object:', JSON.stringify(error[1], null, 2));
-        }
-      }
-      
       // Parse error properly
       let errorMsg = 'Unknown error';
       if (Array.isArray(error) && error.length === 2 && error[0] === 'SlimError' && error[1]) {
         const slimError = error[1];
-        console.log('[DEBUG] SlimError tag:', slimError.tag);
         switch (slimError.tag) {
           case 'sendError':
           case 'sessionError':