Async Backing: Statement Distribution Tests

node/network/protocol/src/lib.rs

@@ -737,7 +737,7 @@ pub mod vstaging {
 	/// Network messages used by the statement distribution subsystem.
 	#[derive(Debug, Clone, Encode, Decode, PartialEq, Eq)]
 	pub enum StatementDistributionMessage {
-		/// A notification of a signed statement in compact form.
+		/// A notification of a signed statement in compact form, for a given relay parent.
 		#[codec(index = 0)]
 		Statement(Hash, UncheckedSignedStatement),
 

node/network/statement-distribution/src/vstaging/grid.rs

@@ -695,7 +695,7 @@ fn decompose_statement_filter<'a>(
 }
 
 /// A summary of a manifest being sent by a counterparty.
-#[derive(Clone)]
+#[derive(Debug, Clone)]
 pub struct ManifestSummary {
 	/// The claimed parent head data hash of the candidate.
 	pub claimed_parent_hash: Hash,

node/network/statement-distribution/src/vstaging/mod.rs

@@ -119,7 +119,7 @@ const COST_UNEXPECTED_REQUEST: Rep = Rep::CostMajor("Unexpected attested candida
 const BENEFIT_VALID_RESPONSE: Rep = Rep::BenefitMajor("Peer Answered Candidate Request");
 const BENEFIT_VALID_STATEMENT: Rep = Rep::BenefitMajor("Peer provided a valid statement");
 const BENEFIT_VALID_STATEMENT_FIRST: Rep =
-	Rep::BenefitMajorFirst("Peer was the first to provide a valid statement");
+	Rep::BenefitMajorFirst("Peer was the first to provide a given valid statement");
 
 struct PerRelayParentState {
 	local_validator: Option<LocalValidatorState>,
@@ -144,6 +144,7 @@ struct LocalValidatorState {
 	grid_tracker: GridTracker,
 }
 
+#[derive(Debug)]
 struct PerSessionState {
 	session_info: SessionInfo,
 	groups: Groups,
@@ -1006,6 +1007,7 @@ pub(crate) async fn share_local_statement<Context>(
 
 // two kinds of targets: those in our 'cluster' (currently just those in the same group),
 // and those we are propagating to through the grid.
+#[derive(Debug)]
 enum DirectTargetKind {
 	Cluster,
 	Grid,