Method apply

src/fork/module/Cron/SystemScheduler.ts:47–84

(job: CronJob)

  }

  async apply(job: CronJob): Promise<CronJob> {
    const scheduler = this.platformScheduler()

    if (!job.enabled) {
      await scheduler?.remove(job.id)
      return {
        ...job,
        systemRegistered: false,
        systemTaskName: undefined,
        systemError: undefined
      }
    }

    assertPortableCronExpression(job.schedule)
    if (!scheduler) {
      throw new Error('Cron system scheduler is not supported on this platform')
    }

    try {
      await mkdirp(this.cronRoot)
      await scheduler.remove(job.id)
      await scheduler.install(job)

      return {
        ...job,
        systemRegistered: true,
        systemTaskName: systemTaskName(job.id),
        systemError: undefined
      }
    } catch (e: any) {
      return {
        ...job,
        systemRegistered: false,
        systemTaskName: systemTaskName(job.id),
        systemError: e?.message || `${e}`
      }
    }
  }
}