Function goalTools

src/index.js:1629–1665

(defaultDirectory)

    const state = await readState2(directory, sessionID);
    const goals = (state.jobs || []).filter(isGoalJob);
    const lines = goals.length ? goals.map((job, index) => {
      const status = goalStatusText(job);
      const checks = job.goalChecks?.length ? ` | checks=${job.goalChecks.length}` : "";
      const acceptance = job.goalAcceptance?.length ? ` | acceptance=${job.goalAcceptance.length}` : "";
      const progress = job.goalProgress?.length ? ` | progress=${job.goalProgress.length}` : "";
      const noProgress = (job.maxNoProgress ?? DEFAULT_GOAL_MAX_NO_PROGRESS) > 0 ? ` | no-progress=${job.noProgressCount || 0}/${job.maxNoProgress ?? DEFAULT_GOAL_MAX_NO_PROGRESS}` : "";
      const rejected = job.goalCompletionRejectedReason ? " | completion-rejected" : "";
      return `${index + 1}. ${job.id}${job.name ? ` (${job.name})` : ""}: ${status} | turns=${job.runCount || 0} | objective=${String(job.action || job.goalFile || "").slice(0, 220)}${checks}${acceptance}${progress}${noProgress}${rejected}`;
    }) : ["No experimental goal jobs."];
    await toast2(client, goals.length ? `${goals.length} experimental goal(s).` : "No experimental goal jobs.", goals.length ? "info" : "warning");
    await say2(client, sessionID, `OpenCode Loop experimental goal status:
` + lines.join(`
`));
  }
  async function pauseGoal(directory, client, sessionID, args) {
    const target = String(args || "").trim() || "goal";
    const state = await readState2(directory, sessionID);
    let count = 0;
    state.jobs = (state.jobs || []).map((job, index) => isGoalJob(job) && matchJob(job, target, index) ? (count++, { ...job, paused: true }) : job);
    await writeState2(directory, sessionID, state);
    await scheduleDueWork(directory, client, sessionID);
    await toast2(client, `Paused ${count} experimental goal(s).`, count ? "success" : "warning");
  }
  async function resumeGoal(directory, client, sessionID, args) {
    const target = String(args || "").trim() || "goal";
    const state = await readState2(directory, sessionID);
    let count = 0;
    state.jobs = (state.jobs || []).map((job, index) => {
      if (!isGoalJob(job) || !matchJob(job, target, index))
        return job;
      count++;
      return { ...job, paused: false, enabled: true, goalStatus: job.goalStatus === "blocked" ? "active" : job.goalStatus || "active", lastRunAt: 0, noProgressCount: 0, goalNoProgressReason: "", goalInterruptedReason: "" };
    });
    await writeState2(directory, sessionID, state);
    await toast2(client, `Resumed ${count} experimental goal(s).`, count ? "success" : "warning");
    if (count) {
      await scheduleDueWork(directory, client, sessionID);
      scheduleIdleWork(directory, client, sessionID);
    }
  }