tmp

Author: AbanoubGhadban

packages/react-on-rails-pro/package.json

@@ -75,5 +75,9 @@
   "bugs": {
     "url": "https://github.com/shakacode/react_on_rails/issues"
   },
-  "homepage": "https://github.com/shakacode/react_on_rails#readme"
+  "homepage": "https://github.com/shakacode/react_on_rails#readme",
+  "devDependencies": {
+    "@types/mock-fs": "^4.13.4",
+    "mock-fs": "^5.5.0"
+  }
 }

packages/react-on-rails-pro/src/streamingUtils.ts

@@ -111,6 +111,7 @@ export const transformRenderStreamChunksToResultObject = (renderState: StreamRen
 
   const transformStream = new PassThrough({
     transform(chunk: Buffer, _, callback) {
+      console.log("Stream working");
       const htmlChunk = chunk.toString();
       const consoleReplayScript = buildConsoleReplay(consoleHistory, previouslyReplayedConsoleMessages);
       previouslyReplayedConsoleMessages = consoleHistory?.length || 0;
@@ -125,6 +126,9 @@ export const transformRenderStreamChunksToResultObject = (renderState: StreamRen
 
       callback();
     },
+    flush() {
+      console.log("Stream flushed");
+    },
   });
 
   let pipedStream: PipeableOrReadableStream | null = null;
@@ -141,6 +145,7 @@ export const transformRenderStreamChunksToResultObject = (renderState: StreamRen
 
   const writeChunk = (chunk: string) => transformStream.write(chunk);
   const endStream = () => {
+    console.log("Stream ended");
     transformStream.end();
     if (pipedStream && 'abort' in pipedStream) {
       pipedStream.abort();

packages/react-on-rails-pro/tests/serverRenderRSCReactComponent.rsc.test.tsx

@@ -0,0 +1,45 @@
+/**
+ * @jest-environment node
+ */
+
+import * as mock from 'mock-fs';
+import * as fs from 'fs';
+import * as path from 'path';
+import { pipeline, finished } from 'stream';
+import ReactOnRails, { RailsContextWithServerStreamingCapabilities } from '../src/ReactOnRailsRSC.ts';
+
+const Component1 = () => <div>HelloWorld</div>;
+
+ReactOnRails.register({ Component1 });
+
+mock({
+  './src/react-client-manifest.json': '{}'
+});
+
+afterAll(() => {
+  mock.restore();
+})
+
+test('eeee', async () => {
+  console.log(path.resolve('./src/react-client-manifest.json'));
+  expect(fs.readFileSync('./src/react-client-manifest.json').toString()).toEqual('{}');
+  const readable = ReactOnRails.serverRenderRSCReactComponent({
+    railsContext: {
+      reactClientManifestFileName: 'react-client-manifest.json',
+      reactServerClientManifestFileName: 'react-server-client-manifest.json',
+    } as unknown as RailsContextWithServerStreamingCapabilities,
+    name: 'Component1',
+    renderingReturnsPromises: true,
+    throwJsErrors: true,
+    domNodeId: 'dom-id',
+  });
+
+  const decoder = new TextDecoder();
+  readable.on('data', chunk => {
+    console.log(decoder.decode(chunk));
+  })
+  await new Promise((resolve, reject) => {
+    readable.on('end', resolve);
+    readable.on('error', reject);
+  })
+}, 100000)

packages/react-on-rails/src/types/index.ts

@@ -225,7 +225,6 @@ export interface RenderParams extends Params {
 
 export interface RSCRenderParams extends Omit<RenderParams, 'railsContext'> {
   railsContext: RailsContextWithServerStreamingCapabilities;
-  reactClientManifestFileName: string;
 }
 
 export interface CreateParams extends Params {

yarn.lock

@@ -1654,6 +1654,13 @@
   resolved "https://registry.npmjs.org/@types/json5/-/json5-0.0.29.tgz"
   integrity sha1-7ihweulOEdK4J7y+UnC86n8+ce4=
 
+"@types/mock-fs@^4.13.4":
+  version "4.13.4"
+  resolved "https://registry.yarnpkg.com/@types/mock-fs/-/mock-fs-4.13.4.tgz#e73edb4b4889d44d23f1ea02d6eebe50aa30b09a"
+  integrity sha512-mXmM0o6lULPI8z3XNnQCpL0BGxPwx1Ul1wXYEPBGl4efShyxW2Rln0JOPEWGyZaYZMM6OVXM/15zUuFMY52ljg==
+  dependencies:
+    "@types/node" "*"
+
 "@types/node@*", "@types/node@^20.17.16":
   version "20.17.16"
   resolved "https://registry.npmjs.org/@types/node/-/node-20.17.16.tgz"
@@ -4729,6 +4736,11 @@ minimist@^1.2.0, minimist@^1.2.6, minimist@^1.2.8:
   resolved "https://registry.npmjs.org/minimist/-/minimist-1.2.8.tgz"
   integrity sha512-2yyAR8qBkN3YuheJanUpWC5U3bb5osDywNB8RzDVlDwDHbocAJveqqj1u8+SVD7jkWT4yvsHCpWqqWqAxb0zCA==
 
+mock-fs@^5.5.0:
+  version "5.5.0"
+  resolved "https://registry.yarnpkg.com/mock-fs/-/mock-fs-5.5.0.tgz#94a46d299aaa588e735a201cbe823c876e91f385"
+  integrity sha512-d/P1M/RacgM3dB0sJ8rjeRNXxtapkPCUnMGmIN0ixJ16F/E4GUZCvWcSGfWGz8eaXYvn1s9baUwNjI4LOPEjiA==
+
 mri@^1.1.0:
   version "1.2.0"
   resolved "https://registry.npmjs.org/mri/-/mri-1.2.0.tgz"