Function listCronJobs

electron/services/cron-api.ts:396–421

(gatewayManager: GatewayManager)

}

async function listCronJobs(gatewayManager: GatewayManager): Promise<CronJob[]> {
  let jobs: GatewayCronJob[] = [];
  let usedFallback = false;

  try {
    const result = await gatewayManager.rpc('cron.list', { includeDisabled: true }, 8000);
    const data = result as { jobs?: GatewayCronJob[] };
    jobs = data?.jobs ?? (Array.isArray(result) ? result as GatewayCronJob[] : []);
  } catch {
    try {
      const cronJsonPath = join(getOpenClawConfigDir(), 'cron', 'cron.json');
      const raw = await readFile(cronJsonPath, 'utf-8');
      const parsed = JSON.parse(raw);
      jobs = (Array.isArray(parsed) ? parsed : (parsed?.jobs ?? [])) as GatewayCronJob[];
      usedFallback = true;
    } catch {
      // No fallback data available.
    }
  }

  if (!usedFallback && jobs.length > 0) {
    repairCronJobsInBackground(gatewayManager, jobs);
  }

  return jobs.map((job) => ({ ...transformCronJob(job), ...(usedFallback ? { _fromFallback: true } : {}) }));
}

function repairCronJobsInBackground(gatewayManager: GatewayManager, jobs: GatewayCronJob[]): void {
  const jobsToRepairDelivery = jobs.filter((job) => {