run_block_file_eval: now writes evaluation results to output file

README.md

@@ -20,6 +20,8 @@ The best way to install Rust is to use [rustup](https://rustup.rs).
 
 ##### bitcoind
 
+If on bitcoind v28.0, ensure the following flag is set prior to initial block download:  `-blocksxor=0`
+
 #### Environment Variables
 
 ### Clone code
@@ -50,11 +52,11 @@ $ cargo test
 
 * execute indexer on a specific bitcoin block data file :
 
-        $ BITCOIND_DATA_DIR=/path/to/bitcoind/data/dir
-        $ BITCOIND_BLOCK_DATA_FILE=xxx.dat
+        $ export BITCOIND_DATA_DIR=/path/to/bitcoind/data/dir
+        $ export BITCOIND_BLOCK_DATA_FILE=xxx.dat
 
         $ ./target/debug/gabriel block-file-eval \
-            -b $BITCOIND_DATA_DIR/$BITCOIND_BLOCK_DATA_FILE \
+            -b $BITCOIND_DATA_DIR/blocks/$BITCOIND_BLOCK_DATA_FILE \
             -o /tmp/$BITCOIND_BLOCK_DATA_FILE.csv
 
 

src/block.rs

@@ -19,8 +19,6 @@ use nom::{
 use rayon::prelude::*;
 use sha2::{Digest, Sha256};
 
-const MAGIC_NUMBER: u32 = 0xD9B4BEF9; // Bitcoin Mainnet magic number
-
 use crate::tx::{Transaction, TransactionInput, TransactionOutput, WitnessItem};
 
 #[derive(Debug)]
@@ -404,13 +402,7 @@ fn parse_block(input: &[u8]) -> IResult<&[u8], BitcoinBlock> {
 
 /// Parses a single block, including the magic number and block size
 fn parse_block_with_magic(input: &[u8]) -> IResult<&[u8], BitcoinBlock> {
-    let (input, magic) = le_u32(input)?;
-    if magic != MAGIC_NUMBER {
-        return Err(nom::Err::Error(nom::error::Error::new(
-            input,
-            nom::error::ErrorKind::Tag,
-        )));
-    }
+    let (input, _magic) = le_u32(input)?;
 
     let (input, block_size) = parse_block_size(input)?;
     let block_size = block_size as usize;

src/main.rs

@@ -78,15 +78,23 @@ fn run_block_file_eval(args: &BlockFileEvalArgs) -> Result<()> {
     let result_map: ResultMap = Default::default();
     let pb = ProgressBar::new(1);
 
-    let size = process_block_file(
+    let blocks_processed = process_block_file(
         &args.block_file_absolute_path,
         &pb,
         &result_map,
         &tx_map,
         &header_map,
     );
-    println!("process_block_file size = {}", size);
+    println!(
+        "block_file_absolute_path: {} ;  blocks processed = {}",
+        &args.block_file_absolute_path.display(),
+        blocks_processed
+    );
+    if blocks_processed < 1 {
+        return Ok(());
+    }
 
+    // prep output file
     let mut file = OpenOptions::new()
         .read(true)
         .write(true)
@@ -97,12 +105,19 @@ fn run_block_file_eval(args: &BlockFileEvalArgs) -> Result<()> {
     // When writing back to the file, ensure we start from the beginning
     file.seek(std::io::SeekFrom::Start(0))?;
     file.set_len(0)?; // Truncate the file
-
     file.write_all(HEADER.as_bytes())?;
-    let mut out: Vec<String> = vec![];
-    // JA Bride:  TO_DO
-    for line in &out {
-        writeln!(file, "{}", line)?;
+
+    let result_map_read = result_map.read().unwrap();
+    for (_key, record) in result_map_read.iter() {
+        // write a record to the file
+        let mut p2pk_addresses = &record.p2pk_addresses_added;
+        let binding = p2pk_addresses - &record.p2pk_addresses_spent;
+        p2pk_addresses = &binding;
+        let mut p2pk_coins = record.p2pk_sats_added.to_owned() as f64 / 100_000_000.0;
+        p2pk_coins -= record.p2pk_sats_spent.to_owned() as f64 / 100_000_000.0;
+        let date = &record.date;
+        let output_line = format!("0,{date},{p2pk_addresses},{p2pk_coins}");
+        writeln!(file, "{}", output_line)?;
     }
 
     Ok(())