abc4c3989b
- Remove nightly-only features from .rustfmt.toml and vendor/ss58-registry/rustfmt.toml - Removed features: imports_granularity, wrap_comments, comment_width, reorder_impl_items, spaces_around_ranges, binop_separator, match_arm_blocks, trailing_semicolon, trailing_comma - Format all 898 affected files with stable rustfmt - Ensures long-term reliability without nightly toolchain dependency
315 lines
9.2 KiB
Rust
315 lines
9.2 KiB
Rust
// Copyright (C) 2021-2022 Parity Technologies (UK) Ltd.
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
//! Enumerations of well-known SS58 account types and tokens used in the Polkadot ecosystem.
|
|
use proc_macro2::Ident;
|
|
use quote::{format_ident, quote};
|
|
use serde::Deserialize;
|
|
use std::{
|
|
collections::{btree_map::Entry, BTreeMap, HashMap},
|
|
env, fs,
|
|
path::Path,
|
|
};
|
|
use unicode_xid::UnicodeXID;
|
|
|
|
#[derive(Deserialize)]
|
|
struct Registry {
|
|
#[serde(rename = "registry")]
|
|
accounts: Vec<AccountType>,
|
|
}
|
|
|
|
fn is_valid_rust_identifier(id: &str) -> Result<(), String> {
|
|
if let Some(ch) = id.chars().next() {
|
|
if ch.is_xid_start() {
|
|
for ch in id.chars().skip(1) {
|
|
if !ch.is_xid_continue() {
|
|
return Err(format!("Invalid char `{ch}` in `{id}`"));
|
|
}
|
|
}
|
|
Ok(())
|
|
} else {
|
|
Err(format!("`{id}` starts with `{ch}` which is not valid at the start"))
|
|
}
|
|
} else {
|
|
Err("empty identifier".into())
|
|
}
|
|
}
|
|
|
|
impl Registry {
|
|
pub fn validate(self) -> Result<(Vec<AccountType>, Vec<TokenType>), String> {
|
|
let mut tokens = BTreeMap::<String, TokenType>::new();
|
|
let mut used_prefixes = HashMap::<u16, AccountType>::new();
|
|
let mut used_networks = HashMap::<String, AccountType>::new();
|
|
for account_type in &self.accounts {
|
|
if let Some(clash) = used_prefixes.insert(account_type.prefix, (*account_type).clone())
|
|
{
|
|
return Err(format!(
|
|
"prefixes must be unique but this account's prefix:\n{account_type:#?}\nclashed with\n{clash:#?}"
|
|
));
|
|
}
|
|
if let Some(clash) = used_networks.insert(account_type.name(), account_type.clone()) {
|
|
return Err(format!(
|
|
"networks must be unique but this account's network:\n{account_type:#?}\nclashed with\n:{clash:#?}"
|
|
));
|
|
}
|
|
if account_type.network.is_empty() {
|
|
return Err("network is mandatory.".into());
|
|
}
|
|
|
|
if let Err(err) = is_valid_rust_identifier(&account_type.name()) {
|
|
return Err(format!("network not valid: {err} for {account_type:#?}"));
|
|
}
|
|
if account_type.decimals.len() != account_type.symbols.len() {
|
|
return Err(format!(
|
|
"decimals must be specified for each symbol: {account_type:?}"
|
|
));
|
|
}
|
|
for (name, decimals) in account_type.symbols.iter().zip(&account_type.decimals) {
|
|
use Entry::*;
|
|
let network = account_type.display_name.clone();
|
|
match tokens.entry(name.to_owned()) {
|
|
Occupied(mut e) => {
|
|
if e.get().decimals != *decimals {
|
|
return Err(format!(
|
|
"Inconsistent decimals specified for token {}.\nPrevious networks: {}\nCurrent network: {}",
|
|
name,
|
|
e.get().networks.join(", "),
|
|
network,
|
|
));
|
|
}
|
|
e.get_mut().networks.push(network);
|
|
},
|
|
Vacant(e) => {
|
|
e.insert(TokenType {
|
|
symbol: name.to_owned(),
|
|
decimals: *decimals,
|
|
networks: vec![network],
|
|
});
|
|
},
|
|
}
|
|
}
|
|
}
|
|
let tokens = tokens.into_values().collect();
|
|
Ok((self.accounts, tokens))
|
|
}
|
|
}
|
|
|
|
#[derive(Deserialize, Debug, Clone, Copy)]
|
|
enum SignatureType {
|
|
#[serde(rename = "Sr25519")]
|
|
Sr25519,
|
|
#[serde(rename = "Ed25519")]
|
|
Ed25519,
|
|
#[serde(rename = "secp256k1")]
|
|
Secp256k1,
|
|
#[serde(rename = "*25519")]
|
|
Any25519,
|
|
}
|
|
|
|
#[derive(Deserialize, Debug, Clone)]
|
|
#[serde(rename_all = "camelCase")]
|
|
struct AccountType {
|
|
prefix: u16,
|
|
network: String,
|
|
display_name: String,
|
|
/// If standard account is None then the network is reserved.
|
|
standard_account: Option<SignatureType>,
|
|
symbols: Vec<String>,
|
|
decimals: Vec<u8>,
|
|
website: Option<String>,
|
|
}
|
|
|
|
impl AccountType {
|
|
fn name(&self) -> String {
|
|
format!("{}Account", inflector::cases::pascalcase::to_pascal_case(&self.network))
|
|
}
|
|
|
|
fn tokens(&self) -> impl Iterator<Item = Ident> + '_ {
|
|
self.symbols.iter().map(|s| token_symbol_to_variant(s))
|
|
}
|
|
|
|
fn is_reserved(&self) -> bool {
|
|
self.standard_account.is_none()
|
|
}
|
|
}
|
|
|
|
fn token_symbol_to_variant(symbol: &str) -> Ident {
|
|
format_ident!("{}", inflector::cases::pascalcase::to_pascal_case(symbol))
|
|
}
|
|
|
|
#[derive(Debug)]
|
|
struct TokenType {
|
|
symbol: String,
|
|
decimals: u8,
|
|
networks: Vec<String>,
|
|
}
|
|
|
|
impl TokenType {
|
|
fn doc_string(&self) -> String {
|
|
format!("{} token used on {}", self.symbol, self.networks.join(", "))
|
|
}
|
|
}
|
|
|
|
fn consecutive_runs(data: &[u16]) -> (Vec<u16>, Vec<u16>) {
|
|
let mut slice_start = 0_u16;
|
|
let (mut starts, mut ends) = (Vec::new(), Vec::new());
|
|
for i in 1..data.len() {
|
|
if data[i - 1] + 1 != data[i] {
|
|
starts.push(slice_start);
|
|
ends.push(data[i - 1]);
|
|
slice_start = data[i];
|
|
}
|
|
}
|
|
if !data.is_empty() {
|
|
starts.push(slice_start);
|
|
ends.push(data[data.len() - 1]);
|
|
}
|
|
(starts, ends)
|
|
}
|
|
|
|
fn create_ss58_registry(json: &str) -> Result<proc_macro2::TokenStream, String> {
|
|
let registry: Registry =
|
|
serde_json::from_str(json).map_err(|e| format!("json parsing error: {e}"))?;
|
|
|
|
let (mut accounts, tokens) = registry.validate()?;
|
|
|
|
// Sort by name so that we can later binary search by network
|
|
accounts.sort_by_key(|a| a.network.clone());
|
|
|
|
// Variables to insert into quote template:
|
|
let identifier: Vec<_> = accounts.iter().map(|r| format_ident!("{}", r.name())).collect();
|
|
|
|
let count = accounts.len();
|
|
let prefix: Vec<_> = accounts.iter().map(|r| r.prefix).collect();
|
|
|
|
let name = accounts.iter().map(|r| r.network.clone());
|
|
let desc = accounts.iter().map(|r| {
|
|
if let Some(website) = &r.website {
|
|
format!("{} - <{}>", r.display_name, website)
|
|
} else {
|
|
r.display_name.clone()
|
|
}
|
|
});
|
|
|
|
let mut prefix_to_idx: Vec<_> = prefix.iter().enumerate().map(|(a, b)| (b, a)).collect();
|
|
prefix_to_idx.sort_by_key(|(prefix, _)| *prefix);
|
|
let prefix_to_idx = prefix_to_idx.iter().map(|(prefix, idx)| quote! { (#prefix, #idx) });
|
|
|
|
let ident_to_tokens: Vec<_> = accounts
|
|
.iter()
|
|
.map(|r| {
|
|
let t = r.tokens();
|
|
quote! { #( TokenRegistry::#t ,)* }
|
|
})
|
|
.collect();
|
|
|
|
let reserved_prefixes = accounts.iter().filter(|r| r.is_reserved()).map(|r| r.prefix);
|
|
|
|
let mut ordered_prefixes = accounts.iter().map(|i| i.prefix).collect::<Vec<_>>();
|
|
ordered_prefixes.sort_unstable();
|
|
let (prefix_starts, prefix_ends) = consecutive_runs(ordered_prefixes.as_slice());
|
|
|
|
let token_defs: Vec<_> = tokens.iter().map(|t| token_symbol_to_variant(&t.symbol)).collect();
|
|
let token_names = tokens.iter().map(|t| t.symbol.to_owned());
|
|
let token_docs = tokens.iter().map(|t| t.doc_string());
|
|
let token_decimals = tokens.iter().map(|t| t.decimals);
|
|
|
|
Ok(quote! {
|
|
/// A known address (sub)format/network ID for SS58.
|
|
#[non_exhaustive]
|
|
#[repr(u16)]
|
|
#[derive(Copy, Clone, PartialEq, Eq, Debug)]
|
|
pub enum Ss58AddressFormatRegistry {
|
|
#(#[doc = #desc] #identifier = #prefix),*,
|
|
}
|
|
|
|
/// All non-custom address formats (Sorted by network)
|
|
pub(crate) static ALL_SS58_ADDRESS_FORMATS: [Ss58AddressFormatRegistry; #count] = [
|
|
#(Ss58AddressFormatRegistry::#identifier),*,
|
|
];
|
|
|
|
/// Names of all address formats (Sorted by network)
|
|
pub(crate) static ALL_SS58_ADDRESS_FORMAT_NAMES: [&str; #count] = [
|
|
#(#name),*,
|
|
];
|
|
|
|
/// (Sorted) prefixes to index of ALL_SS58_ADDRESS_FORMATS
|
|
pub(crate) static PREFIX_TO_INDEX: [(u16, usize); #count] = [
|
|
#(#prefix_to_idx),*,
|
|
];
|
|
|
|
impl Ss58AddressFormatRegistry {
|
|
/// Tokens used on the given network.
|
|
pub fn tokens(&self) -> &'static[TokenRegistry] {
|
|
match self {
|
|
#(Ss58AddressFormatRegistry::#identifier => &[#ident_to_tokens],)*
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
impl Ss58AddressFormat {
|
|
/// Network/AddressType is reserved for future use.
|
|
pub fn is_reserved(&self) -> bool {
|
|
self.prefix() > 16384 || matches!(self.prefix(), #(#reserved_prefixes)|*)
|
|
}
|
|
|
|
/// A custom format is one that is not already known.
|
|
pub fn is_custom(&self) -> bool {
|
|
// A match is faster than bin search
|
|
// as most hits will be in the first group.
|
|
!matches!(self.prefix(), #(#prefix_starts..=#prefix_ends)|*)
|
|
}
|
|
}
|
|
|
|
/// List of well-known tokens used on some network in the ecosystem.
|
|
#[non_exhaustive]
|
|
#[derive(Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]
|
|
pub enum TokenRegistry {
|
|
#(#[doc = #token_docs]
|
|
#token_defs,)*
|
|
}
|
|
|
|
impl From<TokenRegistry> for Token {
|
|
fn from(x: TokenRegistry) -> Self {
|
|
match x {
|
|
#(TokenRegistry::#token_defs => Token { name: #token_names, decimals: #token_decimals },)*
|
|
}
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
fn main() {
|
|
println!("cargo:rerun-if-changed=build.rs");
|
|
println!("cargo:rerun-if-changed=ss58-registry.json");
|
|
|
|
let out_dir = env::var_os("OUT_DIR").expect("OUT_DIR should exist");
|
|
|
|
let code = match create_ss58_registry(include_str!("ss58-registry.json")) {
|
|
Ok(result) => result.to_string(),
|
|
Err(msg) => {
|
|
eprintln!("failed to generate code from json: {msg}");
|
|
std::process::exit(-1);
|
|
},
|
|
};
|
|
|
|
let dest_path = Path::new(&out_dir).join("registry_gen.rs");
|
|
if let Err(err) = fs::write(&dest_path, code) {
|
|
eprintln!("failed to write generated code to {}: {err}", &dest_path.display());
|
|
std::process::exit(-1);
|
|
}
|
|
}
|