Trigger rewarded_set update on bootstrap error

validator-api/src/contract_cache/mod.rs

@@ -131,9 +131,13 @@ impl<C> ValidatorCacheRefresher<C> {
             self.nymd_client.get_gateways(),
         )?;
 
-        let rewarded_set_identities = self.nymd_client.get_rewarded_set_identities().await?;
-        let (rewarded_set, active_set) =
-            self.collect_rewarded_and_active_set_details(&mixnodes, rewarded_set_identities);
+        let (rewarded_set, active_set) = if let Ok(rewarded_set_identities) =
+            self.nymd_client.get_rewarded_set_identities().await
+        {
+            self.collect_rewarded_and_active_set_details(&mixnodes, rewarded_set_identities)
+        } else {
+            (Vec::new(), Vec::new())
+        };
 
         let epoch_rewarding_params = self.nymd_client.get_current_epoch_reward_params().await?;
 
@@ -154,15 +158,19 @@ impl<C> ValidatorCacheRefresher<C> {
             .await;
 
         if let Some(notify) = &self.update_rewarded_set_notify {
-            let update_details = self
+            if let Ok(update_details) = self
                 .nymd_client
                 .get_current_rewarded_set_update_details()
-                .await?;
-
-            if update_details.last_refreshed_block + (update_details.refresh_rate_blocks as u64)
-                < update_details.current_height
+                .await
             {
-                // there's only ever a single waiter -> the set updater
+                if update_details.last_refreshed_block + (update_details.refresh_rate_blocks as u64)
+                    < update_details.current_height
+                {
+                    // there's only ever a single waiter -> the set updater
+                    notify.notify_one()
+                }
+            } else {
+                // This has the potential to be spammy, we'll find out
                 notify.notify_one()
             }
         }

validator-api/src/network_monitor/monitor/preparer.rs

@@ -229,7 +229,7 @@ impl PacketPreparer {
     }
 
     async fn all_mixnodes_and_gateways(&self) -> (Vec<MixNodeBond>, Vec<GatewayBond>) {
-        info!(target: "Monitor", "Obtaining entire network topology...");
+        info!(target: "Monitor", "Obtaining network topology...");
 
         let mixnodes = self.validator_cache.mixnodes_all().await;
         let gateways = self.validator_cache.gateways_all().await;
@@ -237,15 +237,6 @@ impl PacketPreparer {
         (mixnodes, gateways)
     }
 
-    async fn mixnodes_and_gateways(&self) -> (Vec<MixNodeBond>, Vec<GatewayBond>) {
-        info!(target: "Monitor", "Obtaining good network topology...");
-
-        let mixnodes = self.validator_cache.mixnodes().await;
-        let gateways = self.validator_cache.gateways().await;
-
-        (mixnodes, gateways)
-    }
-
     pub(crate) fn try_parse_mix_bond(&self, mix: &MixNodeBond) -> Result<mix::Node, String> {
         let identity = mix.mix_node.identity_key.clone();
         if !self.check_version_compatibility(&mix.mix_node.version) {
@@ -275,7 +266,7 @@ impl PacketPreparer {
         n: usize,
         blacklist: &mut HashSet<String>,
     ) -> Option<Vec<TestRoute>> {
-        let (mixnodes, gateways) = self.mixnodes_and_gateways().await;
+        let (mixnodes, gateways) = self.all_mixnodes_and_gateways().await;
         // separate mixes into layers for easier selection
         let mut layered_mixes = HashMap::new();
         for mix in mixnodes {