Class AgentManager

orchestrate/skills/orchestrate/scripts/core/agent-manager.ts:170–1534

} from "./prompts.ts";

export class AgentManager {
  readonly workspace: string;
  readonly planPath: string;
  readonly statePath: string;
  readonly handoffsDir: string;
  readonly attentionLog: string;
  readonly plan: Plan;
  state: State;
  private readonly apiKey: string;
  readonly slackAdapter?: SlackAdapter;
  readonly andon: AndonPoller;
  private readonly slackMirrorQueue = new Map<string, Promise<void>>();

  private constructor(args: {
    workspace: string;
    plan: Plan;
    state: State;
    apiKey: string;
    slackAdapter?: SlackAdapter;
  }) {
    this.workspace = args.workspace;
    this.plan = args.plan;
    this.state = args.state;
    this.apiKey = args.apiKey;
    this.slackAdapter = args.slackAdapter;
    this.planPath = join(args.workspace, "plan.json");
    this.statePath = join(args.workspace, "state.json");
    this.handoffsDir = join(args.workspace, "handoffs");
    this.attentionLog = join(args.workspace, "attention.log");
    this.andon = new AndonPoller({
      source:
        this.isRootPlanner() && this.slackAdapter && this.plan.slackKickoffRef
          ? new SlackReactionAndonSource(
              this.slackAdapter,
              this.plan.slackKickoffRef
            )
          : undefined,
      getState: () => this.state,
      saveState: reason => this.saveAndonState(reason),
      logAttention: line => this.logAttention(line),
      pollSource: this.isRootPlanner(),
      cachedState: this.andonCachedState(),
    });
  }

  static async load(
    workspacePath: string,
    opts: { slackChannel?: string } = {}
  ): Promise<AgentManager> {
    const workspace = resolve(workspacePath);
    mkdirSync(workspace, { recursive: true });
    const planPath = join(workspace, "plan.json");
    if (!existsSync(planPath)) {
      throw new PlanValidationError(
        `missing ${planPath} — the planner writes plan.json first; see SKILL.md → Phase 1`
      );
    }
    const parsedPlan = parsePlanJson(readFileSync(planPath, "utf8"), planPath);