chore: format code and fix typos (#138)

Author: yjhmelody

substrate-archive-backend/src/frontend.rs

@@ -65,11 +65,11 @@ where
 }
 
 impl SpawnNamed for TaskExecutor {
-	fn spawn(&self, _: &'static str, fut: std::pin::Pin<Box<dyn Future<Output = ()> + Send + 'static>>) {
+	fn spawn_blocking(&self, _: &'static str, fut: std::pin::Pin<Box<dyn Future<Output = ()> + Send + 'static>>) {
 		let _ = self.pool.spawn(fut);
 	}
 
-	fn spawn_blocking(&self, _: &'static str, fut: std::pin::Pin<Box<dyn Future<Output = ()> + Send + 'static>>) {
+	fn spawn(&self, _: &'static str, fut: std::pin::Pin<Box<dyn Future<Output = ()> + Send + 'static>>) {
 		let _ = self.pool.spawn(fut);
 	}
 }

substrate-archive-backend/src/frontend/client.rs

@@ -142,13 +142,12 @@ where
 	type StateBackend = TrieState<Block, D>;
 
 	fn call_api_at<
-		'a,
 		R: Encode + Decode + PartialEq,
 		NC: FnOnce() -> std::result::Result<R, String> + UnwindSafe,
 		C: CoreApi<Block, Error = sp_blockchain::Error>,
 	>(
 		&self,
-		params: CallApiAtParams<'a, Block, C, NC, TrieState<Block, D>>,
+		params: CallApiAtParams<Block, C, NC, TrieState<Block, D>>,
 	) -> sp_blockchain::Result<NativeOrEncoded<R>> {
 		let core_api = params.core_api;
 		let at = params.at;

substrate-archive-backend/src/read_only_backend.rs

@@ -98,6 +98,7 @@ where
 		}
 	}
 
+	/// Get keyed storage value hash or None if there is nothing associated.
 	pub fn storage_hash(&self, hash: Block::Hash, key: &[u8]) -> Option<Block::Hash> {
 		match self.state_at(hash) {
 			Some(state) => state.storage_hash(key).unwrap_or_else(|_| panic!("No storage found for {:?}", hash)),

substrate-archive-backend/src/read_only_backend/main_backend.rs

@@ -35,9 +35,9 @@ type ChainResult<T> = Result<T, BlockchainError>;
 
 impl<Block: BlockT, D: ReadOnlyDB + 'static> Backend<Block> for ReadOnlyBackend<Block, D> {
 	type BlockImportOperation = RealBlockImportOperation<D>;
-	type OffchainStorage = OffchainStorageBackend;
 	type Blockchain = Self;
 	type State = super::state_backend::TrieState<Block, D>;
+	type OffchainStorage = OffchainStorageBackend;
 
 	fn begin_operation(&self) -> ChainResult<Self::BlockImportOperation> {
 		log::warn!("Block import operations are not supported for Read Only Backend");

substrate-archive-backend/src/read_only_backend/state_backend.rs

@@ -118,6 +118,10 @@ impl<B: BlockT, D: ReadOnlyDB> StateBackend<HashFor<B>> for TrieState<B, D> {
 		self.state.next_child_storage_key(child_info, key)
 	}
 
+	fn for_keys_in_child_storage<F: FnMut(&[u8])>(&self, child_info: &ChildInfo, f: F) {
+		self.state.for_keys_in_child_storage(child_info, f)
+	}
+
 	fn for_keys_with_prefix<F: FnMut(&[u8])>(&self, prefix: &[u8], f: F) {
 		self.state.for_keys_with_prefix(prefix, f)
 	}
@@ -126,10 +130,6 @@ impl<B: BlockT, D: ReadOnlyDB> StateBackend<HashFor<B>> for TrieState<B, D> {
 		self.state.for_key_values_with_prefix(prefix, f)
 	}
 
-	fn for_keys_in_child_storage<F: FnMut(&[u8])>(&self, child_info: &ChildInfo, f: F) {
-		self.state.for_keys_in_child_storage(child_info, f)
-	}
-
 	fn for_child_keys_with_prefix<F: FnMut(&[u8])>(&self, child_info: &ChildInfo, prefix: &[u8], f: F) {
 		self.state.for_child_keys_with_prefix(child_info, prefix, f)
 	}

substrate-archive-backend/src/runtime_version_cache.rs

@@ -132,7 +132,7 @@ impl<B: BlockT, D: ReadOnlyDB + 'static> RuntimeVersionCache<B, D> {
 			.collect())
 	}
 
-	/// This can be thought of as similiar to a recursive Binary Search
+	/// This can be thought of as similar to a recursive Binary Search
 	fn find_pivot(&self, blocks: &[SignedBlock<B>], versions: &mut Vec<VersionRange<B>>) -> Result<()> {
 		if blocks.is_empty() {
 			return Ok(());

substrate-archive-common/src/error.rs

@@ -46,7 +46,7 @@ pub enum Error {
 	BgJobGet(#[from] coil::FetchError),
 	#[error("could not build threadpool")]
 	ThreadPool(#[from] rayon::ThreadPoolBuildError),
-	/// Error occured while serializing/deserializing data
+	/// Error occurred while serializing/deserializing data
 	#[error("Error while decoding job data {0}")]
 	De(#[from] rmp_serde::decode::Error),
 	#[error(

substrate-archive/src/actors/actor_pool.rs

@@ -75,7 +75,7 @@ impl<A: Actor + Send + Clone> ActorPool<A> {
 	/// and is not taken out. WeakAddresses can be used to
 	/// communicate directly with a single actor.
 	///
-	/// This has the possiblity of interrupting the pooled actors
+	/// This has the possibility of interrupting the pooled actors
 	/// if many tasks are sent to the one actor.
 	///
 	/// # None

substrate-archive/src/actors/workers/blocks.rs

@@ -43,7 +43,7 @@ where
 	rt_cache: RuntimeVersionCache<B, D>,
 	/// the last maximum block number from which we are sure every block before then is indexed
 	last_max: u32,
-	/// the maximimum amount of blocks to index at once
+	/// the maximum amount of blocks to index at once
 	max_block_load: u32,
 }
 

substrate-archive/src/archive.rs

@@ -152,7 +152,7 @@ fn parse_urls(chain_data_path: Option<String>, pg_url: Option<String>) -> (Strin
 }
 
 /// Create rocksdb secondary directory if it doesn't exist yet.
-/// If the ChainPpec is not specified, a temporary directory is used.
+/// If the ChainSpec is not specified, a temporary directory is used.
 /// Return path to that directory
 ///
 /// # Panics
@@ -220,7 +220,7 @@ where
 		let last_finalized_block = backend.last_finalized()?;
 		let rt = client.runtime_version_at(&BlockId::Hash(last_finalized_block))?;
 		log::info!(
-            "Running archive for chain `{}` 🔗, implemention `{}`. Latest known runtime version: {}. Latest finalized block {} 🛡️",
+            "Running archive for chain `{}` 🔗, implementation `{}`. Latest known runtime version: {}. Latest finalized block {} 🛡️",
             rt.spec_name,
             rt.impl_name,
             rt.spec_version,