From 75255fbe7b0b29b95de30e6573f1528a7757f574 Mon Sep 17 00:00:00 2001
From: Henrique Dias <mail@hacdias.com>
Date: Wed, 27 Mar 2024 14:00:07 +0100
Subject: [PATCH] chore: upgrade go-libp2p-kad-dht

---
 client/rpc/api_test.go            |  1 +
 core/node/libp2p/routingopt.go    | 10 ++++++++--
 go.mod                            |  2 +-
 go.sum                            |  4 ++--
 test/cli/backup_bootstrap_test.go |  2 ++
 5 files changed, 14 insertions(+), 5 deletions(-)

diff --git a/client/rpc/api_test.go b/client/rpc/api_test.go
index 25bd26ceea63..7fa1c91f6128 100644
--- a/client/rpc/api_test.go
+++ b/client/rpc/api_test.go
@@ -47,6 +47,7 @@ func (np NodeProvider) MakeAPISwarm(t *testing.T, ctx context.Context, fullIdent
 				c.Experimental.FilestoreEnabled = true
 				n.WriteConfig(c)
 
+				n.Runner.Env["LAN_DHT_NO_FILTER"] = "true"
 				n.StartDaemon("--enable-pubsub-experiment", "--offline="+strconv.FormatBool(!online))
 
 				if online {
diff --git a/core/node/libp2p/routingopt.go b/core/node/libp2p/routingopt.go
index a58a8c498859..4fb3f00bd87b 100644
--- a/core/node/libp2p/routingopt.go
+++ b/core/node/libp2p/routingopt.go
@@ -116,10 +116,16 @@ func constructDHTRouting(mode dht.ModeOpt) RoutingOption {
 		if args.OptimisticProvideJobsPoolSize != 0 {
 			dhtOpts = append(dhtOpts, dht.OptimisticProvideJobsPoolSize(args.OptimisticProvideJobsPoolSize))
 		}
-		return dual.New(
-			args.Ctx, args.Host,
+		dualOptions := []dual.Option{
 			dual.DHTOption(dhtOpts...),
 			dual.WanDHTOption(dht.BootstrapPeers(args.BootstrapPeers...)),
+		}
+		if os.Getenv("LAN_DHT_NO_FILTER") == "true" {
+			dualOptions = append(dualOptions, dual.LanDHTOption(dht.AddressFilter(nil)))
+		}
+		return dual.New(
+			args.Ctx, args.Host,
+			dualOptions...,
 		)
 	}
 }
diff --git a/go.mod b/go.mod
index d07b3ee8e2b5..43abad8ff36a 100644
--- a/go.mod
+++ b/go.mod
@@ -49,7 +49,7 @@ require (
 	github.com/libp2p/go-doh-resolver v0.4.0
 	github.com/libp2p/go-libp2p v0.33.0
 	github.com/libp2p/go-libp2p-http v0.5.0
-	github.com/libp2p/go-libp2p-kad-dht v0.24.4
+	github.com/libp2p/go-libp2p-kad-dht v0.25.2
 	github.com/libp2p/go-libp2p-kbucket v0.6.3
 	github.com/libp2p/go-libp2p-pubsub v0.10.0
 	github.com/libp2p/go-libp2p-pubsub-router v0.6.0
diff --git a/go.sum b/go.sum
index fc2a4142c103..18ab786a5856 100644
--- a/go.sum
+++ b/go.sum
@@ -518,8 +518,8 @@ github.com/libp2p/go-libp2p-gostream v0.6.0 h1:QfAiWeQRce6pqnYfmIVWJFXNdDyfiR/qk
 github.com/libp2p/go-libp2p-gostream v0.6.0/go.mod h1:Nywu0gYZwfj7Jc91PQvbGU8dIpqbQQkjWgDuOrFaRdA=
 github.com/libp2p/go-libp2p-http v0.5.0 h1:+x0AbLaUuLBArHubbbNRTsgWz0RjNTy6DJLOxQ3/QBc=
 github.com/libp2p/go-libp2p-http v0.5.0/go.mod h1:glh87nZ35XCQyFsdzZps6+F4HYI6DctVFY5u1fehwSg=
-github.com/libp2p/go-libp2p-kad-dht v0.24.4 h1:ktNiJe7ffsJ1wX3ULpMCwXts99mPqGFSE/Qn1i8pErQ=
-github.com/libp2p/go-libp2p-kad-dht v0.24.4/go.mod h1:ybWBJ5Fbvz9sSLkNtXt+2+bK0JB8+tRPvhBbRGHegRU=
+github.com/libp2p/go-libp2p-kad-dht v0.25.2 h1:FOIk9gHoe4YRWXTu8SY9Z1d0RILol0TrtApsMDPjAVQ=
+github.com/libp2p/go-libp2p-kad-dht v0.25.2/go.mod h1:6za56ncRHYXX4Nc2vn8z7CZK0P4QiMcrn77acKLM2Oo=
 github.com/libp2p/go-libp2p-kbucket v0.3.1/go.mod h1:oyjT5O7tS9CQurok++ERgc46YLwEpuGoFq9ubvoUOio=
 github.com/libp2p/go-libp2p-kbucket v0.6.3 h1:p507271wWzpy2f1XxPzCQG9NiN6R6lHL9GiSErbQQo0=
 github.com/libp2p/go-libp2p-kbucket v0.6.3/go.mod h1:RCseT7AH6eJWxxk2ol03xtP9pEHetYSPXOaJnOiD8i0=
diff --git a/test/cli/backup_bootstrap_test.go b/test/cli/backup_bootstrap_test.go
index 017499f3d631..45e5e39a2565 100644
--- a/test/cli/backup_bootstrap_test.go
+++ b/test/cli/backup_bootstrap_test.go
@@ -13,6 +13,8 @@ import (
 func TestBackupBootstrapPeers(t *testing.T) {
 	nodes := harness.NewT(t).NewNodes(3).Init()
 	nodes.ForEachPar(func(n *harness.Node) {
+		n.Runner.Env["LAN_DHT_NO_FILTER"] = "true"
+
 		n.UpdateConfig(func(cfg *config.Config) {
 			cfg.Bootstrap = []string{}
 			cfg.Addresses.Swarm = []string{fmt.Sprintf("/ip4/127.0.0.1/tcp/%d", harness.NewRandPort())}