feat(multi): add multichain BENS priority protocols

Author: lok52

multichain-aggregator/multichain-aggregator-logic/src/services/cluster.rs

@@ -904,9 +904,9 @@ impl Cluster {
     }
 
     pub async fn get_protocols_cached(&self) -> Result<Vec<ProtocolInfo>, ServiceError> {
+        let chain_ids = self.active_chain_ids().await?;
         let key = format!("{}:domain_protocols", self.name);
         let bens_client = self.bens_client.clone();
-        let chain_ids = self.chain_ids.clone();
         let priority_protocols = self.bens_priority_protocols.clone();
         let get = || get_protocols(bens_client, chain_ids, priority_protocols);
         let protocols = maybe_cache_lookup!(self.caches.domain_protocols.as_ref(), key, get)?;

multichain-aggregator/multichain-aggregator-server/src/server.rs

@@ -289,7 +289,7 @@ pub async fn run(settings: Settings) -> Result<(), anyhow::Error> {
             settings.service.quick_search_chains.clone(),
             dapp_client.clone(),
             bens_client.clone(),
-            Default::default(),
+            settings.service.multichain_bens_priority_protocols.clone(),
             caches.clone(),
         ),
     );

multichain-aggregator/multichain-aggregator-server/src/settings.rs

@@ -81,6 +81,10 @@ pub struct ServiceSettings {
     #[serde_as(as = "StringWithSeparator::<CommaSeparator, i64>")]
     #[serde(default = "default_quick_search_chains")]
     pub quick_search_chains: Vec<i64>,
+    /// BENS protocol IDs prioritized for the synthetic multichain cluster (empty `cluster_id` / multichain aggregator APIs).
+    #[serde_as(as = "StringWithSeparator::<CommaSeparator, String>")]
+    #[serde(default = "default_bens_priority_protocols")]
+    pub multichain_bens_priority_protocols: Vec<String>,
     #[serde(default)]
     pub fetch_chains: bool,
     #[serde_as(as = "serde_with::DurationSeconds<u64>")]
@@ -174,6 +178,7 @@ impl Settings {
                     max_page_size: default_max_page_size(),
                 },
                 quick_search_chains: default_quick_search_chains(),
+                multichain_bens_priority_protocols: default_bens_priority_protocols(),
                 fetch_chains: false,
                 marketplace_enabled_cache_update_interval:
                     default_marketplace_enabled_cache_update_interval(),