DragonX/silentdragonlite-cli
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add coinsupply rpc call

Browse Source
This commit is contained in:
Denio
2019-12-05 21:42:38 +01:00
parent ac5a03f07b
commit f53f73a0c0
4 changed files with 68 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
lib/src/grpcconnector.rs
View File

@@ -20,7 +20,7 @@ use tokio::net::tcp::TcpStream;
use zcash_primitives::transaction::{TxId};
use crate::grpc_client::{ChainSpec, BlockId, BlockRange, RawTransaction,
TransparentAddressBlockFilter, TxFilter, Empty, LightdInfo};
TransparentAddressBlockFilter, TxFilter, Empty, LightdInfo,Coinsupply};
use crate::grpc_client::client::CompactTxStreamer;
mod danger {
@@ -169,6 +169,23 @@ pub fn get_info(uri: http::Uri, no_cert: bool) -> Result<LightdInfo, String> {
tokio::runtime::current_thread::Runtime::new().unwrap().block_on(runner)
}
pub fn get_coinsupply(uri: http::Uri, no_cert: bool) -> Result<Coinsupply, String> {
let runner = make_grpc_client!(uri.scheme_str().unwrap(), uri.host().unwrap(), uri.port_part().unwrap(), no_cert)
.and_then(move |mut client| {
client.get_coinsupply(Request::new(Empty{}))
.map_err(|e| {
format!("ERR = {:?}", e)
})
.and_then(move |response| {
Ok(response.into_inner())
})
.map_err(|e| {
format!("ERR = {:?}", e)
})
});
tokio::runtime::current_thread::Runtime::new().unwrap().block_on(runner)
}
pub fn fetch_blocks<F : 'static + std::marker::Send>(uri: &http::Uri, start_height: u64, end_height: u64, no_cert: bool, mut c: F)
where F : FnMut(&[u8], u64) {