!7

concept CronJob {
  bool enabled = true;
  long lastStart, lastEnd, nextStart;
  S name;
  S code;
  S lastError;
  bool realEval;
}

set flag DynModule.

cmodule CronCRUD > DynCRUD<CronJob> {
  start {
    doEvery(10.0, rEnter bingo);
  }
  
  void bingo {
    for (final CronJob job : list()) pcall {
      if (job.enabled && job.nextStart > 0 && job.nextStart <= now()) {
        cset(job, lastStart := now(), nextStart := 0);
        programLog(print("STARTING JOB: " + job);
        startThread(job.name, r {
          try {
            if (job.realEval)
              dm_javaEval(job.code);
            else
              dm_javaEvalOrInterpret(job.code);
            cset(job, lastError := null);
            programLog(print("JOB COMPLETE: " + job);
          } catch e {
            cset(job, lastError := getStackTrace(e));
          } finally {
            cset(job, lastEnd := now());
          }
        });
      }
    }
  }
}