fix(Viewer): crash if log too big

app/utils/local/scripts.js

@@ -30,22 +30,41 @@
   });
 }
 
+const encoder = new TextEncoder();
+
+function byteLength(str) {
+  return encoder.encode(str).byteLength;
+}
+
 function waitForReady(child, expectedResponse, signal) {
   // oxlint-disable-next-line promise/avoid-new
   return new Promise((resolve, reject) => {
     const readlineStdout = readline.createInterface({ input: child.stdout });
     const readlineStderr = readline.createInterface({ input: child.stderr });
 
     let recentOutput = "";
+
     function recordOutput(line) {
-      recentOutput = `${recentOutput} ${line} \n`.slice(-MAX_ERROR_BUFFER_BYTES);
+      const safeLine =
+        byteLength(line) > MAX_ERROR_BUFFER_BYTES / 2
+          ? line.slice(0, MAX_ERROR_BUFFER_BYTES / 2) + "…[truncated]"
+          : line;
+
+      recentOutput = `${recentOutput} ${safeLine}\n`;
+
+      while (byteLength(recentOutput) > MAX_ERROR_BUFFER_BYTES) {
+        const newline = recentOutput.indexOf("\n");
+        if (newline === -1) {
+          recentOutput = "";
+          break;
+        }
+        recentOutput = recentOutput.slice(newline + 1);
+      }
     }
 
     function cleanup() {
-      readlineStdout.removeAllListeners();
-      readlineStdout.close();
-      readlineStderr.removeAllListeners();
-      readlineStderr.close();
+      readlineStdout.removeListener("line", onLine);
+      readlineStderr.removeListener("line", onErrLine);
       child.removeListener("error", onError);
       child.removeListener("close", onClose);
       if (signal) {
@@ -58,6 +77,9 @@
       recordOutput(line);
       if (line.includes(expectedResponse)) {
         cleanup();
+        readlineStdout.on("line", (l) => console.log(`[${child.name}] ${l}`));
+        readlineStderr.on("line", (l) => console.log(`[${child.name}] ${l}`));
+        child.once("close", (code) => console.log(`[${child.name}] exited with code ${code}`));
         resolve(child);
       }
     }