Revert "use overlayedchanges"

This reverts commit c0ddb87.

primitives/state-machine/src/overlayed_changes/mod.rs

@@ -276,7 +276,7 @@ impl OverlayedChanges {
 	/// `None` can be used to delete a value specified by the given key.
 	///
 	/// Can be rolled back or committed when called inside a transaction.
-	pub fn set_child_storage(
+	pub(crate) fn set_child_storage(
 		&mut self,
 		child_info: &ChildInfo,
 		key: StorageKey,

primitives/state-machine/src/testing.rs

@@ -117,12 +117,7 @@ where
 		}
 	}
 
-	/// Returns a mutable reference to the overlayed changes.
-	pub fn overlayed_changes_mut(&mut self) -> &mut OverlayedChanges {
-		&mut self.overlay
-	}
-
-	/// Returns an immutable reference to the overlayed changes.
+	/// Returns the overlayed changes.
 	pub fn overlayed_changes(&self) -> &OverlayedChanges {
 		&self.overlay
 	}

utils/frame/remote-externalities/Cargo.toml

@@ -17,7 +17,6 @@ codec = { package = "parity-scale-codec", version = "3.2.2" }
 log = "0.4.17"
 serde = "1.0.136"
 frame-support = { version = "4.0.0-dev", optional = true, path = "../../../frame/support" }
-sp-state-machine = { version = "0.13.0", path = "../../../primitives/state-machine" }
 sp-core = { version = "7.0.0", path = "../../../primitives/core" }
 sp-io = { version = "7.0.0", path = "../../../primitives/io" }
 sp-runtime = { version = "7.0.0", path = "../../../primitives/runtime" }

utils/frame/remote-externalities/src/lib.rs

@@ -39,7 +39,6 @@ use sp_core::{
 };
 pub use sp_io::TestExternalities;
 use sp_runtime::{traits::Block as BlockT, StateVersion};
-use sp_state_machine::OverlayedChanges;
 use spinners::{Spinner, Spinners};
 use std::{
 	cmp::max,
@@ -521,7 +520,7 @@ where
 		&self,
 		prefix: StorageKey,
 		at: B::Hash,
-		ext_overlay: &mut OverlayedChanges,
+		pending_ext: &mut TestExternalities,
 	) -> Result<Vec<KeyValue>, &'static str> {
 		let start = Instant::now();
 		let mut sp = Spinner::with_timer(Spinners::Dots, "Scraping keys...".into());
@@ -547,7 +546,7 @@ where
 			.collect::<Vec<_>>();
 
 		let bar = ProgressBar::new(payloads.len() as u64);
-		let bar_message = "Downloading key values".to_string();
+		let bar_message = format!("Downloading key values");
 		bar.set_message(bar_message);
 		bar.set_style(
 			ProgressStyle::with_template(
@@ -597,9 +596,7 @@ where
 
 		let mut sp = Spinner::with_timer(Spinners::Dots, "Inserting keys into DB...".into());
 		let start = Instant::now();
-		key_values.clone().into_iter().for_each(|(k, v)| {
-			ext_overlay.set_storage(k.0, Some(v.0));
-		});
+		pending_ext.batch_insert(key_values.clone().into_iter().map(|(k, v)| (k.0, v.0)));
 		sp.stop_with_message(format!("✅ Inserted keys into DB ({}s)", start.elapsed().as_secs()));
 		Ok(key_values)
 	}
@@ -706,7 +703,7 @@ where
 	async fn load_child_remote(
 		&self,
 		top_kv: &[KeyValue],
-		ext_overlay: &mut OverlayedChanges,
+		pending_ext: &mut TestExternalities,
 	) -> Result<ChildKeyValues, &'static str> {
 		let child_roots = top_kv
 			.into_iter()
@@ -750,7 +747,7 @@ where
 				child_kv_inner.iter().cloned().map(|(k, v)| (k.0, v.0)).collect::<Vec<_>>();
 			child_kv.push((info.clone(), child_kv_inner));
 			for (k, v) in key_values {
-				ext_overlay.set_child_storage(&info, k, Some(v));
+				pending_ext.insert_child(info.clone(), k, v);
 			}
 		}
 
@@ -759,11 +756,11 @@ where
 
 	/// Build `Self` from a network node denoted by `uri`.
 	///
-	/// This function populates `ext_overlay`. The return value is for optionally writing to a
-	/// snapshot file.
+	/// This function concurrently populates `pending_ext`. the return value is only for writing to
+	/// cache, we can also optimize further.
 	async fn load_top_remote(
 		&self,
-		ext_overlay: &mut OverlayedChanges,
+		pending_ext: &mut TestExternalities,
 	) -> Result<TopKeyValues, &'static str> {
 		let config = self.as_online();
 		let at = self
@@ -776,7 +773,7 @@ where
 		for prefix in &config.hashed_prefixes {
 			let now = std::time::Instant::now();
 			let additional_key_values =
-				self.rpc_get_pairs_paged(StorageKey(prefix.to_vec()), at, ext_overlay).await?;
+				self.rpc_get_pairs_paged(StorageKey(prefix.to_vec()), at, pending_ext).await?;
 			let elapsed = now.elapsed();
 			log::info!(
 				target: LOG_TARGET,
@@ -796,7 +793,7 @@ where
 			);
 			match self.rpc_get_storage(key.clone(), Some(at)).await? {
 				Some(value) => {
-					ext_overlay.set_storage(key.clone().0, Some(value.clone().0));
+					pending_ext.insert(key.clone().0, value.clone().0);
 					keys_and_values.push((key, value));
 				},
 				None => {
@@ -877,10 +874,8 @@ where
 			Default::default(),
 			self.overwrite_state_version.unwrap_or(state_version),
 		);
-		let top_kv = self.load_top_remote(&mut pending_ext.overlayed_changes_mut()).await?;
-		let child_kv = self
-			.load_child_remote(&top_kv, &mut pending_ext.overlayed_changes_mut())
-			.await?;
+		let top_kv = self.load_top_remote(&mut pending_ext).await?;
+		let child_kv = self.load_child_remote(&top_kv, &mut pending_ext).await?;
 
 		if let Some(path) = self.as_online().state_snapshot.clone().map(|c| c.path) {
 			let snapshot = Snapshot::<B> {
@@ -930,23 +925,24 @@ where
 			Default::default(),
 			self.overwrite_state_version.unwrap_or(state_version),
 		);
-		let ext_overlay = inner_ext.overlayed_changes_mut();
 
-		info!(target: LOG_TARGET, "injecting {} top keys", top.len());
-		top.into_iter()
+		info!(target: LOG_TARGET, "injecting a total of {} top keys", top.len());
+		let top = top
+			.into_iter()
 			.filter(|(k, _)| !is_default_child_storage_key(k.as_ref()))
-			.for_each(|(k, v)| {
-				ext_overlay.set_storage(k.0, Some(v.0));
-			});
+			.map(|(k, v)| (k.0, v.0))
+			.collect::<Vec<_>>();
+		inner_ext.batch_insert(top);
 
 		info!(
 			target: LOG_TARGET,
-			"injecting {} child keys",
+			"injecting a total of {} child keys",
 			child.iter().flat_map(|(_, kv)| kv).count()
 		);
+
 		for (info, key_values) in child {
 			for (k, v) in key_values {
-				ext_overlay.set_child_storage(&info.clone(), k.0, Some(v.0));
+				inner_ext.insert_child(info.clone(), k.0, v.0);
 			}
 		}
 
@@ -964,7 +960,6 @@ where
 				}
 			},
 		};
-		let ext_overlay = ext.inner_ext.overlayed_changes_mut();
 
 		// inject manual key values.
 		if !self.hashed_key_values.is_empty() {
@@ -973,10 +968,7 @@ where
 				"extending externalities with {} manually injected key-values",
 				self.hashed_key_values.len()
 			);
-
-			self.hashed_key_values.into_iter().for_each(|(k, v)| {
-				ext_overlay.set_storage(k.0, Some(v.0));
-			});
+			ext.batch_insert(self.hashed_key_values.into_iter().map(|(k, v)| (k.0, v.0)));
 		}
 
 		// exclude manual key values.