feat: add minmimum request for new work to master , all requests should be later in time from that

this applied only  to auto request for works. on every job share we ask for new work .

Author: Kos-M

README.md

@@ -32,7 +32,7 @@ const work1 = new Worker({
     name = 'worker_1',
     loglevel, // off -> info -> warn -> error -> debug
     transferEncryptToken = null, // token generated from Master
-    ); // work1 instance is ready for incoming new tasks
+    }); // work1 instance is ready for incoming new tasks
 ```
 
 \*\* file an issue if you think Worker should expose any other functionalities (for example, to have more control) .

index.js

@@ -0,0 +1,3 @@
+const Worker = require('./src');
+
+module.exports = Worker;

src/index.js

@@ -1,5 +1,4 @@
 /* eslint-disable no-restricted-syntax */
-// const { Pull, Push } = require('zeromq');
 const fs = require('fs');
 const Bugout = require('bugout');
 const events = require('events');
@@ -10,7 +9,7 @@ const Crypt = require('./Crypt');
 const { Helper } = require('./Helper');
 require('dotenv').config();
 
-const minRequestWorkWindow = 60;
+const minRequestWorkWindow = 15; // seconds
 
 class Worker {
   constructor({ token, name = 'no_name', loglevel, transferEncryptToken = null } = {}) {
@@ -61,7 +60,12 @@ class Worker {
     this.log.info('Announcing to trackers...');
     this.event.addListener('requestWork', this.requestWork);
     this.event.addListener('shareResults', this.shareResults);
-    setInterval(this.requestWork, 10000);
+    setInterval(() => {
+      // prevent unnecessary requests , flooding Master
+      if (Helper.getTimestamp() - this.lastRequestWork > minRequestWorkWindow * 1000) {
+        this.event.emit('requestWork');
+      }
+    }, 30000);
     this.registerRPC();
     this.crypt = new Crypt(transferEncryptToken || process.env.transferEncryptToken);
     if (this.crypt.key instanceof Error) {
@@ -83,7 +87,7 @@ class Worker {
     );
   }
 
-  async requestWork() {
+  requestWork() {
     if (!this.MasterAdress) {
       this.log.warn('Cant requestWork from Master if his address not discovered yet');
       return;
@@ -172,7 +176,7 @@ class Worker {
             this.checkCurrentAssets();
             this.working = false;
             this.event.emit('requestWork');
-          }
+          } else if (answer.status === 'same' && !this.working) this.event.emit('requestWork');
           //
           this.log.debug('requestExecAssets answer:', answer);
         });