3.0.10

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/taskbuffer",
-  "version": "3.0.4",
+  "version": "3.0.10",
   "private": false,
   "description": "flexible task management. TypeScript ready!",
   "main": "dist_ts/index.js",
@@ -28,12 +28,13 @@
   },
   "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": "^3.0.0",
-    "@pushrocks/smarttime": "^3.0.45"
+    "@pushrocks/smarttime": "^4.0.1"
   },
   "devDependencies": {
     "@gitzone/tsbuild": "^2.1.63",
@@ -41,7 +42,7 @@
     "@gitzone/tsrun": "^1.2.39",
     "@gitzone/tstest": "^1.0.72",
     "@pushrocks/tapbundle": "^5.0.4",
-    "@types/node": "^18.6.3"
+    "@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.4',
+  version: '3.0.10',
   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

@@ -4,7 +4,11 @@ import * as plugins from './taskbuffer.plugins.js';
 /**
  * constains all data for the final coordinator to actually make an informed decision
  */
-export interface IDistributedDecisionInfoBasis {
+export interface IDistributedTaskRequest {
+  /**
+   * this needs to correlate to the consultationResult
+   */
+  submitterRandomId: string;
   taskName: string;
   taskVersion: string;
   taskExecutionTime: number;
@@ -13,30 +17,18 @@ export interface IDistributedDecisionInfoBasis {
   status: 'requesting' | 'gotRejected' | 'failed' | 'succeeded';
 }
 
-export interface ITaskConsultationResult {
+export interface IDistributedTaskRequestResult {
+  /**
+   * this needs to correlate to the decisionInfoBasis
+   */
+  submitterRandomId: string;
   considered: boolean;
   rank: string;
   reason: string;
   shouldTrigger: boolean;
 }
 
-export interface IDistributedCoordinatorConstructorOptions {
+export abstract class AbstractDistributedCoordinator {
-  announceDistributedDecisionInfoBasis: (infoBasisArg: IDistributedDecisionInfoBasis) => Promise<ITaskConsultationResult>
+  public abstract fireDistributedTaskRequest(infoBasisArg: IDistributedTaskRequest): Promise<IDistributedTaskRequestResult>
-  updateDistributedDecisionInfoBasis: (infoBasisArg: IDistributedDecisionInfoBasis) => Promise<void>
+  public abstract updateDistributedTaskRequest(infoBasisArg: IDistributedTaskRequest): Promise<void>
-}
-
-export class DistributedCoordinator {
-  public options: IDistributedCoordinatorConstructorOptions;
-
-  constructor(optionsArg: IDistributedCoordinatorConstructorOptions) {
-    this.options = optionsArg;
-  }
-
-  public async announceDistributedDecisionInfoBasis(infoBasisArg: IDistributedDecisionInfoBasis): Promise<ITaskConsultationResult> {
-    return this.options.announceDistributedDecisionInfoBasis(infoBasisArg);
-  }
-  public async updateDistributedDevisionInfoBasis(infoBasisArg: IDistributedDecisionInfoBasis): Promise<void> {
-    return this.options.updateDistributedDecisionInfoBasis(infoBasisArg)
-  }
-
 }

ts/taskbuffer.classes.taskmanager.ts

@@ -1,6 +1,6 @@
 import * as plugins from './taskbuffer.plugins.js';
 import { Task } from './taskbuffer.classes.task.js';
-import { DistributedCoordinator } from './taskbuffer.classes.distributedcoordinator.js';
+import { AbstractDistributedCoordinator } from './taskbuffer.classes.distributedcoordinator.js';
 
 export interface ICronJob {
   cronString: string;
@@ -9,10 +9,11 @@ export interface ICronJob {
 }
 
 export interface ITaskManagerConstructorOptions {
-  distributedCoordinator?: DistributedCoordinator
+  distributedCoordinator?: AbstractDistributedCoordinator
 }
 
 export class TaskManager {
+  public randomId = plugins.isounique.uni();
   public taskMap = new plugins.lik.ObjectMap<Task>();
   private cronJobManager = new plugins.smarttime.CronManager();
 
@@ -20,7 +21,7 @@ export class TaskManager {
     distributedCoordinator: null
   };
 
-  constructor(optionosArg: ITaskManagerConstructorOptions) {
+  constructor(optionosArg: ITaskManagerConstructorOptions = {}) {
     this.options = Object.assign(this.options, optionosArg);
   }
 
@@ -88,14 +89,22 @@ export class TaskManager {
       );
       if (this.options.distributedCoordinator) {
         console.log(`Found a distrubuted coordinator, performing distributed consultation.`);
-        const announcementResult = this.options.distributedCoordinator.announceDistributedDecisionInfoBasis({
+        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();
     });

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 };