mirror of
https://github.com/ipfs/kubo.git
synced 2025-08-06 11:31:54 +08:00
47 lines
1.5 KiB
Go
47 lines
1.5 KiB
Go
package corehttp
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
core "github.com/ipfs/go-ipfs/core"
|
|
context "gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
|
|
bhost "gx/ipfs/QmcQTVCQWCN2MYgBHpFXE5S56rcg2mRsxaRgMYmA1UWgA8/go-libp2p/p2p/host/basic"
|
|
inet "gx/ipfs/QmcQTVCQWCN2MYgBHpFXE5S56rcg2mRsxaRgMYmA1UWgA8/go-libp2p/p2p/net"
|
|
testutil "gx/ipfs/QmcQTVCQWCN2MYgBHpFXE5S56rcg2mRsxaRgMYmA1UWgA8/go-libp2p/p2p/test/util"
|
|
)
|
|
|
|
// This test is based on go-libp2p/p2p/net/swarm.TestConnectednessCorrect
|
|
// It builds 4 nodes and connects them, one being the sole center.
|
|
// Then it checks that the center reports the correct number of peers.
|
|
func TestPeersTotal(t *testing.T) {
|
|
ctx := context.Background()
|
|
|
|
hosts := make([]*bhost.BasicHost, 4)
|
|
for i := 0; i < 4; i++ {
|
|
hosts[i] = testutil.GenHostSwarm(t, ctx)
|
|
}
|
|
|
|
dial := func(a, b inet.Network) {
|
|
testutil.DivulgeAddresses(b, a)
|
|
if _, err := a.DialPeer(ctx, b.LocalPeer()); err != nil {
|
|
t.Fatalf("Failed to dial: %s", err)
|
|
}
|
|
}
|
|
|
|
dial(hosts[0].Network(), hosts[1].Network())
|
|
dial(hosts[0].Network(), hosts[2].Network())
|
|
dial(hosts[0].Network(), hosts[3].Network())
|
|
|
|
// there's something wrong with dial, i think. it's not finishing
|
|
// completely. there must be some async stuff.
|
|
<-time.After(100 * time.Millisecond)
|
|
|
|
node := &core.IpfsNode{PeerHost: hosts[0]}
|
|
collector := IpfsNodeCollector{Node: node}
|
|
actual := collector.PeersTotalValue()
|
|
if actual != 3 {
|
|
t.Fatalf("expected 3 peers, got %d", int(actual))
|
|
}
|
|
}
|