mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-28 06:21:05 +00:00
Pierre Krieger
a0d458aa06
* Update to latest libp2p * Fix indentations * Add basic test * Apply suggestions from code review Co-Authored-By: tomaka <pierre.krieger1708@gmail.com> * Remove Mutex from topology * Remove unused method * Fix concerns
81 lines
2.4 KiB
Rust
81 lines
2.4 KiB
Rust
// Copyright 2018 Parity Technologies (UK) Ltd.
|
|
// This file is part of Substrate.
|
|
|
|
// Substrate 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.
|
|
|
|
// Substrate 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 Substrate. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
//! Networking layer of Substrate.
|
|
|
|
#![recursion_limit = "128"]
|
|
|
|
extern crate parking_lot;
|
|
extern crate fnv;
|
|
extern crate futures;
|
|
extern crate tokio;
|
|
extern crate tokio_io;
|
|
extern crate tokio_timer;
|
|
extern crate libc;
|
|
#[macro_use]
|
|
extern crate libp2p;
|
|
extern crate rand;
|
|
#[macro_use]
|
|
extern crate serde_derive;
|
|
extern crate serde_json;
|
|
extern crate smallvec;
|
|
extern crate void;
|
|
extern crate bytes;
|
|
extern crate unsigned_varint;
|
|
|
|
#[macro_use]
|
|
extern crate error_chain;
|
|
#[macro_use]
|
|
extern crate log;
|
|
#[cfg(test)] #[macro_use]
|
|
extern crate assert_matches;
|
|
|
|
mod behaviour;
|
|
mod custom_proto;
|
|
mod error;
|
|
mod secret;
|
|
mod service_task;
|
|
mod topology;
|
|
mod traits;
|
|
mod transport;
|
|
|
|
pub use custom_proto::RegisteredProtocol;
|
|
pub use error::{Error, ErrorKind, DisconnectReason};
|
|
pub use libp2p::{Multiaddr, multiaddr::{Protocol}, multiaddr, PeerId, core::PublicKey};
|
|
pub use secret::obtain_private_key;
|
|
pub use service_task::{start_service, Service, ServiceEvent};
|
|
pub use traits::{NetworkConfiguration, NodeIndex, NodeId, NonReservedPeerMode};
|
|
pub use traits::{ProtocolId, Secret, Severity};
|
|
|
|
/// Check if node url is valid
|
|
pub fn validate_node_url(url: &str) -> Result<(), Error> {
|
|
match url.parse::<Multiaddr>() {
|
|
Ok(_) => Ok(()),
|
|
Err(_) => Err(ErrorKind::InvalidNodeId.into()),
|
|
}
|
|
}
|
|
|
|
/// Parses a string address and returns the component, if valid.
|
|
pub fn parse_str_addr(addr_str: &str) -> Result<(PeerId, Multiaddr), Error> {
|
|
let mut addr: Multiaddr = addr_str.parse().map_err(|_| ErrorKind::AddressParse)?;
|
|
let who = match addr.pop() {
|
|
Some(Protocol::P2p(key)) =>
|
|
PeerId::from_multihash(key).map_err(|_| ErrorKind::AddressParse)?,
|
|
_ => return Err(ErrorKind::AddressParse.into()),
|
|
};
|
|
Ok((who, addr))
|
|
}
|