mirror of
https://github.com/fluencelabs/go-libp2p-kad-dht
synced 2025-04-24 22:32:13 +00:00
Add some sanity tests for the misdial failure
License: MIT Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
This commit is contained in:
parent
9454558e9d
commit
615497928c
14
dht_test.go
14
dht_test.go
@ -56,10 +56,24 @@ func setupDHTS(ctx context.Context, n int, t *testing.T) ([]ma.Multiaddr, []peer
|
||||
dhts := make([]*IpfsDHT, n)
|
||||
peers := make([]peer.ID, n)
|
||||
|
||||
sanityAddrsMap := make(map[string]struct{})
|
||||
sanityPeersMap := make(map[string]struct{})
|
||||
|
||||
for i := 0; i < n; i++ {
|
||||
dhts[i] = setupDHT(ctx, t)
|
||||
peers[i] = dhts[i].self
|
||||
addrs[i] = dhts[i].peerstore.Addrs(dhts[i].self)[0]
|
||||
|
||||
if _, lol := sanityAddrsMap[addrs[i].String()]; lol {
|
||||
t.Fatal("While setting up DHTs address got dumplicated.")
|
||||
} else {
|
||||
sanityAddrsMap[addrs[i].String()] = struct{}{}
|
||||
}
|
||||
if _, lol := sanityPeersMap[peers[i].String()]; lol {
|
||||
t.Fatal("While setting up DHTs peerid got dumplicated.")
|
||||
} else {
|
||||
sanityPeersMap[peers[i].String()] = struct{}{}
|
||||
}
|
||||
}
|
||||
|
||||
return addrs, peers, dhts
|
||||
|
Loading…
x
Reference in New Issue
Block a user