From 3a81c2407349d478561c481957b757ec23555bb3 Mon Sep 17 00:00:00 2001
From: vyzo <vyzo@hackzen.org>
Date: Mon, 10 Aug 2020 13:49:50 +0300
Subject: [PATCH] don't add direct peers to fanout

---
 gossipsub.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/gossipsub.go b/gossipsub.go
index c4e37d1..489cfbb 100644
--- a/gossipsub.go
+++ b/gossipsub.go
@@ -903,7 +903,8 @@ func (gs *GossipSubRouter) Publish(msg *Message) {
 			if !ok || len(gmap) == 0 {
 				// we don't have any, pick some with score above the publish threshold
 				peers := gs.getPeers(topic, gs.D, func(p peer.ID) bool {
-					return gs.score.Score(p) >= gs.publishThreshold
+					_, direct := gs.direct[p]
+					return !direct && gs.score.Score(p) >= gs.publishThreshold
 				})
 
 				if len(peers) > 0 {