db/block: add mining pool information

Author: dspicher

Cargo.lock

@@ -12,6 +12,7 @@ edition = "2021"
 [dependencies]
 anyhow = "1.0.72"
 bitcoin = "0.30.1"
+bitcoin-pool-identification = "0.2.4"
 clap = { version = "4.3.21", features = [ "cargo" ] }
 diesel = { version = "2.1.0", features = [ "r2d2", "sqlite" ], default-features = false }
 diesel_migrations = "2.1.0"

Cargo.toml

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

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

@@ -23,6 +23,7 @@ pub struct Block {
     pub weight: i64,
     pub turnover: i64,
     pub miner_reward: i64,
+    pub pool: Option<String>,
 }
 
 const MIGRATIONS: diesel_migrations::EmbeddedMigrations = diesel_migrations::embed_migrations!();

src/db/mod.rs

@@ -12,5 +12,6 @@ diesel::table! {
         weight -> BigInt,
         turnover -> BigInt,
         miner_reward -> BigInt,
+        pool -> Nullable<Text>,
     }
 }

src/db/schema.rs

@@ -1,5 +1,7 @@
 use std::time::{Duration, Instant};
 
+use bitcoin_pool_identification::PoolIdentification;
+
 use crate::parser::chain::ChainStorage;
 use crate::ParserOptions;
 
@@ -69,6 +71,8 @@ impl BlockchainParser {
                 .coinbase()
                 .map_or_else(|| 0, |cb| cb.output.iter().map(|output| output.value).sum());
 
+            let pool = block.identify_pool().map(|p| p.name);
+
             tracing::trace!(target: "parser", "on_block(height={}) called", self.cur_height);
             blocks.push(crate::db::Block {
                 height: self.cur_height.try_into()?,
@@ -81,6 +85,7 @@ impl BlockchainParser {
                 weight: block.weight().to_wu().try_into()?,
                 turnover: turnover.try_into()?,
                 miner_reward: miner_reward.try_into()?,
+                pool,
             });
             if blocks.len() == block_buffer_size {
                 self.db.insert_blocks(blocks)?;

src/parser/mod.rs

@@ -133,4 +133,5 @@ fn test_blocks_db() {
         u64::try_from(parser.db().block(50).unwrap().miner_reward).unwrap(),
         50 * bitcoin::Amount::ONE_BTC.to_sat()
     );
+    assert!(parser.db().block(75).unwrap().pool.is_none());
 }