mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-07-10 09:57:30 +00:00
Bastian Köcher
e53d15aa20
* Implement runtime apis for fake runtime
These runtime api implementations are only used to make the compiler
think that we have implemented all required runtime apis. They will not
be called as we switch the executor to `WasmExecutor`. In the near
future we will not require these fake implementations anymore after
Substrate has shifted away from this compile time requirement.
This brings us the advantage that the `polkadot-service` doesn't need to
depend on the runtimes for getting the `RuntimeApi` type.
It also removes around 1min of build time on my machine ;)
* Fix warning
* FMT
* ".git/.scripts/commands/fmt/fmt.sh"
* Use more descriptive id
* Fix warnings
* Adapt path
* Fix 🙈
---------
Co-authored-by: command-bot <>
129 lines
4.0 KiB
Rust
129 lines
4.0 KiB
Rust
// Copyright (C) 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/>.
|
|
|
|
use assert_cmd::cargo::cargo_bin;
|
|
use std::{
|
|
process::{self, Command},
|
|
time::Duration,
|
|
};
|
|
use tempfile::tempdir;
|
|
|
|
pub mod common;
|
|
|
|
#[tokio::test]
|
|
#[cfg(unix)]
|
|
async fn purge_chain_rocksdb_works() {
|
|
use nix::{
|
|
sys::signal::{kill, Signal::SIGINT},
|
|
unistd::Pid,
|
|
};
|
|
|
|
let tmpdir = tempdir().expect("could not create temp dir");
|
|
|
|
let mut cmd = Command::new(cargo_bin("polkadot"))
|
|
.stdout(process::Stdio::piped())
|
|
.stderr(process::Stdio::piped())
|
|
.args(["--dev", "-d"])
|
|
.arg(tmpdir.path())
|
|
.arg("--port")
|
|
.arg("33034")
|
|
.arg("--no-hardware-benchmarks")
|
|
.spawn()
|
|
.unwrap();
|
|
|
|
let (ws_url, _) = common::find_ws_url_from_output(cmd.stderr.take().unwrap());
|
|
|
|
// Let it produce 1 block.
|
|
common::wait_n_finalized_blocks(1, Duration::from_secs(60), &ws_url)
|
|
.await
|
|
.unwrap();
|
|
|
|
// Send SIGINT to node.
|
|
kill(Pid::from_raw(cmd.id().try_into().unwrap()), SIGINT).unwrap();
|
|
// Wait for the node to handle it and exit.
|
|
assert!(common::wait_for(&mut cmd, 30).map(|x| x.success()).unwrap_or_default());
|
|
assert!(tmpdir.path().join("chains/polkadot_dev").exists());
|
|
assert!(tmpdir.path().join("chains/polkadot_dev/db/full").exists());
|
|
assert!(tmpdir.path().join("chains/polkadot_dev/db/full/parachains").exists());
|
|
|
|
// Purge chain
|
|
let status = Command::new(cargo_bin("polkadot"))
|
|
.args(["purge-chain", "--dev", "-d"])
|
|
.arg(tmpdir.path())
|
|
.arg("-y")
|
|
.status()
|
|
.unwrap();
|
|
assert!(status.success());
|
|
|
|
// Make sure that the chain folder exists, but `db/full` is deleted.
|
|
assert!(tmpdir.path().join("chains/polkadot_dev").exists());
|
|
assert!(!tmpdir.path().join("chains/polkadot_dev/db/full").exists());
|
|
}
|
|
|
|
#[tokio::test]
|
|
#[cfg(unix)]
|
|
async fn purge_chain_paritydb_works() {
|
|
use nix::{
|
|
sys::signal::{kill, Signal::SIGINT},
|
|
unistd::Pid,
|
|
};
|
|
|
|
let tmpdir = tempdir().expect("could not create temp dir");
|
|
|
|
let mut cmd = Command::new(cargo_bin("polkadot"))
|
|
.stdout(process::Stdio::piped())
|
|
.stderr(process::Stdio::piped())
|
|
.args(["--dev", "-d"])
|
|
.arg(tmpdir.path())
|
|
.arg("--database")
|
|
.arg("paritydb-experimental")
|
|
.arg("--no-hardware-benchmarks")
|
|
.spawn()
|
|
.unwrap();
|
|
|
|
let (ws_url, _) = common::find_ws_url_from_output(cmd.stderr.take().unwrap());
|
|
|
|
// Let it produce 1 block.
|
|
common::wait_n_finalized_blocks(1, Duration::from_secs(60), &ws_url)
|
|
.await
|
|
.unwrap();
|
|
|
|
// Send SIGINT to node.
|
|
kill(Pid::from_raw(cmd.id().try_into().unwrap()), SIGINT).unwrap();
|
|
// Wait for the node to handle it and exit.
|
|
assert!(common::wait_for(&mut cmd, 30).map(|x| x.success()).unwrap_or_default());
|
|
assert!(tmpdir.path().join("chains/polkadot_dev").exists());
|
|
assert!(tmpdir.path().join("chains/polkadot_dev/paritydb/full").exists());
|
|
assert!(tmpdir.path().join("chains/polkadot_dev/paritydb/parachains").exists());
|
|
|
|
// Purge chain
|
|
let status = Command::new(cargo_bin("polkadot"))
|
|
.args(["purge-chain", "--dev", "-d"])
|
|
.arg(tmpdir.path())
|
|
.arg("--database")
|
|
.arg("paritydb-experimental")
|
|
.arg("-y")
|
|
.status()
|
|
.unwrap();
|
|
assert!(status.success());
|
|
|
|
// Make sure that the chain folder exists, but `db/full` is deleted.
|
|
assert!(tmpdir.path().join("chains/polkadot_dev").exists());
|
|
assert!(!tmpdir.path().join("chains/polkadot_dev/paritydb/full").exists());
|
|
// Parachains removal requires calling "purge-chain --parachains".
|
|
assert!(tmpdir.path().join("chains/polkadot_dev/paritydb/parachains").exists());
|
|
}
|