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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
use anyhow::Result;
use diem_types::{
account_address::AccountAddress,
account_config::diem_root_address,
on_chain_config::ReadWriteSetAnalysis,
transaction::{Script, WriteSetPayload},
};
use handlebars::Handlebars;
use move_compiler::{compiled_unit::AnnotatedCompiledUnit, Compiler, Flags};
use move_core_types::transaction_argument::TransactionArgument;
use read_write_set::analyze;
use serde::Serialize;
use std::{collections::HashMap, io::Write, path::PathBuf};
use tempfile::NamedTempFile;
pub const SCRIPTS_DIR_PATH: &str = "templates";
pub fn compile_script(source_file_str: String) -> Vec<u8> {
let (_files, mut compiled_program) =
Compiler::new(&[source_file_str], &diem_framework::diem_stdlib_files())
.set_flags(Flags::empty().set_sources_shadow_deps(false))
.set_named_address_values(diem_framework::diem_framework_named_addresses())
.build_and_report()
.unwrap();
assert!(compiled_program.len() == 1);
match compiled_program.pop().unwrap() {
AnnotatedCompiledUnit::Module(_) => panic!("Unexpected module when compiling script"),
x @ AnnotatedCompiledUnit::Script(_) => x.into_compiled_unit().serialize(),
}
}
fn compile_admin_script(input: &str) -> Result<Script> {
let mut temp_file = NamedTempFile::new()?;
temp_file.write_all(input.as_bytes())?;
let cur_path = temp_file.path().to_str().unwrap().to_owned();
Ok(Script::new(compile_script(cur_path), vec![], vec![]))
}
pub fn template_path() -> PathBuf {
let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
path.push(SCRIPTS_DIR_PATH.to_string());
path
}
pub fn encode_remove_validators_payload(validators: Vec<AccountAddress>) -> WriteSetPayload {
assert!(!validators.is_empty(), "Unexpected validator set length");
let mut script = template_path();
script.push("remove_validators.move");
let script = {
let mut hb = Handlebars::new();
hb.set_strict_mode(true);
hb.register_template_file("script", script).unwrap();
let mut data = HashMap::new();
data.insert("addresses", validators);
let output = hb.render("script", &data).unwrap();
compile_admin_script(output.as_str()).unwrap()
};
WriteSetPayload::Script {
script,
execute_as: diem_root_address(),
}
}
pub fn encode_custom_script<T: Serialize>(
script_name_in_templates: &str,
args: &T,
execute_as: Option<AccountAddress>,
) -> WriteSetPayload {
let mut script = template_path();
script.push(script_name_in_templates);
let script = {
let mut hb = Handlebars::new();
hb.register_template_file("script", script).unwrap();
hb.set_strict_mode(true);
let output = hb.render("script", args).unwrap();
compile_admin_script(output.as_str()).unwrap()
};
WriteSetPayload::Script {
script,
execute_as: execute_as.unwrap_or_else(diem_root_address),
}
}
pub fn encode_halt_network_payload() -> WriteSetPayload {
let mut script = template_path();
script.push("halt_transactions.move");
WriteSetPayload::Script {
script: Script::new(
compile_script(script.to_str().unwrap().to_owned()),
vec![],
vec![],
),
execute_as: diem_root_address(),
}
}
pub fn encode_initialize_parallel_execution() -> WriteSetPayload {
let mut script = template_path();
script.push("initialize_parallel_execution.move");
WriteSetPayload::Script {
script: Script::new(
compile_script(script.to_str().unwrap().to_owned()),
vec![],
vec![],
),
execute_as: diem_root_address(),
}
}
pub fn encode_disable_parallel_execution() -> WriteSetPayload {
let mut script = template_path();
script.push("disable_parallel_execution.move");
WriteSetPayload::Script {
script: Script::new(
compile_script(script.to_str().unwrap().to_owned()),
vec![],
vec![],
),
execute_as: diem_root_address(),
}
}
pub fn encode_enable_parallel_execution_with_config() -> WriteSetPayload {
let payload = bcs::to_bytes(&ReadWriteSetAnalysis::V1(
analyze(diem_framework_releases::current_modules())
.expect("Failed to get ReadWriteSet for current Diem Framework")
.normalize_all_scripts(diem_vm::read_write_set_analysis::add_on_functions_list())
.trim()
.into_inner(),
))
.expect("Failed to serialize analyze result");
let mut script = template_path();
script.push("update_parallel_execution_config.move");
WriteSetPayload::Script {
script: Script::new(
compile_script(script.to_str().unwrap().to_owned()),
vec![],
vec![TransactionArgument::U8Vector(payload)],
),
execute_as: diem_root_address(),
}
}