[GASP-1099] Prometheus metrics for gasp-node (#421)

[GASP-1099] Provide metrics per chain

gasp-node/pallets/rolldown/rpc/src/lib.rs

@@ -92,7 +92,7 @@ impl<C, Block, L1Update, Chain> RolldownApiServer<<Block as BlockT>::Hash, L1Upd
 where
 	Block: BlockT,
 	L1Update: Decode,
-	Chain: Encode,
+	Chain: Encode + Decode,
 	C: Send + Sync + 'static,
 	C: ProvideRuntimeApi<Block>,
 	C: HeaderBackend<Block>,

gasp-node/pallets/rolldown/runtime-api/src/lib.rs

@@ -6,8 +6,9 @@ use sp_std::vec::Vec;
 sp_api::decl_runtime_apis! {
 	pub trait RolldownRuntimeApi<L1Update, Chain> where
 		L1Update: Decode,
-		Chain: Encode
+		Chain: Encode + Decode,
 	{
+		fn get_all_chains() -> Vec<Chain>;
 		fn get_abi_encoded_l2_request(chain: Chain, requestId: u128) -> Vec<u8>;
 		fn get_native_sequencer_update(hex_payload: Vec<u8>) -> Option<L1Update>;
 		fn verify_sequencer_update(chain: Chain, hash: H256, request_id: u128) -> Option<bool>;

gasp-node/pallets/rolldown/src/lib.rs

@@ -1878,6 +1878,12 @@ impl<T: Config> Pallet<T> {
 
 		Ok(().into())
 	}
+
+	pub fn get_all_chains() -> Vec<ChainIdOf<T>> {
+		let keys1: BTreeSet<_> = LastProcessedRequestOnL2::<T>::iter_keys().collect();
+		let keys2: BTreeSet<_> = L2OriginRequestId::<T>::get().keys().cloned().collect();
+		keys1.union(&keys2).cloned().collect()
+	}
 }
 
 impl<T: Config> RolldownProviderTrait<ChainIdOf<T>, AccountIdOf<T>> for Pallet<T> {

gasp-node/pallets/rolldown/src/messages/mod.rs

@@ -2,6 +2,8 @@
 
 pub mod eth_abi;
 
+use core::fmt::Display;
+
 use self::eth_abi::to_eth_u256;
 use crate::L2Request;
 use alloy_sol_types::SolValue;
@@ -105,6 +107,16 @@ pub enum Chain {
 	Base,
 }
 
+impl AsRef<str> for Chain {
+	fn as_ref(&self) -> &'static str {
+		match self {
+			Chain::Ethereum => "Ethereum",
+			Chain::Arbitrum => "Arbitrum",
+			Chain::Base => "Base",
+		}
+	}
+}
+
 #[repr(u8)]
 #[derive(
 	Default, Eq, PartialEq, RuntimeDebug, Clone, Encode, Decode, TypeInfo, Serialize, Copy,

gasp-node/rollup/node/src/metrics.rs

@@ -87,15 +87,19 @@ where
 
 	fn collect(&self, mut set: impl FnMut(&[&str], Self::N)) {
 		let at = self.0.info().best_hash;
-		set(
-			&["Ethereum"],
-			self.0
-				.runtime_api()
-				.get_last_processed_request_on_l2(at, pallet_rolldown::messages::Chain::Ethereum)
-				.unwrap_or(None)
-				.unwrap_or_default()
-				.saturated_into::<u64>(),
-		);
+		let chains = self.0.runtime_api().get_all_chains(at).unwrap_or_default();
+
+		for c in chains {
+			set(
+				&[c.as_ref()],
+				self.0
+					.runtime_api()
+					.get_last_processed_request_on_l2(at, c)
+					.unwrap_or(None)
+					.unwrap_or_default()
+					.saturated_into::<u64>(),
+			);
+		}
 	}
 }
 
@@ -151,15 +155,19 @@ where
 
 	fn collect(&self, mut set: impl FnMut(&[&str], Self::N)) {
 		let at = self.0.info().best_hash;
-		set(
-			&["Ethereum"],
-			self.0
-				.runtime_api()
-				.get_number_of_pending_requests(at, pallet_rolldown::messages::Chain::Ethereum)
-				.unwrap_or(None)
-				.unwrap_or_default()
-				.saturated_into::<u64>(),
-		);
+		let chains = self.0.runtime_api().get_all_chains(at).unwrap_or_default();
+
+		for c in chains {
+			set(
+				&[c.as_ref()],
+				self.0
+					.runtime_api()
+					.get_number_of_pending_requests(at, c)
+					.unwrap_or(None)
+					.unwrap_or_default()
+					.saturated_into::<u64>(),
+			);
+		}
 	}
 }
 

gasp-node/rollup/runtime/src/lib.rs

@@ -1050,6 +1050,10 @@ impl_runtime_apis! {
 		) -> Vec<u8>{
 			Rolldown::get_abi_encoded_l2_request(chain, request_id)
 		}
+
+		fn get_all_chains() -> Vec<pallet_rolldown::messages::Chain>{
+			Rolldown::get_all_chains()
+		}
 	}
 
 	impl proof_of_stake_runtime_api::ProofOfStakeApi<Block, Balance , TokenId,  AccountId> for Runtime{