Skip to content
Snippets Groups Projects
Unverified Commit 909bfc2d authored by Andrei Eres's avatar Andrei Eres Committed by GitHub
Browse files

[subsystem-bench] Trigger own assignments in approval-voting (#4772)

parent a0fc3b54
No related merge requests found
Pipeline #482306 waiting for manual action with stages
in 1 hour, 18 minutes, and 57 seconds
......@@ -60,7 +60,7 @@ use polkadot_node_subsystem_util::metrics::Metrics;
use polkadot_overseer::Handle as OverseerHandleReal;
use polkadot_primitives::{
BlockNumber, CandidateEvent, CandidateIndex, CandidateReceipt, Hash, Header, Slot,
ValidatorIndex,
ValidatorIndex, ASSIGNMENT_KEY_TYPE_ID,
};
use prometheus::Registry;
use sc_keystore::LocalKeystore;
......@@ -68,6 +68,7 @@ use sc_service::SpawnTaskHandle;
use serde::{Deserialize, Serialize};
use sp_consensus_babe::Epoch as BabeEpoch;
use sp_core::H256;
use sp_keystore::Keystore;
use std::{
cmp::max,
collections::{HashMap, HashSet},
......@@ -785,6 +786,12 @@ fn build_overseer(
let db: polkadot_node_subsystem_util::database::kvdb_impl::DbAdapter<kvdb_memorydb::InMemory> =
polkadot_node_subsystem_util::database::kvdb_impl::DbAdapter::new(db, &[]);
let keystore = LocalKeystore::in_memory();
keystore
.sr25519_generate_new(
ASSIGNMENT_KEY_TYPE_ID,
Some(state.test_authorities.key_seeds.get(NODE_UNDER_TEST as usize).unwrap().as_str()),
)
.unwrap();
let system_clock =
PastSystemClock::new(SystemClock {}, state.delta_tick_from_generated.clone());
......
......@@ -28,7 +28,7 @@ use polkadot_node_subsystem_types::OverseerSignal;
use polkadot_primitives::{
node_features, AsyncBackingParams, CandidateEvent, CandidateReceipt, CoreState, GroupIndex,
GroupRotationInfo, IndexedVec, NodeFeatures, OccupiedCore, ScheduledCore, SessionIndex,
SessionInfo, ValidatorIndex,
SessionInfo, ValidationCode, ValidatorIndex,
};
use sp_consensus_babe::Epoch as BabeEpoch;
use sp_core::H256;
......@@ -288,6 +288,15 @@ impl MockRuntimeApi {
};
tx.send(Ok((groups, group_rotation_info))).unwrap();
},
RuntimeApiMessage::Request(
_parent,
RuntimeApiRequest::ValidationCodeByHash(_, tx),
) => {
let validation_code = ValidationCode(Vec::new());
if let Err(err) = tx.send(Ok(Some(validation_code))) {
gum::error!(target: LOG_TARGET, ?err, "validation code wasn't received");
}
},
// Long term TODO: implement more as needed.
message => {
unimplemented!("Unexpected runtime-api message: {:?}", message)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment