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

Use claim_hash not claim_id

Browse source
This commit is contained in:
Brendon J. Brewer 2020-02-05 07:51:29 +13:00 committed by Lex Berezhny
parent 39996d7612
commit 17d8a3e5d6
1 changed files with 17 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
lbry/wallet/server/db/trending/ar.py
View file

@ -24,21 +24,23 @@ DECAY_PER_RENORM = DECAY**(RENORM_INTERVAL)
TRENDING_LOG = True TRENDING_LOG = True
# Stubs
def install(connection): def install(connection):
"""
Install the AR trending algorithm.
"""
check_trending_values(connection) check_trending_values(connection)
if TRENDING_LOG: if TRENDING_LOG:
f = open("trending_ar.log", "w") f = open("trending_ar.log", "w")
f.close() f.close()
# Stub
CREATE_TREND_TABLE = "" CREATE_TREND_TABLE = ""
def check_trending_values(connection): def check_trending_values(connection):
""" """
If the trending values appear to be based on the standard algorithm, If the trending values appear to be based on the zscore algorithm,
reset them. This will allow resyncing from a standard snapshot. reset them. This will allow resyncing from a standard snapshot.
""" """
c = connection.cursor() c = connection.cursor()
@ -109,14 +111,14 @@ class TrendingData:
# Have all claims been read from db yet? # Have all claims been read from db yet?
self.initialised = False self.initialised = False
def insert_claim_from_load(self, claim_id, trending_score, total_amount): def insert_claim_from_load(self, claim_hash, trending_score, total_amount):
assert not self.initialised assert not self.initialised
self.claims[claim_id] = {"trending_score": trending_score, self.claims[claim_hash] = {"trending_score": trending_score,
"total_amount": total_amount, "total_amount": total_amount,
"changed": False} "changed": False}
def update_claim(self, claim_id, total_amount, time_boost=1.0): def update_claim(self, claim_hash, total_amount, time_boost=1.0):
""" """
Update trending data for a claim, given its new total amount. Update trending data for a claim, given its new total amount.
""" """
@ -124,8 +126,8 @@ class TrendingData:
# Extract existing total amount and trending score # Extract existing total amount and trending score
# or use starting values if the claim is new # or use starting values if the claim is new
if claim_id in self.claims: if claim_hash in self.claims:
old_state = copy.deepcopy(self.claims[claim_id]) old_state = copy.deepcopy(self.claims[claim_hash])
else: else:
old_state = {"trending_score": 0.0, old_state = {"trending_score": 0.0,
"total_amount": 0.0, "total_amount": 0.0,
@ -141,9 +143,9 @@ class TrendingData:
old_state["total_amount"], old_state["total_amount"],
time_boost) time_boost)
trending_score = old_state["trending_score"] + spike trending_score = old_state["trending_score"] + spike
self.claims[claim_id] = {"total_amount": total_amount, self.claims[claim_hash] = {"total_amount": total_amount,
"trending_score": trending_score, "trending_score": trending_score,
"changed": True} "changed": True}
@ -178,6 +180,7 @@ def run(db, height, final_height, recalculate_claim_hashes):
if height < final_height - 5*HALF_LIFE: if height < final_height - 5*HALF_LIFE:
trending_log("Skipping AR trending at block {h}.\n".format(h=height)) trending_log("Skipping AR trending at block {h}.\n".format(h=height))
return
start = time.time() start = time.time()
@ -213,7 +216,7 @@ def run(db, height, final_height, recalculate_claim_hashes):
if not trending_data.initialised: if not trending_data.initialised:
# On fresh launch # On fresh launch
for row in db.execute(""" for row in db.execute("""
SELECT claim_id, trending_mixed, SELECT claim_hash, trending_mixed,
(amount + support_amount) (amount + support_amount)
AS total_amount AS total_amount
FROM claim; FROM claim;
@ -222,7 +225,7 @@ def run(db, height, final_height, recalculate_claim_hashes):
trending_data.initialised = True trending_data.initialised = True
else: else:
for row in db.execute(f""" for row in db.execute(f"""
SELECT claim_id, SELECT claim_hash,
(amount + support_amount) (amount + support_amount)
AS total_amount AS total_amount
FROM claim FROM claim
@ -249,7 +252,7 @@ def run(db, height, final_height, recalculate_claim_hashes):
trending_log("{n} scores to write...".format(n=len(the_list))) trending_log("{n} scores to write...".format(n=len(the_list)))
db.executemany("UPDATE claim SET trending_mixed=? WHERE claim_id=?;", db.executemany("UPDATE claim SET trending_mixed=? WHERE claim_hash=?;",
the_list) the_list)
trending_log("done.\n") trending_log("done.\n")