From 86dff903642151a5872d95570a13abd5efc37b2d Mon Sep 17 00:00:00 2001
From: Kilian Tyler <kilian@kil.dev>
Date: Fri, 2 Jan 2026 14:25:59 -0500
Subject: [PATCH] perf(gossip): add fanout-limited relay to reduce bandwidth

Instead of relaying messages to ALL connections, relay to max 3
random peers. This reduces O(N) per-hop to O(1) while maintaining
epidemic spread through the network.
---
 server.js | 27 +++++++++++++++++++++++----
 1 file changed, 23 insertions(+), 4 deletions(-)

diff --git a/server.js b/server.js
index 65e7140..cfdccb6 100644
--- a/server.js
+++ b/server.js
@@ -9,6 +9,9 @@ const PORT = process.env.PORT || 3000;
 const TOPIC_NAME = "hypermind-lklynet-v1";
 const TOPIC = crypto.createHash("sha256").update(TOPIC_NAME).digest();
 
+// Gossip protocol tuning
+const GOSSIP_FANOUT = 3; // Relay to max 3 random peers instead of all
+
 // --- SECURITY ---
 // We use Ed25519 for signatures and a PoW puzzle to prevent Sybil attacks.
 // Difficulty: Hash(ID + nonce) must start with '0000'
@@ -176,12 +179,28 @@ function handleMessage(msg, sourceSocket) {
   }
 }
 
+// Fisher-Yates shuffle for random peer selection
+function shuffleArray(array) {
+  for (let i = array.length - 1; i > 0; i--) {
+    const j = Math.floor(Math.random() * (i + 1));
+    [array[i], array[j]] = [array[j], array[i]];
+  }
+  return array;
+}
+
 function relayMessage(msg, sourceSocket) {
   const data = JSON.stringify(msg) + "\n";
-  for (const socket of swarm.connections) {
-    if (socket !== sourceSocket) {
-      socket.write(data);
-    }
+  
+  // Get all eligible sockets (excluding source)
+  const eligibleSockets = [...swarm.connections].filter(s => s !== sourceSocket);
+  
+  // Apply fanout limiting - only relay to GOSSIP_FANOUT random peers
+  const targetSockets = eligibleSockets.length <= GOSSIP_FANOUT 
+    ? eligibleSockets 
+    : shuffleArray(eligibleSockets).slice(0, GOSSIP_FANOUT);
+  
+  for (const socket of targetSockets) {
+    socket.write(data);
   }
 }