Fix flaky libp2p tests (#105)

Addresses #103

libp2p/libp2pendpoint_test.go

@@ -12,6 +12,7 @@ import (
 	"github.com/libp2p/go-libp2p/core/peer"
 	"github.com/libp2p/go-libp2p/p2p/net/swarm"
 	ma "github.com/multiformats/go-multiaddr"
+	manet "github.com/multiformats/go-multiaddr/net"
 	"github.com/stretchr/testify/require"
 
 	"github.com/plprobelab/go-kademlia/event"
@@ -135,12 +136,16 @@ func TestConnections(t *testing.T) {
 	connectedness, err = endpoints[0].Connectedness(ids[1])
 	require.NoError(t, err)
 	require.Equal(t, endpoint.Connected, connectedness)
+
 	// test peerinfo
 	peerinfo, err = endpoints[0].PeerInfo(ids[1])
 	require.NoError(t, err)
-	require.Len(t, peerinfo.Addrs, len(addrs[1].Addrs))
-	for _, addr := range peerinfo.Addrs {
-		require.Contains(t, addrs[1].Addrs, addr)
+	// filter out loopback addresses
+	expectedAddrs := ma.FilterAddrs(addrs[1].Addrs, func(a ma.Multiaddr) bool {
+		return !manet.IsIPLoopback(a)
+	})
+	for _, addr := range expectedAddrs {
+		require.Contains(t, peerinfo.Addrs, addr, addr.String(), expectedAddrs)
 	}
 	peerinfo, err = endpoints[0].PeerInfo(ids[2])
 	require.NoError(t, err)
@@ -181,7 +186,7 @@ func TestAsyncDial(t *testing.T) {
 		// AsyncDialAndReport adds the dial action to the event queue, so we
 		// need to run the scheduler
 		for !scheds[0].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[0].Clock().Sleep(time.Millisecond)
 		}
 		wg.Done()
 	}()
@@ -216,7 +221,7 @@ func TestAsyncDial(t *testing.T) {
 		// AsyncDialAndReport adds the dial action to the event queue, so we
 		// need to run the scheduler
 		for !scheds[0].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[0].Clock().Sleep(time.Millisecond)
 		}
 		wg.Done()
 	}()
@@ -327,15 +332,15 @@ func TestSuccessfulRequest(t *testing.T) {
 	go func() {
 		// run server 1
 		for !scheds[1].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[1].Clock().Sleep(time.Millisecond)
 		}
 		require.False(t, scheds[1].RunOne(ctx)) // only 1 action should run on server
 		wg.Done()
 	}()
 	go func() {
 		// timeout is queued in the scheduler 0
 		for !scheds[0].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[0].Clock().Sleep(time.Millisecond)
 		}
 		require.False(t, scheds[0].RunOne(ctx))
 		wg.Done()
@@ -384,7 +389,7 @@ func TestReqUnknownPeer(t *testing.T) {
 	go func() {
 		// timeout is queued in the scheduler 0
 		for !scheds[0].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[0].Clock().Sleep(time.Millisecond)
 		}
 		require.False(t, scheds[0].RunOne(ctx))
 		wg.Done()
@@ -425,7 +430,7 @@ func TestReqTimeout(t *testing.T) {
 	go func() {
 		// timeout is queued in the scheduler 0
 		for !scheds[0].RunOne(ctx) {
-			time.Sleep(1 * time.Millisecond)
+			scheds[0].Clock().Sleep(time.Millisecond)
 		}
 		require.False(t, scheds[0].RunOne(ctx))
 		wg.Done()
@@ -473,7 +478,7 @@ func TestReqHandlerError(t *testing.T) {
 	wg.Add(2)
 	go func() {
 		for !scheds[1].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[1].Clock().Sleep(time.Millisecond)
 		}
 		require.False(t, scheds[1].RunOne(ctx))
 		cancel()
@@ -482,7 +487,7 @@ func TestReqHandlerError(t *testing.T) {
 	go func() {
 		// timeout is queued in the scheduler 0
 		for !scheds[0].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[0].Clock().Sleep(time.Millisecond)
 		}
 		require.False(t, scheds[0].RunOne(ctx))
 		wg.Done()
@@ -527,7 +532,7 @@ func TestReqHandlerReturnsWrongType(t *testing.T) {
 	wg.Add(2)
 	go func() {
 		for !scheds[1].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[1].Clock().Sleep(time.Millisecond)
 		}
 		require.False(t, scheds[1].RunOne(ctx))
 		cancel()
@@ -536,7 +541,7 @@ func TestReqHandlerReturnsWrongType(t *testing.T) {
 	go func() {
 		// timeout is queued in the scheduler 0
 		for !scheds[0].RunOne(ctx) {
-			time.Sleep(time.Millisecond)
+			scheds[0].Clock().Sleep(time.Millisecond)
 		}
 		require.False(t, scheds[0].RunOne(ctx))
 		wg.Done()