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

copy some of lex's changes to boris

Browse source
This commit is contained in:
Alex Grintsvayg 2019-12-11 14:13:36 -05:00
parent 8d2c68505e
commit 5e07e8dbbd
No known key found for this signature in database
GPG key ID: AEB3F089F86A22B5
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lbry/scripts/wallet_server_monitor.py
View file

@ -113,16 +113,18 @@ async def monitor(db, server):
async for msg in ws: async for msg in ws:
event = json.loads(msg.data) event = json.loads(msg.data)
height = event['status']['height'] height = event['status'].get('height')
height_change_time = int(time()-height_changed[1]) height_change_time = int(time()-height_changed[1])
if height_changed[0] != height: if height is None:
pass
elif height_changed[0] != height:
height_changed = (height, time()) height_changed = (height, time())
if height_change_reported: if height_change_reported:
await boris_says( await boris_says(
f"Server {server} received new block after {height_change_time / 60:.1f} minutes.", f"Server {server} received new block after {height_change_time / 60:.1f} minutes.",
) )
height_change_reported = False height_change_reported = False
elif height_change_time > 10*60: elif height_change_time > 30*60:
if not height_change_reported or height_change_time % (2*60) == 0: if not height_change_reported or height_change_time % (2*60) == 0:
await boris_says( await boris_says(
f"It's been {height_change_time/60:.1f} minutes since {server} received a new block.", f"It's been {height_change_time/60:.1f} minutes since {server} received a new block.",