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

Fixing cycle reset at top of the hour

Browse Source
This commit is contained in:
softsimon 2023-08-04 13:23:09 +09:00
parent 813f3dc09d
commit 2892bfa1d8
No known key found for this signature in database
GPG Key ID: 488D7DCFB5A430D7
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
backend/src/tasks/price-updater.ts
View File

@ -28,6 +28,7 @@ class PriceUpdater {
private timeBetweenUpdatesMs = 3600000 / config.MEMPOOL.PRICE_UPDATES_PER_HOUR; private timeBetweenUpdatesMs = 3600000 / config.MEMPOOL.PRICE_UPDATES_PER_HOUR;
private cyclePosition = -1; private cyclePosition = -1;
private firstRun = true; private firstRun = true;
private lastTime = -1;
private lastHistoricalRun = 0; private lastHistoricalRun = 0;
private running = false; private running = false;
private feeds: PriceFeed[] = []; private feeds: PriceFeed[] = [];
@ -136,7 +137,13 @@ class PriceUpdater {
} }
const millisecondsSinceBeginningOfHour = this.getMillisecondsSinceBeginningOfHour(); const millisecondsSinceBeginningOfHour = this.getMillisecondsSinceBeginningOfHour();
if (millisecondsSinceBeginningOfHour < this.timeBetweenUpdatesMs * this.cyclePosition && !forceUpdate) {
// Reset the cycle on new hour
if (this.lastTime > millisecondsSinceBeginningOfHour) {
this.cyclePosition = 0;
}
this.lastTime = millisecondsSinceBeginningOfHour;
if (millisecondsSinceBeginningOfHour < this.timeBetweenUpdatesMs * this.cyclePosition && !forceUpdate && this.cyclePosition !== 0) {
return; return;
} }
@ -190,9 +197,6 @@ class PriceUpdater {
if (!forceUpdate) { if (!forceUpdate) {
this.cyclePosition++; this.cyclePosition++;
if (this.cyclePosition > config.MEMPOOL.PRICE_UPDATES_PER_HOUR) {
this.cyclePosition = 0;
}
} }
if (this.latestPrices.USD === -1) { if (this.latestPrices.USD === -1) {