stronk/OrchestratorTracker
1
0
Fork 0
mirror of https://github.com/stronk-dev/OrchestratorTracker.git synced 2025-07-05 10:55:09 +02:00
Code Issues Packages Projects Releases Wiki Activity

Ignore stats for insufficient sender reserve

Browse Source
This commit is contained in:
Marco van Dijk 2022-08-09 14:10:37 +02:00
parent d18c4a6cc8
commit 32e398d4d0
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
client/src/routes/orchTester.js
View File

@ -181,10 +181,12 @@ const discoverOrchestrator = async function (target) {
sig: CONT_SIG sig: CONT_SIG
}, function (err, res) { }, function (err, res) {
if (err) { if (err) {
console.log("discovery err: ", err) console.log("discovery err: ", err.details);
orchestratorInfo = err.details;
} else {
orchestratorInfo = res;
} }
elapsed = new Date().getTime() - start; elapsed = new Date().getTime() - start;
orchestratorInfo = res;
receivedResults = true; receivedResults = true;
}); });
while (!receivedResults && new Date().getTime() - start < 5000) { await sleep(200); } while (!receivedResults && new Date().getTime() - start < 5000) { await sleep(200); }
@ -199,10 +201,12 @@ const pingOrchestrator = async function (target) {
var elapsed; var elapsed;
await client.Ping({ value: "koekjes" }, function (err, res) { await client.Ping({ value: "koekjes" }, function (err, res) {
if (err) { if (err) {
console.log("Ping err: ", err) console.log("Ping err: ", err.details);
pingPong = err.details;
} else {
pingPong = res;
} }
elapsed = new Date().getTime() - start; elapsed = new Date().getTime() - start;
pingPong = res;
receivedResults = true; receivedResults = true;
}); });
while (!receivedResults && new Date().getTime() - start < 5000) { await sleep(200); } while (!receivedResults && new Date().getTime() - start < 5000) { await sleep(200); }
@ -214,6 +218,10 @@ const testOrchestrator = async function (id, target) {
target = target.replace(/^https?:\/\//, ''); target = target.replace(/^https?:\/\//, '');
console.log("Target is " + target); console.log("Target is " + target);
const { discoveryResults, elapsed } = await discoverOrchestrator(target); const { discoveryResults, elapsed } = await discoverOrchestrator(target);
if (discoveryResults && discoveryResults == "insufficient sender reserve"){
console.log('Ignoring ' + id + ' for stats due to insufficient sender reserve');
return;
}
await postStatistics(id, discoveryResults, elapsed); await postStatistics(id, discoveryResults, elapsed);
} }