push.rocks/taskbuffer
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2020-09-02 13:04:12 +00:00
parent eee146ae8b
commit 575912eab7
5 changed files with 2576 additions and 1499 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4036
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

14
package.json
View File

@ -27,21 +27,21 @@
}, },
"homepage": "https://gitlab.com/pushrocks/taskbuffer#readme", "homepage": "https://gitlab.com/pushrocks/taskbuffer#readme",
"dependencies": { "dependencies": {
"@pushrocks/lik": "^4.0.14", "@pushrocks/lik": "^4.0.17",
"@pushrocks/smartdelay": "^2.0.10", "@pushrocks/smartdelay": "^2.0.10",
"@pushrocks/smartlog": "^2.0.35", "@pushrocks/smartlog": "^2.0.36",
"@pushrocks/smartpromise": "^3.0.6", "@pushrocks/smartpromise": "^3.0.6",
"@pushrocks/smartrx": "^2.0.18", "@pushrocks/smartrx": "^2.0.18",
"@pushrocks/smarttime": "^3.0.24", "@pushrocks/smarttime": "^3.0.24",
"@types/cron": "^1.7.2" "@types/cron": "^1.7.2"
}, },
"devDependencies": { "devDependencies": {
"@gitzone/tsbuild": "^2.1.24", "@gitzone/tsbuild": "^2.1.25",
"@gitzone/tsbundle": "^1.0.72", "@gitzone/tsbundle": "^1.0.78",
"@gitzone/tstest": "^1.0.43", "@gitzone/tstest": "^1.0.44",
"@pushrocks/tapbundle": "^3.2.9", "@pushrocks/tapbundle": "^3.2.9",
"@types/node": "^14.0.22", "@types/node": "^14.6.2",
"tslint": "^6.1.2", "tslint": "^6.1.3",
"tslint-config-prettier": "^1.18.0" "tslint-config-prettier": "^1.18.0"
}, },
"files": [ "files": [

5
test/test.4.taskmanager.browser.ts
View File

@ -28,6 +28,7 @@ tap.test('should run the task as expected', async () => {
}, },
}) })
); );
myTaskManager.start();
await myTaskManager.triggerTaskByName('myTask'); await myTaskManager.triggerTaskByName('myTask');
// tslint:disable-next-line:no-unused-expression // tslint:disable-next-line:no-unused-expression
expect(referenceBoolean).to.be.true; expect(referenceBoolean).to.be.true;
@ -39,4 +40,8 @@ tap.test('should schedule task', async () => {
myTaskManager.descheduleTaskByName('myTask'); myTaskManager.descheduleTaskByName('myTask');
}); });
tap.test('should stop the taskmanager', async () => {
myTaskManager.stop();
});
tap.start(); tap.start();

5
test/test.4.taskmanager.ts
View File

@ -28,6 +28,7 @@ tap.test('should run the task as expected', async () => {
}, },
}) })
); );
myTaskManager.start();
await myTaskManager.triggerTaskByName('myTask'); await myTaskManager.triggerTaskByName('myTask');
// tslint:disable-next-line:no-unused-expression // tslint:disable-next-line:no-unused-expression
expect(referenceBoolean).to.be.true; expect(referenceBoolean).to.be.true;
@ -39,4 +40,8 @@ tap.test('should schedule task', async () => {
myTaskManager.descheduleTaskByName('myTask'); myTaskManager.descheduleTaskByName('myTask');
}); });
tap.test('should stop the taskmanager', async () => {
myTaskManager.stop();
});
tap.start(); tap.start();

15
ts/taskbuffer.classes.taskmanager.ts
View File

@ -74,7 +74,6 @@ export class TaskManager {
await taskToSchedule.triggerBuffered(); await taskToSchedule.triggerBuffered();
}); });
taskToSchedule.cronJob = cronJob; taskToSchedule.cronJob = cronJob;
this.cronJobManager.start();
} }
/** /**
@ -104,4 +103,18 @@ export class TaskManager {
* @param taskNameArg * @param taskNameArg
*/ */
public getSchedulesForTaskName(taskNameArg: string) {} public getSchedulesForTaskName(taskNameArg: string) {}
/**
* starts the taskmanager
*/
public start() {
this.cronJobManager.start();
}
/**
* stops the taskmanager
*/
public stop() {
this.cronJobManager.stop();
}
} }