mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-07-22 20:45:40 +00:00
Add the XCM primitives crate. (#1760)
Co-authored-by: Gavin Wood <gavin@parity.io> Co-authored-by: Gavin Wood <gavin@parity.io>
This commit is contained in:
@@ -0,0 +1,393 @@
|
||||
// Copyright 2020 Parity Technologies (UK) Ltd.
|
||||
// This file is part of Cumulus.
|
||||
|
||||
// Substrate is free software: you can redistribute it and/or modify
|
||||
// it under the terms of the GNU General Public License as published by
|
||||
// the Free Software Foundation, either version 3 of the License, or
|
||||
// (at your option) any later version.
|
||||
|
||||
// Substrate is distributed in the hope that it will be useful,
|
||||
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
// GNU General Public License for more details.
|
||||
|
||||
// You should have received a copy of the GNU General Public License
|
||||
// along with Cumulus. If not, see <http://www.gnu.org/licenses/>.
|
||||
|
||||
//! Cross-Consensus Message format data structures.
|
||||
|
||||
use core::{result, mem, convert::TryFrom};
|
||||
|
||||
use codec::{self, Encode, Decode};
|
||||
use super::Junction;
|
||||
use crate::VersionedMultiLocation;
|
||||
|
||||
/// A relative path between state-bearing consensus systems.
|
||||
///
|
||||
/// A location in a consensus system is defined as an *isolatable state machine* held within global consensus. The
|
||||
/// location in question need not have a sophisticated consensus algorithm of its own; a single account within
|
||||
/// Ethereum, for example, could be considered a location.
|
||||
///
|
||||
/// A very-much non-exhaustive list of types of location include:
|
||||
/// - A (normal, layer-1) block chain, e.g. the Bitcoin mainnet or a parachain.
|
||||
/// - A layer-0 super-chain, e.g. the Polkadot Relay chain.
|
||||
/// - A layer-2 smart contract, e.g. an ERC-20 on Ethereum.
|
||||
/// - A logical functional component of a chain, e.g. a single instance of a pallet on a Frame-based Substrate chain.
|
||||
/// - An account.
|
||||
///
|
||||
/// A `MultiLocation` is a *relative identifier*, meaning that it can only be used to define the relative path
|
||||
/// between two locations, and cannot generally be used to refer to a location universally. It is comprised of a
|
||||
/// number of *junctions*, each morphing the previous location, either diving down into one of its internal locations,
|
||||
/// called a *sub-consensus*, or going up into its parent location. Correct `MultiLocation` values must have all
|
||||
/// `Parent` junctions as a prefix to all *sub-consensus* junctions.
|
||||
///
|
||||
/// This specific `MultiLocation` implementation uses a Rust `enum` in order to make pattern matching easier.
|
||||
///
|
||||
/// The `MultiLocation` value of `Null` simply refers to the interpreting consensus system.
|
||||
#[derive(Clone, Eq, PartialEq, Ord, PartialOrd, Encode, Decode, Debug)]
|
||||
pub enum MultiLocation {
|
||||
/// The interpreting consensus system.
|
||||
Null,
|
||||
/// A relative path comprising one junction.
|
||||
X1(Junction),
|
||||
/// A relative path comprising two junctions.
|
||||
X2(Junction, Junction),
|
||||
/// A relative path comprising three junctions.
|
||||
X3(Junction, Junction, Junction),
|
||||
/// A relative path comprising four junctions.
|
||||
X4(Junction, Junction, Junction, Junction),
|
||||
}
|
||||
|
||||
impl From<Junction> for MultiLocation {
|
||||
fn from(x: Junction) -> Self {
|
||||
MultiLocation::X1(x)
|
||||
}
|
||||
}
|
||||
|
||||
impl From<()> for MultiLocation {
|
||||
fn from(_: ()) -> Self {
|
||||
MultiLocation::Null
|
||||
}
|
||||
}
|
||||
impl From<(Junction,)> for MultiLocation {
|
||||
fn from(x: (Junction,)) -> Self {
|
||||
MultiLocation::X1(x.0)
|
||||
}
|
||||
}
|
||||
impl From<(Junction, Junction)> for MultiLocation {
|
||||
fn from(x: (Junction, Junction)) -> Self {
|
||||
MultiLocation::X2(x.0, x.1)
|
||||
}
|
||||
}
|
||||
impl From<(Junction, Junction, Junction)> for MultiLocation {
|
||||
fn from(x: (Junction, Junction, Junction)) -> Self {
|
||||
MultiLocation::X3(x.0, x.1, x.2)
|
||||
}
|
||||
}
|
||||
impl From<(Junction, Junction, Junction, Junction)> for MultiLocation {
|
||||
fn from(x: (Junction, Junction, Junction, Junction)) -> Self {
|
||||
MultiLocation::X4(x.0, x.1, x.2, x.3)
|
||||
}
|
||||
}
|
||||
|
||||
impl From<[Junction; 0]> for MultiLocation {
|
||||
fn from(_: [Junction; 0]) -> Self {
|
||||
MultiLocation::Null
|
||||
}
|
||||
}
|
||||
impl From<[Junction; 1]> for MultiLocation {
|
||||
fn from(x: [Junction; 1]) -> Self {
|
||||
let [x0] = x;
|
||||
MultiLocation::X1(x0)
|
||||
}
|
||||
}
|
||||
impl From<[Junction; 2]> for MultiLocation {
|
||||
fn from(x: [Junction; 2]) -> Self {
|
||||
let [x0, x1] = x;
|
||||
MultiLocation::X2(x0, x1)
|
||||
}
|
||||
}
|
||||
impl From<[Junction; 3]> for MultiLocation {
|
||||
fn from(x: [Junction; 3]) -> Self {
|
||||
let [x0, x1, x2] = x;
|
||||
MultiLocation::X3(x0, x1, x2)
|
||||
}
|
||||
}
|
||||
impl From<[Junction; 4]> for MultiLocation {
|
||||
fn from(x: [Junction; 4]) -> Self {
|
||||
let [x0, x1, x2, x3] = x;
|
||||
MultiLocation::X4(x0, x1, x2, x3)
|
||||
}
|
||||
}
|
||||
|
||||
pub struct MultiLocationIterator(MultiLocation);
|
||||
impl Iterator for MultiLocationIterator {
|
||||
type Item = Junction;
|
||||
fn next(&mut self) -> Option<Junction> {
|
||||
self.0.take_first()
|
||||
}
|
||||
}
|
||||
|
||||
pub struct MultiLocationReverseIterator(MultiLocation);
|
||||
impl Iterator for MultiLocationReverseIterator {
|
||||
type Item = Junction;
|
||||
fn next(&mut self) -> Option<Junction> {
|
||||
self.0.take_last()
|
||||
}
|
||||
}
|
||||
|
||||
pub struct MultiLocationRefIterator<'a>(&'a MultiLocation, usize);
|
||||
impl<'a> Iterator for MultiLocationRefIterator<'a> {
|
||||
type Item = &'a Junction;
|
||||
fn next(&mut self) -> Option<&'a Junction> {
|
||||
let result = self.0.at(self.1);
|
||||
self.1 += 1;
|
||||
result
|
||||
}
|
||||
}
|
||||
|
||||
pub struct MultiLocationReverseRefIterator<'a>(&'a MultiLocation, usize);
|
||||
impl<'a> Iterator for MultiLocationReverseRefIterator<'a> {
|
||||
type Item = &'a Junction;
|
||||
fn next(&mut self) -> Option<&'a Junction> {
|
||||
self.1 += 1;
|
||||
self.0.at(self.0.len().checked_sub(self.1)?)
|
||||
}
|
||||
}
|
||||
|
||||
impl MultiLocation {
|
||||
/// Returns first junction, or `None` if the location is empty.
|
||||
pub fn first(&self) -> Option<&Junction> {
|
||||
match &self {
|
||||
MultiLocation::Null => None,
|
||||
MultiLocation::X1(ref a) => Some(a),
|
||||
MultiLocation::X2(ref a, ..) => Some(a),
|
||||
MultiLocation::X3(ref a, ..) => Some(a),
|
||||
MultiLocation::X4(ref a, ..) => Some(a),
|
||||
}
|
||||
}
|
||||
|
||||
/// Returns last junction, or `None` if the location is empty.
|
||||
pub fn last(&self) -> Option<&Junction> {
|
||||
match &self {
|
||||
MultiLocation::Null => None,
|
||||
MultiLocation::X1(ref a) => Some(a),
|
||||
MultiLocation::X2(.., ref a) => Some(a),
|
||||
MultiLocation::X3(.., ref a) => Some(a),
|
||||
MultiLocation::X4(.., ref a) => Some(a),
|
||||
}
|
||||
}
|
||||
|
||||
/// Splits off the first junction, returning the remaining suffix (first item in tuple) and the first element
|
||||
/// (second item in tuple) or `None` if it was empty.
|
||||
pub fn split_first(self) -> (MultiLocation, Option<Junction>) {
|
||||
match self {
|
||||
MultiLocation::Null => (MultiLocation::Null, None),
|
||||
MultiLocation::X1(a) => (MultiLocation::Null, Some(a)),
|
||||
MultiLocation::X2(a, b) => (MultiLocation::X1(b), Some(a)),
|
||||
MultiLocation::X3(a, b, c) => (MultiLocation::X2(b, c), Some(a)),
|
||||
MultiLocation::X4(a, b, c ,d) => (MultiLocation::X3(b, c, d), Some(a)),
|
||||
}
|
||||
}
|
||||
|
||||
/// Splits off the last junction, returning the remaining prefix (first item in tuple) and the last element
|
||||
/// (second item in tuple) or `None` if it was empty.
|
||||
pub fn split_last(self) -> (MultiLocation, Option<Junction>) {
|
||||
match self {
|
||||
MultiLocation::Null => (MultiLocation::Null, None),
|
||||
MultiLocation::X1(a) => (MultiLocation::Null, Some(a)),
|
||||
MultiLocation::X2(a, b) => (MultiLocation::X1(a), Some(b)),
|
||||
MultiLocation::X3(a, b, c) => (MultiLocation::X2(a, b), Some(c)),
|
||||
MultiLocation::X4(a, b, c ,d) => (MultiLocation::X3(a, b, c), Some(d)),
|
||||
}
|
||||
}
|
||||
|
||||
/// Removes the first element from `self`, returning it (or `None` if it was empty).
|
||||
pub fn take_first(&mut self) -> Option<Junction> {
|
||||
let mut d = MultiLocation::Null;
|
||||
mem::swap(&mut *self, &mut d);
|
||||
let (tail, head) = d.split_first();
|
||||
*self = tail;
|
||||
head
|
||||
}
|
||||
|
||||
/// Removes the last element from `self`, returning it (or `None` if it was empty).
|
||||
pub fn take_last(&mut self) -> Option<Junction> {
|
||||
let mut d = MultiLocation::Null;
|
||||
mem::swap(&mut *self, &mut d);
|
||||
let (head, tail) = d.split_last();
|
||||
*self = head;
|
||||
tail
|
||||
}
|
||||
|
||||
/// Consumes `self` and returns a `MultiLocation` suffixed with `new`, or an `Err` with the original value of
|
||||
/// `self` in case of overflow.
|
||||
pub fn pushed_with(self, new: Junction) -> result::Result<Self, Self> {
|
||||
Ok(match self {
|
||||
MultiLocation::Null => MultiLocation::X1(new),
|
||||
MultiLocation::X1(a) => MultiLocation::X2(a, new),
|
||||
MultiLocation::X2(a, b) => MultiLocation::X3(a, b, new),
|
||||
MultiLocation::X3(a, b, c) => MultiLocation::X4(a, b, c, new),
|
||||
s => Err(s)?,
|
||||
})
|
||||
}
|
||||
|
||||
/// Consumes `self` and returns a `MultiLocation` prefixed with `new`, or an `Err` with the original value of
|
||||
/// `self` in case of overflow.
|
||||
pub fn pushed_front_with(self, new: Junction) -> result::Result<Self, Self> {
|
||||
Ok(match self {
|
||||
MultiLocation::Null => MultiLocation::X1(new),
|
||||
MultiLocation::X1(a) => MultiLocation::X2(new, a),
|
||||
MultiLocation::X2(a, b) => MultiLocation::X3(new, a, b),
|
||||
MultiLocation::X3(a, b, c) => MultiLocation::X4(new, a, b, c),
|
||||
s => Err(s)?,
|
||||
})
|
||||
}
|
||||
|
||||
/// Returns the number of junctions in `self`.
|
||||
pub fn len(&self) -> usize {
|
||||
match &self {
|
||||
MultiLocation::Null => 0,
|
||||
MultiLocation::X1(..) => 1,
|
||||
MultiLocation::X2(..) => 2,
|
||||
MultiLocation::X3(..) => 3,
|
||||
MultiLocation::X4(..) => 4,
|
||||
}
|
||||
}
|
||||
|
||||
/// Returns the junction at index `i`, or `None` if the location doesn't contain that many elements.
|
||||
pub fn at(&self, i: usize) -> Option<&Junction> {
|
||||
Some(match (i, &self) {
|
||||
(0, MultiLocation::X1(ref a)) => a,
|
||||
(0, MultiLocation::X2(ref a, ..)) => a,
|
||||
(0, MultiLocation::X3(ref a, ..)) => a,
|
||||
(0, MultiLocation::X4(ref a, ..)) => a,
|
||||
(1, MultiLocation::X2(_, ref a)) => a,
|
||||
(1, MultiLocation::X3(_, ref a, ..)) => a,
|
||||
(1, MultiLocation::X4(_, ref a, ..)) => a,
|
||||
(2, MultiLocation::X3(_, _, ref a)) => a,
|
||||
(2, MultiLocation::X4(_, _, ref a, ..)) => a,
|
||||
(3, MultiLocation::X4(_, _, _, ref a)) => a,
|
||||
_ => return None,
|
||||
})
|
||||
}
|
||||
|
||||
/// Returns a mutable reference to the junction at index `i`, or `None` if the location doesn't contain that many
|
||||
/// elements.
|
||||
pub fn at_mut(&mut self, i: usize) -> Option<&mut Junction> {
|
||||
Some(match (i, self) {
|
||||
(0, MultiLocation::X1(ref mut a)) => a,
|
||||
(0, MultiLocation::X2(ref mut a, ..)) => a,
|
||||
(0, MultiLocation::X3(ref mut a, ..)) => a,
|
||||
(0, MultiLocation::X4(ref mut a, ..)) => a,
|
||||
(1, MultiLocation::X2(_, ref mut a)) => a,
|
||||
(1, MultiLocation::X3(_, ref mut a, ..)) => a,
|
||||
(1, MultiLocation::X4(_, ref mut a, ..)) => a,
|
||||
(2, MultiLocation::X3(_, _, ref mut a)) => a,
|
||||
(2, MultiLocation::X4(_, _, ref mut a, ..)) => a,
|
||||
(3, MultiLocation::X4(_, _, _, ref mut a)) => a,
|
||||
_ => return None,
|
||||
})
|
||||
}
|
||||
|
||||
/// Returns a reference iterator over the junctions.
|
||||
pub fn iter(&self) -> MultiLocationRefIterator {
|
||||
MultiLocationRefIterator(&self, 0)
|
||||
}
|
||||
|
||||
/// Returns a reference iterator over the junctions in reverse.
|
||||
pub fn iter_rev(&self) -> MultiLocationReverseRefIterator {
|
||||
MultiLocationReverseRefIterator(&self, 0)
|
||||
}
|
||||
|
||||
/// Consumes `self` and returns an iterator over the junctions.
|
||||
pub fn into_iter(self) -> MultiLocationIterator {
|
||||
MultiLocationIterator(self)
|
||||
}
|
||||
|
||||
/// Consumes `self` and returns an iterator over the junctions in reverse.
|
||||
pub fn into_iter_rev(self) -> MultiLocationReverseIterator {
|
||||
MultiLocationReverseIterator(self)
|
||||
}
|
||||
|
||||
/// Mutates `self`, suffixing it with `new`. Returns `Err` in case of overflow.
|
||||
pub fn push(&mut self, new: Junction) -> result::Result<(), ()> {
|
||||
let mut n = MultiLocation::Null;
|
||||
mem::swap(&mut *self, &mut n);
|
||||
match n.pushed_with(new) {
|
||||
Ok(result) => { *self = result; Ok(()) }
|
||||
Err(old) => { *self = old; Err(()) }
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/// Mutates `self`, prefixing it with `new`. Returns `Err` in case of overflow.
|
||||
pub fn push_front(&mut self, new: Junction) -> result::Result<(), ()> {
|
||||
let mut n = MultiLocation::Null;
|
||||
mem::swap(&mut *self, &mut n);
|
||||
match n.pushed_front_with(new) {
|
||||
Ok(result) => { *self = result; Ok(()) }
|
||||
Err(old) => { *self = old; Err(()) }
|
||||
}
|
||||
}
|
||||
|
||||
/// Returns the number of `Parent` junctions at the beginning of `self`.
|
||||
pub fn parent_count(&self) -> usize {
|
||||
match self {
|
||||
MultiLocation::X4(Junction::Parent, Junction::Parent, Junction::Parent, Junction::Parent) => 4,
|
||||
MultiLocation::X4(Junction::Parent, Junction::Parent, Junction::Parent, ..) => 3,
|
||||
MultiLocation::X3(Junction::Parent, Junction::Parent, Junction::Parent) => 3,
|
||||
MultiLocation::X4(Junction::Parent, Junction::Parent, ..) => 2,
|
||||
MultiLocation::X3(Junction::Parent, Junction::Parent, ..) => 2,
|
||||
MultiLocation::X2(Junction::Parent, Junction::Parent) => 2,
|
||||
MultiLocation::X4(Junction::Parent, ..) => 1,
|
||||
MultiLocation::X3(Junction::Parent, ..) => 1,
|
||||
MultiLocation::X2(Junction::Parent, ..) => 1,
|
||||
MultiLocation::X1(Junction::Parent) => 1,
|
||||
_ => 0,
|
||||
}
|
||||
}
|
||||
|
||||
/// Mutate `self` so that it is prefixed with `prefix`. The correct normalised form is returned, removing any
|
||||
/// internal `Parent`s.
|
||||
///
|
||||
/// Does not modify `self` and returns `Err` with `prefix` in case of overflow.
|
||||
pub fn prepend_with(&mut self, prefix: MultiLocation) -> Result<(), MultiLocation> {
|
||||
let self_parents = self.parent_count();
|
||||
let prefix_rest = prefix.len() - prefix.parent_count();
|
||||
let skipped = self_parents.min(prefix_rest);
|
||||
if self.len() + prefix.len() - 2 * skipped > 4 {
|
||||
return Err(prefix);
|
||||
}
|
||||
|
||||
let mut prefix = prefix;
|
||||
while match (prefix.last(), self.first()) {
|
||||
(Some(x), Some(Junction::Parent)) if x != &Junction::Parent => {
|
||||
prefix.take_last();
|
||||
self.take_first();
|
||||
true
|
||||
}
|
||||
_ => false,
|
||||
} {}
|
||||
|
||||
for j in prefix.into_iter_rev() {
|
||||
self.push_front(j).expect("len + prefix minus 2*skipped is less than 4; qed");
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
}
|
||||
|
||||
impl From<MultiLocation> for VersionedMultiLocation {
|
||||
fn from(x: MultiLocation) -> Self {
|
||||
VersionedMultiLocation::V0(x)
|
||||
}
|
||||
}
|
||||
|
||||
impl TryFrom<VersionedMultiLocation> for MultiLocation {
|
||||
type Error = ();
|
||||
fn try_from(x: VersionedMultiLocation) -> result::Result<Self, ()> {
|
||||
match x {
|
||||
VersionedMultiLocation::V0(x) => Ok(x),
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user