subalfred-core 0.9.4

Subalfred's core libraries.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

//! Subalfred core runtime state library.

#[cfg(test)] mod test;

pub mod diff;
pub use diff::*;

pub mod export;
pub use export::*;

pub mod fork_off;
pub use fork_off::*;

pub mod insert;
pub use insert::*;

pub mod r#override;
pub use r#override::*;

// std
use std::{path::Path, thread};
// subalfred
use crate::{prelude::*, system};
use subspector::ChainSpec;

fn read_chain_spec_concurrent<P, P_>(a: P, b: P_) -> Result<(ChainSpec, ChainSpec)>
where
	P: Send + AsRef<Path>,
	P_: Send + AsRef<Path>,
{
	let (a, b) = thread::scope(|scope| {
		let a = scope.spawn(|| system::read_file_to_struct::<_, ChainSpec>(a));
		let b = scope.spawn(|| system::read_file_to_struct::<_, ChainSpec>(b));

		(a.join(), b.join())
	});

	Ok((a.map_err(error::quick_err)??, b.map_err(error::quick_err)??))
}

fn override_top(mut a: ChainSpec, b: ChainSpec) -> ChainSpec {
	let a_state = &mut a.genesis.raw.top;
	let b_state = b.genesis.raw.top;

	b_state.into_iter().for_each(|(k, v)| {
		a_state.insert(k, v);
	});

	a
}

fn write_to_custom_extension_file(
	base_path: &Path,
	file_extension: &str,
	chain_spec: ChainSpec,
) -> Result<()> {
	system::write_data_to_file(
		base_path.with_file_name(format!(
			"{}.{}",
			base_path
				.file_name()
				.expect(
					"[core::state] able to read the file in previous steps, thus never fails at this step; qed"
				)
				.to_string_lossy(),
			file_extension
		)),
		&serde_json::to_vec(&serde_json::to_value(chain_spec).map_err(error::Generic::Serde)?)
			.map_err(error::Generic::Serde)?,
	)
}