fix: use the routing table filter

Stebalien · Stebalien · commit c7a9b7321daa · 2020-04-08T16:34:15.000-07:00
fixes #575
diff --git a/subscriber_notifee.go b/subscriber_notifee.go
@@ -172,11 +172,11 @@ func handleLocalReachabilityChangedEvent(dht *IpfsDHT, e event.EvtLocalReachabil
 // routing table
 func (dht *IpfsDHT) validRTPeer(p peer.ID) (bool, error) {
 	protos, err := dht.peerstore.SupportsProtocols(p, protocol.ConvertToStrings(dht.protocols)...)
-	if err != nil {
+	if len(protos) == 0 || err != nil {
 		return false, err
 	}
 
-	return len(protos) > 0, nil
+	return dht.routingTablePeerFilter == nil || dht.routingTablePeerFilter(dht, dht.Host().Network().ConnsToPeer(p)), nil
 }
 
 func (nn *subscriberNotifee) Disconnected(n network.Network, v network.Conn) {

Original file line number	Diff line number	Diff line change
`@@ -172,11 +172,11 @@ func handleLocalReachabilityChangedEvent(dht *IpfsDHT, e event.EvtLocalReachabil`
`172`	`172`	`// routing table`
`173`	`173`	`func (dht *IpfsDHT) validRTPeer(p peer.ID) (bool, error) {`
`174`	`174`	`protos, err := dht.peerstore.SupportsProtocols(p, protocol.ConvertToStrings(dht.protocols)...)`
`175`		`- if err != nil {`
	`175`	`+ if len(protos) == 0 \|\| err != nil {`
`176`	`176`	`return false, err`
`177`	`177`	`}`
`178`	`178`
`179`		`- return len(protos) > 0, nil`
	`179`	`+ return dht.routingTablePeerFilter == nil \|\| dht.routingTablePeerFilter(dht, dht.Host().Network().ConnsToPeer(p)), nil`
`180`	`180`	`}`
`181`	`181`
`182`	`182`	`func (nn *subscriberNotifee) Disconnected(n network.Network, v network.Conn) {`