fix(js): skip watcher if --watch=false for node executor (#17887)

e2e/node/src/node-esbuild.test.ts

@@ -3,8 +3,11 @@ import {
   checkFilesExist,
   cleanupProject,
   newProject,
+  promisifiedTreeKill,
+  readFile,
   runCLI,
   runCLIAsync,
+  runCommandUntil,
   tmpProjPath,
   uniq,
   updateFile,
@@ -24,12 +27,21 @@ describe('Node Applications + esbuild', () => {
     checkFilesDoNotExist(`apps/${app}/webpack.config.js`);
 
     updateFile(`apps/${app}/src/main.ts`, `console.log('Hello World!');`);
-    await runCLIAsync(`build ${app}`);
 
+    const p = await runCommandUntil(`serve ${app} --watch=false`, (output) => {
+      process.stdout.write(output);
+      return output.includes(`Hello World!`);
+    });
     checkFilesExist(`dist/apps/${app}/main.js`);
-    const result = execSync(`node dist/apps/${app}/main.js`, {
+
-      cwd: tmpProjPath(),
+    // Check that updating the file won't trigger a rebuild since --watch=false.
-    }).toString();
+    updateFile(`apps/${app}/src/main.ts`, `console.log('Bye1');`);
-    expect(result).toMatch(/Hello World!/);
+    await new Promise((res) => setTimeout(res, 2000));
+
+    expect(readFile(`dist/apps/${app}/apps/${app}/src/main.js`)).not.toContain(
+      `Bye!`
+    );
+
+    await promisifiedTreeKill(p.pid, 'SIGKILL');
   }, 300_000);
 });

packages/js/src/executors/node/node.impl.ts

@@ -213,46 +213,48 @@ export async function* nodeExecutor(
       tasks.push(task);
     };
 
-    const stopWatch = await daemonClient.registerFileWatcher(
+    if (options.watch) {
-      {
+      const stopWatch = await daemonClient.registerFileWatcher(
-        watchProjects: [context.projectName],
+        {
-        includeDependentProjects: true,
+          watchProjects: [context.projectName],
-      },
+          includeDependentProjects: true,
-      async (err, data) => {
+        },
-        if (err === 'closed') {
+        async (err, data) => {
-          logger.error(`Watch error: Daemon closed the connection`);
+          if (err === 'closed') {
-          process.exit(1);
+            logger.error(`Watch error: Daemon closed the connection`);
-        } else if (err) {
+            process.exit(1);
-          logger.error(`Watch error: ${err?.message ?? 'Unknown'}`);
+          } else if (err) {
-        } else {
+            logger.error(`Watch error: ${err?.message ?? 'Unknown'}`);
-          logger.info(`NX File change detected. Restarting...`);
+          } else {
-          await addToQueue();
+            logger.info(`NX File change detected. Restarting...`);
-          await debouncedProcessQueue();
+            await addToQueue();
+            await debouncedProcessQueue();
+          }
         }
-      }
+      );
-    );
 
-    const stopAllTasks = (signal: NodeJS.Signals = 'SIGTERM') => {
+      const stopAllTasks = (signal: NodeJS.Signals = 'SIGTERM') => {
-      for (const task of tasks) {
+        for (const task of tasks) {
-        task.stop(signal);
+          task.stop(signal);
-      }
+        }
-    };
+      };
 
-    process.on('SIGTERM', async () => {
+      process.on('SIGTERM', async () => {
-      stopWatch();
+        stopWatch();
-      stopAllTasks('SIGTERM');
+        stopAllTasks('SIGTERM');
-      process.exit(128 + 15);
+        process.exit(128 + 15);
-    });
+      });
-    process.on('SIGINT', async () => {
+      process.on('SIGINT', async () => {
-      stopWatch();
+        stopWatch();
-      stopAllTasks('SIGINT');
+        stopAllTasks('SIGINT');
-      process.exit(128 + 2);
+        process.exit(128 + 2);
-    });
+      });
-    process.on('SIGHUP', async () => {
+      process.on('SIGHUP', async () => {
-      stopWatch();
+        stopWatch();
-      stopAllTasks('SIGHUP');
+        stopAllTasks('SIGHUP');
-      process.exit(128 + 1);
+        process.exit(128 + 1);
-    });
+      });
+    }
 
     await addToQueue();
     await processQueue();