mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-05-30 11:41:02 +00:00
Remove assumption that there is a local bootnode in RPC collator (#2091)
* Remove assumption that there is a local bootnode * Bump zombienet to 1.3.29 * Separate "--"
This commit is contained in:
@@ -30,7 +30,7 @@ variables:
|
|||||||
CI_IMAGE: "paritytech/ci-linux:production"
|
CI_IMAGE: "paritytech/ci-linux:production"
|
||||||
DOCKER_OS: "debian:stretch"
|
DOCKER_OS: "debian:stretch"
|
||||||
ARCH: "x86_64"
|
ARCH: "x86_64"
|
||||||
ZOMBIENET_IMAGE: "docker.io/paritytech/zombienet:v1.2.82"
|
ZOMBIENET_IMAGE: "docker.io/paritytech/zombienet:v1.3.29"
|
||||||
|
|
||||||
.collect-artifacts:
|
.collect-artifacts:
|
||||||
artifacts:
|
artifacts:
|
||||||
|
|||||||
@@ -14,7 +14,7 @@
|
|||||||
// You should have received a copy of the GNU General Public License
|
// You should have received a copy of the GNU General Public License
|
||||||
// along with Cumulus. If not, see <http://www.gnu.org/licenses/>.
|
// along with Cumulus. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
use std::{pin::Pin, str::FromStr};
|
use std::pin::Pin;
|
||||||
|
|
||||||
use cumulus_relay_chain_interface::{RelayChainError, RelayChainResult};
|
use cumulus_relay_chain_interface::{RelayChainError, RelayChainResult};
|
||||||
use cumulus_relay_chain_rpc_interface::RelayChainRpcClient;
|
use cumulus_relay_chain_rpc_interface::RelayChainRpcClient;
|
||||||
@@ -24,12 +24,9 @@ use polkadot_overseer::RuntimeApiSubsystemClient;
|
|||||||
use polkadot_service::{AuxStore, HeaderBackend};
|
use polkadot_service::{AuxStore, HeaderBackend};
|
||||||
use sc_authority_discovery::AuthorityDiscovery;
|
use sc_authority_discovery::AuthorityDiscovery;
|
||||||
|
|
||||||
use sc_network_common::config::MultiaddrWithPeerId;
|
|
||||||
use sp_api::{ApiError, RuntimeApiInfo};
|
use sp_api::{ApiError, RuntimeApiInfo};
|
||||||
use sp_blockchain::Info;
|
use sp_blockchain::Info;
|
||||||
|
|
||||||
const LOG_TARGET: &str = "blockchain-rpc-client";
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
#[derive(Clone)]
|
||||||
pub struct BlockChainRpcClient {
|
pub struct BlockChainRpcClient {
|
||||||
rpc_client: RelayChainRpcClient,
|
rpc_client: RelayChainRpcClient,
|
||||||
@@ -338,27 +335,6 @@ impl AuthorityDiscovery<Block> for BlockChainRpcClient {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl BlockChainRpcClient {
|
impl BlockChainRpcClient {
|
||||||
pub async fn local_listen_addresses(
|
|
||||||
&self,
|
|
||||||
) -> Result<Vec<MultiaddrWithPeerId>, RelayChainError> {
|
|
||||||
let addresses = self.rpc_client.system_local_listen_addresses().await?;
|
|
||||||
tracing::debug!(target: LOG_TARGET, ?addresses, "Fetched listen address from RPC node.");
|
|
||||||
|
|
||||||
let mut result_vec = Vec::new();
|
|
||||||
for address in addresses {
|
|
||||||
match MultiaddrWithPeerId::from_str(&address) {
|
|
||||||
Ok(addr) => result_vec.push(addr),
|
|
||||||
Err(err) =>
|
|
||||||
return Err(RelayChainError::GenericError(format!(
|
|
||||||
"Failed to parse a local listen addresses from the RPC node: {}",
|
|
||||||
err
|
|
||||||
))),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Ok(result_vec)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn import_notification_stream(
|
pub async fn import_notification_stream(
|
||||||
&self,
|
&self,
|
||||||
) -> RelayChainResult<Pin<Box<dyn Stream<Item = Header> + Send>>> {
|
) -> RelayChainResult<Pin<Box<dyn Stream<Item = Header> + Send>>> {
|
||||||
|
|||||||
@@ -127,10 +127,6 @@ async fn new_minimal_relay_chain(
|
|||||||
) -> Result<NewMinimalNode, RelayChainError> {
|
) -> Result<NewMinimalNode, RelayChainError> {
|
||||||
let role = config.role.clone();
|
let role = config.role.clone();
|
||||||
|
|
||||||
// Use the given RPC node as bootnode, since we do not have a chain spec with valid boot nodes
|
|
||||||
let mut boot_node_address = relay_chain_rpc_client.local_listen_addresses().await?;
|
|
||||||
config.network.boot_nodes.append(&mut boot_node_address);
|
|
||||||
|
|
||||||
let task_manager = {
|
let task_manager = {
|
||||||
let registry = config.prometheus_config.as_ref().map(|cfg| &cfg.registry);
|
let registry = config.prometheus_config.as_ref().map(|cfg| &cfg.registry);
|
||||||
TaskManager::new(config.tokio_handle.clone(), registry)?
|
TaskManager::new(config.tokio_handle.clone(), registry)?
|
||||||
|
|||||||
@@ -179,11 +179,6 @@ impl RelayChainRpcClient {
|
|||||||
.await
|
.await
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Get local listen address of the node
|
|
||||||
pub async fn system_local_listen_addresses(&self) -> Result<Vec<String>, RelayChainError> {
|
|
||||||
self.request("system_localListenAddresses", rpc_params![]).await
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Get system health information
|
/// Get system health information
|
||||||
pub async fn system_health(&self) -> Result<Health, RelayChainError> {
|
pub async fn system_health(&self) -> Result<Health, RelayChainError> {
|
||||||
self.request("system_health", rpc_params![]).await
|
self.request("system_health", rpc_params![]).await
|
||||||
|
|||||||
@@ -39,7 +39,7 @@ cumulus_based = true
|
|||||||
validator = true
|
validator = true
|
||||||
image = "{{COL_IMAGE}}"
|
image = "{{COL_IMAGE}}"
|
||||||
command = "test-parachain"
|
command = "test-parachain"
|
||||||
args = ["-lparachain=trace,blockchain-rpc-client=debug", "--relay-chain-rpc-urls {{'one'|zombie('wsUri')}} {{'two'|zombie('wsUri')}} {{'three'|zombie('wsUri')}}", "-- --bootnodes {{'one'|zombie('multiAddress')}} {{'two'|zombie('multiAddress')}} {{'three'|zombie('multiAddress')}}"]
|
args = ["-lparachain=trace,blockchain-rpc-client=debug", "--relay-chain-rpc-urls {{'one'|zombie('wsUri')}} {{'two'|zombie('wsUri')}} {{'three'|zombie('wsUri')}}", "--", "--bootnodes {{'one'|zombie('multiAddress')}} {{'two'|zombie('multiAddress')}} {{'three'|zombie('multiAddress')}}"]
|
||||||
|
|
||||||
# run eve as parachain full node
|
# run eve as parachain full node
|
||||||
[[parachains.collators]]
|
[[parachains.collators]]
|
||||||
@@ -47,4 +47,4 @@ cumulus_based = true
|
|||||||
validator = true
|
validator = true
|
||||||
image = "{{COL_IMAGE}}"
|
image = "{{COL_IMAGE}}"
|
||||||
command = "test-parachain"
|
command = "test-parachain"
|
||||||
args = ["-lparachain=trace,blockchain-rpc-client=debug", "--relay-chain-rpc-urls {{'one'|zombie('wsUri')}} {{'two'|zombie('wsUri')}} {{'three'|zombie('wsUri')}}", "-- --bootnodes {{'one'|zombie('multiAddress')}} {{'two'|zombie('multiAddress')}} {{'three'|zombie('multiAddress')}}"]
|
args = ["-lparachain=trace,blockchain-rpc-client=debug", "--relay-chain-rpc-urls {{'one'|zombie('wsUri')}} {{'two'|zombie('wsUri')}} {{'three'|zombie('wsUri')}}", "--", "--bootnodes {{'one'|zombie('multiAddress')}} {{'two'|zombie('multiAddress')}} {{'three'|zombie('multiAddress')}}"]
|
||||||
|
|||||||
Reference in New Issue
Block a user