chore: add redundancy fallback mode header

pkg/bee/api/api.go

@@ -15,13 +15,14 @@ import (
 )
 
 const (
-	apiVersion               = "v1"
-	contentType              = "application/json; charset=utf-8"
-	postageStampBatchHeader  = "Swarm-Postage-Batch-Id"
-	deferredUploadHeader     = "Swarm-Deferred-Upload"
-	swarmPinHeader           = "Swarm-Pin"
-	swarmTagHeader           = "Swarm-Tag"
-	swarmCacheDownloadHeader = "Swarm-Cache"
+	apiVersion                  = "v1"
+	contentType                 = "application/json; charset=utf-8"
+	postageStampBatchHeader     = "Swarm-Postage-Batch-Id"
+	deferredUploadHeader        = "Swarm-Deferred-Upload"
+	swarmPinHeader              = "Swarm-Pin"
+	swarmTagHeader              = "Swarm-Tag"
+	swarmCacheDownloadHeader    = "Swarm-Cache"
+	swarmRedundancyFallbackMode = "Swarm-Redundancy-Fallback-Mode"
 )
 
 var userAgent = "beekeeper/" + beekeeper.Version
@@ -196,6 +197,9 @@ func (c *Client) requestData(ctx context.Context, method, path string, body io.R
 	if opts != nil && opts.Cache != nil {
 		req.Header.Set(swarmCacheDownloadHeader, strconv.FormatBool(*opts.Cache))
 	}
+	if opts != nil && opts.RedundancyFallbackMode != nil {
+		req.Header.Set(swarmRedundancyFallbackMode, strconv.FormatBool(*opts.RedundancyFallbackMode))
+	}
 
 	r, err := c.httpClient.Do(req)
 	if err != nil {
@@ -317,5 +321,6 @@ type UploadOptions struct {
 }
 
 type DownloadOptions struct {
-	Cache *bool
+	Cache                  *bool
+	RedundancyFallbackMode *bool
 }

pkg/bee/api/bytes.go

@@ -13,8 +13,8 @@ import (
 type BytesService service
 
 // Download downloads data from the node
-func (b *BytesService) Download(ctx context.Context, a swarm.Address) (resp io.ReadCloser, err error) {
-	return b.client.requestData(ctx, http.MethodGet, "/"+apiVersion+"/bytes/"+a.String(), nil, nil)
+func (b *BytesService) Download(ctx context.Context, a swarm.Address, opts *DownloadOptions) (resp io.ReadCloser, err error) {
+	return b.client.requestData(ctx, http.MethodGet, "/"+apiVersion+"/bytes/"+a.String(), nil, opts)
 }
 
 // BytesUploadResponse represents Upload's response

pkg/bee/client.go

@@ -183,8 +183,8 @@ func (c *Client) Balances(ctx context.Context) (resp Balances, err error) {
 }
 
 // DownloadBytes downloads chunk from the node
-func (c *Client) DownloadBytes(ctx context.Context, a swarm.Address) (data []byte, err error) {
-	r, err := c.api.Bytes.Download(ctx, a)
+func (c *Client) DownloadBytes(ctx context.Context, a swarm.Address, opts *api.DownloadOptions) (data []byte, err error) {
+	r, err := c.api.Bytes.Download(ctx, a, opts)
 	if err != nil {
 		return nil, fmt.Errorf("download chunk %s: %w", a, err)
 	}

pkg/check/redundancy/redundancy.go

@@ -87,7 +87,8 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, o interf
 			return fmt.Errorf("upload chunks: %w", err)
 		}
 		c.logger.Infof("upload completed. Downloading %s", root.String())
-		d, err := downloadClient.DownloadBytes(ctx, root)
+		fallbackMode := true
+		d, err := downloadClient.DownloadBytes(ctx, root, &api.DownloadOptions{RedundancyFallbackMode: &fallbackMode})
 		if err != nil {
 			return fmt.Errorf("download bytes: %w", err)
 		}

pkg/check/smoke/smoke.go

@@ -261,7 +261,7 @@ func (t *test) download(ctx context.Context, cName string, addr swarm.Address) (
 	client := t.clients[cName]
 	t.logger.Infof("node %s: downloading address %s", cName, addr)
 	start := time.Now()
-	data, err := client.DownloadBytes(ctx, addr)
+	data, err := client.DownloadBytes(ctx, addr, nil)
 	if err != nil {
 		return nil, 0, fmt.Errorf("download from node %s: %w", cName, err)
 	}