chore: fix unparsable lines in monitor command

journey/pepr-deploy.ts

@@ -60,14 +60,15 @@ export function peprDeploy() {
         const stdout: String = data.toString()
         state.accept = stdout.includes("✅") ? true : state.accept
         state.reject = stdout.includes("❌") ? true : state.reject
-
+        expect(stdout.includes("IGNORED")).toBe(false)
         if (state.accept && state.reject) {
           proc.kill()
           proc.stdin.destroy()
           proc.stdout.destroy()
           proc.stderr.destroy()
         }
       })
+
       proc.on('exit', () => state.done = true);
 
       await until(() => state.done)

src/cli/monitor.ts

@@ -42,28 +42,29 @@ export default function (program: RootCmd) {
       const log = new K8sLog(kc);
 
       const logStream = new stream.PassThrough();
-
-      logStream.on("data", chunk => {
+      logStream.on("data", async chunk => {
         const respMsg = `"msg":"Check response"`;
         // Split the chunk into lines
-        const lines = chunk.toString().split("\n");
+        const lines = await 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 payload = JSON.parse(line.trim());
               const isMutate = payload.res.patchType || payload.res.warnings;
 
               const name = `${payload.namespace}${payload.name}`;
-              const uid = payload.uid;
+              const uid = payload.res.uid;
 
               if (isMutate) {
-                const plainPatch = atob(payload.res.patch) || "";
-                const patch = JSON.stringify(JSON.parse(plainPatch), null, 2);
+                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) {

src/lib/helpers.test.ts

@@ -319,6 +319,7 @@ describe("validateCapabilityNames Property-Based Tests", () => {
     );
   });
 });
+
 describe("validateCapabilityNames", () => {
   test("should return true if all capability names are valid", () => {
     const capabilities = mockCapabilities;