Function buildGoalPrompt

src/index.js:629–669

(directory, job)

    child.stdout?.on("data", (data) => stdout.push(Buffer.from(data)));
    child.stderr?.on("data", (data) => stderr.push(Buffer.from(data)));
    child.on("error", (error) => {
      clearTimeout(timer);
      resolve({ code: -1, stdout: "", stderr: String(error) });
    });
    child.on("close", (code) => {
      clearTimeout(timer);
      resolve({ code: code ?? 0, stdout: Buffer.concat(stdout).toString("utf8"), stderr: Buffer.concat(stderr).toString("utf8") });
    });
  });
}
async function runShellCommand(command, cwd, timeoutMs = 120000) {
  return await new Promise((resolve) => {
    const child = spawn(command, [], { cwd, shell: true, windowsHide: true });
    const stdout = [];
    const stderr = [];
    const timer = setTimeout(() => {
      try {
        child.kill("SIGTERM");
      } catch {}
    }, timeoutMs);
    child.stdout?.on("data", (data) => stdout.push(Buffer.from(data)));
    child.stderr?.on("data", (data) => stderr.push(Buffer.from(data)));
    child.on("error", (error) => {
      clearTimeout(timer);
      resolve({ code: -1, stdout: "", stderr: String(error) });
    });
    child.on("close", (code) => {
      clearTimeout(timer);
      resolve({ code: code ?? 0, stdout: Buffer.concat(stdout).toString("utf8"), stderr: Buffer.concat(stderr).toString("utf8") });
    });
  });
}
async function notifyJob(directory, job, reason) {
  if (!job.notifyCommand)
    return;
  const command = String(job.notifyCommand).replace(/\{reason\}/g, String(reason || "")).replace(/\{job\}/g, String(job.name || job.id || ""));
  await runShellCommand(command, directory, 60000);
}

// src/source/opencode/sdk.js
function sdkError(result) {
  if (!result || typeof result !== "object")
    return;
  return result.error || result.error === null ? result.error : undefined;