From 6b6ca48fca9333b38f662771e062dafe68a7e03e Mon Sep 17 00:00:00 2001
From: Cassandra Heart <cassandra@quilibrium.com>
Date: Sun, 27 Oct 2024 01:51:00 -0500
Subject: [PATCH] adjust blossomsub to background discovery

---
 node/p2p/blossomsub.go | 44 ++++++++++++++++++++++--------------------
 1 file changed, 23 insertions(+), 21 deletions(-)

diff --git a/node/p2p/blossomsub.go b/node/p2p/blossomsub.go
index 2bdcb1f..50d5d7d 100644
--- a/node/p2p/blossomsub.go
+++ b/node/p2p/blossomsub.go
@@ -854,33 +854,35 @@ func discoverPeers(
 			return
 		}
 
-		count := 12
+		count := 36
 		for peer := range peerChan {
 			if count == 0 {
 				break
 			}
 			peer := peer
-			if peer.ID == h.ID() ||
-				h.Network().Connectedness(peer.ID) == network.Connected ||
-				h.Network().Connectedness(peer.ID) == network.Limited {
-				continue
-			}
+			count--
+			go func() {
+				if peer.ID == h.ID() ||
+					h.Network().Connectedness(peer.ID) == network.Connected ||
+					h.Network().Connectedness(peer.ID) == network.Limited {
+					return
+				}
 
-			logger.Debug("found peer", zap.String("peer_id", peer.ID.String()))
-			err := h.Connect(ctx, peer)
-			if err != nil {
-				logger.Debug(
-					"error while connecting to blossomsub peer",
-					zap.String("peer_id", peer.ID.String()),
-					zap.Error(err),
-				)
-			} else {
-				count--
-				logger.Debug(
-					"connected to peer",
-					zap.String("peer_id", peer.ID.String()),
-				)
-			}
+				logger.Debug("found peer", zap.String("peer_id", peer.ID.String()))
+				err := h.Connect(ctx, peer)
+				if err != nil {
+					logger.Debug(
+						"error while connecting to blossomsub peer",
+						zap.String("peer_id", peer.ID.String()),
+						zap.Error(err),
+					)
+				} else {
+					logger.Debug(
+						"connected to peer",
+						zap.String("peer_id", peer.ID.String()),
+					)
+				}
+			}()
 		}
 	}