refactor: block standardization

Author: lgalabru

Cargo.lock

@@ -68,6 +68,7 @@ tracing-subscriber = "0.2"
 tracing-appender = "0.1"
 ctrlc = "3.1.9"
 strum = { version = "0.22", features = ["derive"] }
+bitcoincore-rpc = "0.14.0"
 
 [dependencies.tui]
 version = "0.15.0"

Cargo.toml

@@ -179,16 +179,16 @@ export interface StacksBlockMetadata {
   bitcoin_anchor_block_identifier: BlockIdentifier;
   /**
    *
-   * @type {BlockIdentifier}
+   * @type {number}
    * @memberof StacksBlockMetadata
    */
-  bitcoin_genesis_block_identifier: BlockIdentifier;
+  pox_cycle_index: number;
   /**
    *
    * @type {number}
    * @memberof StacksBlockMetadata
    */
-  pox_cycle_index: number;
+  pox_cycle_position: number;
   /**
    *
    * @type {number}

node-bindings/lib/types.ts

@@ -18,6 +18,7 @@ mod macros;
 mod frontend;
 mod generate;
 mod integrate;
+mod indexer;
 mod poke;
 mod publish;
 mod runnner;

src/bin.rs

@@ -0,0 +1,57 @@
+use bitcoincore_rpc::{Auth, Client, RpcApi};
+use bitcoincore_rpc::bitcoin::hashes::Hash;
+use bitcoincore_rpc::bitcoin::BlockHash;
+use clarity_repl::clarity::util::hash::{hex_bytes};
+use crate::indexer::IndexerConfig;
+use crate::types::{BitcoinBlockData, BitcoinBlockMetadata, BlockIdentifier};
+use rocket::serde::json::{Value as JsonValue};
+
+#[allow(dead_code)]
+#[derive(Deserialize)]
+pub struct NewBurnBlock {
+    burn_block_hash: String,
+    burn_block_height: u64,
+    reward_slot_holders: Vec<String>,
+    burn_amount: u64,
+}
+
+pub fn standardize_bitcoin_block(indexer_config: &IndexerConfig, marshalled_block: JsonValue) -> BitcoinBlockData {
+    let mut transactions = vec![];
+
+    let auth = Auth::UserPass(
+        indexer_config.bitcoin_node_rpc_username.clone(),
+        indexer_config.bitcoin_node_rpc_password.clone());
+
+    let rpc = Client::new(&indexer_config.bitcoin_node_rpc_url, auth).unwrap();
+
+    let partial_block: NewBurnBlock = serde_json::from_value(marshalled_block).unwrap();
+    let block_height = partial_block.burn_block_height;
+    let block_hash = {
+        let block_hash_str = partial_block.burn_block_hash.strip_prefix("0x").unwrap();
+        let mut block_hash_bytes = hex_bytes(&block_hash_str).unwrap();
+        block_hash_bytes.reverse();
+        BlockHash::from_slice(&block_hash_bytes).unwrap()
+    };
+    let block = rpc.get_block(&block_hash).unwrap();
+    
+    for txdata in block.txdata.iter() {
+        // let _ = tx.send(DevnetEvent::debug(format!(
+        //     "Tx.out: {:?}", txdata.output
+        // )));
+    }
+
+    BitcoinBlockData {
+        block_identifier: BlockIdentifier {
+            hash: block.header.block_hash().to_string(),
+            index: block_height,
+        },
+        parent_block_identifier: BlockIdentifier {
+            hash: block.header.prev_blockhash.to_string(),
+            index: block_height - 1,
+        },
+        timestamp: block.header.time,
+        metadata: BitcoinBlockMetadata {},
+        transactions: transactions,
+    }
+}
+

src/indexer/chains/bitcoin.rs

@@ -0,0 +1,5 @@
+pub mod bitcoin;
+pub mod stacks;
+
+pub use bitcoin::standardize_bitcoin_block;
+pub use stacks::standardize_stacks_block;