Compare commits

..

2 Commits

Author SHA1 Message Date
725102d02c 3.0.24 2020-07-12 00:25:56 +00:00
7c73579c9f fix(core): update 2020-07-12 00:25:55 +00:00
3 changed files with 29 additions and 22 deletions

2
package-lock.json generated
View File

@ -1,6 +1,6 @@
{ {
"name": "@pushrocks/smarttime", "name": "@pushrocks/smarttime",
"version": "3.0.23", "version": "3.0.24",
"lockfileVersion": 1, "lockfileVersion": 1,
"requires": true, "requires": true,
"dependencies": { "dependencies": {

View File

@ -1,7 +1,7 @@
{ {
"name": "@pushrocks/smarttime", "name": "@pushrocks/smarttime",
"private": false, "private": false,
"version": "3.0.23", "version": "3.0.24",
"description": "handle time in smart ways", "description": "handle time in smart ways",
"main": "dist_ts/index.js", "main": "dist_ts/index.js",
"typings": "dist_ts/index.d.ts", "typings": "dist_ts/index.d.ts",

View File

@ -28,29 +28,36 @@ export class CronManager {
* starts the cronjob * starts the cronjob
*/ */
public start() { public start() {
this.status = 'started'; if (this.status !== 'started') {
for (const cronJob of this.cronjobs.getArray()) { this.status = 'started';
cronJob.start(); for (const cronJob of this.cronjobs.getArray()) {
} cronJob.start();
this.executionTimeout = new plugins.smartdelay.Timeout(0); }
this.executionTimeout = new plugins.smartdelay.Timeout(0);
// recursion // recursion
const runCheckExecution = () => { const runCheckExecution = () => {
console.log(`Next CronJob scheduled in ${this.executionTimeout.getTimeLeft()} milliseconds`); console.log(
this.executionTimeout.promise.then(() => { `Next CronJob scheduled in ${this.executionTimeout.getTimeLeft()} milliseconds`
let timeToNextOverallExecution: number; );
for (const cronJob of this.cronjobs.getArray()) { this.executionTimeout.promise.then(() => {
const timeToNextJobExecution = cronJob.checkExecution(); let timeToNextOverallExecution: number;
if (timeToNextJobExecution < timeToNextOverallExecution || !timeToNextOverallExecution) { for (const cronJob of this.cronjobs.getArray()) {
timeToNextOverallExecution = timeToNextJobExecution; const timeToNextJobExecution = cronJob.checkExecution();
if (
timeToNextJobExecution < timeToNextOverallExecution ||
!timeToNextOverallExecution
) {
timeToNextOverallExecution = timeToNextJobExecution;
}
} }
} this.executionTimeout = new plugins.smartdelay.Timeout(timeToNextOverallExecution);
this.executionTimeout = new plugins.smartdelay.Timeout(timeToNextOverallExecution); runCheckExecution();
runCheckExecution(); });
}); };
};
runCheckExecution(); runCheckExecution();
}
} }
/** /**