Bisq statistics page.

backend/mempool-config.sample.json

@@ -14,7 +14,7 @@
   "TX_PER_SECOND_SPAN_SECONDS": 150,
   "ELECTRS_API_URL": "https://www.blockstream.info/testnet/api",
   "BISQ_ENABLED": false,
-  "BSQ_BLOCKS_DATA_PATH": "/mempool/data/all/blocks.json",
+  "BSQ_BLOCKS_DATA_PATH": "/bisq/data/all/blocks.json",
   "SSL": false,
   "SSL_CERT_FILE_PATH": "/etc/letsencrypt/live/mysite/fullchain.pem",
   "SSL_KEY_FILE_PATH": "/etc/letsencrypt/live/mysite/privkey.pem"

backend/src/api/bisq.ts

@@ -1,6 +1,6 @@
 const config = require('../../mempool-config.json');
 import * as fs from 'fs';
-import { BisqBlocks, BisqBlock, BisqTransaction } from '../interfaces';
+import { BisqBlocks, BisqBlock, BisqTransaction, BisqStats } from '../interfaces';
 
 class Bisq {
   private blocks: BisqBlock[] = [];
@@ -8,6 +8,13 @@ class Bisq {
   private transactionIndex: { [txId: string]: BisqTransaction } = {};
   private blockIndex: { [hash: string]: BisqBlock } = {};
   private addressIndex: { [address: string]: BisqTransaction[] } = {};
+  private stats: BisqStats = {
+    minted: 0,
+    burnt: 0,
+    addresses: 0,
+    unspent_txos: 0,
+    spent_txos: 0,
+  };
 
   constructor() {}
 
@@ -48,11 +55,16 @@ class Bisq {
     return [this.blocks.slice(start, length + start), this.blocks.length];
   }
 
+  getStats(): BisqStats {
+    return this.stats;
+  }
+
   private async loadBisqDumpFile(): Promise<void> {
     try {
       const data = await this.loadData();
       await this.loadBisqBlocksDump(data);
       this.buildIndex();
+      this.calculateStats();
     } catch (e) {
       console.log('loadBisqDumpFile() error.', e.message);
     }
@@ -101,6 +113,38 @@ class Bisq {
     console.log('Bisq data index rebuilt in ' + time + ' ms');
   }
 
+  private calculateStats() {
+    let minted = 0;
+    let burned = 0;
+    let unspent = 0;
+    let spent = 0;
+
+    this.transactions.forEach((tx) => {
+      tx.outputs.forEach((output) => {
+        if (output.opReturn) {
+          return;
+        }
+        if (output.txOutputType === 'GENESIS_OUTPUT' || output.txOutputType === 'ISSUANCE_CANDIDATE_OUTPUT' && output.isVerified) {
+          minted += output.bsqAmount;
+        }
+        if (output.isUnspent) {
+          unspent++;
+        } else {
+          spent++;
+        }
+      });
+      burned += tx['burntFee'];
+    });
+
+    this.stats = {
+      addresses: Object.keys(this.addressIndex).length,
+      minted: minted,
+      burnt: burned,
+      spent_txos: spent,
+      unspent_txos: unspent,
+    };
+  }
+
   private async loadBisqBlocksDump(cacheData: string): Promise<void> {
     const start = new Date().getTime();
     if (cacheData && cacheData.length !== 0) {

backend/src/index.ts

@@ -92,6 +92,7 @@ class Server {
 
     if (config.BISQ_ENABLED) {
       this.app
+        .get(config.API_ENDPOINT + 'bisq/stats', routes.getBisqStats)
         .get(config.API_ENDPOINT + 'bisq/tx/:txId', routes.getBisqTransaction)
         .get(config.API_ENDPOINT + 'bisq/block/:hash', routes.getBisqBlock)
         .get(config.API_ENDPOINT + 'bisq/blocks/:index/:length', routes.getBisqBlocks)

backend/src/interfaces.ts

@@ -259,6 +259,14 @@ export interface BisqTransaction {
   unlockBlockHeight: number;
 }
 
+export interface BisqStats {
+  minted: number;
+  burnt: number;
+  addresses: number;
+  unspent_txos: number;
+  spent_txos: number;
+}
+
 interface BisqInput {
   spendingTxOutputIndex: number;
   spendingTxId: string;

backend/src/routes.ts

@@ -87,6 +87,11 @@ class Routes {
     res.send(backendInfo.getBackendInfo());
   }
 
+  public getBisqStats(req: Request, res: Response) {
+    const result = bisq.getStats();
+    res.send(result);
+  }
+
   public getBisqTransaction(req: Request, res: Response) {
     const result = bisq.getTransaction(req.params.txId);
     if (result) {