Function runPlannotatorCli

apps/opencode-plugin/cli-bridge.ts:248–322

(options: RunCliOptions)

}

async function runPlannotatorCli(options: RunCliOptions): Promise<RunCliResult> {
  const readyFile = path.join(
    tmpdir(),
    `plannotator-opencode-${process.pid}-${Date.now()}-${randomUUID()}.jsonl`,
  );
  const loggedUrls = new Set<string>();
  const cwd = options.cwd || process.cwd();
  const env = {
    ...process.env,
    ...options.extraEnv,
    ...buildCliBridgeEnv(options.bridge),
    OPENCODE: "1",
    PLANNOTATOR_ORIGIN: "opencode",
    PLANNOTATOR_CWD: cwd,
    PLANNOTATOR_READY_FILE: readyFile,
  };

  const bin = getPlannotatorBin();
  const spawnConfig = buildCliSpawnConfig(bin, options.args);
  log(options.client, "info", `[Plannotator] Starting ${options.readyLabel}...`);

  return await new Promise((resolve, reject) => {
    const child = spawn(spawnConfig.command, spawnConfig.args, {
      cwd,
      env,
      shell: spawnConfig.shell,
      stdio: ["pipe", "pipe", "pipe"],
    });

    let stdout = "";
    let stderr = "";
    const stderrForwarder = createCliStderrForwarder(options.client);
    const interval = setInterval(
      () => logReadyFile(options.client, readyFile, options.readyLabel, loggedUrls),
      250,
    );

    if (!child.stdin || !child.stdout || !child.stderr) {
      clearInterval(interval);
      rmSync(readyFile, { force: true });
      reject(new Error("Failed to open pipes for the plannotator CLI process."));
      return;
    }

    child.stdout.setEncoding("utf-8");
    child.stderr.setEncoding("utf-8");
    child.stdout.on("data", (chunk) => {
      stdout += chunk;
    });
    child.stderr.on("data", (chunk) => {
      stderr += chunk;
      stderrForwarder.push(chunk);
    });
    child.on("error", (error: NodeJS.ErrnoException) => {
      clearInterval(interval);
      stderrForwarder.flush();
      logReadyFile(options.client, readyFile, options.readyLabel, loggedUrls);
      rmSync(readyFile, { force: true });