Method registerJob

src/runtime/adapters/scheduler.ts:150–206

* Register a job: validate, create cron task (if enabled), store in map. * Does NOT persist – callers decide when to persist.

(
    jobConfig: ScheduledJobConfig,
  )

  // -------------------------------------------------------------------------

  /**
   * Register a job: validate, create cron task (if enabled), store in map.
   * Does NOT persist – callers decide when to persist.
   */
  private registerJob(
    jobConfig: ScheduledJobConfig,
  ): { registered: boolean; message: string } {
    const normalizedConfig = normalizeScheduledJobConfig(jobConfig);
    const normalizedCron = normalizeJobCron(normalizedConfig.cron);

    if (!isValidJobId(normalizedConfig.id)) {
      const msg = `[Scheduler] Invalid job id "${normalizedConfig.id}": must be non-empty, must not contain "/", "\\\\", or line breaks, and must be ≤128 chars`;
      console.error(msg);
      return { registered: false, message: msg };
    }

    if (normalizedCron) {
      // Validate cron expression
      if (!cron.validate(normalizedCron)) {
        const msg = `[Scheduler] Invalid cron expression for job "${normalizedConfig.name}": ${normalizedCron}`;
        console.error(msg);
        return { registered: false, message: msg };
      }

      // Validate timezone if provided
      if (normalizedConfig.timezone && !isValidTimezone(normalizedConfig.timezone)) {
        const msg = `[Scheduler] Invalid timezone for job "${normalizedConfig.name}": ${normalizedConfig.timezone}`;
        console.error(msg);
        return { registered: false, message: msg };
      }
    }

    // Stop/remove existing job with the same id if any
    this.removeFromMap(normalizedConfig.id);

    // Create cron task only for recurring enabled jobs
    let task: ReturnType<typeof cron.schedule> | null = null;
    if (normalizedCron && normalizedConfig.enabled !== false) {
      task = this.createCronTask(normalizedConfig);
      console.log(
        `[Scheduler] Job "${normalizedConfig.name}" scheduled: ${normalizedCron}${normalizedConfig.timezone ? ` (${normalizedConfig.timezone})` : ""}`,
      );
    } else if (normalizedCron) {
      console.log(
        `[Scheduler] Job "${normalizedConfig.name}" registered (disabled)`,
      );
    } else {
      console.log(
        `[Scheduler] Job "${normalizedConfig.name}" registered as one-time (manual trigger only)`,
      );
    }

    this.jobs.set(normalizedConfig.id, {
      config: normalizedConfig,
      task,
      running: false,
      notifyFailed: false,
    });