openethereum/rpc/src/v1/impls/net.rs

51 lines
1.6 KiB
Rust
Raw Normal View History

2016-02-05 13:40:41 +01:00
// Copyright 2015, 2016 Ethcore (UK) Ltd.
// This file is part of Parity.
// Parity is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// Parity is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with Parity. If not, see <http://www.gnu.org/licenses/>.
2016-01-21 11:25:39 +01:00
//! Net rpc implementation.
2016-02-29 11:58:33 +01:00
use std::sync::{Arc, Weak};
2016-01-26 13:14:22 +01:00
use jsonrpc_core::*;
use ethsync::SyncProvider;
use v1::traits::Net;
2016-01-21 11:25:39 +01:00
/// Net rpc implementation.
pub struct NetClient<S> where S: SyncProvider {
sync: Weak<S>
}
2016-01-21 11:25:39 +01:00
impl<S> NetClient<S> where S: SyncProvider {
/// Creates new NetClient.
pub fn new(sync: &Arc<S>) -> Self {
NetClient {
2016-02-29 11:58:33 +01:00
sync: Arc::downgrade(sync)
}
}
2016-01-21 11:25:39 +01:00
}
impl<S> Net for NetClient<S> where S: SyncProvider + 'static {
2016-01-25 17:45:26 +01:00
fn version(&self, _: Params) -> Result<Value, Error> {
Ok(Value::String(format!("{}", take_weak!(self.sync).status().network_id).to_owned()))
2016-01-25 17:45:26 +01:00
}
2016-01-21 11:25:39 +01:00
fn peer_count(&self, _params: Params) -> Result<Value, Error> {
2016-03-11 10:17:20 +01:00
Ok(Value::String(format!("0x{:x}", take_weak!(self.sync).status().num_peers as u64).to_owned()))
2016-01-21 11:25:39 +01:00
}
2016-03-11 10:21:25 +01:00
fn is_listening(&self, _: Params) -> Result<Value, Error> {
// right now (11 march 2016), we are always listening for incoming connections
Ok(Value::Bool(true))
}
2016-01-21 11:25:39 +01:00
}