fix: use a non-limited connection for querying

libp2p · Aug 19, 2024 · eca466c · eca466c
1 parent be9a8e7
commit eca466c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/query.go b/query.go
@@ -8,6 +8,7 @@ import (
 	"sync"
 	"time"
 
+	"github.com/libp2p/go-libp2p-core/network"
 	"github.com/libp2p/go-libp2p/core/peer"
 	pstore "github.com/libp2p/go-libp2p/core/peerstore"
 	"github.com/libp2p/go-libp2p/core/routing"
@@ -529,7 +530,7 @@ func (dht *IpfsDHT) dialPeer(ctx context.Context, p peer.ID) error {
 	defer span.End()
 
 	// short-circuit if we're already connected.
-	if HasValidConnectedness(dht.host, p) {
+	if dht.host.Network().Connectedness(p) == network.Connected {
 		return nil
 	}