src/runner/proxy.ts (1)

109-115: pipe() won't propagate source-stream errors — consider pipeline(); also, req.end(body) only accepts string | Buffer | Uint8Array.

Two edge-case concerns with the body handling:

1. If the ReadableStream emits an error, pipe() won't forward it to req, so the wrapping Promise may hang (no resolve or reject). Using pipeline() from node:stream/promises or manually wiring .on("error") on the readable side would make this more resilient.

2. req.end(body) on line 112 only accepts string | Buffer | Uint8Array, but BodyInit also includes Blob, ArrayBuffer, FormData, and URLSearchParams. If any of these are ever passed, it would silently produce incorrect output or throw.

Both are unlikely in the current dev-proxy context, so just flagging for awareness.

🔧 Optional: safer streaming with pipeline()

-import { Readable } from "node:stream";
+import { Readable, pipeline } from "node:stream";

     if (init!.body instanceof ReadableStream) {
-      Readable.fromWeb(init!.body as import("node:stream/web").ReadableStream).pipe(req);
+      const nodeBody = Readable.fromWeb(init!.body as import("node:stream/web").ReadableStream);
+      pipeline(nodeBody, req, (err) => {
+        if (err) reject(err);
+      });
     } else if (init!.body) {

test/unit/proxy.test.ts (2)

1-7: Use pathe instead of node:path per project coding guidelines.

Line 3 imports join from node:path. The usage is for a Unix socket path, which is platform-specific anyway, but the guideline applies to all *.ts files.

♻️ Suggested fix

-import { join } from "node:path";
+import { join } from "pathe";

As per coding guidelines: **/*.{js,ts}: Use pathe for cross-platform path operations instead of node:path.

---

84-86: Socket file not cleaned up after tests.

socketServer.close() stops listening but the .sock file may remain on disk in tmpdir(). Consider unlinking it in afterAll for clean test runs.

♻️ Optional cleanup

+import { unlinkSync } from "node:fs";

 afterAll(() => {
   socketServer?.close();
+  try { unlinkSync(socketPath); } catch {}
 });