use crate::{
crate_metadata::CrateMetadata,
maybe_println,
util,
workspace::{
ManifestPath,
Workspace,
},
Network,
UnstableFlags,
Verbosity,
};
use anyhow::Result;
use blake2::digest::{
consts::U32,
Digest as _,
};
use colored::Colorize;
use contract_metadata::{
CodeHash,
Compiler,
Contract,
ContractMetadata,
Language,
Source,
SourceCompiler,
SourceLanguage,
SourceWasm,
User,
};
use semver::Version;
use std::{
fs,
path::{
Path,
PathBuf,
},
};
use url::Url;
const METADATA_FILE: &str = "metadata.json";
#[derive(serde::Serialize)]
pub struct MetadataResult {
pub dest_metadata: PathBuf,
pub dest_bundle: PathBuf,
}
struct ExtendedMetadataResult {
source: Source,
contract: Contract,
user: Option<User>,
}
pub(crate) fn execute(
crate_metadata: &CrateMetadata,
final_contract_wasm: &Path,
network: Network,
verbosity: Verbosity,
total_steps: usize,
unstable_options: &UnstableFlags,
) -> Result<MetadataResult> {
let target_directory = crate_metadata.target_directory.clone();
let out_path_metadata = target_directory.join(METADATA_FILE);
let fname_bundle = format!("{}.contract", crate_metadata.contract_artifact_name);
let out_path_bundle = target_directory.join(fname_bundle);
let ExtendedMetadataResult {
source,
contract,
user,
} = extended_metadata(crate_metadata, final_contract_wasm)?;
let generate_metadata = |manifest_path: &ManifestPath| -> Result<()> {
let mut current_progress = 4;
maybe_println!(
verbosity,
" {} {}",
format!("[{}/{}]", current_progress, total_steps).bold(),
"Generating metadata".bright_green().bold()
);
let target_dir_arg =
format!("--target-dir={}", target_directory.to_string_lossy());
let stdout = util::invoke_cargo(
"run",
&[
"--package",
"metadata-gen",
&manifest_path.cargo_arg()?,
&target_dir_arg,
"--release",
&network.to_string(),
],
crate_metadata.manifest_path.directory(),
verbosity,
vec![],
)?;
let ink_meta: serde_json::Map<String, serde_json::Value> =
serde_json::from_slice(&stdout)?;
let metadata = ContractMetadata::new(source, contract, user, ink_meta);
{
let mut metadata = metadata.clone();
metadata.remove_source_wasm_attribute();
let contents = serde_json::to_string_pretty(&metadata)?;
fs::write(&out_path_metadata, contents)?;
current_progress += 1;
}
maybe_println!(
verbosity,
" {} {}",
format!("[{}/{}]", current_progress, total_steps).bold(),
"Generating bundle".bright_green().bold()
);
let contents = serde_json::to_string(&metadata)?;
fs::write(&out_path_bundle, contents)?;
Ok(())
};
if unstable_options.original_manifest {
generate_metadata(&crate_metadata.manifest_path)?;
} else {
Workspace::new(&crate_metadata.cargo_meta, &crate_metadata.root_package.id)?
.with_root_package_manifest(|manifest| {
manifest
.with_added_crate_type("rlib")?
.with_profile_release_lto(false)?;
Ok(())
})?
.with_metadata_gen_package(
crate_metadata.manifest_path.absolute_directory()?,
)?
.using_temp(generate_metadata)?;
}
Ok(MetadataResult {
dest_metadata: out_path_metadata,
dest_bundle: out_path_bundle,
})
}
fn extended_metadata(
crate_metadata: &CrateMetadata,
final_contract_wasm: &Path,
) -> Result<ExtendedMetadataResult> {
let contract_package = &crate_metadata.root_package;
let ink_version = &crate_metadata.ink_version;
let rust_version = Version::parse(&rustc_version::version()?.to_string())?;
let contract_name = contract_package.name.clone();
let contract_version = Version::parse(&contract_package.version.to_string())?;
let contract_authors = contract_package.authors.clone();
let description = contract_package.description.clone();
let documentation = crate_metadata.documentation.clone();
let repository = contract_package
.repository
.as_ref()
.map(|repo| Url::parse(repo))
.transpose()?;
let homepage = crate_metadata.homepage.clone();
let license = contract_package.license.clone();
let source = {
let lang = SourceLanguage::new(Language::Ink, ink_version.clone());
let compiler = SourceCompiler::new(Compiler::RustC, rust_version);
let wasm = fs::read(final_contract_wasm)?;
let hash = blake2_hash(wasm.as_slice());
Source::new(Some(SourceWasm::new(wasm)), hash, lang, compiler)
};
let mut builder = Contract::builder();
builder
.name(contract_name)
.version(contract_version)
.authors(contract_authors);
if let Some(description) = description {
builder.description(description);
}
if let Some(documentation) = documentation {
builder.documentation(documentation);
}
if let Some(repository) = repository {
builder.repository(repository);
}
if let Some(homepage) = homepage {
builder.homepage(homepage);
}
if let Some(license) = license {
builder.license(license);
}
let contract = builder.build().map_err(|err| {
anyhow::anyhow!("Invalid contract metadata builder state: {}", err)
})?;
let user = crate_metadata.user.clone().map(User::new);
Ok(ExtendedMetadataResult {
source,
contract,
user,
})
}
fn blake2_hash(code: &[u8]) -> CodeHash {
let mut blake2 = blake2::Blake2b::<U32>::new();
blake2.update(code);
let result = blake2.finalize();
CodeHash(result.into())
}
#[cfg(feature = "test-ci-only")]
#[cfg(test)]
mod tests {
use crate::{
cmd,
cmd::metadata::blake2_hash,
crate_metadata::CrateMetadata,
util::tests::with_new_contract_project,
ManifestPath,
};
use anyhow::Context;
use contract_metadata::*;
use serde_json::{
Map,
Value,
};
use std::{
fmt::Write,
fs,
};
use toml::value;
struct TestContractManifest {
toml: value::Table,
manifest_path: ManifestPath,
}
impl TestContractManifest {
fn new(manifest_path: ManifestPath) -> anyhow::Result<Self> {
Ok(Self {
toml: toml::from_slice(&fs::read(&manifest_path)?)?,
manifest_path,
})
}
fn package_mut(&mut self) -> anyhow::Result<&mut value::Table> {
self.toml
.get_mut("package")
.context("package section not found")?
.as_table_mut()
.context("package section should be a table")
}
fn add_user_metadata_value(
&mut self,
key: &'static str,
value: value::Value,
) -> anyhow::Result<()> {
self.package_mut()?
.entry("metadata")
.or_insert(value::Value::Table(Default::default()))
.as_table_mut()
.context("metadata section should be a table")?
.entry("contract")
.or_insert(value::Value::Table(Default::default()))
.as_table_mut()
.context("metadata.contract section should be a table")?
.entry("user")
.or_insert(value::Value::Table(Default::default()))
.as_table_mut()
.context("metadata.contract.user section should be a table")?
.insert(key.into(), value);
Ok(())
}
fn add_package_value(
&mut self,
key: &'static str,
value: value::Value,
) -> anyhow::Result<()> {
self.package_mut()?.insert(key.into(), value);
Ok(())
}
fn write(&self) -> anyhow::Result<()> {
let toml = toml::to_string(&self.toml)?;
fs::write(&self.manifest_path, toml).map_err(Into::into)
}
}
#[test]
fn generate_metadata() {
crate::util::tests::init_tracing_subscriber();
with_new_contract_project(|manifest_path| {
let mut test_manifest = TestContractManifest::new(manifest_path)?;
test_manifest
.add_package_value("description", "contract description".into())?;
test_manifest
.add_package_value("documentation", "http://documentation.com".into())?;
test_manifest
.add_package_value("repository", "http://repository.com".into())?;
test_manifest.add_package_value("homepage", "http://homepage.com".into())?;
test_manifest.add_package_value("license", "Apache-2.0".into())?;
test_manifest.add_user_metadata_value(
"some-user-provided-field",
"and-its-value".into(),
)?;
test_manifest.add_user_metadata_value(
"more-user-provided-fields",
vec!["and", "their", "values"].into(),
)?;
test_manifest.write()?;
let crate_metadata = CrateMetadata::collect(&test_manifest.manifest_path)?;
let final_contract_wasm_path = &crate_metadata.dest_wasm;
fs::create_dir_all(final_contract_wasm_path.parent().unwrap()).unwrap();
fs::write(final_contract_wasm_path, "TEST FINAL WASM BLOB").unwrap();
let mut args = crate::cmd::build::ExecuteArgs::default();
args.manifest_path = test_manifest.manifest_path;
let build_result = cmd::build::execute(args)?;
let dest_bundle = build_result
.metadata_result
.expect("Metadata should be generated")
.dest_bundle;
let metadata_json: Map<String, Value> =
serde_json::from_slice(&fs::read(&dest_bundle)?)?;
assert!(
dest_bundle.exists(),
"Missing metadata file '{}'",
dest_bundle.display()
);
let source = metadata_json.get("source").expect("source not found");
let hash = source.get("hash").expect("source.hash not found");
let language = source.get("language").expect("source.language not found");
let compiler = source.get("compiler").expect("source.compiler not found");
let wasm = source.get("wasm").expect("source.wasm not found");
let contract = metadata_json.get("contract").expect("contract not found");
let name = contract.get("name").expect("contract.name not found");
let version = contract.get("version").expect("contract.version not found");
let authors = contract
.get("authors")
.expect("contract.authors not found")
.as_array()
.expect("contract.authors is an array")
.iter()
.map(|author| author.as_str().expect("author is a string"))
.collect::<Vec<_>>();
let description = contract
.get("description")
.expect("contract.description not found");
let documentation = contract
.get("documentation")
.expect("contract.documentation not found");
let repository = contract
.get("repository")
.expect("contract.repository not found");
let homepage = contract
.get("homepage")
.expect("contract.homepage not found");
let license = contract.get("license").expect("contract.license not found");
let user = metadata_json.get("user").expect("user section not found");
let fs_wasm = fs::read(&crate_metadata.dest_wasm)?;
let expected_hash = blake2_hash(&fs_wasm[..]);
let expected_wasm = build_byte_str(&fs_wasm);
let expected_language =
SourceLanguage::new(Language::Ink, crate_metadata.ink_version)
.to_string();
let expected_rustc_version =
semver::Version::parse(&rustc_version::version()?.to_string())?;
let expected_compiler =
SourceCompiler::new(Compiler::RustC, expected_rustc_version).to_string();
let mut expected_user_metadata = serde_json::Map::new();
expected_user_metadata
.insert("some-user-provided-field".into(), "and-its-value".into());
expected_user_metadata.insert(
"more-user-provided-fields".into(),
serde_json::Value::Array(vec![
"and".into(),
"their".into(),
"values".into(),
]),
);
assert_eq!(build_byte_str(&expected_hash.0[..]), hash.as_str().unwrap());
assert_eq!(expected_wasm, wasm.as_str().unwrap());
assert_eq!(expected_language, language.as_str().unwrap());
assert_eq!(expected_compiler, compiler.as_str().unwrap());
assert_eq!(
crate_metadata.contract_artifact_name,
name.as_str().unwrap()
);
assert_eq!(
crate_metadata.root_package.version.to_string(),
version.as_str().unwrap()
);
assert_eq!(crate_metadata.root_package.authors, authors);
assert_eq!("contract description", description.as_str().unwrap());
assert_eq!("http://documentation.com/", documentation.as_str().unwrap());
assert_eq!("http://repository.com/", repository.as_str().unwrap());
assert_eq!("http://homepage.com/", homepage.as_str().unwrap());
assert_eq!("Apache-2.0", license.as_str().unwrap());
assert_eq!(&expected_user_metadata, user.as_object().unwrap());
Ok(())
})
}
fn build_byte_str(bytes: &[u8]) -> String {
let mut str = String::new();
write!(str, "0x").expect("failed writing to string");
for byte in bytes {
write!(str, "{:02x}", byte).expect("failed writing to string");
}
str
}
}