Method crontabScript

src/app/service/sandbox/runtime.ts:240–291

(script: ScriptLoadInfo)

  private crontabSripts: ScriptRunResource[] = [];

  crontabScript(script: ScriptLoadInfo) {
    // 执行定时脚本 运行表达式
    if (!script.metadata.crontab) {
      throw new Error(script.name + " - " + t("cron_invalid_expr"));
    }
    // 如果有nextruntime,则加入重试队列
    this.joinRetryList(script);
    this.crontabSripts.push(script);

    const ERROR_MESSAGES: Record<number, string> = {
      0: "crontabScript: cron expression failed",
      2: "crontabScript: onTick creation failed",
      4: "crontabScript: create cronjob failed",
      6: "crontabScript: cronjob start failed",
    };

    const logError = (ok: number, val: string, e: unknown) =>
      this.logger.error(
        ERROR_MESSAGES[ok] ?? "crontabScript: execution failed",
        { uuid: script.uuid, crontab: val },
        Logger.E(e)
      );

    const cronJobList: Array<CronJob> = [];
    script.metadata.crontab.forEach((val) => {
      let ok = 0;
      try {
        const { cronExpr, oncePos } = extractCronExpr(val);
        ok = 2;
        const onTick = this.crontabExec(script, oncePos);
        ok = 4;
        const cron = new CronJob(cronExpr, onTick);
        ok = 6;
        cron.start();
        ok = 8;
        cronJobList.push(cron);
      } catch (e) {
        logError(ok, val, e);
      }
    });

    const allSucceeded = cronJobList.length === script.metadata.crontab.length;
    if (allSucceeded) {
      this.cronJob.set(script.uuid, cronJobList);
    } else {
      // 有表达式失败了
      for (const crontab of cronJobList) {
        crontab.stop();
      }
    }
    return allSucceeded;
  }

  crontabExec(script: ScriptLoadInfo, oncePos: number) {
    return this.execScript.bind(this, script, { cronJobOncePos: oncePos });