Added log if initial peers are invalid

Author: 0xMimir

CHANGELOG.md

@@ -36,6 +36,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   Dashboard, documenting all endpoints and specific data fields used by the
   frontend ([#1566](https://github.com/o1-labs/mina-rust/issues/1566))
 
+- **Feature**: Add logging if initial peers are invalid
+  ([#1703](https://github.com/o1-labs/mina-rust/pull/1703))
+
 ### Fixed
 
 - **Docker Compose**: Fix frontend black screen issue by changing environment

node/src/reducer.rs

@@ -17,7 +17,32 @@ pub fn reducer(
     let meta = action.meta().clone();
     match action.action() {
         Action::CheckTimeouts(_) => {
-            if state.p2p.ready().is_some() {
+            if let Some(p2p) = state.p2p.ready() {
+                if let Some(kad_state) = &p2p.network.scheduler.discovery_state {
+                    if p2p.ready_peers().is_empty() && kad_state.has_bootstraped {
+                        if let Some(tip) = &state.transition_frontier.best_tip_breadcrumb() {
+                            // TODO: this might need to change in future
+                            if tip.height() == 296372 {
+                                let initial_peers = state
+                                    .p2p
+                                    .config()
+                                    .initial_peers
+                                    .iter()
+                                    .map(|opts| opts.to_string())
+                                    .collect::<Vec<_>>()
+                                    .join(", ");
+
+                                crate::core::error!(
+                                    crate::core::log::system_time();
+                                    summary = "Exiting",
+                                    error = "Invalid initial peers",
+                                    initial_peers = initial_peers
+                                );
+                            }
+                        }
+                    }
+                }
+
                 if let Err(error) =
                     P2pState::p2p_timeout_dispatch(Substate::new(state, dispatcher), &meta)
                 {

p2p/src/network/kad/p2p_network_kad_reducer.rs

@@ -133,6 +133,7 @@ impl super::P2pNetworkKadState {
                     time: meta.time(),
                     stats: bootstrap_state.stats.clone(),
                 };
+                state.has_bootstraped = true;
                 Ok(())
             }
             (_, P2pNetworkKademliaAction::UpdateRoutingTable { peer_id, addrs }) => {

p2p/src/network/kad/p2p_network_kad_state.rs

@@ -60,6 +60,7 @@ pub struct P2pNetworkKadState {
     pub streams: StreamState<P2pNetworkKadStreamState>,
     pub status: P2pNetworkKadStatus,
     pub filter_addrs: bool,
+    pub has_bootstraped: bool,
 }
 
 impl Default for P2pNetworkKadState {
@@ -74,6 +75,7 @@ impl Default for P2pNetworkKadState {
                 .ok()
                 .and_then(|s| s.parse().ok())
                 .unwrap_or(true),
+            has_bootstraped: false,
         }
     }
 }