mirror of
https://github.com/ipfs/kubo.git
synced 2026-03-01 06:17:56 +08:00
098933ade4
* go-datastore and friends: GetSize * badger: new release, fewer allocations * go-mplex: send fewer packets * go-bitswap: pack multiple blocks in a single message, fewer allocations * go-buffer-pool: replace the buffer pool from go-msgio * yamux: fixed data race and uses go-buffer-pool for stream read-buffers to reduce memory and allocations. * go-libp2p-secio: get rid of a hot-spot allocation * go-libp2p-peerstore: reduced allocations (at the cost of some memory) More? License: MIT Signed-off-by: Steven Allen <steven@stebalien.com>
152 lines
3.3 KiB
Go
152 lines
3.3 KiB
Go
package coreapi_test
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
"io/ioutil"
|
|
"math/rand"
|
|
"testing"
|
|
"time"
|
|
|
|
ipath "gx/ipfs/QmQmMu1vsgsjxyB8tzrA6ZTCTCLDLVaXMb4Q57r2v886Sx/go-path"
|
|
files "gx/ipfs/QmSP88ryZkHSRn1fnngAaV2Vcn63WUJzAavnRM9CVdU1Ky/go-ipfs-cmdkit/files"
|
|
|
|
coreiface "github.com/ipfs/go-ipfs/core/coreapi/interface"
|
|
opt "github.com/ipfs/go-ipfs/core/coreapi/interface/options"
|
|
)
|
|
|
|
var rnd = rand.New(rand.NewSource(0x62796532303137))
|
|
|
|
func addTestObject(ctx context.Context, api coreiface.CoreAPI) (coreiface.Path, error) {
|
|
return api.Unixfs().Add(ctx, files.NewReaderFile("", "", ioutil.NopCloser(&io.LimitedReader{R: rnd, N: 4092}), nil))
|
|
}
|
|
|
|
func TestBasicPublishResolve(t *testing.T) {
|
|
ctx := context.Background()
|
|
nds, apis, err := makeAPISwarm(ctx, true, 5)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
n := nds[0]
|
|
api := apis[0]
|
|
|
|
p, err := addTestObject(ctx, api)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
e, err := api.Name().Publish(ctx, p)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
if e.Name() != n.Identity.Pretty() {
|
|
t.Errorf("expected e.Name to equal '%s', got '%s'", n.Identity.Pretty(), e.Name())
|
|
}
|
|
|
|
if e.Value().String() != p.String() {
|
|
t.Errorf("expected paths to match, '%s'!='%s'", e.Value().String(), p.String())
|
|
}
|
|
|
|
resPath, err := api.Name().Resolve(ctx, e.Name())
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
if resPath.String() != p.String() {
|
|
t.Errorf("expected paths to match, '%s'!='%s'", resPath.String(), p.String())
|
|
}
|
|
}
|
|
|
|
func TestBasicPublishResolveKey(t *testing.T) {
|
|
ctx := context.Background()
|
|
_, apis, err := makeAPISwarm(ctx, true, 5)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
api := apis[0]
|
|
|
|
k, err := api.Key().Generate(ctx, "foo")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
p, err := addTestObject(ctx, api)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
e, err := api.Name().Publish(ctx, p, opt.Name.Key(k.Name()))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
if ipath.Join([]string{"/ipns", e.Name()}) != k.Path().String() {
|
|
t.Errorf("expected e.Name to equal '%s', got '%s'", e.Name(), k.Path().String())
|
|
}
|
|
|
|
if e.Value().String() != p.String() {
|
|
t.Errorf("expected paths to match, '%s'!='%s'", e.Value().String(), p.String())
|
|
}
|
|
|
|
resPath, err := api.Name().Resolve(ctx, e.Name())
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
if resPath.String() != p.String() {
|
|
t.Errorf("expected paths to match, '%s'!='%s'", resPath.String(), p.String())
|
|
}
|
|
}
|
|
|
|
func TestBasicPublishResolveTimeout(t *testing.T) {
|
|
t.Skip("ValidTime doesn't appear to work at this time resolution")
|
|
|
|
ctx := context.Background()
|
|
nds, apis, err := makeAPISwarm(ctx, true, 5)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
n := nds[0]
|
|
api := apis[0]
|
|
p, err := addTestObject(ctx, api)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
e, err := api.Name().Publish(ctx, p, opt.Name.ValidTime(time.Millisecond*100))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
return
|
|
}
|
|
|
|
if e.Name() != n.Identity.Pretty() {
|
|
t.Errorf("expected e.Name to equal '%s', got '%s'", n.Identity.Pretty(), e.Name())
|
|
}
|
|
|
|
if e.Value().String() != p.String() {
|
|
t.Errorf("expected paths to match, '%s'!='%s'", e.Value().String(), p.String())
|
|
}
|
|
|
|
time.Sleep(time.Second)
|
|
|
|
_, err = api.Name().Resolve(ctx, e.Name())
|
|
if err == nil {
|
|
t.Fatal("Expected an error")
|
|
return
|
|
}
|
|
}
|
|
|
|
//TODO: When swarm api is created, add multinode tests
|