Minor improvements:

1. Added exit codes to existing commands
2. Added FORCE_COLOR flag to make the output show up with color
3. Added short circuit to terminal applies if every change is NOOP

Author: kevinwang5658

src/commands/apply/index.ts

@@ -37,5 +37,7 @@ export default class Apply extends Command {
 
     const resolvedPath = path.resolve(flags.path ?? '.');
     await ApplyOrchestrator.run(resolvedPath);
+
+    this.exit(0);
   }
 }

src/commands/plan/index.ts

@@ -38,5 +38,7 @@ export default class Plan extends Command {
     const resolvedPath = path.resolve(flags.path ?? '.');
 
     await PlanOrchestrator.run(resolvedPath);
+
+    this.exit(0);
   }
 }

src/orchestrators/apply.ts

@@ -1,3 +1,4 @@
+import { ResourceOperation } from 'codify-schemas';
 import readline from 'node:readline';
 
 import { PlanOrchestrator } from './plan.js';
@@ -8,6 +9,13 @@ export const ApplyOrchestrator = {
   async run(rootDirectory: string): Promise<void> {
     const { plan, pluginCollection } = await PlanOrchestrator.run(rootDirectory, false);
 
+    // Short circuit and exit if every change is NOOP
+    if (plan.every((p) => p.operation === ResourceOperation.NOOP)) {
+      console.log('No changes necessary. Exiting');
+      await pluginCollection.destroy();
+      return;
+    }
+
     const response = await new Promise((resolve) => {
       rl.question('Is this okay?\n', (answer) => resolve(answer));
     });

src/plugins/plugin-process.ts

@@ -19,17 +19,21 @@ export class PluginProcess {
   }
 
   static async start(jsFileDir: string): Promise<PluginProcess> {
-    const process = fork(
+    const _process = fork(
       jsFileDir,
       [],
-      { execArgv: ['--import', 'tsx'], silent: true },
+      {
+        execArgv: ['--import', 'tsx'],
+        env: { ...process.env, FORCE_COLOR: '1' },
+        silent: true
+      },
     );
 
-    process.stdout!.on('data', (message) => console.log(message.toString()));
-    process.stderr!.on('data', (message) => console.log(message.toString()));
+    _process.stdout!.on('data', (message) => console.log(message.toString()));
+    _process.stderr!.on('data', (message) => console.log(message.toString()));
 
 
-    return new PluginProcess(process);
+    return new PluginProcess(_process);
   }
 
   killPlugin(): void {
@@ -58,12 +62,18 @@ class SendMessageForResultHandler {
   promiseReject: Reject;
   timer: NodeJS.Timeout;
 
-  constructor(messageToSend: PluginMessage, process: ChildProcess, resolve: Resolve, reject: Reject) {
+  constructor(
+    messageToSend: PluginMessage,
+    process: ChildProcess,
+    resolve: Resolve,
+    reject: Reject,
+    timeout = 600_000, // Default time is 10 minutes for a command
+  ) {
     this.messageToSend = messageToSend;
     this.process = process;
     this.promiseResolve = resolve;
     this.promiseReject = reject;
-    this.timer = this.setResultTimeout();
+    this.timer = this.setResultTimeout(timeout);
   }
 
   messageListener = (incomingMessage: unknown) => {
@@ -98,9 +108,9 @@ class SendMessageForResultHandler {
     this.promiseResolve(value);
   }
 
-  private setResultTimeout = () => setTimeout(() => {
+  private setResultTimeout = (timeout: number) => setTimeout(() => {
     this.reject(new Error(`Plugin did not respond in 10s to call: ${this.messageToSend.cmd}`))
-  }, 10_000);
+  }, timeout);
 
   private validateIpcMessage(response: unknown): response is IpcMessage {
     return ipcMessageValidator(response);