db/block: add miner reward metric

Author: dspicher

migrations/2023-08-09-202146_add_opreturn_table/up.sql

@@ -7,5 +7,6 @@ CREATE TABLE blocks (
     tx_count INTEGER NOT NULL,
     size INTEGER NOT NULL,
     weight BIGINT NOT NULL,
-    turnover BIGINT NOT NULL
+    turnover BIGINT NOT NULL,
+    miner_reward BIGINT NOT NULL
 );

src/db/mod.rs

@@ -22,6 +22,7 @@ pub struct Block {
     pub size: i32,
     pub weight: i64,
     pub turnover: i64,
+    pub miner_reward: i64,
 }
 
 const MIGRATIONS: diesel_migrations::EmbeddedMigrations = diesel_migrations::embed_migrations!();

src/db/schema.rs

@@ -11,5 +11,6 @@ diesel::table! {
         size -> Integer,
         weight -> BigInt,
         turnover -> BigInt,
+        miner_reward -> BigInt,
     }
 }

src/parser/mod.rs

@@ -65,6 +65,10 @@ impl BlockchainParser {
                 .flat_map(|tx| tx.output.iter().map(|output| output.value))
                 .sum();
 
+            let miner_reward = block
+                .coinbase()
+                .map_or_else(|| 0, |cb| cb.output.iter().map(|output| output.value).sum());
+
             tracing::trace!(target: "parser", "on_block(height={}) called", self.cur_height);
             blocks.push(crate::db::Block {
                 height: self.cur_height.try_into()?,
@@ -76,6 +80,7 @@ impl BlockchainParser {
                 size: block.size().try_into()?,
                 weight: block.weight().to_wu().try_into()?,
                 turnover: turnover.try_into()?,
+                miner_reward: miner_reward.try_into()?,
             });
             if blocks.len() == block_buffer_size {
                 self.db.insert_blocks(blocks)?;

tests/bitcoin.rs

@@ -129,4 +129,8 @@ fn test_blocks_db() {
         u64::try_from(parser.db().block(170).unwrap().turnover).unwrap(),
         100 * bitcoin::Amount::ONE_BTC.to_sat()
     );
+    assert_eq!(
+        u64::try_from(parser.db().block(50).unwrap().miner_reward).unwrap(),
+        50 * bitcoin::Amount::ONE_BTC.to_sat()
+    );
 }