chore: fix unparsable lines in monitor command

src/cli/monitor.ts

@@ -6,7 +6,7 @@
 import stream from "stream";
 import { ResponseItem } from "../lib/types";
 import { RootCmd } from "./root";
-
+import { sleep } from "../lib/helpers";
 export default function (program: RootCmd) {
   program
     .command("monitor [module-uuid]")
@@ -42,51 +42,54 @@
       const log = new K8sLog(kc);
 
       const logStream = new stream.PassThrough();
-
       logStream.on("data", chunk => {
         const respMsg = `"msg":"Check response"`;
         // Split the chunk into lines
         const lines = chunk.toString().split("\n");
-
-        for (const line of lines) {
-          // Check for `"msg":"Hello Pepr"`
-          if (line.includes(respMsg)) {
-            try {
-              const payload = JSON.parse(line);
-              const isMutate = payload.res.patchType || payload.res.warnings;
-
-              const name = `${payload.namespace}${payload.name}`;
-              const uid = payload.uid;
-
-              if (isMutate) {
-                const plainPatch = atob(payload.res.patch) || "";
-                const patch = JSON.stringify(JSON.parse(plainPatch), null, 2);
-
-                const patchType = payload.res.patchType || payload.res.warnings || "";
-
-                const allowOrDeny = payload.res.allowed ? "🔀" : "🚫";
-                console.log(`\n${allowOrDeny}  MUTATE     ${name} (${uid})`);
-                if (patchType.length > 0) {
-                  console.log(`\n\u001b[1;34m${patch}\u001b[0m`);
-                }
-              } else {
-                const failures = Array.isArray(payload.res) ? payload.res : [payload.res];
-
-                const filteredFailures = failures
-                  .filter((r: ResponseItem) => !r.allowed)
-                  .map((r: ResponseItem) => r.status.message);
-                if (filteredFailures.length > 0) {
-                  console.log(`\n❌  VALIDATE   ${name} (${uid})`);
-                  console.log(`\u001b[1;31m${filteredFailures}\u001b[0m`);
+        sleep(2, () => {
+          for (const line of lines) {
+            // Check for `"msg":"Hello Pepr"`
+            if (line.includes(respMsg)) {
+              try {
+                const payload = JSON.parse(line.trim());
+                const isMutate = payload.res.patchType || payload.res.warnings;
+
+                const name = `${payload.namespace}${payload.name}`;
+                const uid = payload.res.uid;
+
+                if (isMutate) {
+                  const plainPatch =
+                    payload.res?.patch !== undefined && payload.res?.patch !== null
+                      ? atob(payload.res.patch)
+                      : "";
+
+                  const patch =
+                    plainPatch !== "" && JSON.stringify(JSON.parse(plainPatch), null, 2);
+                  const patchType = payload.res.patchType || payload.res.warnings || "";
+                  const allowOrDeny = payload.res.allowed ? "🔀" : "🚫";
+                  console.log(`\n${allowOrDeny}  MUTATE     ${name} (${uid})`);
+                  if (patchType.length > 0) {
+                    console.log(`\n\u001b[1;34m${patch}\u001b[0m`);
+                  }
                 } else {
-                  console.log(`\n✅  VALIDATE   ${name} (${uid})`);
+                  const failures = Array.isArray(payload.res) ? payload.res : [payload.res];
+
+                  const filteredFailures = failures
+                    .filter((r: ResponseItem) => !r.allowed)
+                    .map((r: ResponseItem) => r.status.message);
+                  if (filteredFailures.length > 0) {
+                    console.log(`\n❌  VALIDATE   ${name} (${uid})`);
+                    console.log(`\u001b[1;31m${filteredFailures}\u001b[0m`);
+                  } else {
+                    console.log(`\n✅  VALIDATE   ${name} (${uid})`);
+                  }
                 }
+              } catch {
+                console.warn(`\nIGNORED - Unable to parse line: ${line}.`);
               }
-            } catch {
-              console.warn(`\nIGNORED - Unable to parse line: ${line}.`);
             }
           }
-        }
+        });
       });
 
       for (const podName of podNames) {

src/lib/helpers.test.ts

@@ -10,6 +10,7 @@ import {
   validateHash,
   ValidationError,
   validateCapabilityNames,
+  sleep,
 } from "./helpers";
 import { expect, describe, test, jest, beforeEach, afterEach } from "@jest/globals";
 import { parseTimeout, secretOverLimit, replaceString } from "./helpers";
@@ -292,6 +293,22 @@ const mockCapabilities: CapabilityExport[] = JSON.parse(`[
         ]
     }
 ]`);
+
+describe("sleep function tests", () => {
+  jest.useFakeTimers();
+
+  test("sleep function delays for the specified time and executes callback before resolving", () => {
+    const callback = jest.fn();
+    const sleepPromise = sleep(1, callback);
+    jest.advanceTimersByTime(1000);
+
+    return sleepPromise.then(() => {
+      expect(callback).toHaveBeenCalled();
+      expect(callback).toHaveBeenCalledTimes(1);
+    });
+  });
+});
+
 describe("validateCapabilityNames", () => {
   test("should return true if all capability names are valid", () => {
     const capabilities = mockCapabilities;

src/lib/helpers.ts

@@ -9,6 +9,15 @@ import { sanitizeResourceName } from "../sdk/sdk";
 
 export class ValidationError extends Error {}
 
+export function sleep(seconds: number, callback: () => void) {
+  return new Promise<void>(resolve => {
+    setTimeout(() => {
+      callback();
+      resolve();
+    }, seconds * 1000);
+  });
+}
+
 export function validateCapabilityNames(capabilities: CapabilityExport[] | undefined): void {
   if (capabilities && capabilities.length > 0) {
     for (let i = 0; i < capabilities.length; i++) {