Feat/lp v2 gateway multi router

Cargo.toml

@@ -85,6 +85,7 @@ impl-trait-for-tuples = "0.2.2"
 num-traits = { version = "0.2.17", default-features = false }
 num_enum = { version = "0.5.3", default-features = false }
 chrono = { version = "0.4", default-features = false }
+itertools = { version = "0.13.0", default-features = false }
 
 # Cumulus
 cumulus-pallet-aura-ext = { git = "https://github.com/paritytech/polkadot-sdk", default-features = false, branch = "release-polkadot-v1.7.2" }

libs/mocks/src/liquidity_pools.rs

@@ -2,7 +2,7 @@
 pub mod pallet {
 	use cfg_traits::liquidity_pools::InboundMessageHandler;
 	use frame_support::pallet_prelude::*;
-	use mock_builder::{execute_call, register_call};
+	use mock_builder::{execute_call, register_call, CallHandler};
 
 	#[pallet::config]
 	pub trait Config: frame_system::Config {
@@ -17,8 +17,10 @@ pub mod pallet {
 	type CallIds<T: Config> = StorageMap<_, _, String, mock_builder::CallId>;
 
 	impl<T: Config> Pallet<T> {
-		pub fn mock_handle(f: impl Fn(T::DomainAddress, T::Message) -> DispatchResult + 'static) {
-			register_call!(move |(sender, msg)| f(sender, msg));
+		pub fn mock_handle(
+			f: impl Fn(T::DomainAddress, T::Message) -> DispatchResult + 'static,
+		) -> CallHandler {
+			register_call!(move |(sender, msg)| f(sender, msg))
 		}
 	}
 

libs/mocks/src/router_message.rs

@@ -2,7 +2,7 @@
 pub mod pallet {
 	use cfg_traits::liquidity_pools::{MessageReceiver, MessageSender};
 	use frame_support::pallet_prelude::*;
-	use mock_builder::{execute_call, register_call};
+	use mock_builder::{execute_call, register_call, CallHandler};
 
 	#[pallet::config]
 	pub trait Config: frame_system::Config {
@@ -25,8 +25,8 @@ pub mod pallet {
 
 		pub fn mock_send(
 			f: impl Fn(T::Middleware, T::Origin, Vec<u8>) -> DispatchResult + 'static,
-		) {
-			register_call!(move |(a, b, c)| f(a, b, c));
+		) -> CallHandler {
+			register_call!(move |(a, b, c)| f(a, b, c))
 		}
 	}
 

libs/primitives/src/lib.rs

@@ -161,6 +161,9 @@ pub mod types {
 
 	/// The type for LP gateway message nonces.
 	pub type LPGatewayQueueMessageNonce = u64;
+
+	/// The type for LP gateway session IDs.
+	pub type LPGatewaySessionId = u64;
 }
 
 /// Common constants for all runtimes

libs/traits/src/liquidity_pools.rs

@@ -15,6 +15,8 @@ use frame_support::{dispatch::DispatchResult, weights::Weight};
 use sp_runtime::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 {
@@ -31,11 +33,20 @@ pub trait LPEncoding: Sized {
 	/// Creates an empty message.
 	/// It's the identity message for composing messages with pack_with
 	fn empty() -> Self;
+
+	/// Retrieves the message proof hash, if the message is a proof type.
+	fn get_proof(&self) -> Option<Proof>;
+
+	/// Converts the message into a message proof type.
+	fn to_proof_message(&self) -> Self;
 }
 
-pub trait RouterSupport<Domain>: Sized {
+pub trait RouterProvider<Domain>: Sized {
+	/// The router identifier.
+	type RouterId;
+
 	/// Returns a list of routers supported for the given domain.
-	fn for_domain(domain: Domain) -> Vec<Self>;
+	fn routers_for_domain(domain: Domain) -> Vec<Self::RouterId>;
 }
 
 /// The behavior of an entity that can send messages

pallets/axelar-router/src/lib.rs

@@ -62,6 +62,12 @@ pub enum AxelarId {
 	Evm(EVMChainId),
 }
 
+impl Default for AxelarId {
+	fn default() -> Self {
+		Self::Evm(1)
+	}
+}
+
 /// Configuration for outbound messages though axelar
 #[derive(Debug, Encode, Decode, Clone, PartialEq, Eq, TypeInfo, MaxEncodedLen)]
 pub struct AxelarConfig {

pallets/liquidity-pools-gateway/Cargo.toml

@@ -19,6 +19,7 @@ hex = { workspace = true }
 orml-traits = { workspace = true }
 parity-scale-codec = { workspace = true }
 scale-info = { workspace = true }
+sp-arithmetic = { workspace = true }
 sp-core = { workspace = true }
 sp-runtime = { workspace = true }
 sp-std = { workspace = true }
@@ -34,6 +35,8 @@ 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]
@@ -53,6 +56,7 @@ std = [
   "cfg-utils/std",
   "hex/std",
   "cfg-primitives/std",
+  "sp-arithmetic/std",
 ]
 try-runtime = [
   "cfg-traits/try-runtime",

pallets/liquidity-pools-gateway/queue/src/lib.rs

@@ -38,7 +38,7 @@ pub mod pallet {
 		type RuntimeEvent: From<Event<Self>> + IsType<<Self as frame_system::Config>::RuntimeEvent>;
 
 		/// The message type.
-		type Message: Clone + Debug + PartialEq + MaxEncodedLen + TypeInfo + FullCodec + Default;
+		type Message: Clone + Debug + PartialEq + MaxEncodedLen + TypeInfo + FullCodec;
 
 		/// Type used for message identification.
 		type MessageNonce: Parameter