test(codex): align app-server CI fixtures

sunlit-deng · sunlit-deng · commit ff3d36df77de · 2026-07-26T16:45:58.000+08:00
diff --git a/extensions/codex/src/app-server/sandbox-exec-server.pipe-survival.test.ts b/extensions/codex/src/app-server/sandbox-exec-server.pipe-survival.test.ts
@@ -11,6 +11,7 @@
  * (no `error` listener on the stream) and the test fails.
  */
 import type { ChildProcessWithoutNullStreams } from "node:child_process";
+import { pathToFileURL } from "node:url";
 import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
 
 // Capture every child the exec-server spawns so tests can drive real stream
@@ -45,6 +46,7 @@ import {
 } from "./sandbox-exec-server.test-helpers.js";
 
 const TMPDIR = process.env.TMPDIR ?? "/tmp";
+const TMPDIR_URL = pathToFileURL(TMPDIR).href;
 const WS_OPEN = 1;
 
 function delay(ms: number): Promise<void> {
@@ -98,7 +100,7 @@ describe("sandbox exec-server pipe survival", () => {
     const start = (await rpc(socket, "process/start", {
       processId,
       argv: [process.execPath, "-e", SCRIPT],
-      cwd: TMPDIR,
+      cwd: TMPDIR_URL,
       tty: false,
       pipeStdin: false,
     })) as { processId: string };
@@ -122,7 +124,7 @@ describe("sandbox exec-server pipe survival", () => {
     await rpc(socket, "process/start", {
       processId: followId,
       argv: [process.execPath, "-e", "process.stdout.write('bridge-survived')"],
-      cwd: TMPDIR,
+      cwd: TMPDIR_URL,
       tty: false,
       pipeStdin: false,
     });
diff --git a/extensions/codex/src/app-server/sandbox-exec-server/streaming-response.ts b/extensions/codex/src/app-server/sandbox-exec-server/streaming-response.ts
@@ -23,7 +23,9 @@ export function readStreamingSandboxHttpResponse(params: {
     let streamFailure: string | null = null;
     let lastBodySeq = 0;
     let stdoutBuffer = "";
+    const stdoutDecoder = new TextDecoder();
     let stderr = "";
+    const stderrDecoder = new TextDecoder();
     const finalizeOnClose = async (status: "completed" | "failed", exitCode: number | null) => {
       await params.finalizeExec?.({
         status,
@@ -58,7 +60,7 @@ export function readStreamingSandboxHttpResponse(params: {
       }
     };
     params.child.stdout.on("data", (chunk: Buffer) => {
-      stdoutBuffer += chunk.toString("utf8");
+      stdoutBuffer += stdoutDecoder.decode(chunk, { stream: true });
       let newline = stdoutBuffer.indexOf("\n");
       while (newline >= 0) {
         const line = stdoutBuffer.slice(0, newline).trim();
@@ -101,7 +103,7 @@ export function readStreamingSandboxHttpResponse(params: {
       }
     });
     params.child.stderr.on("data", (chunk: Buffer) => {
-      stderr = sliceUtf16Safe(`${stderr}${chunk.toString("utf8")}`, -4096);
+      stderr = sliceUtf16Safe(`${stderr}${stderrDecoder.decode(chunk, { stream: true })}`, -4096);
     });
     onChildOutputStreamError(params.child, (message) => {
       if (failed) {
@@ -126,6 +128,8 @@ export function readStreamingSandboxHttpResponse(params: {
       childFailure ??= error.message;
     });
     params.child.once("close", (code) => {
+      stdoutBuffer += stdoutDecoder.decode();
+      stderr = sliceUtf16Safe(`${stderr}${stderrDecoder.decode()}`, -4096);
       const exitCode = code ?? 1;
       if (streamFailure) {
         finalizeAfterClose("failed", exitCode);
