machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Avoid parralel hashrate indexing when initial query is too slow

Browse Source
This commit is contained in:
nymkappa 2022-04-02 23:29:37 +09:00
parent 8d97351598
commit 2ef2a34766
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
backend/src/api/mining.ts
View File

@ -86,16 +86,17 @@ class Mining {
return; return;
} }
this.weeklyHashrateIndexingStarted = true;
// We only run this once a week // We only run this once a week
const latestTimestamp = await HashratesRepository.$getLatestRunTimestamp('last_weekly_hashrates_indexing') * 1000; const latestTimestamp = await HashratesRepository.$getLatestRunTimestamp('last_weekly_hashrates_indexing') * 1000;
const now = new Date(); const now = new Date();
if (now.getTime() - latestTimestamp < 604800000) { if (now.getTime() - latestTimestamp < 604800000) {
this.weeklyHashrateIndexingStarted = false;
return; return;
} }
try { try {
this.weeklyHashrateIndexingStarted = true;
logger.info(`Indexing mining pools weekly hashrates`); logger.info(`Indexing mining pools weekly hashrates`);
const indexedTimestamp = await HashratesRepository.$getWeeklyHashrateTimestamps(); const indexedTimestamp = await HashratesRepository.$getWeeklyHashrateTimestamps();
@ -186,16 +187,17 @@ class Mining {
return; return;
} }
this.hashrateIndexingStarted = true;
// We only run this once a day // We only run this once a day
const latestTimestamp = await HashratesRepository.$getLatestRunTimestamp('last_hashrates_indexing') * 1000; const latestTimestamp = await HashratesRepository.$getLatestRunTimestamp('last_hashrates_indexing') * 1000;
const now = new Date().getTime(); const now = new Date().getTime();
if (now - latestTimestamp < 86400000) { if (now - latestTimestamp < 86400000) {
this.hashrateIndexingStarted = false;
return; return;
} }
try { try {
this.hashrateIndexingStarted = true;
logger.info(`Indexing network daily hashrate`); logger.info(`Indexing network daily hashrate`);
const indexedTimestamp = (await HashratesRepository.$getNetworkDailyHashrate(null)).map(hashrate => hashrate.timestamp); const indexedTimestamp = (await HashratesRepository.$getNetworkDailyHashrate(null)).map(hashrate => hashrate.timestamp);