Move reward stats to component - Add /api/v1/mining/reward-stats/{blockCount}

backend/src/api/mining.ts

@@ -1,4 +1,4 @@
-import { PoolInfo, PoolStats } from '../mempool.interfaces';
+import { PoolInfo, PoolStats, RewardStats } from '../mempool.interfaces';
 import BlocksRepository from '../repositories/BlocksRepository';
 import PoolsRepository from '../repositories/PoolsRepository';
 import HashratesRepository from '../repositories/HashratesRepository';
@@ -70,6 +70,13 @@ class Mining {
     };
   }
 
+  /**
+   * Get miner reward stats
+   */
+  public async $getRewardStats(blockCount: number): Promise<RewardStats> {
+    return await BlocksRepository.$getBlockStats(blockCount);
+  }
+
   /**
    * [INDEXING] Generate weekly mining pool hashrate history
    */

backend/src/index.ts

@@ -312,6 +312,7 @@ class Server {
         .get(config.MEMPOOL.API_URL_PREFIX + 'mining/hashrate/pools/:interval', routes.$getPoolsHistoricalHashrate)
         .get(config.MEMPOOL.API_URL_PREFIX + 'mining/hashrate', routes.$getHistoricalHashrate)
         .get(config.MEMPOOL.API_URL_PREFIX + 'mining/hashrate/:interval', routes.$getHistoricalHashrate)
+        .get(config.MEMPOOL.API_URL_PREFIX + 'mining/reward-stats/:blockCount', routes.$getRewardStats)
       ;
     }
 

backend/src/mempool.interfaces.ts

@@ -209,3 +209,9 @@ export interface IDifficultyAdjustment {
   timeAvg: number;
   timeOffset: number;
 }
+
+export interface RewardStats {
+  totalReward: number;
+  totalFee: number;
+  totalTx: number;
+}

backend/src/repositories/BlocksRepository.ts

@@ -354,6 +354,9 @@ class BlocksRepository {
     }
   }
 
+  /**
+   * Return oldest blocks height
+   */
   public async $getOldestIndexedBlockHeight(): Promise<number> {
     const connection = await DB.getConnection();
     try {
@@ -367,6 +370,29 @@ class BlocksRepository {
       throw e;
     }
   }
+
+  /**
+   * Get general block stats
+   */
+  public async $getBlockStats(blockCount: number): Promise<any> {
+    let connection;
+    try {
+      connection = await DB.getConnection();
+
+      // We need to use a subquery
+      const query = `SELECT SUM(reward) as totalReward, SUM(fees) as totalFee, SUM(tx_count) as totalTx
+        FROM (SELECT reward, fees, tx_count FROM blocks ORDER by height DESC LIMIT ${blockCount}) as sub`;
+
+      const [rows]: any = await connection.query(query);
+      connection.release();
+ 
+      return rows[0];
+    } catch (e) {
+      connection.release();
+      logger.err('$getBlockStats() error: ' + (e instanceof Error ? e.message : e));
+      throw e;
+    }
+  }
 }
 
 export default new BlocksRepository();

backend/src/routes.ts

@@ -935,6 +935,15 @@ class Routes {
       res.status(500).end();
     }
   }
+
+  public async $getRewardStats(req: Request, res: Response) {
+    try {
+      const response = await mining.$getRewardStats(parseInt(req.params.blockCount))
+      res.json(response);
+    } catch (e) {
+      res.status(500).end();
+    }
+  }
 }
 
 export default new Routes();