Transfer asset via bridge

Cargo.toml

@@ -36,6 +36,7 @@ members = [
 	"primitives/utility",
 	"polkadot-parachain",
 	"parachains/common",
+	"parachains/pallets/bridge-transfer",
 	"parachains/pallets/parachain-info",
 	"parachains/pallets/ping",
 	"parachains/runtimes/testing/rococo-parachain",

parachains/pallets/bridge-transfer/Cargo.toml

@@ -0,0 +1,62 @@
+[package]
+name = "pallet-bridge-transfer"
+version = "0.1.0"
+authors = ["Parity Technologies <[email protected]>"]
+edition = "2021"
+license = "Apache-2.0"
+homepage = "https://docs.substrate.io/"
+repository = "https://github.com/paritytech/cumulus/"
+description = "Pallet for message transfer through bridges"
+readme = "README.md"
+
+[dependencies]
+codec = { package = "parity-scale-codec", version = "3.0.0", default-features = false, features = ["derive"] }
+scale-info = { version = "2.3.0", default-features = false, features = ["derive"] }
+log = { version = "0.4.14", default-features = false }
+
+# Substrate
+sp-std = { git = "https://github.com/paritytech/substrate", default-features = false, branch = "master" }
+sp-runtime = { git = "https://github.com/paritytech/substrate", default-features = false, branch = "master" }
+frame-benchmarking = { git = "https://github.com/paritytech/substrate", optional = true, default-features = false, branch = "master" }
+frame-system-benchmarking = { git = "https://github.com/paritytech/substrate", optional = true, default-features = false, branch = "master" }
+frame-support = { git = "https://github.com/paritytech/substrate", default-features = false, branch = "master" }
+frame-system = { git = "https://github.com/paritytech/substrate", default-features = false, branch = "master" }
+
+# Polkadot
+xcm = { git = "https://github.com/paritytech/polkadot", default-features = false, branch = "master" }
+xcm-builder = { git = "https://github.com/paritytech/polkadot", default-features = false, branch = "master" }
+xcm-executor = { git = "https://github.com/paritytech/polkadot", default-features = false, branch = "master" }
+
+# Cumulus
+pallet-bridge-transfer-primitives = { path = "./primitives", default-features = false }
+
+[dev-dependencies]
+sp-version = { git = "https://github.com/paritytech/substrate", branch = "master" }
+pallet-balances = { git = "https://github.com/paritytech/substrate", branch = "master" }
+polkadot-parachain = { git = "https://github.com/paritytech/polkadot", branch = "master" }
+cumulus-pallet-xcmp-queue = { path = "../../../pallets/xcmp-queue" }
+
+[features]
+default = ["std"]
+std = [
+	"codec/std",
+	"log/std",
+	"scale-info/std",
+	"pallet-bridge-transfer-primitives/std",
+	"sp-std/std",
+	"sp-runtime/std",
+	"frame-support/std",
+	"frame-system/std",
+	"xcm/std",
+	"xcm-builder/std",
+	"xcm-executor/std",
+]
+runtime-benchmarks = [
+	"frame-benchmarking/runtime-benchmarks",
+	"frame-support/runtime-benchmarks",
+	"frame-system-benchmarking/runtime-benchmarks",
+	"frame-system/runtime-benchmarks",
+	"sp-runtime/runtime-benchmarks",
+	"xcm-builder/runtime-benchmarks",
+]
+try-runtime = ["frame-support/try-runtime"]

parachains/pallets/bridge-transfer/primitives/Cargo.toml

@@ -0,0 +1,28 @@
+[package]
+name = "pallet-bridge-transfer-primitives"
+version = "0.1.0"
+authors = ["Parity Technologies <[email protected]>"]
+edition = "2021"
+license = "Apache-2.0"
+homepage = "https://docs.substrate.io/"
+repository = "https://github.com/paritytech/cumulus/"
+description = "Pallet with primitives for message transfer through bridges"
+
+[dependencies]
+
+# Substrate
+sp-std = { git = "https://github.com/paritytech/substrate", default-features = false, branch = "master" }
+frame-support = { git = "https://github.com/paritytech/substrate", default-features = false, branch = "master" }
+
+# Polkadot
+xcm = { git = "https://github.com/paritytech/polkadot", default-features = false, branch = "master" }
+xcm-builder = { git = "https://github.com/paritytech/polkadot", default-features = false, branch = "master" }
+
+[features]
+default = ["std"]
+std = [
+	"sp-std/std",
+	"frame-support/std",
+	"xcm/std",
+	"xcm-builder/std",
+]

parachains/pallets/bridge-transfer/primitives/src/asset_filter.rs

@@ -0,0 +1,72 @@
+// Copyright (C) 2023 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.
+
+//! Primitives for matching asset `MultiLocation`.
+
+use xcm::prelude::*;
+
+/// Trait for matching asset location
+pub trait MatchAssetLocation {
+	fn matches(&self, location: &MultiLocation) -> bool;
+}
+
+/// Simple asset location filter
+#[derive(Debug)]
+pub enum AssetFilter {
+	ByMultiLocation(MultiLocationFilter),
+}
+
+impl MatchAssetLocation for AssetFilter {
+	fn matches(&self, asset_location: &MultiLocation) -> bool {
+		match self {
+			AssetFilter::ByMultiLocation(by_location) => by_location.matches(asset_location),
+		}
+	}
+}
+
+#[derive(Debug, Default)]
+pub struct MultiLocationFilter {
+	/// Requested location equals to `MultiLocation`
+	pub equals_any: sp_std::vec::Vec<MultiLocation>,
+	/// Requested location starts with `MultiLocation`
+	pub starts_with_any: sp_std::vec::Vec<MultiLocation>,
+}
+
+impl MultiLocationFilter {
+	pub fn add_equals(mut self, filter: MultiLocation) -> Self {
+		self.equals_any.push(filter);
+		self
+	}
+	pub fn add_starts_with(mut self, filter: MultiLocation) -> Self {
+		self.starts_with_any.push(filter);
+		self
+	}
+}
+
+impl MatchAssetLocation for MultiLocationFilter {
+	fn matches(&self, location: &MultiLocation) -> bool {
+		for filter in &self.equals_any {
+			if location.eq(filter) {
+				return true
+			}
+		}
+		for filter in &self.starts_with_any {
+			if location.starts_with(filter) {
+				return true
+			}
+		}
+		false
+	}
+}

parachains/pallets/bridge-transfer/primitives/src/config.rs

@@ -0,0 +1,121 @@
+// Copyright (C) 2023 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.
+
+//! Primitives for easier configuration.
+
+use crate::{
+	AssetFilter, EnsureReachableDestination, MaybePaidLocation, ReachableDestination,
+	ReachableDestinationError,
+};
+use frame_support::{
+	traits::{ConstU32, Get},
+	BoundedBTreeMap,
+};
+use xcm::prelude::*;
+use xcm_builder::ExporterFor;
+
+/// Configuration represents bridge to target location with possible asset filtering
+#[derive(Debug)]
+pub struct BridgeConfig {
+	/// Location, which is able to bridge XCM messages to bridged network
+	pub bridge_location: MaybePaidLocation,
+	/// Contains target destination on bridged network. E.g.: MultiLocation of Statemine/t on different consensus + its configuration
+	pub allowed_target_locations: sp_std::vec::Vec<(MaybePaidLocation, Option<AssetFilter>)>,
+}
+
+impl BridgeConfig {
+	pub fn new(bridge_location: MaybePaidLocation) -> Self {
+		Self { bridge_location, allowed_target_locations: Default::default() }
+	}
+
+	pub fn add_target_location(
+		mut self,
+		target_location: MaybePaidLocation,
+		asset_filter: Option<AssetFilter>,
+	) -> Self {
+		self.allowed_target_locations.push((target_location, asset_filter));
+		self
+	}
+
+	pub fn allowed_target_location_for(
+		&self,
+		destination: &MultiLocation,
+	) -> Option<(&MaybePaidLocation, &Option<AssetFilter>)> {
+		for (allowed_target_location, asset_filter) in &self.allowed_target_locations {
+			if destination.starts_with(&allowed_target_location.location) ||
+				destination.eq(&allowed_target_location.location)
+			{
+				return Some((allowed_target_location, asset_filter))
+			}
+		}
+		None
+	}
+}
+
+/// Type represents all "stored" `BridgeConfig`s.
+pub type BridgesConfig = BoundedBTreeMap<NetworkId, BridgeConfig, ConstU32<24>>;
+
+/// Builder for creating `BridgesConfig`.
+#[derive(Default)]
+pub struct BridgesConfigBuilder {
+	configs: BoundedBTreeMap<NetworkId, BridgeConfig, ConstU32<24>>,
+}
+impl BridgesConfigBuilder {
+	pub fn add_or_panic(mut self, network_id: NetworkId, bridge_config: BridgeConfig) -> Self {
+		self.configs.try_insert(network_id, bridge_config).expect("check bounds");
+		self
+	}
+
+	pub fn build(self) -> BoundedBTreeMap<NetworkId, BridgeConfig, ConstU32<24>> {
+		self.configs
+	}
+}
+
+/// Adapter for accessing `BridgesConfig`.
+pub struct BridgesConfigAdapter<Bridges>(sp_std::marker::PhantomData<Bridges>);
+
+/// Adapter implementation of `ExporterFor` for `BridgesConfig`
+impl<Bridges: Get<BridgesConfig>> ExporterFor for BridgesConfigAdapter<Bridges> {
+	fn exporter_for(
+		network: &NetworkId,
+		_remote_location: &InteriorMultiLocation,
+		_message: &Xcm<()>,
+	) -> Option<(MultiLocation, Option<MultiAsset>)> {
+		Bridges::get().get(network).map(|config| {
+			(config.bridge_location.location, config.bridge_location.maybe_fee.clone())
+		})
+	}
+}
+
+/// Adapter implementation of `EnsureReachableDestination` for `BridgesConfig`
+impl<Bridges: Get<BridgesConfig>> EnsureReachableDestination for BridgesConfigAdapter<Bridges> {
+	fn ensure_destination(
+		remote_network: NetworkId,
+		remote_destination: MultiLocation,
+	) -> Result<ReachableDestination, ReachableDestinationError> {
+		if let Some(config) = Bridges::get().get(&remote_network) {
+			if let Some((allowed_target_location, _)) =
+				config.allowed_target_location_for(&remote_destination)
+			{
+				return Ok(ReachableDestination {
+					bridge: config.bridge_location.clone(),
+					target: allowed_target_location.clone(),
+					target_destination: remote_destination,
+				})
+			}
+		}
+		Err(ReachableDestinationError::UnsupportedDestination)
+	}
+}