Use BoundedVec

Author: AndreiEres

substrate/client/statement-store/statement-latency-bench/src/main.rs

@@ -25,7 +25,7 @@ use jsonrpsee::{
 };
 use log::{debug, info, warn};
 use serde::{Deserialize, Serialize};
-use sp_core::{blake2_256, sr25519, Bytes, Pair};
+use sp_core::{blake2_256, bounded_vec::BoundedVec, sr25519, Bytes, ConstU32, Pair};
 use sp_statement_store::{Statement, SubmitResult, TopicFilter};
 use std::{sync::Arc, time::Duration};
 use tokio::{sync::Barrier, time::timeout};
@@ -179,10 +179,14 @@ async fn run_client(
 			.map(|idx| generate_topic(test_run_id, neighbour_id, round, idx).to_vec().into())
 			.collect();
 
+		let bounded_topics: BoundedVec<Bytes, ConstU32<128>> = expected_topics
+			.try_into()
+			.map_err(|_| anyhow!("Client {client_id}: Too many topics (max 128)"))?;
+
 		let mut subscription: Subscription<Bytes> = rpc_client
 			.subscribe(
 				"statement_subscribeStatement",
-				rpc_params![TopicFilter::MatchAny(expected_topics)],
+				rpc_params![TopicFilter::MatchAny(bounded_topics)],
 				"statement_unsubscribeStatement",
 			)
 			.await