Skip to content

Commit

Permalink
test: refactor some utities out of mod package
Browse files Browse the repository at this point in the history
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
  • Loading branch information
Kubuxu committed Aug 18, 2016
1 parent de3c28f commit 00a2f0c
Show file tree
Hide file tree
Showing 3 changed files with 151 additions and 180 deletions.
56 changes: 5 additions & 51 deletions unixfs/io/dagserv_test.go
Original file line number Diff line number Diff line change
@@ -1,63 +1,17 @@
package io

import (
"bytes"
"fmt"
"io"
"io/ioutil"
"testing"

imp "github.com/ipfs/go-ipfs/importer"
"github.com/ipfs/go-ipfs/importer/chunk"
mdag "github.com/ipfs/go-ipfs/merkledag"
mdagmock "github.com/ipfs/go-ipfs/merkledag/test"

u "gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
context "gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context"
)

func sizeSplitterGen(size int64) chunk.SplitterGen {
return func(r io.Reader) chunk.Splitter {
return chunk.NewSizeSplitter(r, size)
}
}

func getNode(t testing.TB, dserv mdag.DAGService, data []byte) *mdag.Node {
in := bytes.NewReader(data)
node, err := imp.BuildTrickleDagFromReader(dserv, sizeSplitterGen(500)(in))
if err != nil {
t.Fatal(err)
}

return node
}

func getRandomNode(t testing.TB, dserv mdag.DAGService, size int64) ([]byte, *mdag.Node) {
in := io.LimitReader(u.NewTimeSeededRand(), size)
buf, err := ioutil.ReadAll(in)
if err != nil {
t.Fatal(err)
}

node := getNode(t, dserv, buf)
return buf, node
}

func arrComp(a, b []byte) error {
if len(a) != len(b) {
return fmt.Errorf("Arrays differ in length. %d != %d", len(a), len(b))
}
for i, v := range a {
if v != b[i] {
return fmt.Errorf("Arrays differ at index: %d", i)
}
}
return nil
}
testu "github.com/ipfs/go-ipfs/unixfs/test"
)

func TestBasicRead(t *testing.T) {
dserv := mdagmock.Mock()
inbuf, node := getRandomNode(t, dserv, 1024)
dserv := testu.GetDAGServ()
inbuf, node := testu.GetRandomNode(t, dserv, 1024)
ctx, closer := context.WithCancel(context.Background())
defer closer()

Expand All @@ -71,7 +25,7 @@ func TestBasicRead(t *testing.T) {
t.Fatal(err)
}

err = arrComp(inbuf, outbuf)
err = testu.ArrComp(inbuf, outbuf)
if err != nil {
t.Fatal(err)
}
Expand Down
Loading

0 comments on commit 00a2f0c

Please sign in to comment.