LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

fix trending overflow

Browse source
This commit is contained in:
Jack Robison 2021-09-07 14:42:25 -04:00 committed by Victor Shyba
parent 8f9e6a519d
commit ca335b7a65
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
lbry/wallet/server/db/elasticsearch/search.py
View file

@ -161,7 +161,11 @@ class SearchIndex:
async def update_trending_score(self, params): async def update_trending_score(self, params):
update_trending_score_script = """ update_trending_score_script = """
double softenLBC(double lbc) { Math.pow(lbc, 1.0f / 3.0f) } double softenLBC(double lbc) { Math.pow(lbc, 1.0f / 3.0f) }
double inflateUnits(int height) { Math.pow(2.0, height / 400.0f) } double inflateUnits(int height) {
int renormalizationPeriod = 300000;
double doublingRate = 400.0f;
Math.pow(2.0, (height % renormalizationPeriod) / doublingRate)
}
double spikePower(double newAmount) { double spikePower(double newAmount) {
if (newAmount < 50.0) { if (newAmount < 50.0) {
0.5 0.5
@ -174,10 +178,11 @@ class SearchIndex:
double spikeMass(double oldAmount, double newAmount) { double spikeMass(double oldAmount, double newAmount) {
double softenedChange = softenLBC(Math.abs(newAmount - oldAmount)); double softenedChange = softenLBC(Math.abs(newAmount - oldAmount));
double changeInSoftened = Math.abs(softenLBC(newAmount) - softenLBC(oldAmount)); double changeInSoftened = Math.abs(softenLBC(newAmount) - softenLBC(oldAmount));
double power = spikePower(newAmount);
if (oldAmount > newAmount) { if (oldAmount > newAmount) {
-1.0 * Math.pow(changeInSoftened, spikePower(newAmount)) * Math.pow(softenedChange, 1.0 - spikePower(newAmount)) -1.0 * Math.pow(changeInSoftened, power) * Math.pow(softenedChange, 1.0 - power)
} else { } else {
Math.pow(changeInSoftened, spikePower(newAmount)) * Math.pow(softenedChange, 1.0 - spikePower(newAmount)) Math.pow(changeInSoftened, power) * Math.pow(softenedChange, 1.0 - power)
} }
} }
for (i in params.src.changes) { for (i in params.src.changes) {
@ -212,8 +217,8 @@ class SearchIndex:
{ {
'height': p.height, 'height': p.height,
'added': p.added, 'added': p.added,
'prev_amount': p.prev_amount, 'prev_amount': p.prev_amount * 1E-9,
'new_amount': p.new_amount, 'new_amount': p.new_amount * 1E-9,
} for p in claim_updates } for p in claim_updates
] ]
}} }}