#![cfg_attr(not(feature = "std"), no_std)]
extern crate alloc;
#[cfg(any(feature = "std", feature = "serde"))]
use alloc::fmt;
#[cfg(feature = "serde")]
use serde::{Deserialize, Serialize};
#[cfg(feature = "std")]
use std::collections::HashSet;
#[doc(hidden)]
pub use alloc::borrow::Cow;
use codec::{Decode, Encode, Input};
use scale_info::TypeInfo;
#[allow(deprecated)]
pub use sp_runtime::{create_runtime_str, StateVersion};
#[doc(hidden)]
pub use sp_std;
#[cfg(feature = "std")]
use sp_core::traits::CallContext;
#[cfg(feature = "std")]
use sp_runtime::traits::Block as BlockT;
#[cfg(feature = "std")]
pub mod embed;
pub use sp_version_proc_macro::runtime_version;
pub type ApiId = [u8; 8];
pub type ApisVec = alloc::borrow::Cow<'static, [(ApiId, u32)]>;
#[macro_export]
macro_rules! create_apis_vec {
( $y:expr ) => {
$crate::Cow::Borrowed(&$y)
};
}
#[derive(Clone, PartialEq, Eq, Encode, Default, Debug, TypeInfo)]
pub struct RuntimeVersion {
pub spec_name: Cow<'static, str>,
pub impl_name: Cow<'static, str>,
pub authoring_version: u32,
pub spec_version: u32,
pub impl_version: u32,
pub apis: ApisVec,
pub transaction_version: u32,
pub system_version: u8,
}
#[cfg(feature = "serde")]
impl serde::Serialize for RuntimeVersion {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut state = serializer.serialize_struct("RuntimeVersion", 9)?;
state.serialize_field("specName", &self.spec_name)?;
state.serialize_field("implName", &self.impl_name)?;
state.serialize_field("authoringVersion", &self.authoring_version)?;
state.serialize_field("specVersion", &self.spec_version)?;
state.serialize_field("implVersion", &self.impl_version)?;
state.serialize_field("apis", {
struct SerializeWith<'a>(&'a ApisVec);
impl<'a> serde::Serialize for SerializeWith<'a> {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
apis_serialize::serialize(self.0, serializer)
}
}
&SerializeWith(&self.apis)
})?;
state.serialize_field("transactionVersion", &self.transaction_version)?;
state.serialize_field("systemVersion", &self.system_version)?;
state.serialize_field("stateVersion", &self.system_version)?;
state.end()
}
}
#[cfg(feature = "serde")]
impl<'de> serde::Deserialize<'de> for RuntimeVersion {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
use core::marker::PhantomData;
enum Field {
SpecName,
ImplName,
AuthoringVersion,
SpecVersion,
ImplVersion,
Apis,
TransactionVersion,
SystemVersion,
Ignore,
}
struct FieldVisitor;
impl<'de> serde::de::Visitor<'de> for FieldVisitor {
type Value = Field;
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
formatter.write_str("field identifier")
}
fn visit_u64<E>(self, value: u64) -> Result<Self::Value, E>
where
E: serde::de::Error,
{
match value {
0 => Ok(Field::SpecName),
1 => Ok(Field::ImplName),
2 => Ok(Field::AuthoringVersion),
3 => Ok(Field::SpecVersion),
4 => Ok(Field::ImplVersion),
5 => Ok(Field::Apis),
6 => Ok(Field::TransactionVersion),
7 => Ok(Field::SystemVersion),
_ => Ok(Field::Ignore),
}
}
fn visit_str<E>(self, value: &str) -> Result<Self::Value, E>
where
E: serde::de::Error,
{
match value {
"specName" => Ok(Field::SpecName),
"implName" => Ok(Field::ImplName),
"authoringVersion" => Ok(Field::AuthoringVersion),
"specVersion" => Ok(Field::SpecVersion),
"implVersion" => Ok(Field::ImplVersion),
"apis" => Ok(Field::Apis),
"transactionVersion" => Ok(Field::TransactionVersion),
"systemVersion" | "stateVersion" => Ok(Field::SystemVersion),
_ => Ok(Field::Ignore),
}
}
fn visit_bytes<E>(self, value: &[u8]) -> Result<Self::Value, E>
where
E: serde::de::Error,
{
match value {
b"specName" => Ok(Field::SpecName),
b"implName" => Ok(Field::ImplName),
b"authoringVersion" => Ok(Field::AuthoringVersion),
b"specVersion" => Ok(Field::SpecVersion),
b"implVersion" => Ok(Field::ImplVersion),
b"apis" => Ok(Field::Apis),
b"transactionVersion" => Ok(Field::TransactionVersion),
b"systemVersion" | b"stateVersion" => Ok(Field::SystemVersion),
_ => Ok(Field::Ignore),
}
}
}
impl<'de> serde::Deserialize<'de> for Field {
#[inline]
fn deserialize<E>(deserializer: E) -> Result<Self, E::Error>
where
E: serde::Deserializer<'de>,
{
deserializer.deserialize_identifier(FieldVisitor)
}
}
struct Visitor<'de> {
lifetime: PhantomData<&'de ()>,
}
impl<'de> serde::de::Visitor<'de> for Visitor<'de> {
type Value = RuntimeVersion;
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
formatter.write_str("struct RuntimeVersion")
}
#[inline]
fn visit_seq<A>(self, mut seq: A) -> Result<Self::Value, A::Error>
where
A: serde::de::SeqAccess<'de>,
{
let spec_name = match seq.next_element()? {
Some(spec_name) => spec_name,
None => {
return Err(serde::de::Error::invalid_length(
0usize,
&"struct RuntimeVersion with 8 elements",
))
},
};
let impl_name = match seq.next_element()? {
Some(impl_name) => impl_name,
None => {
return Err(serde::de::Error::invalid_length(
1usize,
&"struct RuntimeVersion with 8 elements",
))
},
};
let authoring_version = match seq.next_element()? {
Some(authoring_version) => authoring_version,
None => {
return Err(serde::de::Error::invalid_length(
2usize,
&"struct RuntimeVersion with 8 elements",
))
},
};
let spec_version = match seq.next_element()? {
Some(spec_version) => spec_version,
None => {
return Err(serde::de::Error::invalid_length(
3usize,
&"struct RuntimeVersion with 8 elements",
))
},
};
let impl_version = match seq.next_element()? {
Some(impl_version) => impl_version,
None => {
return Err(serde::de::Error::invalid_length(
4usize,
&"struct RuntimeVersion with 8 elements",
))
},
};
let apis = match {
struct DeserializeWith<'de> {
value: ApisVec,
phantom: PhantomData<RuntimeVersion>,
lifetime: PhantomData<&'de ()>,
}
impl<'de> serde::Deserialize<'de> for DeserializeWith<'de> {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
Ok(DeserializeWith {
value: apis_serialize::deserialize(deserializer)?,
phantom: PhantomData,
lifetime: PhantomData,
})
}
}
seq.next_element::<DeserializeWith<'de>>()?.map(|wrap| wrap.value)
} {
Some(apis) => apis,
None => {
return Err(serde::de::Error::invalid_length(
5usize,
&"struct RuntimeVersion with 8 elements",
))
},
};
let transaction_version = match seq.next_element()? {
Some(transaction_version) => transaction_version,
None => {
return Err(serde::de::Error::invalid_length(
6usize,
&"struct RuntimeVersion with 8 elements",
))
},
};
let system_version = match seq.next_element()? {
Some(system_version) => system_version,
None => {
return Err(serde::de::Error::invalid_length(
7usize,
&"struct RuntimeVersion with 8 elements",
))
},
};
Ok(RuntimeVersion {
spec_name,
impl_name,
authoring_version,
spec_version,
impl_version,
apis,
transaction_version,
system_version,
})
}
#[inline]
fn visit_map<A>(self, mut map: A) -> Result<Self::Value, A::Error>
where
A: serde::de::MapAccess<'de>,
{
let mut spec_name: Option<Cow<'static, str>> = None;
let mut impl_name: Option<Cow<'static, str>> = None;
let mut authoring_version: Option<u32> = None;
let mut spec_version: Option<u32> = None;
let mut impl_version: Option<u32> = None;
let mut apis: Option<ApisVec> = None;
let mut transaction_version: Option<u32> = None;
let mut system_version: Option<u8> = None;
while let Some(key) = map.next_key()? {
match key {
Field::SpecName => {
if spec_name.is_some() {
return Err(<A::Error as serde::de::Error>::duplicate_field(
"specName",
));
}
spec_name = Some(map.next_value()?);
},
Field::ImplName => {
if impl_name.is_some() {
return Err(<A::Error as serde::de::Error>::duplicate_field(
"implName",
));
}
impl_name = Some(map.next_value()?);
},
Field::AuthoringVersion => {
if authoring_version.is_some() {
return Err(<A::Error as serde::de::Error>::duplicate_field(
"authoringVersion",
));
}
authoring_version = Some(map.next_value()?);
},
Field::SpecVersion => {
if spec_version.is_some() {
return Err(<A::Error as serde::de::Error>::duplicate_field(
"specVersion",
));
}
spec_version = Some(map.next_value()?);
},
Field::ImplVersion => {
if impl_version.is_some() {
return Err(<A::Error as serde::de::Error>::duplicate_field(
"implVersion",
));
}
impl_version = Some(map.next_value()?);
},
Field::Apis => {
if apis.is_some() {
return Err(<A::Error as serde::de::Error>::duplicate_field(
"apis",
));
}
apis = Some({
struct DeserializeWith<'de> {
value: ApisVec,
lifetime: PhantomData<&'de ()>,
}
impl<'de> serde::Deserialize<'de> for DeserializeWith<'de> {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
Ok(DeserializeWith {
value: apis_serialize::deserialize(deserializer)?,
lifetime: PhantomData,
})
}
}
map.next_value::<DeserializeWith<'de>>()?.value
});
},
Field::TransactionVersion => {
if transaction_version.is_some() {
return Err(<A::Error as serde::de::Error>::duplicate_field(
"transactionVersion",
));
}
transaction_version = Some(map.next_value()?);
},
Field::SystemVersion => {
if let Some(system_version) = system_version {
let new_value = map.next_value::<u8>()?;
if system_version != new_value {
return Err(<A::Error as serde::de::Error>::custom(
alloc::format!(
r#"Duplicated "stateVersion" and "systemVersion" \
fields must have the same value, but different values \
were provided: {system_version} vs {new_value}"#
),
));
}
} else {
system_version = Some(map.next_value()?);
}
},
_ => {
map.next_value::<serde::de::IgnoredAny>()?;
},
}
}
let spec_name = spec_name
.ok_or_else(|| <A::Error as serde::de::Error>::missing_field("specName"))?;
let impl_name = impl_name
.ok_or_else(|| <A::Error as serde::de::Error>::missing_field("implName"))?;
let authoring_version = authoring_version.ok_or_else(|| {
<A::Error as serde::de::Error>::missing_field("authoringVersion")
})?;
let spec_version = spec_version
.ok_or_else(|| <A::Error as serde::de::Error>::missing_field("specVersion"))?;
let impl_version = impl_version
.ok_or_else(|| <A::Error as serde::de::Error>::missing_field("implVersion"))?;
let apis =
apis.ok_or_else(|| <A::Error as serde::de::Error>::missing_field("apis"))?;
let transaction_version = transaction_version.ok_or_else(|| {
<A::Error as serde::de::Error>::missing_field("transactionVersion")
})?;
let system_version = system_version.ok_or_else(|| {
<A::Error as serde::de::Error>::missing_field("systemVersion")
})?;
Ok(RuntimeVersion {
spec_name,
impl_name,
authoring_version,
spec_version,
impl_version,
apis,
transaction_version,
system_version,
})
}
}
const FIELDS: &[&str] = &[
"specName",
"implName",
"authoringVersion",
"specVersion",
"implVersion",
"apis",
"transactionVersion",
"stateVersion",
"systemVersion",
];
deserializer.deserialize_struct("RuntimeVersion", FIELDS, Visitor { lifetime: PhantomData })
}
}
impl RuntimeVersion {
pub fn decode_with_version_hint<I: Input>(
input: &mut I,
core_version: Option<u32>,
) -> Result<RuntimeVersion, codec::Error> {
let spec_name = Decode::decode(input)?;
let impl_name = Decode::decode(input)?;
let authoring_version = Decode::decode(input)?;
let spec_version = Decode::decode(input)?;
let impl_version = Decode::decode(input)?;
let apis = Decode::decode(input)?;
let core_version =
if core_version.is_some() { core_version } else { core_version_from_apis(&apis) };
let transaction_version =
if core_version.map(|v| v >= 3).unwrap_or(false) { Decode::decode(input)? } else { 1 };
let system_version =
if core_version.map(|v| v >= 4).unwrap_or(false) { Decode::decode(input)? } else { 0 };
Ok(RuntimeVersion {
spec_name,
impl_name,
authoring_version,
spec_version,
impl_version,
apis,
transaction_version,
system_version,
})
}
}
impl Decode for RuntimeVersion {
fn decode<I: Input>(input: &mut I) -> Result<Self, codec::Error> {
Self::decode_with_version_hint(input, None)
}
}
#[cfg(feature = "std")]
impl fmt::Display for RuntimeVersion {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(
f,
"{}-{} ({}-{}.tx{}.au{})",
self.spec_name,
self.spec_version,
self.impl_name,
self.impl_version,
self.transaction_version,
self.authoring_version,
)
}
}
#[cfg(feature = "std")]
fn has_api_with<P: Fn(u32) -> bool>(apis: &ApisVec, id: &ApiId, predicate: P) -> bool {
apis.iter().any(|(s, v)| s == id && predicate(*v))
}
pub fn core_version_from_apis(apis: &ApisVec) -> Option<u32> {
let id = sp_crypto_hashing_proc_macro::blake2b_64!(b"Core");
apis.iter().find(|(s, _v)| s == &id).map(|(_s, v)| *v)
}
#[cfg(feature = "std")]
impl RuntimeVersion {
pub fn can_call_with(&self, other: &RuntimeVersion) -> bool {
self.spec_version == other.spec_version &&
self.spec_name == other.spec_name &&
self.authoring_version == other.authoring_version
}
pub fn has_api_with<P: Fn(u32) -> bool>(&self, id: &ApiId, predicate: P) -> bool {
has_api_with(&self.apis, id, predicate)
}
pub fn api_version(&self, id: &ApiId) -> Option<u32> {
self.apis.iter().find_map(|a| (a.0 == *id).then(|| a.1))
}
}
impl RuntimeVersion {
pub fn state_version(&self) -> StateVersion {
self.system_version.try_into().unwrap_or(StateVersion::V1)
}
pub fn extrinsics_root_state_version(&self) -> StateVersion {
match self.system_version {
0 | 1 => StateVersion::V0,
_ => StateVersion::V1,
}
}
}
#[derive(Debug)]
#[cfg(feature = "std")]
pub struct NativeVersion {
pub runtime_version: RuntimeVersion,
pub can_author_with: HashSet<u32>,
}
#[cfg(feature = "std")]
impl NativeVersion {
pub fn can_author_with(&self, other: &RuntimeVersion) -> Result<(), String> {
if self.runtime_version.spec_name != other.spec_name {
Err(format!(
"`spec_name` does not match `{}` vs `{}`",
self.runtime_version.spec_name, other.spec_name,
))
} else if self.runtime_version.authoring_version != other.authoring_version &&
!self.can_author_with.contains(&other.authoring_version)
{
Err(format!(
"`authoring_version` does not match `{version}` vs `{other_version}` and \
`can_author_with` not contains `{other_version}`",
version = self.runtime_version.authoring_version,
other_version = other.authoring_version,
))
} else {
Ok(())
}
}
}
#[cfg(feature = "std")]
pub trait GetNativeVersion {
fn native_version(&self) -> &NativeVersion;
}
#[cfg(feature = "std")]
pub trait GetRuntimeVersionAt<Block: BlockT> {
fn runtime_version(
&self,
at: <Block as BlockT>::Hash,
call_context: CallContext,
) -> Result<RuntimeVersion, String>;
}
#[cfg(feature = "std")]
impl<T: GetRuntimeVersionAt<Block>, Block: BlockT> GetRuntimeVersionAt<Block>
for std::sync::Arc<T>
{
fn runtime_version(
&self,
at: <Block as BlockT>::Hash,
call_context: CallContext,
) -> Result<RuntimeVersion, String> {
(&**self).runtime_version(at, call_context)
}
}
#[cfg(feature = "std")]
impl<T: GetNativeVersion> GetNativeVersion for std::sync::Arc<T> {
fn native_version(&self) -> &NativeVersion {
(&**self).native_version()
}
}
#[cfg(feature = "serde")]
mod apis_serialize {
use super::*;
use alloc::vec::Vec;
use impl_serde::serialize as bytes;
use serde::{de, ser::SerializeTuple, Serializer};
#[derive(Serialize)]
struct ApiId<'a>(#[serde(serialize_with = "serialize_bytesref")] &'a super::ApiId, &'a u32);
pub fn serialize<S>(apis: &ApisVec, ser: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
let len = apis.len();
let mut seq = ser.serialize_tuple(len)?;
for (api, ver) in &**apis {
seq.serialize_element(&ApiId(api, ver))?;
}
seq.end()
}
pub fn serialize_bytesref<S>(&apis: &&super::ApiId, ser: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
bytes::serialize(apis, ser)
}
#[derive(Deserialize)]
struct ApiIdOwned(#[serde(deserialize_with = "deserialize_bytes")] super::ApiId, u32);
pub fn deserialize<'de, D>(deserializer: D) -> Result<ApisVec, D::Error>
where
D: de::Deserializer<'de>,
{
struct Visitor;
impl<'de> de::Visitor<'de> for Visitor {
type Value = ApisVec;
fn expecting(&self, formatter: &mut core::fmt::Formatter) -> core::fmt::Result {
formatter.write_str("a sequence of api id and version tuples")
}
fn visit_seq<V>(self, mut visitor: V) -> Result<Self::Value, V::Error>
where
V: de::SeqAccess<'de>,
{
let mut apis = Vec::new();
while let Some(value) = visitor.next_element::<ApiIdOwned>()? {
apis.push((value.0, value.1));
}
Ok(apis.into())
}
}
deserializer.deserialize_seq(Visitor)
}
pub fn deserialize_bytes<'de, D>(d: D) -> Result<super::ApiId, D::Error>
where
D: de::Deserializer<'de>,
{
let mut arr = [0; 8];
bytes::deserialize_check_len(d, bytes::ExpectedLen::Exact(&mut arr[..]))?;
Ok(arr)
}
}