aboutsummaryrefslogtreecommitdiffstats
path: root/swarm/api
diff options
context:
space:
mode:
Diffstat (limited to 'swarm/api')
-rw-r--r--swarm/api/api.go7
-rw-r--r--swarm/api/config.go4
-rw-r--r--swarm/api/http/server_test.go6
-rw-r--r--swarm/api/manifest.go66
4 files changed, 45 insertions, 38 deletions
diff --git a/swarm/api/api.go b/swarm/api/api.go
index d733ad989..d7b6d8419 100644
--- a/swarm/api/api.go
+++ b/swarm/api/api.go
@@ -250,13 +250,6 @@ func NewAPI(fileStore *storage.FileStore, dns Resolver, resourceHandler *mru.Han
return
}
-// Upload to be used only in TEST
-func (a *API) Upload(ctx context.Context, uploadDir, index string, toEncrypt bool) (hash string, err error) {
- fs := NewFileSystem(a)
- hash, err = fs.Upload(uploadDir, index, toEncrypt)
- return hash, err
-}
-
// Retrieve FileStore reader API
func (a *API) Retrieve(ctx context.Context, addr storage.Address) (reader storage.LazySectionReader, isEncrypted bool) {
return a.fileStore.Retrieve(ctx, addr)
diff --git a/swarm/api/config.go b/swarm/api/config.go
index 3044dc2e5..baa13105a 100644
--- a/swarm/api/config.go
+++ b/swarm/api/config.go
@@ -62,6 +62,7 @@ type Config struct {
NetworkID uint64
SwapEnabled bool
SyncEnabled bool
+ SyncingSkipCheck bool
DeliverySkipCheck bool
LightNodeEnabled bool
SyncUpdateDelay time.Duration
@@ -89,7 +90,8 @@ func NewConfig() (c *Config) {
NetworkID: network.DefaultNetworkID,
SwapEnabled: false,
SyncEnabled: true,
- DeliverySkipCheck: false,
+ SyncingSkipCheck: false,
+ DeliverySkipCheck: true,
SyncUpdateDelay: 15 * time.Second,
SwapAPI: "",
}
diff --git a/swarm/api/http/server_test.go b/swarm/api/http/server_test.go
index efefa9fae..2acdbd1ad 100644
--- a/swarm/api/http/server_test.go
+++ b/swarm/api/http/server_test.go
@@ -477,12 +477,12 @@ func testBzzGetPath(encrypted bool, t *testing.T) {
var wait func(context.Context) error
ctx := context.TODO()
addr[i], wait, err = srv.FileStore.Store(ctx, reader[i], int64(len(mf)), encrypted)
- for j := i + 1; j < len(testmanifest); j++ {
- testmanifest[j] = strings.Replace(testmanifest[j], fmt.Sprintf("<key%v>", i), addr[i].Hex(), -1)
- }
if err != nil {
t.Fatal(err)
}
+ for j := i + 1; j < len(testmanifest); j++ {
+ testmanifest[j] = strings.Replace(testmanifest[j], fmt.Sprintf("<key%v>", i), addr[i].Hex(), -1)
+ }
err = wait(ctx)
if err != nil {
t.Fatal(err)
diff --git a/swarm/api/manifest.go b/swarm/api/manifest.go
index a1329a800..d44ad2277 100644
--- a/swarm/api/manifest.go
+++ b/swarm/api/manifest.go
@@ -69,9 +69,12 @@ func (a *API) NewManifest(ctx context.Context, toEncrypt bool) (storage.Address,
if err != nil {
return nil, err
}
- key, wait, err := a.Store(ctx, bytes.NewReader(data), int64(len(data)), toEncrypt)
- wait(ctx)
- return key, err
+ addr, wait, err := a.Store(ctx, bytes.NewReader(data), int64(len(data)), toEncrypt)
+ if err != nil {
+ return nil, err
+ }
+ err = wait(ctx)
+ return addr, err
}
// Manifest hack for supporting Mutable Resource Updates from the bzz: scheme
@@ -87,8 +90,12 @@ func (a *API) NewResourceManifest(ctx context.Context, resourceAddr string) (sto
if err != nil {
return nil, err
}
- key, _, err := a.Store(ctx, bytes.NewReader(data), int64(len(data)), false)
- return key, err
+ addr, wait, err := a.Store(ctx, bytes.NewReader(data), int64(len(data)), false)
+ if err != nil {
+ return nil, err
+ }
+ err = wait(ctx)
+ return addr, err
}
// ManifestWriter is used to add and remove entries from an underlying manifest
@@ -106,21 +113,26 @@ func (a *API) NewManifestWriter(ctx context.Context, addr storage.Address, quitC
return &ManifestWriter{a, trie, quitC}, nil
}
-// AddEntry stores the given data and adds the resulting key to the manifest
-func (m *ManifestWriter) AddEntry(ctx context.Context, data io.Reader, e *ManifestEntry) (key storage.Address, err error) {
+// AddEntry stores the given data and adds the resulting address to the manifest
+func (m *ManifestWriter) AddEntry(ctx context.Context, data io.Reader, e *ManifestEntry) (addr storage.Address, err error) {
entry := newManifestTrieEntry(e, nil)
if data != nil {
- key, _, err = m.api.Store(ctx, data, e.Size, m.trie.encrypted)
+ var wait func(context.Context) error
+ addr, wait, err = m.api.Store(ctx, data, e.Size, m.trie.encrypted)
+ if err != nil {
+ return nil, err
+ }
+ err = wait(ctx)
if err != nil {
return nil, err
}
- entry.Hash = key.Hex()
+ entry.Hash = addr.Hex()
}
if entry.Hash == "" {
- return key, errors.New("missing entry hash")
+ return addr, errors.New("missing entry hash")
}
m.trie.addEntry(entry, m.quitC)
- return key, nil
+ return addr, nil
}
// RemoveEntry removes the given path from the manifest
@@ -129,7 +141,7 @@ func (m *ManifestWriter) RemoveEntry(path string) error {
return nil
}
-// Store stores the manifest, returning the resulting storage key
+// Store stores the manifest, returning the resulting storage address
func (m *ManifestWriter) Store() (storage.Address, error) {
return m.trie.ref, m.trie.recalcAndStore()
}
@@ -211,51 +223,51 @@ type manifestTrieEntry struct {
subtrie *manifestTrie
}
-func loadManifest(ctx context.Context, fileStore *storage.FileStore, hash storage.Address, quitC chan bool, decrypt DecryptFunc) (trie *manifestTrie, err error) { // non-recursive, subtrees are downloaded on-demand
- log.Trace("manifest lookup", "key", hash)
+func loadManifest(ctx context.Context, fileStore *storage.FileStore, addr storage.Address, quitC chan bool, decrypt DecryptFunc) (trie *manifestTrie, err error) { // non-recursive, subtrees are downloaded on-demand
+ log.Trace("manifest lookup", "addr", addr)
// retrieve manifest via FileStore
- manifestReader, isEncrypted := fileStore.Retrieve(ctx, hash)
- log.Trace("reader retrieved", "key", hash)
- return readManifest(manifestReader, hash, fileStore, isEncrypted, quitC, decrypt)
+ manifestReader, isEncrypted := fileStore.Retrieve(ctx, addr)
+ log.Trace("reader retrieved", "addr", addr)
+ return readManifest(manifestReader, addr, fileStore, isEncrypted, quitC, decrypt)
}
-func readManifest(mr storage.LazySectionReader, hash storage.Address, fileStore *storage.FileStore, isEncrypted bool, quitC chan bool, decrypt DecryptFunc) (trie *manifestTrie, err error) { // non-recursive, subtrees are downloaded on-demand
+func readManifest(mr storage.LazySectionReader, addr storage.Address, fileStore *storage.FileStore, isEncrypted bool, quitC chan bool, decrypt DecryptFunc) (trie *manifestTrie, err error) { // non-recursive, subtrees are downloaded on-demand
// TODO check size for oversized manifests
size, err := mr.Size(mr.Context(), quitC)
if err != nil { // size == 0
// can't determine size means we don't have the root chunk
- log.Trace("manifest not found", "key", hash)
+ log.Trace("manifest not found", "addr", addr)
err = fmt.Errorf("Manifest not Found")
return
}
if size > manifestSizeLimit {
- log.Warn("manifest exceeds size limit", "key", hash, "size", size, "limit", manifestSizeLimit)
+ log.Warn("manifest exceeds size limit", "addr", addr, "size", size, "limit", manifestSizeLimit)
err = fmt.Errorf("Manifest size of %v bytes exceeds the %v byte limit", size, manifestSizeLimit)
return
}
manifestData := make([]byte, size)
read, err := mr.Read(manifestData)
if int64(read) < size {
- log.Trace("manifest not found", "key", hash)
+ log.Trace("manifest not found", "addr", addr)
if err == nil {
err = fmt.Errorf("Manifest retrieval cut short: read %v, expect %v", read, size)
}
return
}
- log.Debug("manifest retrieved", "key", hash)
+ log.Debug("manifest retrieved", "addr", addr)
var man struct {
Entries []*manifestTrieEntry `json:"entries"`
}
err = json.Unmarshal(manifestData, &man)
if err != nil {
- err = fmt.Errorf("Manifest %v is malformed: %v", hash.Log(), err)
- log.Trace("malformed manifest", "key", hash)
+ err = fmt.Errorf("Manifest %v is malformed: %v", addr.Log(), err)
+ log.Trace("malformed manifest", "addr", addr)
return
}
- log.Trace("manifest entries", "key", hash, "len", len(man.Entries))
+ log.Trace("manifest entries", "addr", addr, "len", len(man.Entries))
trie = &manifestTrie{
fileStore: fileStore,
@@ -406,12 +418,12 @@ func (mt *manifestTrie) recalcAndStore() error {
sr := bytes.NewReader(manifest)
ctx := context.TODO()
- key, wait, err2 := mt.fileStore.Store(ctx, sr, int64(len(manifest)), mt.encrypted)
+ addr, wait, err2 := mt.fileStore.Store(ctx, sr, int64(len(manifest)), mt.encrypted)
if err2 != nil {
return err2
}
err2 = wait(ctx)
- mt.ref = key
+ mt.ref = addr
return err2
}
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-19 21:13:22 +0800