3.0.15

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/taskbuffer",
-  "version": "3.0.13",
+  "version": "3.0.15",
   "private": false,
   "description": "flexible task management. TypeScript ready!",
   "main": "dist_ts/index.js",

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/taskbuffer',
-  version: '3.0.13',
+  version: '3.0.15',
   description: 'flexible task management. TypeScript ready!'
 }

ts/taskbuffer.classes.bufferrunner.ts

@@ -5,7 +5,7 @@ export class BufferRunner {
   // initialize by default
   public bufferCounter: number = 0;
 
-  constructor(taskArg: Task) {
+  constructor(taskArg: Task<any>) {
     this.task = taskArg;
   }
 

ts/taskbuffer.classes.cyclecounter.ts

@@ -9,7 +9,7 @@ export interface ICycleObject {
 export class CycleCounter {
   public task: Task;
   public cycleObjectArray: ICycleObject[] = [];
-  constructor(taskArg: Task) {
+  constructor(taskArg: Task<any>) {
     this.task = taskArg;
   }
   public getPromiseForCycle(cycleCountArg: number) {

ts/taskbuffer.classes.taskmanager.ts

@@ -21,8 +21,8 @@ export class TaskManager {
     distributedCoordinator: null,
   };
 
-  constructor(optionosArg: ITaskManagerConstructorOptions = {}) {
+  constructor(optionsArg: ITaskManagerConstructorOptions = {}) {
-    this.options = Object.assign(this.options, optionosArg);
+    this.options = Object.assign(this.options, optionsArg);
   }
 
   /**
@@ -137,11 +137,19 @@ export class TaskManager {
   public async descheduleTask(task: Task) {
     await this.descheduleTaskByName(task.name);
   }
+
   /**
-   * returns all schedules of a specific task
+ * returns the schedule of a specific task
  * @param taskNameArg
  */
-  public getSchedulesForTaskName(taskNameArg: string) {}
+public getScheduleForTaskName(taskNameArg: string): string | null {
+  const task = this.getTaskByName(taskNameArg);
+  if (!task || !task.cronJob) {
+    return null;
+  }
+  return task.cronJob.cronExpression;
+}
+
 
   /**
    * starts the taskmanager