3.0.9

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/taskbuffer",
-  "version": "3.0.2",
+  "version": "3.0.9",
   "private": false,
   "description": "flexible task management. TypeScript ready!",
   "main": "dist_ts/index.js",
@@ -28,21 +28,21 @@
   },
   "homepage": "https://gitlab.com/pushrocks/taskbuffer#readme",
   "dependencies": {
+    "@pushrocks/isounique": "^1.0.5",
     "@pushrocks/lik": "^6.0.0",
     "@pushrocks/smartdelay": "^2.0.13",
     "@pushrocks/smartlog": "^3.0.1",
     "@pushrocks/smartpromise": "^3.1.7",
-    "@pushrocks/smartrx": "^2.0.25",
-    "@pushrocks/smarttime": "^3.0.45"
+    "@pushrocks/smartrx": "^3.0.0",
+    "@pushrocks/smarttime": "^4.0.1"
   },
   "devDependencies": {
     "@gitzone/tsbuild": "^2.1.63",
     "@gitzone/tsbundle": "^2.0.6",
+    "@gitzone/tsrun": "^1.2.39",
     "@gitzone/tstest": "^1.0.72",
     "@pushrocks/tapbundle": "^5.0.4",
-    "@types/node": "^18.6.3",
-    "tslint": "^6.1.3",
-    "tslint-config-prettier": "^1.18.0"
+    "@types/node": "^18.11.18"
   },
   "files": [
     "ts/**/*",

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@pushrocks/taskbuffer',
-  version: '3.0.2',
+  version: '3.0.9',
   description: 'flexible task management. TypeScript ready!'
 }

ts/index.ts

@@ -6,3 +6,7 @@ export { TaskManager } from './taskbuffer.classes.taskmanager.js';
 export { TaskOnce } from './taskbuffer.classes.taskonce.js';
 export { TaskRunner } from './taskbuffer.classes.taskrunner.js';
 export { TaskDebounced } from './taskbuffer.classes.taskdebounced.js';
+import * as distributedCoordination from './taskbuffer.classes.distributedcoordinator.js';
+export {
+  distributedCoordination
+}

ts/taskbuffer.classes.distributedcoordinator.ts

@@ -0,0 +1,34 @@
+import { Task } from './taskbuffer.classes.task.js';
+import * as plugins from './taskbuffer.plugins.js';
+
+/**
+ * constains all data for the final coordinator to actually make an informed decision
+ */
+export interface IDistributedTaskRequest {
+  /**
+   * this needs to correlate to the consultationResult
+   */
+  submitterRandomId: string;
+  taskName: string;
+  taskVersion: string;
+  taskExecutionTime: number;
+  taskExecutionTimeout: number;
+  taskExecutionParallel: number;
+  status: 'requesting' | 'gotRejected' | 'failed' | 'succeeded';
+}
+
+export interface IDsitributedTaskRequestResult {
+  /**
+   * this needs to correlate to the decisionInfoBasis
+   */
+  submitterRandomId: string;
+  considered: boolean;
+  rank: string;
+  reason: string;
+  shouldTrigger: boolean;
+}
+
+export abstract class AbstractDistributedCoordinator {
+  public abstract fireDistributedTaskRequest(infoBasisArg: IDistributedTaskRequest): Promise<IDsitributedTaskRequestResult>
+  public abstract updateDistributedTaskRequest(infoBasisArg: IDistributedTaskRequest): Promise<void>
+}

ts/taskbuffer.classes.task.ts

@@ -128,12 +128,19 @@ export class Task {
   // INSTANCE
   // mandatory properties
   public name: string;
+  /**
+   * the version of the task
+   * should follow semver
+   * might be important for DistributedCoordinator
+   */
+  public version: string;
   public taskFunction: ITaskFunction;
   public buffered: boolean;
   public cronJob: plugins.smarttime.CronJob;
 
   public bufferMax: number;
   public execDelay: number;
+  public timeout: number;
 
   // tasks to run before and after
   public preTask: Task | TPreOrAfterTaskFunction;

ts/taskbuffer.classes.taskmanager.ts

@@ -1,5 +1,6 @@
 import * as plugins from './taskbuffer.plugins.js';
 import { Task } from './taskbuffer.classes.task.js';
+import { AbstractDistributedCoordinator } from './taskbuffer.classes.distributedcoordinator.js';
 
 export interface ICronJob {
   cronString: string;
@@ -7,12 +8,21 @@ export interface ICronJob {
   job: any;
 }
 
+export interface ITaskManagerConstructorOptions {
+  distributedCoordinator?: AbstractDistributedCoordinator
+}
+
 export class TaskManager {
+  public randomId = plugins.isounique.uni();
   public taskMap = new plugins.lik.ObjectMap<Task>();
   private cronJobManager = new plugins.smarttime.CronManager();
 
-  constructor() {
-    // nothing here
+  public options: ITaskManagerConstructorOptions = {
+    distributedCoordinator: null
+  };
+
+  constructor(optionosArg: ITaskManagerConstructorOptions = {}) {
+    this.options = Object.assign(this.options, optionosArg);
   }
 
   /**
@@ -68,7 +78,7 @@ export class TaskManager {
    */
   public scheduleTaskByName(taskNameArg: string, cronStringArg: string) {
     const taskToSchedule = this.getTaskByName(taskNameArg);
-    const cronJob = this.cronJobManager.addCronjob(cronStringArg, async () => {
+    const cronJob = this.cronJobManager.addCronjob(cronStringArg, async (triggerTimeArg: number) => {
       console.log(`taskbuffer schedule triggered task >>${taskToSchedule.name}<<`);
       console.log(
         `task >>${taskToSchedule.name}<< is ${
@@ -77,6 +87,25 @@ export class TaskManager {
             : `unbuffered`
         }`
       );
+      if (this.options.distributedCoordinator) {
+        console.log(`Found a distrubuted coordinator, performing distributed consultation.`);
+        const announcementResult = await this.options.distributedCoordinator.fireDistributedTaskRequest({
+          submitterRandomId: this.randomId,
+          status: 'requesting',
+          taskExecutionParallel: 1,
+          taskExecutionTime: triggerTimeArg,
+          taskExecutionTimeout: taskToSchedule.timeout,
+          taskName: taskToSchedule.name,
+          taskVersion: taskToSchedule.version,
+        });
+
+        if (!announcementResult.shouldTrigger) {
+          console.log('distributed coordinator result: NOT EXECUTING')
+          return;
+        } else {
+          console.log('distributed coordinator result: CHOSEN AND EXECUTING')
+        }
+      }
       await taskToSchedule.trigger();
     });
     taskToSchedule.cronJob = cronJob;

ts/taskbuffer.plugins.ts

@@ -1,8 +1,9 @@
-import * as smartlog from '@pushrocks/smartlog';
+import * as isounique from '@pushrocks/isounique';
 import * as lik from '@pushrocks/lik';
+import * as smartlog from '@pushrocks/smartlog';
 import * as smartpromise from '@pushrocks/smartpromise';
 import * as smartdelay from '@pushrocks/smartdelay';
 import * as smartrx from '@pushrocks/smartrx';
 import * as smarttime from '@pushrocks/smarttime';
 
-export { smartlog, lik, smartpromise, smartdelay, smartrx, smarttime };
+export { isounique, lik, smartlog, smartpromise, smartdelay, smartrx, smarttime };