feat: add skip_check option

Author: fedosov

consensus/poscan_grid2d/src/lib.rs

@@ -176,20 +176,34 @@ impl DoubleHash {
 pub struct PoscanAlgorithm<Block, C, AccountId, BlockNumber> {
 	client: Arc<C>,
 	_phantom: PhantomData<(Block, AccountId, BlockNumber)>,
+	skip_check: bool,
 }
 
 impl<Block, C, AccountId, BlockNumber> PoscanAlgorithm<Block, C, AccountId, BlockNumber> {
 	pub fn new(client: Arc<C>) -> Self {
 		Self {
 			client,
 			_phantom: PhantomData,
+			skip_check: false,
+		}
+	}
+
+	pub fn with_skip_check(client: Arc<C>, skip_check: bool) -> Self {
+		Self {
+			client,
+			_phantom: PhantomData,
+			skip_check,
 		}
 	}
 }
 
 impl<Block, C, AccountId, BlockNumber> Clone for PoscanAlgorithm<Block, C, AccountId, BlockNumber> {
 	fn clone(&self) -> Self {
-		Self::new(self.client.clone())
+		Self {
+			client: self.client.clone(),
+			_phantom: PhantomData,
+			skip_check: self.skip_check,
+		}
 	}
 }
 
@@ -297,6 +311,10 @@ where
 			}
 		};
 
+		if self.skip_check {
+			return Ok(true);
+		}
+
 		let parent_id = BlockId::<B>::hash(*parent);
 		let parent_num = self
 			.client
@@ -323,17 +341,6 @@ where
 		let obj = poscan_data.obj.clone().to_vec();
 		let hashes = poscan_data.hashes.clone();
 
-		// let ver = self.client
-		// 	.runtime_api()
-		// 	.version(&parent_id)
-		// 	// .map(|d| if parent_num >= SCALE_DIFF_SINCE.into() { d / SCALE_DIFF_BY } else { d })
-		// 	.map_err(|err| {
-		// 		sc_consensus_poscan::Error::<B>::Environment(format!(
-		// 			">>> get version call failed: {:?}",
-		// 			err
-		// 		))
-		// 	})?;
-
 		if ver.spec_version >= 123 {
 			info!("poscan: start validate");
 
@@ -461,6 +468,10 @@ where
 			}
 		};
 
+		if self.skip_check {
+			return Ok(true);
+		}
+
 		let parent_id = BlockId::<B>::hash(*parent);
 		let parent_num = self
 			.client

nodes/poscan-consensus/src/cli.rs

@@ -15,6 +15,9 @@ pub struct Cli {
 
 	#[clap(long)]
 	pub threads: Option<usize>,
+
+	#[clap(long, help = "Skip verification checks for finalized blocks")]
+	pub skip_check: bool,
 }
 
 #[derive(Debug, clap::Parser)]

nodes/poscan-consensus/src/command.rs

@@ -90,7 +90,7 @@ pub fn run() -> sc_cli::Result<()> {
 					task_manager,
 					import_queue,
 					..
-				} = service::new_partial(&config, None)?;
+				} = service::new_partial(&config, None, false)?;
 				Ok((cmd.run(client, import_queue), task_manager))
 			})
 		}
@@ -101,7 +101,7 @@ pub fn run() -> sc_cli::Result<()> {
 					client,
 					task_manager,
 					..
-				} = service::new_partial(&config, None)?;
+				} = service::new_partial(&config, None, false)?;
 				Ok((cmd.run(client, config.database), task_manager))
 			})
 		}
@@ -112,7 +112,7 @@ pub fn run() -> sc_cli::Result<()> {
 					client,
 					task_manager,
 					..
-				} = service::new_partial(&config, None)?;
+				} = service::new_partial(&config, None, false)?;
 				Ok((cmd.run(client, config.chain_spec), task_manager))
 			})
 		}
@@ -124,7 +124,7 @@ pub fn run() -> sc_cli::Result<()> {
 					task_manager,
 					import_queue,
 					..
-				} = service::new_partial(&config, None)?;
+				} = service::new_partial(&config, None, false)?;
 				Ok((cmd.run(client, import_queue), task_manager))
 			})
 		}
@@ -140,7 +140,7 @@ pub fn run() -> sc_cli::Result<()> {
 					task_manager,
 					backend,
 					..
-				} = service::new_partial(&config, None)?;
+				} = service::new_partial(&config, None, false)?;
 				// TODO:!!! None ?`
 				Ok((cmd.run(client, backend, None), task_manager))
 			})
@@ -241,6 +241,7 @@ pub fn run() -> sc_cli::Result<()> {
 						config,
 						cli.author.as_ref().map(|s| s.as_str()),
 						cli.threads.unwrap_or(1),
+						cli.skip_check,
 					),
 				}
 				.map_err(sc_cli::Error::Service)