feat: LP V2 message forwarding

Cargo.toml

@@ -23,6 +23,7 @@ members = [
   "pallets/liquidity-pools",
   "pallets/liquidity-pools-gateway",
   "pallets/liquidity-pools-gateway/queue",
+  "pallets/liquidity-pools-forwarder",
   "pallets/liquidity-rewards",
   "pallets/loans",
   "pallets/oracle-feed",
@@ -236,6 +237,7 @@ pallet-keystore = { path = "pallets/keystore", default-features = false }
 pallet-liquidity-pools = { path = "pallets/liquidity-pools", default-features = false }
 pallet-liquidity-pools-gateway = { path = "pallets/liquidity-pools-gateway", default-features = false }
 pallet-liquidity-pools-gateway-queue = { path = "pallets/liquidity-pools-gateway/queue", default-features = false }
+pallet-liquidity-pools-forwarder = { path = "pallets/liquidity-pools-forwarder", default-features = false }
 pallet-liquidity-rewards = { path = "pallets/liquidity-rewards", default-features = false }
 pallet-loans = { path = "pallets/loans", default-features = false }
 pallet-oracle-feed = { path = "pallets/oracle-feed", default-features = false }

libs/mocks/src/router_message.rs

@@ -40,10 +40,11 @@ pub mod pallet {
 	}
 
 	impl<T: Config> MessageSender for Pallet<T> {
+		type Message = Vec<u8>;
 		type Middleware = T::Middleware;
 		type Origin = T::Origin;
 
-		fn send(a: Self::Middleware, b: Self::Origin, c: Vec<u8>) -> DispatchResult {
+		fn send(a: Self::Middleware, b: Self::Origin, c: Self::Message) -> DispatchResult {
 			execute_call!((a, b, c))
 		}
 	}

libs/traits/src/liquidity_pools.rs

@@ -12,14 +12,16 @@
 // GNU General Public License for more details.
 
 use frame_support::{dispatch::DispatchResult, weights::Weight};
-use sp_runtime::DispatchError;
+use sp_runtime::{app_crypto::sp_core::H160, DispatchError};
 use sp_std::vec::Vec;
 
 pub type Proof = [u8; 32];
 
 /// An encoding & decoding trait for the purpose of meeting the
 /// LiquidityPools General Message Passing Format
-pub trait LPEncoding: Sized {
+pub trait LpMessage: Sized {
+	type Domain;
+
 	fn serialize(&self) -> Vec<u8>;
 	fn deserialize(input: &[u8]) -> Result<Self, DispatchError>;
 
@@ -39,6 +41,16 @@ pub trait LPEncoding: Sized {
 
 	/// Converts the message into a message proof type.
 	fn to_proof_message(&self) -> Self;
+
+	/// Unwraps a forwarded message.
+	fn unwrap_forwarded(self) -> Option<(Self::Domain, H160, Self)>;
+
+	/// Attempts to wrap into a forwarded message.
+	fn try_wrap_forward(
+		domain: Self::Domain,
+		forwarding_contract: H160,
+		message: Self,
+	) -> Result<Self, DispatchError>;
 }
 
 pub trait RouterProvider<Domain>: Sized {
@@ -57,9 +69,15 @@ pub trait MessageSender {
 	/// The originator of the message to be sent
 	type Origin;
 
+	/// The type of the message
+	type Message;
+
 	/// Sends a message for origin to destination
-	fn send(middleware: Self::Middleware, origin: Self::Origin, message: Vec<u8>)
-		-> DispatchResult;
+	fn send(
+		middleware: Self::Middleware,
+		origin: Self::Origin,
+		message: Self::Message,
+	) -> DispatchResult;
 }
 
 /// The behavior of an entity that can receive messages

pallets/axelar-router/src/lib.rs

@@ -131,13 +131,13 @@ pub mod pallet {
 		/// messages from
 		type AdminOrigin: EnsureOrigin<Self::RuntimeOrigin>;
 
-		/// The target of the messages comming from other chains
+		/// The target of the messages coming from other chains
 		type Receiver: MessageReceiver<Middleware = Self::Middleware, Origin = DomainAddress>;
 
 		/// Middleware used by the gateway
 		type Middleware: From<AxelarId>;
 
-		/// The target of the messages comming from this chain
+		/// The target of the messages coming from this chain
 		type Transactor: EthereumTransactor;
 
 		/// Checker to ensure an evm account code is registered
@@ -319,10 +319,15 @@ pub mod pallet {
 	}
 
 	impl<T: Config> MessageSender for Pallet<T> {
+		type Message = Vec<u8>;
 		type Middleware = AxelarId;
 		type Origin = DomainAddress;
 
-		fn send(axelar_id: AxelarId, origin: Self::Origin, message: Vec<u8>) -> DispatchResult {
+		fn send(
+			axelar_id: AxelarId,
+			origin: Self::Origin,
+			message: Self::Message,
+		) -> DispatchResult {
 			let chain_name = ChainNameById::<T>::get(axelar_id)
 				.ok_or(Error::<T>::RouterConfigurationNotFound)?;
 			let config = Configuration::<T>::get(&chain_name)

pallets/liquidity-pools-forwarder/Cargo.toml

@@ -0,0 +1,83 @@
+[package]
+name = "pallet-liquidity-pools-forwarder"
+description = "Centrifuge Liquidity Pools Relayer Pallet"
+version = "0.0.1"
+authors.workspace = true
+edition.workspace = true
+license.workspace = true
+homepage.workspace = true
+repository.workspace = true
+documentation.workspace = true
+
+[package.metadata.docs.rs]
+targets = ["x86_64-unknown-linux-gnu"]
+
+[dependencies]
+frame-support = { workspace = true }
+frame-system = { workspace = true }
+hex = { workspace = true }
+orml-traits = { workspace = true }
+parity-scale-codec = { workspace = true }
+scale-info = { workspace = true }
+serde = { workspace = true }
+sp-arithmetic = { workspace = true }
+sp-core = { workspace = true }
+sp-runtime = { workspace = true }
+sp-std = { workspace = true }
+
+# Benchmarking
+frame-benchmarking = { workspace = true, optional = true }
+
+# Our custom pallets
+cfg-primitives = { workspace = true }
+cfg-traits = { workspace = true }
+cfg-types = { workspace = true }
+cfg-utils = { workspace = true }
+
+[dev-dependencies]
+cfg-mocks = { workspace = true, default-features = true }
+itertools = { workspace = true, default-features = true }
+lazy_static = { workspace = true, default-features = true }
+sp-io = { workspace = true, default-features = true }
+
+[features]
+default = ["std"]
+std = [
+  "parity-scale-codec/std",
+  "cfg-types/std",
+  "cfg-traits/std",
+  "frame-support/std",
+  "frame-system/std",
+  "frame-benchmarking/std",
+  "orml-traits/std",
+  "sp-std/std",
+  "sp-core/std",
+  "sp-runtime/std",
+  "scale-info/std",
+  "cfg-utils/std",
+  "hex/std",
+  "cfg-primitives/std",
+  "serde/std",
+  "sp-arithmetic/std",
+]
+try-runtime = [
+  "cfg-traits/try-runtime",
+  "cfg-types/try-runtime",
+  "frame-support/try-runtime",
+  "frame-system/try-runtime",
+  "sp-runtime/try-runtime",
+  "cfg-utils/try-runtime",
+  "cfg-mocks/try-runtime",
+  "cfg-primitives/try-runtime",
+]
+runtime-benchmarks = [
+  "frame-benchmarking/runtime-benchmarks",
+  "cfg-traits/runtime-benchmarks",
+  "cfg-types/runtime-benchmarks",
+  "frame-support/runtime-benchmarks",
+  "frame-system/runtime-benchmarks",
+  "sp-runtime/runtime-benchmarks",
+  "cfg-utils/runtime-benchmarks",
+  "cfg-mocks/runtime-benchmarks",
+  "cfg-primitives/runtime-benchmarks",
+]