mirrors/electrs
1
0
Fork 0
mirror of https://github.com/romanz/electrs.git synced 2024-11-19 09:54:09 +01:00
Code Issues Projects Releases Wiki Activity

Add server.features RPC

Browse Source
This commit is contained in:
Roman Zeyde 2021-07-23 11:11:39 +03:00
parent d9b8691a27
commit 18a467b9aa
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/electrum.rs
View File

@ -116,6 +116,7 @@ pub struct Rpc {
rpc_duration: Histogram, rpc_duration: Histogram,
daemon: Daemon, daemon: Daemon,
banner: String, banner: String,
port: u16,
} }
impl Rpc { impl Rpc {
@ -130,6 +131,7 @@ impl Rpc {
rpc_duration, rpc_duration,
daemon: Daemon::connect(config)?, daemon: Daemon::connect(config)?,
banner: config.server_banner.clone(), banner: config.server_banner.clone(),
port: config.electrum_rpc_addr.port(),
}) })
} }
@ -327,11 +329,14 @@ impl Rpc {
Ok(json!(self.tracker.fees_histogram())) Ok(json!(self.tracker.fees_histogram()))
} }
fn server_id(&self) -> String {
format!("electrs/{}", ELECTRS_VERSION)
}
fn version(&self, (client_id, client_version): (String, Version)) -> Result<Value> { fn version(&self, (client_id, client_version): (String, Version)) -> Result<Value> {
match client_version { match client_version {
Version::Single(v) if v == PROTOCOL_VERSION => { Version::Single(v) if v == PROTOCOL_VERSION => {
let server_id = format!("electrs/{}", ELECTRS_VERSION); Ok(json!([self.server_id(), PROTOCOL_VERSION]))
Ok(json!([server_id, PROTOCOL_VERSION]))
} }
_ => { _ => {
bail!( bail!(
@ -344,6 +349,18 @@ impl Rpc {
} }
} }
fn features(&self) -> Result<Value> {
Ok(json!({
"genesis_hash": self.tracker.chain().get_block_hash(0),
"hosts": { "tcp_port": self.port },
"protocol_max": PROTOCOL_VERSION,
"protocol_min": PROTOCOL_VERSION,
"pruning": null,
"server_version": self.server_id(),
"hash_function": "sha256"
}))
}
pub fn handle_request(&self, client: &mut Client, line: &str) -> String { pub fn handle_request(&self, client: &mut Client, line: &str) -> String {
let error_msg_no_id = |err| error_msg(Value::Null, RpcError::Standard(err)); let error_msg_no_id = |err| error_msg(Value::Null, RpcError::Standard(err));
let response: Value = match serde_json::from_str(line) { let response: Value = match serde_json::from_str(line) {
@ -383,6 +400,7 @@ impl Rpc {
Call::BlockHeaders(args) => self.block_headers(args), Call::BlockHeaders(args) => self.block_headers(args),
Call::Donation => Ok(Value::Null), Call::Donation => Ok(Value::Null),
Call::EstimateFee(args) => self.estimate_fee(args), Call::EstimateFee(args) => self.estimate_fee(args),
Call::Features => self.features(),
Call::HeadersSubscribe => self.headers_subscribe(client), Call::HeadersSubscribe => self.headers_subscribe(client),
Call::MempoolFeeHistogram => self.get_fee_histogram(), Call::MempoolFeeHistogram => self.get_fee_histogram(),
Call::PeersSubscribe => Ok(json!([])), Call::PeersSubscribe => Ok(json!([])),
@ -421,6 +439,7 @@ enum Call {
TransactionBroadcast((String,)), TransactionBroadcast((String,)),
Donation, Donation,
EstimateFee((u16,)), EstimateFee((u16,)),
Features,
HeadersSubscribe, HeadersSubscribe,
MempoolFeeHistogram, MempoolFeeHistogram,
PeersSubscribe, PeersSubscribe,
@ -451,6 +470,7 @@ impl Call {
"mempool.get_fee_histogram" => Call::MempoolFeeHistogram, "mempool.get_fee_histogram" => Call::MempoolFeeHistogram,
"server.banner" => Call::Banner, "server.banner" => Call::Banner,
"server.donation_address" => Call::Donation, "server.donation_address" => Call::Donation,
"server.features" => Call::Features,
"server.peers.subscribe" => Call::PeersSubscribe, "server.peers.subscribe" => Call::PeersSubscribe,
"server.ping" => Call::Ping, "server.ping" => Call::Ping,
"server.version" => Call::Version(convert(params)?), "server.version" => Call::Version(convert(params)?),