mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-25 06:06:44 +00:00
0de16bd17e
* SectionReader -> LazySectionReader: Size method signature change * introduce abort channel to joiner to fix process leak * add abort channel context to all manifest retrieval methods * global waitgroup fixes intermittent upload test failures due to unfinished storage of chunks * add back final slash to paths in manifest matching * simplify downloader code and fix process leak * fix filesystem api tests * streamline joiner logic, contexts now unique to each readAt call * LazyChunkReader seeker complains about missing size only if whence=2
62 lines
1.8 KiB
Go
62 lines
1.8 KiB
Go
package api
|
|
|
|
import (
|
|
// "encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/ethereum/go-ethereum/swarm/storage"
|
|
)
|
|
|
|
func manifest(paths ...string) (manifestReader storage.LazySectionReader) {
|
|
var entries []string
|
|
for _, path := range paths {
|
|
entry := fmt.Sprintf(`{"path":"%s"}`, path)
|
|
entries = append(entries, entry)
|
|
}
|
|
manifest := fmt.Sprintf(`{"entries":[%s]}`, strings.Join(entries, ","))
|
|
return &storage.LazyTestSectionReader{io.NewSectionReader(strings.NewReader(manifest), 0, int64(len(manifest)))}
|
|
}
|
|
|
|
func testGetEntry(t *testing.T, path, match string, paths ...string) *manifestTrie {
|
|
quitC := make(chan bool)
|
|
trie, err := readManifest(manifest(paths...), nil, nil, quitC)
|
|
if err != nil {
|
|
t.Errorf("unexpected error making manifest: %v", err)
|
|
}
|
|
checkEntry(t, path, match, trie)
|
|
return trie
|
|
}
|
|
|
|
func checkEntry(t *testing.T, path, match string, trie *manifestTrie) {
|
|
entry, fullpath := trie.getEntry(path)
|
|
if match == "-" && entry != nil {
|
|
t.Errorf("expected no match for '%s', got '%s'", path, fullpath)
|
|
} else if entry == nil {
|
|
if match != "-" {
|
|
t.Errorf("expected entry '%s' to match '%s', got no match", match, path)
|
|
}
|
|
} else if fullpath != match {
|
|
t.Errorf("incorrect entry retrieved for '%s'. expected path '%v', got '%s'", path, match, fullpath)
|
|
}
|
|
}
|
|
|
|
func TestGetEntry(t *testing.T) {
|
|
// file system manifest always contains regularized paths
|
|
testGetEntry(t, "a", "a", "a")
|
|
testGetEntry(t, "b", "-", "a")
|
|
testGetEntry(t, "/a//", "a", "a")
|
|
// fallback
|
|
testGetEntry(t, "/a", "", "")
|
|
testGetEntry(t, "/a/b", "a/b", "a/b")
|
|
// longest/deepest math
|
|
testGetEntry(t, "a/b", "-", "a", "a/ba", "a/b/c")
|
|
testGetEntry(t, "a/b", "a/b", "a", "a/b", "a/bb", "a/b/c")
|
|
testGetEntry(t, "//a//b//", "a/b", "a", "a/b", "a/bb", "a/b/c")
|
|
}
|
|
|
|
func TestDeleteEntry(t *testing.T) {
|
|
|
|
}
|