Merge pull request #15 from sargonas/peering-overhaul

Peering overhaul

Author: sargonas

dev-cluster.sh

@@ -8,7 +8,7 @@ CLUSTER_DIR=".dev-cluster"
 NODES=${STELLAR_DEV_NODES:-5}
 BASE_WEB_PORT=8081
 BASE_DHT_PORT=7871
-BINARY="./stellar-mesh"
+BINARY="./stellar-lab"
 
 # Colors for output
 RED='\033[0;31m'

routing_table.go

@@ -363,6 +363,46 @@ func (rt *RoutingTable) GetUnverifiedCount() int {
 	return count
 }
 
+// PeerStateBreakdown provides a clear view of peer states
+type PeerStateBreakdown struct {
+	Total    int `json:"total"`    // All known systems (not including self)
+	Active   int `json:"active"`   // Verified, recent, responding (fail=0)
+	Degraded int `json:"degraded"` // Verified but failing (0 < fail < max)
+	Pending  int `json:"pending"`  // Heard via gossip, not yet verified
+	Stale    int `json:"stale"`    // Was verified but outside cutoff window
+}
+
+// GetPeerStateBreakdown returns counts of peers in each state
+func (rt *RoutingTable) GetPeerStateBreakdown() PeerStateBreakdown {
+	rt.cacheMu.RLock()
+	defer rt.cacheMu.RUnlock()
+
+	now := time.Now()
+	cutoff := now.Add(-VerificationCutoff)
+
+	breakdown := PeerStateBreakdown{
+		Total: len(rt.systemCache),
+	}
+
+	for _, cached := range rt.systemCache {
+		if !cached.Verified {
+			// Never verified - pending
+			breakdown.Pending++
+		} else if cached.LastVerified.IsZero() || cached.LastVerified.Before(cutoff) {
+			// Verified but too long ago - stale
+			breakdown.Stale++
+		} else if cached.FailCount > 0 {
+			// Recently verified but now failing - degraded
+			breakdown.Degraded++
+		} else {
+			// Verified, recent, responding - active
+			breakdown.Active++
+		}
+	}
+
+	return breakdown
+}
+
 // GetCacheSize returns the number of cached systems
 func (rt *RoutingTable) GetCacheSize() int {
 	rt.cacheMu.RLock()