Method start

src/runtime/adapters/scheduler.ts:104–140

(ctx: AdapterContext)

    adapter: string,
    channelId: string,
    text: string,
  ) => Promise<void> = async () => {};
  private jobs = new Map<string, ManagedJob>();

  async start(ctx: AdapterContext): Promise<void> {
    this.agent = ctx.agent;
    this.rootDir = ctx.rootDir;
    this.ipcBroadcaster = ctx.ipcBroadcaster ?? null;
    this.notifyFn = ctx.notify || (async () => {});
    console.log(
      `[Scheduler] IPC broadcaster ${this.ipcBroadcaster ? "attached" : "not available"} for agent events`,
    );

    const jobConfigs = loadJobFile(this.rootDir).jobs;

    let scheduledCount = 0;
    let disabledCount = 0;
    let oneTimeCount = 0;
    for (const jc of jobConfigs) {
      const result = this.registerJob(jc);
      if (result.registered) {
        if (!isRecurringJob(jc)) {
          oneTimeCount++;
        } else if (jc.enabled === false) {
          disabledCount++;
        } else {
          scheduledCount++;
        }
      }
    }

    const parts: string[] = [];
    if (scheduledCount > 0) parts.push(`${scheduledCount} active`);
    if (disabledCount > 0) parts.push(`${disabledCount} disabled`);
    if (oneTimeCount > 0) parts.push(`${oneTimeCount} one-time`);
    if (parts.length > 0) {
      console.log(`[SchedulerAdapter] Started with ${parts.join(", ")} job(s)`);
    } else {
      console.log("[SchedulerAdapter] Started (no jobs configured)");
    }