mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-07-03 20:27:22 +00:00
Max Inden
2d5ec72331
* client/authority-discovery: Rename AuthorityDiscovery to XXXWorker
* client/authority-discovery: Introduce AuthorityDiscoveryService
Add a basic `AuthorityDiscoveryService` implementation which enables
callers to get the addresses for a given `AuthorityId` from the local
cache.
* client/authority-discovery: Split into worker and service mod
Move `Service` and `Worker` to their own Rust modules resulting in the
following file structure.
├── build.rs
├── Cargo.toml
└── src
├── error.rs
├── lib.rs
├── service.rs
├── tests.rs
├── worker
│ ├── addr_cache.rs
│ ├── schema
│ │ └── dht.proto
│ └── tests.rs
└── worker.rs
* client/authority-discovery: Cache PeerId -> AuthorityId mapping
* client/authority-discovery: Update priority group on interval
Instead of updating the authority discovery peerset priority group each
time a new DHT value is found, update it regularly on an interval.
This removes the need for deterministic random selection. Instead of
trying to return a random stable set of `Multiaddr`s, the `AddrCache`
now returns a random set on each call.
* client/authority-discovery: Implement Service::get_authority_id
* client/authority-discovery: Use HashMap instead of BTreeMap
* client/authority-discovery: Rework priority group interval
* client/authority-discovery: Fix comment
* bin/node/cli: Update authority discovery constructor
* client/authority-discovery: Fuse from_service receiver
* client/authority-discovery: Remove Rng import
* client/authority-discovery: Ignore Multiaddr without PeerId
* client/authority-discovery/service: Add note on returned None
* client/authority-discovery/addr_cache: Replace double clone with deref
79 lines
2.7 KiB
Rust
79 lines
2.7 KiB
Rust
// Copyright 2019-2020 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/>.
|
|
|
|
#![warn(missing_docs)]
|
|
|
|
//! Substrate authority discovery.
|
|
//!
|
|
//! This crate enables Substrate authorities to discover and directly connect to
|
|
//! other authorities. It is split into two components the [`Worker`] and the
|
|
//! [`Service`].
|
|
//!
|
|
//! See [`Worker`] and [`Service`] for more documentation.
|
|
|
|
pub use crate::{service::Service, worker::{NetworkProvider, Worker, Role}};
|
|
|
|
use std::pin::Pin;
|
|
use std::sync::Arc;
|
|
|
|
use futures::channel::{mpsc, oneshot};
|
|
use futures::Stream;
|
|
|
|
use sc_client_api::blockchain::HeaderBackend;
|
|
use sc_network::{config::MultiaddrWithPeerId, DhtEvent, Multiaddr, PeerId};
|
|
use sp_authority_discovery::{AuthorityDiscoveryApi, AuthorityId};
|
|
use sp_runtime::traits::Block as BlockT;
|
|
use sp_api::ProvideRuntimeApi;
|
|
|
|
mod error;
|
|
mod service;
|
|
#[cfg(test)]
|
|
mod tests;
|
|
mod worker;
|
|
|
|
/// Create a new authority discovery [`Worker`] and [`Service`].
|
|
pub fn new_worker_and_service<Client, Network, Block>(
|
|
client: Arc<Client>,
|
|
network: Arc<Network>,
|
|
sentry_nodes: Vec<MultiaddrWithPeerId>,
|
|
dht_event_rx: Pin<Box<dyn Stream<Item = DhtEvent> + Send>>,
|
|
role: Role,
|
|
prometheus_registry: Option<prometheus_endpoint::Registry>,
|
|
) -> (Worker<Client, Network, Block>, Service)
|
|
where
|
|
Block: BlockT + Unpin + 'static,
|
|
Network: NetworkProvider,
|
|
Client: ProvideRuntimeApi<Block> + Send + Sync + 'static + HeaderBackend<Block>,
|
|
<Client as ProvideRuntimeApi<Block>>::Api: AuthorityDiscoveryApi<Block, Error = sp_blockchain::Error>,
|
|
{
|
|
let (to_worker, from_service) = mpsc::channel(0);
|
|
|
|
let worker = Worker::new(
|
|
from_service, client, network, sentry_nodes, dht_event_rx, role, prometheus_registry,
|
|
);
|
|
let service = Service::new(to_worker);
|
|
|
|
(worker, service)
|
|
}
|
|
|
|
/// Message send from the [`Service`] to the [`Worker`].
|
|
pub(crate) enum ServicetoWorkerMsg {
|
|
/// See [`Service::get_addresses_by_authority_id`].
|
|
GetAddressesByAuthorityId(AuthorityId, oneshot::Sender<Option<Vec<Multiaddr>>>),
|
|
/// See [`Service::get_authority_id_by_peer_id`].
|
|
GetAuthorityIdByPeerId(PeerId, oneshot::Sender<Option<AuthorityId>>)
|
|
}
|