Struct Client

pub struct Client { /* private fields */ }

Implementations

impl Client

pub fn new(url: &str, user: &str, pass: &str) -> Result<Self, Error>

Examples found in repository

examples/example.rs (line 107)

fn main() {
    let password = env::var("BITCOIND_PASSWORD").expect("BITCOIND_PASSWORD env variable not set");
    let username = env::var("BITCOIND_USERNAME").expect("BITCOIND_USERNAME env variable not set");
    let url = env::var("BITCOIND_URL").expect("BITCOIND_URL env variable not set");
    let client = Client::new(&url, &username, &password).expect("failed to create client");

    let block_height = get_block_height(&client);
    println!("BLOCK HEIGHT: {:#?}", block_height);

    let seconds_since_last_block = get_time_since_last_block(&client).0;
    println!(
        "TIME SINCE LAST BLOCK: {}",
        format_duration(seconds_since_last_block)
    );

    let average_seconds_per_block = get_average_block_time(&client);
    println!(
        "AVERAGE BLOCK TIME (2016): {}",
        format_duration(average_seconds_per_block as i64)
    );

    // Errors out
    // let total_money_supply = get_total_money_supply(&client);
    // println!("TOTAL MONEY SUPPLY: {:#?}", total_money_supply);

    // let chain_size = get_chain_size(&client);
    // let chain_size_in_gbs = chain_size as f64 / 1_000_000_000.0;
    // println!("CHAIN SIZE: {:#?}GB", chain_size_in_gbs);

    // let hash_rate = GetNetworkHashPsCommand::new()
    //     .set_n_blocks(
    //         bitcoind_request::command::get_network_hash_ps::BlocksToIncludeArg::NBlocks(2016),
    //     )
    //     .set_height(bitcoind_request::command::get_network_hash_ps::HeightArg::Height(block_height))
    //     .call(&client);
    // println!("hash_rate:{:#?}", hash_rate);

    // let connection_count = GetConnectionCountCommand::new().call(&client);
    // println!("connection_count:{:#?}", connection_count);

    // let node_addresses = GetNodeAddressesCommand::new()
    //     .set_count(CountArg::AllAddresses)
    //     .set_network(NetworkArg::All)
    //     .call(&client);
    // println!("node addresses:{:#?}", node_addresses.unwrap().0);
    // let mut reachable_nodes = 0;
    // node_addresses.unwrap().0.iter().for_each(|node| {
    //     let current_datetime = chrono::offset::Utc::now();
    //     let datetime_of_node = Utc.timestamp(node.time as i64, 0);
    //     let difference: Duration = current_datetime.signed_duration_since(datetime_of_node);
    //     let seconds = difference.num_seconds();
    //     let seconds_in_a_day = 60 * 60 * 24;
    //     if seconds < seconds_in_a_day {
    //         reachable_nodes = reachable_nodes + 1;
    //     }
    // });
    // println!("reachable nodes count: {}", reachable_nodes);

    // let peer_info = GetPeerInfoCommand::new().call(&client);
    // println!("peerinfo:{:#?}", peer_info.unwrap().0.last());

    // let network_info = GetNetworkInfoCommand::new().call(&client);
    // println!("network info:{:#?}", network_info);

    // let mempool_info = GetMempoolInfoCommand::new().call(&client);
    // println!("mempool info:{:#?}", mempool_info);

    // let raw_mempool = GetRawMempoolCommand::new()
    //     .set_verbose(true)
    //     .set_mempool_sequence(false)
    //     .call(&client);
    // println!("raw_mempool:{:#?}", raw_mempool);

    // what happens if the txid is no longer in the mempool
    //let mempool_entry = GetMempoolEntryCommand::new(
    //    "cbcedc2a784311f24c7cce95faae32fab093b2e98417d79db1eb9620115206e7".to_string(),
    //)
    //.call(&client);
    //let mempool_entry = GetMempoolEntryCommand::new(
    //    "cbcedc2a784311f24c7cce95faae32fab093b2e98417d79db1eb9620115206e7".to_string(),
    //)
    //.call(&client);
    //println!("mempool entry:{:#?}", mempool_entry);
    //
    let maybe_get_block_command_response = GetBlockCommand::new(Blockhash(
        "0000000000000000000137aa8bf31a6b8ad42ce1c08c33acfc033f97f0ef2bc7".to_string(),
    ))
    .verbosity(GetBlockCommandVerbosity::BlockObjectWithTransactionInformation)
    .call(&client);

    match maybe_get_block_command_response {
        Ok(get_block_command_response) => match get_block_command_response {
            GetBlockCommandResponse::Block(block) => {
                println!("height: {}", block.height);
                println!("hash: {}", block.hash);
                println!("time: {}", block.time);
                println!("size: {}", block.size);
                println!("weight: {}", block.weight);
            }
            GetBlockCommandResponse::BlockHash(hash) => panic!("not supported"),
        },
        Err(err) => {}
    }

    // let block = GetBlockCommand::new(Blockhash(
    //     "000000000000000000010887fdbbc731013853dde72c31110dc7130606df9474".to_string(),
    // ))
    // .verbosity(GetBlockCommandVerbosity::BlockObjectWithTransactionInformation)
    // .call(&client);
    // println!("mempool entry:{:#?}", block);

    // let transaction = GetRawTransactionCommand::new(
    //     "ef851362b06934b0082d4e2ea8a544c1982002deacef65198e18dc85a73aa49e".to_string(),
    // )
    // .verbose(true)
    // .call(&client);
    // println!("mempool entry:{:#?}", transaction);
    let tx_out_set_info = GetTxOutSetInfoCommand::new().call(&client);
    let x = tx_out_set_info.unwrap().txouts;
    println!("{}", x);
}

pub fn build_request<'a>( &self, command: &'a str, params: &'a Vec<Box<RawValue>>, ) -> Request<'a>

pub fn send_request( &self, request: Request<'_>, ) -> Result<JsonRPCResponse, Error>