fix: use direct upload (#363)

ethersphere · Oct 26, 2023 · 7d384c3 · 7d384c3
1 parent 966d6dd
commit 7d384c3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/pkg/bee/api/files.go b/pkg/bee/api/files.go
@@ -34,6 +34,9 @@ func (f *FilesService) Upload(ctx context.Context, name string, data io.Reader,
 	if o.Tag != 0 {
 		header.Set(swarmTagHeader, strconv.FormatUint(o.Tag, 10))
 	}
+	if o.Direct {
+		header.Set(deferredUploadHeader, strconv.FormatBool(false))
+	}
 	header.Set(postageStampBatchHeader, o.BatchID)
 
 	err = f.client.requestWithHeader(ctx, http.MethodPost, "/"+apiVersion+"/bzz?"+url.QueryEscape("name="+name), header, data, &resp)

diff --git a/pkg/check/settlements/settlements.go b/pkg/check/settlements/settlements.go
@@ -42,7 +42,7 @@ func NewDefaultOptions() Options {
 		FileSize:           1 * 1024 * 1024, // 1mb
 		GasPrice:           "",
 		PostageAmount:      1,
-		PostageDepth:       16,
+		PostageDepth:       20,
 		PostageLabel:       "test-label",
 		Seed:               0,
 		Threshold:          10000000000000,
@@ -126,7 +126,7 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, opts int
 		}
 		c.logger.Infof("node %s: batch id %s", uNode, batchID)
 
-		if err := client.UploadFile(ctx, &file, api.UploadOptions{BatchID: batchID}); err != nil {
+		if err := client.UploadFile(ctx, &file, api.UploadOptions{BatchID: batchID, Direct: true}); err != nil {
 			return fmt.Errorf("node %s: %w", uNode, err)
 		}
 		c.logger.Infof("File %s uploaded successfully to node %s", file.Address().String(), overlays[uNode].String())