Function maybeRunDueJobs

src/index.js:1237–1361

(directory, client, sessionID, options = {})

function goalStatusText(job) {
  const status = job?.goalStatus || (isGoalJob(job) ? "active" : "");
  if (!status)
    return "";
  if (status === "completed")
    return "completed";
  if (status === "blocked")
    return "blocked";
  if (job?.paused)
    return "paused";
  return status;
}
function applyTestfixPreset(job, defaults = {}) {
  if (defaults.testfixPreset) {
    const defaultCommand = String(defaults.verifyCommand || "npm test");
    const parsedAction = String(job.action || "").trim();
    const usedDefaultAction = parsedAction === String(defaults.action || "").trim();
    if (!usedDefaultAction && job.verifyCommand === defaults.verifyCommand) {
      job.verifyCommand = parsedAction;
      job.action = `Run the project tests. Fix failures. Re-run the tests. Test command hint: ${parsedAction}`;
    } else if (usedDefaultAction && job.verifyCommand !== defaults.verifyCommand) {
      job.action = `Run the project tests. Fix failures. Re-run the tests. Test command hint: ${job.verifyCommand || defaultCommand}`;
    }
  }
  return job;
}

// src/source/opencode/command-router.js
var HANDLER_NAMES = [
  "addGoal",
  "statusGoal",
  "pauseGoal",
  "resumeGoal",
  "clearGoal",
  "completeGoalCommand",
  "blockGoalCommand",
  "addLoop",
  "stopLoop",
  "statusLoop",
  "logsLoop",
  "helpLoop",
  "runNow",
  "updateJobState",
  "doctorLoop",
  "initLoop",
  "exportLoop"
];
function requireFunction(value, name) {
  if (typeof value !== "function")
    throw new TypeError(`createCommandRouter requires ${name}`);
  return value;
}
function createCommandRouter(options = {}) {
  const rememberSession = requireFunction(options.rememberSession, "rememberSession");
  const captureSessionExecutionContext2 = typeof options.captureSessionExecutionContext === "function" ? options.captureSessionExecutionContext : captureSessionExecutionContext;
  const guardLoopOwnedUserMessage2 = typeof options.guardLoopOwnedUserMessage === "function" ? options.guardLoopOwnedUserMessage : guardLoopOwnedUserMessage;
  const handlers = {};
  for (const name of HANDLER_NAMES)
    handlers[name] = requireFunction(options.handlers?.[name], `handlers.${name}`);
  return async function handleCommand(directory, client, input, fallbackName, fallbackArgs, output, source = "before") {