feat: update to go-libp2p-core 0.7.0

This uses the latest stream interface changes. (it also fixes a bug in the test)
libp2p · Sep 2, 2020 · 8682466 · 8682466
1 parent 6e94b6c
commit 8682466
Show file tree

Hide file tree

Showing 8 changed files with 63 additions and 20 deletions.
diff --git a/autonat.go b/autonat.go
@@ -15,7 +15,7 @@ import (
 
 	logging "github.com/ipfs/go-log"
 	ma "github.com/multiformats/go-multiaddr"
-	manet "github.com/multiformats/go-multiaddr-net"
+	manet "github.com/multiformats/go-multiaddr/net"
 )
 
 var log = logging.Logger("autonat")

diff --git a/autonat_test.go b/autonat_test.go
@@ -107,7 +107,7 @@ func TestAutoNATPrivate(t *testing.T) {
 	}
 
 	connect(t, hs, hc)
-	time.Sleep(1 * time.Second)
+	time.Sleep(2 * time.Millisecond)
 
 	status = an.Status()
 	if status != network.ReachabilityPrivate {

diff --git a/client.go b/client.go
@@ -5,7 +5,6 @@ import (
 	"fmt"
 
 	pb "github.com/libp2p/go-libp2p-autonat/pb"
-	"github.com/libp2p/go-libp2p-core/helpers"
 
 	ggio "github.com/gogo/protobuf/io"
 	"github.com/libp2p/go-libp2p-core/host"
@@ -41,7 +40,7 @@ func (c *client) DialBack(ctx context.Context, p peer.ID) (ma.Multiaddr, error)
 	}
 	// Might as well just reset the stream. Once we get to this point, we
 	// don't care about being nice.
-	defer helpers.FullClose(s)
+	defer s.Close()
 
 	r := ggio.NewDelimitedReader(s, network.MessageSizeMax)
 	w := ggio.NewDelimitedWriter(s)

diff --git a/dialpolicy.go b/dialpolicy.go
@@ -5,7 +5,7 @@ import (
 
 	"github.com/libp2p/go-libp2p-core/host"
 	ma "github.com/multiformats/go-multiaddr"
-	manet "github.com/multiformats/go-multiaddr-net"
+	manet "github.com/multiformats/go-multiaddr/net"
 )
 
 type dialPolicy struct {

diff --git a/go.mod b/go.mod
@@ -5,10 +5,9 @@ require (
 	github.com/ipfs/go-log v1.0.4
 	github.com/libp2p/go-eventbus v0.2.1
 	github.com/libp2p/go-libp2p-blankhost v0.2.0
-	github.com/libp2p/go-libp2p-core v0.6.0
-	github.com/libp2p/go-libp2p-swarm v0.2.8
-	github.com/multiformats/go-multiaddr v0.2.2
-	github.com/multiformats/go-multiaddr-net v0.1.5
+	github.com/libp2p/go-libp2p-core v0.7.0
+	github.com/libp2p/go-libp2p-swarm v0.3.0
+	github.com/multiformats/go-multiaddr v0.3.1
 )
 
 go 1.13
diff --git a/go.sum b/go.sum
diff --git a/notify.go b/notify.go
@@ -4,7 +4,7 @@ import (
 	"github.com/libp2p/go-libp2p-core/network"
 
 	ma "github.com/multiformats/go-multiaddr"
-	manet "github.com/multiformats/go-multiaddr-net"
+	manet "github.com/multiformats/go-multiaddr/net"
 )
 
 var _ network.Notifiee = (*AmbientAutoNAT)(nil)

diff --git a/svc.go b/svc.go
@@ -8,7 +8,6 @@ import (
 	"sync"
 	"time"
 
-	"github.com/libp2p/go-libp2p-core/helpers"
 	"github.com/libp2p/go-libp2p-core/network"
 	"github.com/libp2p/go-libp2p-core/peer"
 	"github.com/libp2p/go-libp2p-core/peerstore"
@@ -17,7 +16,7 @@ import (
 
 	ggio "github.com/gogo/protobuf/io"
 	ma "github.com/multiformats/go-multiaddr"
-	manet "github.com/multiformats/go-multiaddr-net"
+	manet "github.com/multiformats/go-multiaddr/net"
 )
 
 // AutoNATService provides NAT autodetection services to other peers
@@ -51,7 +50,7 @@ func newAutoNATService(ctx context.Context, c *config) (*autoNATService, error)
 }
 
 func (as *autoNATService) handleStream(s network.Stream) {
-	defer helpers.FullClose(s)
+	defer s.Close()
 
 	pid := s.Conn().RemotePeer()
 	log.Debugf("New stream from %s", pid.Pretty())