status-go/peers/cache_test.go

98 lines
2.3 KiB
Go
Raw Normal View History

2018-04-10 06:44:09 +00:00
package peers
import (
"net"
"testing"
"github.com/ethereum/go-ethereum/p2p/enode"
"github.com/ethereum/go-ethereum/crypto"
2018-04-10 06:44:09 +00:00
"github.com/ethereum/go-ethereum/p2p/discv5"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/syndtr/goleveldb/leveldb"
"github.com/syndtr/goleveldb/leveldb/storage"
2018-04-10 06:44:09 +00:00
)
func TestPeersRange(t *testing.T) {
peersDB, err := newInMemoryCache()
2018-04-10 06:44:09 +00:00
require.NoError(t, err)
topic := discv5.Topic("test")
peerCount := 3
peers, err := createDiscv5Peers(peerCount)
require.NoError(t, err)
addedPeerIDs := make(map[string]struct{})
2018-04-10 06:44:09 +00:00
for _, peer := range peers {
assert.NoError(t, peersDB.AddPeer(peer, topic))
addedPeerIDs[peer.String()] = struct{}{}
2018-04-10 06:44:09 +00:00
}
// check if all peers are cached
cachedNodes := peersDB.GetPeersRange(topic, peerCount)
require.Len(t, cachedNodes, peerCount)
// and returned peers are these we just created
for _, node := range cachedNodes {
_, ok := addedPeerIDs[node.String()]
assert.True(t, ok)
}
// test removing peers
pk, err := peers[0].ID.Pubkey()
require.NoError(t, err)
require.NoError(t, peersDB.RemovePeer(enode.PubkeyToIDV4(pk), topic))
cachedNodes = peersDB.GetPeersRange(topic, peerCount)
require.Len(t, cachedNodes, peerCount-1)
2018-04-10 06:44:09 +00:00
}
func TestMultipleTopics(t *testing.T) {
peersDB, err := newInMemoryCache()
require.NoError(t, err)
topics := []discv5.Topic{discv5.Topic("first"), discv5.Topic("second")}
peerCount := 3
peers, err := createDiscv5Peers(peerCount)
require.NoError(t, err)
for i := range topics {
for _, peer := range peers {
assert.NoError(t, peersDB.AddPeer(peer, topics[i]))
}
}
for i := range topics {
nodes := peersDB.GetPeersRange(topics[i], peerCount+1)
assert.Len(t, nodes, peerCount)
}
}
// newInMemoryCache creates a cache for tests
func newInMemoryCache() (*Cache, error) {
memdb, err := leveldb.Open(storage.NewMemStorage(), nil)
if err != nil {
return nil, err
}
return NewCache(memdb), nil
}
func createDiscv5Peers(count int) ([]*discv5.Node, error) {
nodes := make([]*discv5.Node, count)
for i := 0; i < count; i++ {
id, err := crypto.GenerateKey()
if err != nil {
return nil, err
}
nodes[i] = discv5.NewNode(
discv5.PubkeyID(&id.PublicKey),
net.IPv4(10, 10, 0, byte(i)),
32311,
32311,
)
}
return nodes, nil
}