1import { spawn } from "node:child_process";
2import { writeFile, mkdtemp } from "node:fs/promises";
3import { tmpdir } from "node:os";
4import path from "node:path";
5import { GenError, type CodexRunResult } from "./types.ts";
6import { parseEventStream } from "./parser.ts";
7 
8export interface SpawnInput {
9  instruction: string;
10  timeoutMs: number;
11  refImages?: string[];
12}
13 
14export async function runCodexExec(input: SpawnInput): Promise<CodexRunResult> {
15  const start = Date.now();
16  const logDir = await mkdtemp(path.join(tmpdir(), "codex-imggen-"));
17  const rawLogPath = path.join(logDir, "stream.jsonl");
18 
19  // --skip-git-repo-check: lets the wrapper run from non-git cwds
20  //   (e.g. /tmp, or a skill installed under ~/.claude/plugins/...).
21  //   Without it, codex refuses with "Not inside a trusted directory".
22  const args = [
23    "exec",
24    "--json",
25    "--sandbox",
26    "danger-full-access",
27    "--skip-git-repo-check",
28  ];
29  for (const img of input.refImages ?? []) {
30    args.push("--image", img);
31  }
32  args.push("-");
33 
34  let timedOut = false;
35  const child = spawn("codex", args, { stdio: ["pipe", "pipe", "pipe"] });
36 
37  let stdout = "";
38  let stderr = "";
39  child.stdout.on("data", (chunk) => {
40    stdout += chunk.toString();
41  });
42  child.stderr.on("data", (chunk) => {
43    stderr += chunk.toString();
44  });
45 
46  child.stdin.write(input.instruction);
47  child.stdin.end();
48 
49  const timer = setTimeout(() => {
50    timedOut = true;
51    child.kill("SIGTERM");
52    setTimeout(() => child.kill("SIGKILL"), 2000);
53  }, input.timeoutMs);
54 
55  const exit = await new Promise<{ code: number | null; signal: NodeJS.Signals | null }>((resolve) => {
56    child.on("close", (code, signal) => resolve({ code, signal }));
57  });
58  clearTimeout(timer);
59 
60  await writeFile(rawLogPath, stdout + (stderr ? `\n--- stderr ---\n${stderr}` : ""));
61 
62  if (timedOut) {
63    throw new GenError("timeout", `codex exec exceeded ${input.timeoutMs}ms (log: ${rawLogPath})`);
64  }
65  if (exit.code !== 0) {
66    if (stderr.includes("command not found") || stderr.includes("not found: codex")) {
67      throw new GenError("codex_not_installed", "codex CLI not installed", false);
68    }
69    throw new GenError(
70      "spawn_failed",
71      `codex exec exited ${exit.code} signal=${exit.signal} (log: ${rawLogPath})`,
72    );
73  }
74 
75  const parsed = parseEventStream(stdout);
76  return {
77    ...parsed,
78    rawLogPath,
79    durationMs: Date.now() - start,
80  };
81}
82