smarttime/ts/smarttime.classes.cronmanager.ts

import * as plugins from './smarttime.plugins.js';
import { CronJob, type TJobFunction } from './smarttime.classes.cronjob.js';
import { getMilliSecondsAsHumanReadableString } from './smarttime.units.js';

export class CronManager {
  public executionTimeout: plugins.smartdelay.Timeout<void>;

  public status: 'started' | 'stopped' = 'stopped';
  public cronjobs = new plugins.lik.ObjectMap<CronJob>();

  constructor() {}

  public addCronjob(cronIdentifierArg: string, cronFunctionArg: TJobFunction) {
    const newCronJob = new CronJob(this, cronIdentifierArg, cronFunctionArg);
    this.cronjobs.add(newCronJob);
    if (this.status === 'started') {
      newCronJob.start();
    }

    return newCronJob;
  }

  public removeCronjob(cronjobArg: CronJob) {
    cronjobArg.stop();
    this.cronjobs.remove(cronjobArg);
  }

  /**
   * starts the cronjob
   */
  public start() {
    if (this.status !== 'started') {
      this.status = 'started';
      for (const cronJob of this.cronjobs.getArray()) {
        cronJob.start();
      }
      this.runCronCycle();
    }
  }

  private async runCronCycle() {
    this.executionTimeout = new plugins.smartdelay.Timeout(0);
    do {
      let nextRunningCronjob: CronJob;
      for (const cronJob of this.cronjobs.getArray()) {
        cronJob.checkExecution();
        if (
          !nextRunningCronjob ||
          cronJob.getTimeToNextExecution() < nextRunningCronjob.getTimeToNextExecution()
        ) {
          nextRunningCronjob = cronJob;
        }
      }
      if (nextRunningCronjob) {
        this.executionTimeout = new plugins.smartdelay.Timeout(
          nextRunningCronjob.getTimeToNextExecution()
        );
        console.log(
          `Next CronJob scheduled in ${getMilliSecondsAsHumanReadableString(
            this.executionTimeout.getTimeLeft()
          )}`
        );
      } else {
        this.executionTimeout = new plugins.smartdelay.Timeout(1000);
        console.log('no cronjobs specified! Checking again in 1 second');
      }

      await this.executionTimeout.promise;
    } while (this.status === 'started');
  };

  /**
   * stops all cronjobs
   */
  public stop() {
    if (this.status === 'started') {
      this.status = 'stopped';
      this.executionTimeout.cancel();
    } else {
      console.log(`You tried to stop a CronManager that was not actually started.`);
    }
    for (const cron of this.cronjobs.getArray()) {
      cron.stop();
    }
  }
}