Remove unnecessary console logs from worker and test files

Author: AbanoubGhadban

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

@@ -81,9 +81,7 @@ const setResponse = async (result: ResponseResult, res: FastifyReply) => {
   setHeaders(headers, res);
   res.status(status);
   if (stream) {
-    console.log('Sending stream');
     await res.send(stream);
-    console.log('Stream sent');
   } else {
     res.send(data);
   }
@@ -396,15 +394,13 @@ export default function run(config: Partial<Config>) {
           return undefined;
         },
       });
-      console.log('handleIncrementalRenderStream done 1');
     } catch (err) {
       // If an error occurred during stream processing, send error response
       const errorResponse = errorResponseResult(
         formatExceptionMessage('IncrementalRender', err, 'Error while processing incremental render stream'),
       );
       await setResponse(errorResponse, res);
     }
-    console.log('handleIncrementalRenderStream done 2');
   });
 
   // There can be additional files that might be required at the runtime.

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

@@ -75,7 +75,6 @@ export async function handleIncrementalRenderStream(
               const result = await onRenderRequestReceived(parsed);
               const { response, shouldContinue: continueFlag } = result;
 
-              // eslint-disable-next-line no-await-in-loop
               void onResponseStart(response);
 
               if (!continueFlag) {
@@ -90,7 +89,6 @@ export async function handleIncrementalRenderStream(
           } else {
             try {
               // eslint-disable-next-line no-await-in-loop
-              console.log('onUpdateReceived', parsed);
               await onUpdateReceived(parsed);
             } catch (err) {
               // Error in update chunk processing - log and report but continue processing
@@ -103,7 +101,6 @@ export async function handleIncrementalRenderStream(
         }
       }
     }
-    console.log('handleIncrementalRenderStream done');
   } catch (err) {
     const error = err instanceof Error ? err : new Error(String(err));
     // Update the error message in place to retain the original stack trace, rather than creating a new error object
@@ -112,7 +109,5 @@ export async function handleIncrementalRenderStream(
   }
 
   // Stream ended normally
-  console.log('onRequestEnded');
   void onRequestEnded();
-  console.log('onRequestEnded done');
 }

react_on_rails_pro/packages/node-renderer/tests/incrementalRender.test.ts

@@ -160,7 +160,6 @@ describe('incremental render NDJSON endpoint', () => {
 
     const sink: incremental.IncrementalRenderSink = {
       add: (chunk) => {
-        console.log('Sink.add called with chunk:', chunk);
         processedChunks.push(chunk);
         sinkAdd(chunk);
       },
@@ -224,11 +223,9 @@ describe('incremental render NDJSON endpoint', () => {
       req.on('response', (res) => {
         res.on('data', (chunk: Buffer) => {
           const chunkStr = chunk.toString();
-          console.log('Client received chunk:', chunkStr);
           streamedChunks.push(chunkStr);
         });
         res.on('end', () => {
-          console.log('Client response ended, total chunks received:', streamedChunks.length);
           resolve({
             statusCode: res.statusCode || 0,
             streamedData: streamedChunks,
@@ -250,13 +247,11 @@ describe('incremental render NDJSON endpoint', () => {
   });
 
   afterAll(async () => {
-    console.log('afterAll');
     await app.close();
-    console.log('afterAll done');
   });
 
   test('calls handleIncrementalRenderRequest immediately after first chunk and processes each subsequent chunk immediately', async () => {
-    const { sink, sinkAddCalls, sinkEnd, sinkAbort, handleSpy, SERVER_BUNDLE_TIMESTAMP } =
+    const { sinkAddCalls, sinkEnd, sinkAbort, handleSpy, SERVER_BUNDLE_TIMESTAMP } =
       await createBasicTestSetup();
 
     // Create the HTTP request
@@ -434,7 +429,6 @@ describe('incremental render NDJSON endpoint', () => {
       expect(sinkEnd).toHaveBeenCalledTimes(1);
       expect(sinkAbort).not.toHaveBeenCalled();
     });
-    console.log('sinkAddCalls');
   });
 
   test('handles empty lines gracefully in the stream', async () => {
@@ -559,7 +553,6 @@ describe('incremental render NDJSON endpoint', () => {
 
     // Write first object (valid JSON)
     const initialObj = createInitialObject(SERVER_BUNDLE_TIMESTAMP);
-    console.log('Sending initial chunk:', initialObj);
     req.write(`${JSON.stringify(initialObj)}\n`);
 
     // Wait for the server to process the first object and set up the response
@@ -584,13 +577,10 @@ describe('incremental render NDJSON endpoint', () => {
     });
 
     // End the request
-    console.log('Ending request');
     req.end();
 
     // Wait for the request to complete and capture the streaming response
-    console.log('Waiting for response');
     const response = await responsePromise;
-    console.log('Response:', response);
 
     // Verify the response status
     expect(response.statusCode).toBe(200);
@@ -607,10 +597,8 @@ describe('incremental render NDJSON endpoint', () => {
     // Verify that all request chunks were processed
     expect(processedChunks).toEqual(chunksToSend);
 
-    console.log('handleSpy');
     // Verify that the mock was called correctly
     expect(handleSpy).toHaveBeenCalledTimes(1);
-    console.log('handleSpy done');
 
     await waitFor(() => {
       expect(sink.end).toHaveBeenCalled();