mirror of
https://github.com/ipfs/kubo.git
synced 2026-02-26 12:57:44 +08:00
bugfixes in core + mocktest
This commit is contained in:
parent
b7fb545c2a
commit
5e0c02c099
@ -8,10 +8,15 @@ import (
|
||||
)
|
||||
|
||||
func TestSubsetWhenMaxIsGreaterThanLengthOfSlice(t *testing.T) {
|
||||
var ps []peer.Peer
|
||||
var ps []peer.PeerInfo
|
||||
sizeofSlice := 100
|
||||
for i := 0; i < sizeofSlice; i++ {
|
||||
ps = append(ps, testutil.RandPeer())
|
||||
pid, err := testutil.RandPeerID()
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
ps = append(ps, peer.PeerInfo{ID: pid})
|
||||
}
|
||||
out := randomSubsetOfPeers(ps, 2*sizeofSlice)
|
||||
if len(out) != len(ps) {
|
||||
|
||||
@ -3,9 +3,8 @@ package core
|
||||
import (
|
||||
"testing"
|
||||
|
||||
config "github.com/jbenet/go-ipfs/config"
|
||||
"github.com/jbenet/go-ipfs/peer"
|
||||
context "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/go.net/context"
|
||||
config "github.com/jbenet/go-ipfs/config"
|
||||
)
|
||||
|
||||
func TestInitialization(t *testing.T) {
|
||||
@ -60,22 +59,6 @@ func TestInitialization(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
func TestPeerIsLocal(t *testing.T) {
|
||||
t.Log("Ensure that peer is Local after initializing identity")
|
||||
|
||||
online := false
|
||||
peers := peer.NewPeerstore()
|
||||
|
||||
cfg := testIdentity
|
||||
p, err := initIdentity(&cfg, peers, online)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if p.GetType() != peer.Local {
|
||||
t.Fail()
|
||||
}
|
||||
}
|
||||
|
||||
var testIdentity = config.Identity{
|
||||
PeerID: "QmNgdzLieYi8tgfo2WfTUzNVH5hQK9oAYGVf6dxN12NrHt",
|
||||
PrivKey: "CAASrRIwggkpAgEAAoICAQCwt67GTUQ8nlJhks6CgbLKOx7F5tl1r9zF4m3TUrG3Pe8h64vi+ILDRFd7QJxaJ/n8ux9RUDoxLjzftL4uTdtv5UXl2vaufCc/C0bhCRvDhuWPhVsD75/DZPbwLsepxocwVWTyq7/ZHsCfuWdoh/KNczfy+Gn33gVQbHCnip/uhTVxT7ARTiv8Qa3d7qmmxsR+1zdL/IRO0mic/iojcb3Oc/PRnYBTiAZFbZdUEit/99tnfSjMDg02wRayZaT5ikxa6gBTMZ16Yvienq7RwSELzMQq2jFA4i/TdiGhS9uKywltiN2LrNDBcQJSN02pK12DKoiIy+wuOCRgs2NTQEhU2sXCk091v7giTTOpFX2ij9ghmiRfoSiBFPJA5RGwiH6ansCHtWKY1K8BS5UORM0o3dYk87mTnKbCsdz4bYnGtOWafujYwzueGx8r+IWiys80IPQKDeehnLW6RgoyjszKgL/2XTyP54xMLSW+Qb3BPgDcPaPO0hmop1hW9upStxKsefW2A2d46Ds4HEpJEry7PkS5M4gKL/zCKHuxuXVk14+fZQ1rstMuvKjrekpAC2aVIKMI9VRA3awtnje8HImQMdj+r+bPmv0N8rTTr3eS4J8Yl7k12i95LLfK+fWnmUh22oTNzkRlaiERQrUDyE4XNCtJc0xs1oe1yXGqazCIAQIDAQABAoICAQCk1N/ftahlRmOfAXk//8wNl7FvdJD3le6+YSKBj0uWmN1ZbUSQk64chr12iGCOM2WY180xYjy1LOS44PTXaeW5bEiTSnb3b3SH+HPHaWCNM2EiSogHltYVQjKW+3tfH39vlOdQ9uQ+l9Gh6iTLOqsCRyszpYPqIBwi1NMLY2Ej8PpVU7ftnFWouHZ9YKS7nAEiMoowhTu/7cCIVwZlAy3AySTuKxPMVj9LORqC32PVvBHZaMPJ+X1Xyijqg6aq39WyoztkXg3+Xxx5j5eOrK6vO/Lp6ZUxaQilHDXoJkKEJjgIBDZpluss08UPfOgiWAGkW+L4fgUxY0qDLDAEMhyEBAn6KOKVL1JhGTX6GjhWziI94bddSpHKYOEIDzUy4H8BXnKhtnyQV6ELS65C2hj9D0IMBTj7edCF1poJy0QfdK0cuXgMvxHLeUO5uc2YWfbNosvKxqygB9rToy4b22YvNwsZUXsTY6Jt+p9V2OgXSKfB5VPeRbjTJL6xqvvUJpQytmII/C9JmSDUtCbYceHj6X9jgigLk20VV6nWHqCTj3utXD6NPAjoycVpLKDlnWEgfVELDIk0gobxUqqSm3jTPEKRPJgxkgPxbwxYumtw++1UY2y35w3WRDc2xYPaWKBCQeZy+mL6ByXp9bWlNvxS3Knb6oZp36/ovGnf2pGvdQKCAQEAyKpipz2lIUySDyE0avVWAmQb2tWGKXALPohzj7AwkcfEg2GuwoC6GyVE2sTJD1HRazIjOKn3yQORg2uOPeG7sx7EKHxSxCKDrbPawkvLCq8JYSy9TLvhqKUVVGYPqMBzu2POSLEA81QXas+aYjKOFWA2Zrjq26zV9ey3+6Lc6WULePgRQybU8+RHJc6fdjUCCfUxgOrUO2IQOuTJ+FsDpVnrMUGlokmWn23OjL4qTL9wGDnWGUs2pjSzNbj3qA0d8iqaiMUyHX/D/VS0wpeT1osNBSm8suvSibYBn+7wbIApbwXUxZaxMv2OHGz3empae4ckvNZs7r8wsI9UwFt8mwKCAQEA4XK6gZkv9t+3YCcSPw2ensLvL/xU7i2bkC9tfTGdjnQfzZXIf5KNdVuj/SerOl2S1s45NMs3ysJbADwRb4ahElD/V71nGzV8fpFTitC20ro9fuX4J0+twmBolHqeH9pmeGTjAeL1rvt6vxs4FkeG/yNft7GdXpXTtEGaObn8Mt0tPY+aB3UnKrnCQoQAlPyGHFrVRX0UEcp6wyyNGhJCNKeNOvqCHTFObhbhO+KWpWSN0MkVHnqaIBnIn1Te8FtvP/iTwXGnKc0YXJUG6+LM6LmOguW6tg8ZqiQeYyyR+e9eCFH4csLzkrTl1GxCxwEsoSLIMm7UDcjttW6tYEghkwKCAQEAmeCO5lCPYImnN5Lu71ZTLmI2OgmjaANTnBBnDbi+hgv61gUCToUIMejSdDCTPfwv61P3TmyIZs0luPGxkiKYHTNqmOE9Vspgz8Mr7fLRMNApESuNvloVIY32XVImj/GEzh4rAfM6F15U1sN8T/EUo6+0B/Glp+9R49QzAfRSE2g48/rGwgf1JVHYfVWFUtAzUA+GdqWdOixo5cCsYJbqpNHfWVZN/bUQnBFIYwUwysnC29D+LUdQEQQ4qOm+gFAOtrWU62zMkXJ4iLt8Ify6kbrvsRXgbhQIzzGS7WH9XDarj0eZciuslr15TLMC1Azadf+cXHLR9gMHA13mT9vYIQKCAQA/DjGv8cKCkAvf7s2hqROGYAs6Jp8yhrsN1tYOwAPLRhtnCs+rLrg17M2vDptLlcRuI/vIElamdTmylRpjUQpX7yObzLO73nfVhpwRJVMdGU394iBIDncQ+JoHfUwgqJskbUM40dvZdyjbrqc/Q/4z+hbZb+oN/GXb8sVKBATPzSDMKQ/xqgisYIw+wmDPStnPsHAaIWOtni47zIgilJzD0WEk78/YjmPbUrboYvWziK5JiRRJFA1rkQqV1c0M+OXixIm+/yS8AksgCeaHr0WUieGcJtjT9uE8vyFop5ykhRiNxy9wGaq6i7IEecsrkd6DqxDHWkwhFuO1bSE83q/VAoIBAEA+RX1i/SUi08p71ggUi9WFMqXmzELp1L3hiEjOc2AklHk2rPxsaTh9+G95BvjhP7fRa/Yga+yDtYuyjO99nedStdNNSg03aPXILl9gs3r2dPiQKUEXZJ3FrH6tkils/8BlpOIRfbkszrdZIKTO9GCdLWQ30dQITDACs8zV/1GFGrHFrqnnMe/NpIFHWNZJ0/WZMi8wgWO6Ik8jHEpQtVXRiXLqy7U6hk170pa4GHOzvftfPElOZZjy9qn7KjdAQqy6spIrAE94OEL+fBgbHQZGLpuTlj6w6YGbMtPU8uo7sXKoc6WOCb68JWft3tejGLDa1946HAWqVM9B/UcneNc=",
|
||||
|
||||
@ -4,14 +4,18 @@ import (
|
||||
"testing"
|
||||
|
||||
ci "github.com/jbenet/go-ipfs/crypto"
|
||||
peer "github.com/jbenet/go-ipfs/peer"
|
||||
mockrouting "github.com/jbenet/go-ipfs/routing/mock"
|
||||
u "github.com/jbenet/go-ipfs/util"
|
||||
testutil "github.com/jbenet/go-ipfs/util/testutil"
|
||||
)
|
||||
|
||||
func TestRoutingResolve(t *testing.T) {
|
||||
local := testutil.NewPeerWithIDString("testID")
|
||||
d := mockrouting.NewServer().Client(local)
|
||||
local, err := testutil.RandPeerID()
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
d := mockrouting.NewServer().Client(peer.PeerInfo{ID: local})
|
||||
|
||||
resolver := NewRoutingResolver(d)
|
||||
publisher := NewRoutingPublisher(d)
|
||||
|
||||
@ -25,28 +25,44 @@ func randPeer(t *testing.T) peer.ID {
|
||||
func TestNetworkSetup(t *testing.T) {
|
||||
|
||||
ctx := context.Background()
|
||||
p1 := randPeer(t)
|
||||
p2 := randPeer(t)
|
||||
p3 := randPeer(t)
|
||||
sk1, _, err := testutil.RandKeyPair(512)
|
||||
if err != nil {
|
||||
t.Fatal(t)
|
||||
}
|
||||
sk2, _, err := testutil.RandKeyPair(512)
|
||||
if err != nil {
|
||||
t.Fatal(t)
|
||||
}
|
||||
sk3, _, err := testutil.RandKeyPair(512)
|
||||
if err != nil {
|
||||
t.Fatal(t)
|
||||
}
|
||||
mn := New(ctx)
|
||||
// peers := []peer.ID{p1, p2, p3}
|
||||
|
||||
// add peers to mock net
|
||||
|
||||
n1, err := mn.AddPeer(p1)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
a1 := testutil.RandLocalTCPAddress()
|
||||
a2 := testutil.RandLocalTCPAddress()
|
||||
a3 := testutil.RandLocalTCPAddress()
|
||||
|
||||
n2, err := mn.AddPeer(p2)
|
||||
n1, err := mn.AddPeer(sk1, a1)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
p1 := n1.LocalPeer()
|
||||
|
||||
n3, err := mn.AddPeer(p3)
|
||||
n2, err := mn.AddPeer(sk2, a2)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
p2 := n2.LocalPeer()
|
||||
|
||||
n3, err := mn.AddPeer(sk3, a3)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
p3 := n3.LocalPeer()
|
||||
|
||||
// check peers and net
|
||||
if mn.Net(p1) != n1 {
|
||||
@ -377,17 +393,25 @@ func TestAdding(t *testing.T) {
|
||||
|
||||
mn := New(context.Background())
|
||||
|
||||
p1 := randPeer(t)
|
||||
p2 := randPeer(t)
|
||||
p3 := randPeer(t)
|
||||
peers := []peer.ID{p1, p2, p3}
|
||||
|
||||
for _, p := range peers {
|
||||
if _, err := mn.AddPeer(p); err != nil {
|
||||
t.Error(err)
|
||||
peers := []peer.ID{}
|
||||
for i := 0; i < 3; i++ {
|
||||
sk, _, err := testutil.RandKeyPair(512)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
a := testutil.RandLocalTCPAddress()
|
||||
n, err := mn.AddPeer(sk, a)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
peers = append(peers, n.LocalPeer())
|
||||
}
|
||||
|
||||
p1 := peers[0]
|
||||
p2 := peers[1]
|
||||
|
||||
// link them
|
||||
for _, p1 := range peers {
|
||||
for _, p2 := range peers {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user