5.0.30

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/smartdata",
-  "version": "5.0.28",
+  "version": "5.0.30",
   "private": false,
   "description": "do more with data",
   "main": "dist_ts/index.js",
@@ -30,8 +30,8 @@
     "@push.rocks/smartrx": "^3.0.6",
     "@push.rocks/smartstring": "^4.0.7",
     "@push.rocks/smarttime": "^4.0.5",
-    "@push.rocks/smartunique": "^3.0.3",
-    "@push.rocks/taskbuffer": "^3.1.3",
+    "@push.rocks/smartunique": "^3.0.6",
+    "@push.rocks/taskbuffer": "^3.1.5",
     "@tsclass/tsclass": "^4.0.42",
     "mongodb": "^5.7.0"
   },

test/test.distributedcoordinator.ts

@@ -75,6 +75,7 @@ tap.test('SmartdataDistributedCoordinator should update distributed task request
 
     const mockTaskRequest: taskbuffer.distributedCoordination.IDistributedTaskRequest = {
         submitterId: "mockSubmitter12345",    // Some unique mock submitter ID
+        requestResponseId: 'uni879873462hjhfkjhsdf', // Some unique ID for the request-response
         taskName: "SampleTask",
         taskVersion: "1.0.0",                  // Assuming it's a version string
         taskExecutionTime: Date.now(),

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartdata',
-  version: '5.0.28',
+  version: '5.0.30',
   description: 'do more with data'
 }

ts/smartdata.classes.distributedcoordinator.ts

@@ -174,7 +174,7 @@ export class SmartdataDistributedCoordinator extends plugins.taskbuffer.distribu
       });
       console.log(`bidding for leadership...`);
       await plugins.smartdelay.delayFor(
-        plugins.smarttime.getMilliSecondsFromUnits({ seconds: 20 })
+        plugins.smarttime.getMilliSecondsFromUnits({ seconds: 5 })
       );
       await this.asyncExecutionStack.getExclusiveExecutionSlot(async () => {
         let biddingInstances = await DistributedClass.getInstances({});
@@ -182,7 +182,7 @@ export class SmartdataDistributedCoordinator extends plugins.taskbuffer.distribu
           (instanceArg) =>
             instanceArg.data.status === 'bidding' &&
             instanceArg.data.lastUpdated >=
-              Date.now() - plugins.smarttime.getMilliSecondsFromUnits({ seconds: 25 })
+              Date.now() - plugins.smarttime.getMilliSecondsFromUnits({ seconds: 10 })
         );
         console.log(`found ${biddingInstances.length} bidding instances...`);
         this.ownInstance.data.elected = true;
@@ -234,9 +234,12 @@ export class SmartdataDistributedCoordinator extends plugins.taskbuffer.distribu
         console.error('instance need to be started first...');
         return;
       }
+      await this.ownInstance.updateFromDb();
       this.ownInstance.data.taskRequests.push(taskRequestArg);
       await this.ownInstance.save();
     });
+    await plugins.smartdelay.delayFor(10000);
+
     return null;
   }