Enhance incremental render functionality and improve test coverage

- Updated the `setResponse` call in the `run` function to correctly use `result.response`.
- Expanded the incremental render tests to cover new scenarios, including basic updates, multi-bundle interactions, and error handling for malformed update chunks.
- Introduced new helper functions in test fixtures to streamline the creation of async values and streams, enhancing the robustness of the tests.
- Improved the secondary bundle's functionality to support async value resolution and streaming, ensuring consistent behavior across bundles.

Author: AbanoubGhadban

react_on_rails_pro/packages/node-renderer/src/worker.ts

@@ -236,7 +236,7 @@ export default function run(config: Partial<Config>) {
             providedNewBundles,
             assetsToCopy,
           });
-          await setResponse(result, res);
+          await setResponse(result.response, res);
         } catch (err) {
           const exceptionMessage = formatExceptionMessage(
             renderingRequest,

react_on_rails_pro/packages/node-renderer/tests/fixtures/bundle.js

@@ -1,3 +1,57 @@
+const { PassThrough } = require('stream');
+
 global.ReactOnRails = {
   dummy: { html: 'Dummy Object' },
+  
+  // Get or create async value promise
+  getAsyncValue: function() {
+    debugger;
+    if (!sharedExecutionContext.has('asyncPromise')) {
+      const promiseData = {};
+      const promise = new Promise((resolve, reject) => {
+        promiseData.resolve = resolve;
+        promiseData.reject = reject;
+      });
+      promiseData.promise = promise;
+      sharedExecutionContext.set('asyncPromise', promiseData);
+    }
+    return sharedExecutionContext.get('asyncPromise').promise;
+  },
+  
+  // Resolve the async value promise
+  setAsyncValue: function(value) {
+    debugger;
+    if (!sharedExecutionContext.has('asyncPromise')) {
+      ReactOnRails.getAsyncValue();
+    }
+    const promiseData = sharedExecutionContext.get('asyncPromise');
+    promiseData.resolve(value);
+  },
+  
+  // Get or create stream
+  getStreamValues: function() {
+    if (!sharedExecutionContext.has('stream')) {
+      const stream = new PassThrough();
+      sharedExecutionContext.set('stream', { stream });
+    }
+    return sharedExecutionContext.get('stream').stream;
+  },
+  
+  // Add value to stream
+  addStreamValue: function(value) {
+    if (!sharedExecutionContext.has('stream')) {
+      // Create the stream first if it doesn't exist
+      ReactOnRails.getStreamValues();
+    }
+    const { stream } = sharedExecutionContext.get('stream');
+    stream.write(value);
+    return value;
+  },
+
+  endStream: function() {
+    if (sharedExecutionContext.has('stream')) {
+      const { stream } = sharedExecutionContext.get('stream');
+      stream.end();
+    }
+  },
 };

react_on_rails_pro/packages/node-renderer/tests/fixtures/secondary-bundle.js

@@ -1,3 +1,53 @@
 global.ReactOnRails = {
   dummy: { html: 'Dummy Object from secondary bundle' },
+  
+  
+  // Get or create async value promise
+  getAsyncValue: function() {
+    if (!sharedExecutionContext.has('secondaryAsyncPromise')) {
+      const promiseData = {};
+      const promise = new Promise((resolve, reject) => {
+        promiseData.resolve = resolve;
+        promiseData.reject = reject;
+      });
+      promiseData.promise = promise;
+      sharedExecutionContext.set('secondaryAsyncPromise', promiseData);
+    }
+    return sharedExecutionContext.get('secondaryAsyncPromise').promise;
+  },
+  
+  // Resolve the async value promise
+  setAsyncValue: function(value) {
+    if (!sharedExecutionContext.has('secondaryAsyncPromise')) {
+      ReactOnRails.getAsyncValue();
+    }
+    const promiseData = sharedExecutionContext.get('secondaryAsyncPromise');
+    promiseData.resolve(value);
+  },
+  
+  // Get or create stream
+  getStreamValues: function() {
+    if (!sharedExecutionContext.has('secondaryStream')) {
+      const stream = new PassThrough();
+      sharedExecutionContext.set('secondaryStream', { stream });
+    }
+    return sharedExecutionContext.get('secondaryStream').stream;
+  },
+  
+  // Add value to stream
+  addStreamValue: function(value) {
+    if (!sharedExecutionContext.has('secondaryStream')) {
+      // Create the stream first if it doesn't exist
+      ReactOnRails.getStreamValues();
+    }
+    const { stream } = sharedExecutionContext.get('secondaryStream');
+    stream.write(value);
+  },
+
+  endStream: function() {
+    if (sharedExecutionContext.has('secondaryStream')) {
+      const { stream } = sharedExecutionContext.get('secondaryStream');
+      stream.end();
+    }
+  },
 };