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

Merge pull request #1498 from mempool/nymkappa/bugfix/avoid-duplicated-indexing

Browse Source 
Avoid parralel hashrate indexing when initial query is too slow
This commit is contained in:
softsimon 2022-04-03 15:57:43 +04:00 committed by GitHub
commit effe85f7c0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 24 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -86,16 +86,23 @@ class Mining {
return; return;
} }
// We only run this once a week
const latestTimestamp = await HashratesRepository.$getLatestRunTimestamp('last_weekly_hashrates_indexing') * 1000;
const now = new Date(); const now = new Date();
if (now.getTime() - latestTimestamp < 604800000) {
return;
}
try { try {
this.weeklyHashrateIndexingStarted = true; this.weeklyHashrateIndexingStarted = true;
// We only run this once a week
const latestTimestamp = await HashratesRepository.$getLatestRunTimestamp('last_weekly_hashrates_indexing') * 1000;
if (now.getTime() - latestTimestamp < 604800000) {
this.weeklyHashrateIndexingStarted = false;
return;
}
} catch (e) {
this.weeklyHashrateIndexingStarted = false;
throw e;
}
try {
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 +193,23 @@ class Mining {
return; return;
} }
// We only run this once a day
const latestTimestamp = await HashratesRepository.$getLatestRunTimestamp('last_hashrates_indexing') * 1000;
const now = new Date().getTime(); const now = new Date().getTime();
if (now - latestTimestamp < 86400000) {
return;
}
try { try {
this.hashrateIndexingStarted = true; this.hashrateIndexingStarted = true;
// We only run this once a day
const latestTimestamp = await HashratesRepository.$getLatestRunTimestamp('last_hashrates_indexing') * 1000;
if (now - latestTimestamp < 86400000) {
this.hashrateIndexingStarted = false;
return;
}
} catch (e) {
this.hashrateIndexingStarted = false;
throw e;
}
try {
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);