From d47925db4b540ac59b956aef96421abf8a5fb65f Mon Sep 17 00:00:00 2001 From: ChronosX88 Date: Thu, 22 Oct 2020 02:04:31 +0400 Subject: [PATCH] Change DHT implementation to dual DHT --- node/node.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/node/node.go b/node/node.go index aa250eb..3e70d95 100644 --- a/node/node.go +++ b/node/node.go @@ -5,6 +5,7 @@ import ( "crypto/rand" "flag" "fmt" + "github.com/libp2p/go-libp2p-kad-dht/dual" "sync" "time" @@ -18,7 +19,6 @@ import ( "github.com/libp2p/go-libp2p-core/host" peer "github.com/libp2p/go-libp2p-core/peer" discovery "github.com/libp2p/go-libp2p-discovery" - dht "github.com/libp2p/go-libp2p-kad-dht" peerstore "github.com/libp2p/go-libp2p-peerstore" "github.com/multiformats/go-multiaddr" "github.com/sirupsen/logrus" @@ -98,9 +98,9 @@ func (n *Node) setupLibp2pHost(ctx context.Context, privateKey crypto.PrivKey) { } n.Host = host - logrus.Info(fmt.Sprintf("[*] Your Multiaddress Is: /ip4/%s/tcp/%v/p2p/%s\n", n.Config.ListenAddr, n.Config.ListenPort, host.ID().Pretty())) + logrus.Info(fmt.Sprintf("[*] Your Multiaddress Is: /ip4/%s/tcp/%v/p2p/%s", n.Config.ListenAddr, n.Config.ListenPort, host.ID().Pretty())) - kademliaDHT, err := dht.New(context.Background(), n.Host) + kademliaDHT, err := dual.New(context.Background(), n.Host) if err != nil { logrus.Fatal("Failed to create new DHT instance: ", err) }