PoolToolBackend-DB/fixPoolBlocks.py at master · PoolTool-io/PoolToolBackend-DB · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
from config import *
from pg_utils import *
from fb_utils import *
allowChanges=True
pg=pg_utils("fixPoolBlocks")
fb=fb_utils()


pg.cur1_execute("select epoch from blocks order by block desc limit 1")
row=pg.cur1_fetchone()
current_epoch=row['epoch']

# scan all previous epoch pools and make sure there is an entry set in their pool blocks table for 0 blocks.
pg.cur1_execute("select pool_id from (select pools.pool_id, block_count from pools left join pool_epoch_blocks on pool_epoch_blocks.pool_id=pools.pool_id and pool_epoch_blocks.epoch=%s) as a where block_count is null",[current_epoch-1])
row=pg.cur1_fetchone()
while row:
    print(row['pool_id'],"fix pool blocks")
    if allowChanges:
        fb.writeFb(baseNetwork+"/pool_stats/"+row['pool_id']+"/blocks",{str(current_epoch-1):0})
    else:
        print(baseNetwork+"/pool_stats/"+row['pool_id']+"/blocks",{str(current_epoch-1):0})
    row=pg.cur1_fetchone()

fb.writeBatch()