3.1.7

.gitea/workflows/default_tags.yaml

@@ -119,6 +119,6 @@ jobs:
         run: |
           npmci node install stable
           npmci npm install
-          pnpm install -g @gitzone/tsdoc
+          pnpm install -g @git.zone/tsdoc
           npmci command tsdoc
         continue-on-error: true

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/taskbuffer",
-  "version": "3.1.2",
+  "version": "3.1.7",
   "private": false,
   "description": "flexible task management. TypeScript ready!",
   "main": "dist_ts/index.js",
@@ -29,21 +29,21 @@
   },
   "homepage": "https://gitlab.com/pushrocks/taskbuffer#readme",
   "dependencies": {
-    "@push.rocks/isounique": "^1.0.5",
+    "@push.rocks/lik": "^6.0.5",
-    "@push.rocks/lik": "^6.0.3",
     "@push.rocks/smartdelay": "^3.0.5",
     "@push.rocks/smartlog": "^3.0.3",
     "@push.rocks/smartpromise": "^4.0.3",
     "@push.rocks/smartrx": "^3.0.6",
-    "@push.rocks/smarttime": "^4.0.4"
+    "@push.rocks/smarttime": "^4.0.6",
+    "@push.rocks/smartunique": "^3.0.6"
   },
   "devDependencies": {
-    "@gitzone/tsbuild": "^2.1.66",
+    "@git.zone/tsbuild": "^2.1.66",
-    "@gitzone/tsbundle": "^2.0.8",
+    "@git.zone/tsbundle": "^2.0.8",
-    "@gitzone/tsrun": "^1.2.44",
+    "@git.zone/tsrun": "^1.2.44",
-    "@gitzone/tstest": "^1.0.77",
+    "@git.zone/tstest": "^1.0.77",
     "@push.rocks/tapbundle": "^5.0.15",
-    "@types/node": "^20.4.10"
+    "@types/node": "^20.8.7"
   },
   "files": [
     "ts/**/*",

ts/00_commitinfo_data.ts

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

ts/taskbuffer.classes.distributedcoordinator.ts

@@ -6,6 +6,7 @@ import * as plugins from './taskbuffer.plugins.js';
  */
 export interface IDistributedTaskRequest {
   submitterId: string;
+  requestResponseId: string;
   taskName: string;
   taskVersion: string;
   taskExecutionTime: number;
@@ -16,6 +17,7 @@ export interface IDistributedTaskRequest {
 
 export interface IDistributedTaskRequestResult {
   submitterId: string;
+  requestResponseId: string;
   considered: boolean;
   rank: number;
   reason: string;
@@ -30,4 +32,7 @@ export abstract class AbstractDistributedCoordinator {
   public abstract updateDistributedTaskRequest(
     infoBasis: IDistributedTaskRequest
   ): Promise<void>;
+
+  public abstract start(): Promise<void>;
+  public abstract stop(): Promise<void>;
 }

ts/taskbuffer.classes.taskmanager.ts

@@ -13,7 +13,7 @@ export interface ITaskManagerConstructorOptions {
 }
 
 export class TaskManager {
-  public randomId = plugins.isounique.uni();
+  public randomId = plugins.smartunique.shortId();
   public taskMap = new plugins.lik.ObjectMap<Task>();
   private cronJobManager = new plugins.smarttime.CronManager();
   public options: ITaskManagerConstructorOptions = {
@@ -90,8 +90,10 @@ export class TaskManager {
 
   private async performDistributedConsultation(task: Task, triggerTime: number): Promise<IDistributedTaskRequestResult> {
     console.log('Found a distributed coordinator, performing consultation.');
+
     return this.options.distributedCoordinator.fireDistributedTaskRequest({
       submitterId: this.randomId,
+      requestResponseId: plugins.smartunique.shortId(),
       status: 'requesting',
       taskExecutionParallel: 1,
       taskExecutionTime: triggerTime,
@@ -121,11 +123,17 @@ export class TaskManager {
     return task && task.cronJob ? task.cronJob.cronExpression : null;
   }
 
-  public start() {
+  public async start() {
+    if (this.options.distributedCoordinator) {
+      await this.options.distributedCoordinator.start();
+    }
     this.cronJobManager.start();
   }
 
-  public stop() {
+  public async stop() {
     this.cronJobManager.stop();
+    if (this.options.distributedCoordinator) {
+      await this.options.distributedCoordinator.stop();
+    }
   }
 }

ts/taskbuffer.plugins.ts

@@ -1,9 +1,9 @@
-import * as isounique from '@push.rocks/isounique';
 import * as lik from '@push.rocks/lik';
 import * as smartlog from '@push.rocks/smartlog';
 import * as smartpromise from '@push.rocks/smartpromise';
 import * as smartdelay from '@push.rocks/smartdelay';
 import * as smartrx from '@push.rocks/smartrx';
 import * as smarttime from '@push.rocks/smarttime';
+import * as smartunique from '@push.rocks/smartunique';
 
-export { isounique, lik, smartlog, smartpromise, smartdelay, smartrx, smarttime };
+export { lik, smartlog, smartpromise, smartdelay, smartrx, smarttime, smartunique };

tsconfig.json

@@ -3,9 +3,12 @@
     "experimentalDecorators": true,
     "useDefineForClassFields": false,
     "target": "ES2022",
-    "module": "ES2022",
+    "module": "NodeNext",
-    "moduleResolution": "nodenext",
+    "moduleResolution": "NodeNext",
     "esModuleInterop": true,
-    "verbatimModuleSyntax": true,
+    "verbatimModuleSyntax": true
-  }
+  },
+  "exclude": [
+    "dist_*/**/*.d.ts"
+  ]
 }