electrs/examples/bench_parse.rs

extern crate bitcoin;
extern crate electrs;

#[macro_use]
extern crate log;
extern crate error_chain;

use std::path::Path;

use electrs::{
    bulk::Parser, config::Config, daemon::Daemon, errors::*, metrics::Metrics,
    store::{DBStore, StoreOptions, WriteStore},
};

use error_chain::ChainedError;

fn run(config: Config) -> Result<()> {
    let metrics = Metrics::new(config.monitoring_addr);
    metrics.start();

    let daemon = Daemon::new(
        &config.daemon_dir,
        &config.cookie,
        config.network_type,
        &metrics,
    )?;
    let store = DBStore::open(Path::new("./test-db"), StoreOptions { bulk_import: true });

    let parser = Parser::new(&daemon, &store, &metrics)?;
    for rows in parser.start().iter() {
        store.write(rows?);
    }
    Ok(())
}

fn main() {
    if let Err(e) = run(Config::from_args()) {
        error!("{}", e.display_chain());
    }
}