refactor: write error checks

ethersphere · Dec 1, 2023 · 155e846 · 155e846
1 parent 113682f
commit 155e846
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 4 deletions.
diff --git a/pkg/file/joiner/joiner_test.go b/pkg/file/joiner/joiner_test.go
@@ -974,8 +974,14 @@ func TestJoinerRedundancy(t *testing.T) {
 		if err != nil {
 			t.Fatal(err)
 		}
-		store.Put(ctx, dataChunks[i])
-		pipe.Write(chunkData)
+		err = store.Put(ctx, dataChunks[i])
+		if err != nil {
+			t.Fatal(err)
+		}
+		_, err = pipe.Write(chunkData)
+		if err != nil {
+			t.Fatal(err)
+		}
 	}
 
 	// reader init

diff --git a/pkg/file/redundancy/getter/getter_test.go b/pkg/file/redundancy/getter/getter_test.go
@@ -52,15 +52,21 @@ func initData(ctx context.Context, erasureBuffer [][]byte, dataShardCount int, s
 		if err != nil {
 			return nil, nil, err
 		}
-		s.Put(ctx, chunk)
+		err = s.Put(ctx, chunk)
+		if err != nil {
+			return nil, nil, err
+		}
 		sAddresses = append(sAddresses, chunk.Address())
 	}
 	for i := dataShardCount; i < len(erasureBuffer); i++ {
 		chunk, err := cac.NewWithDataSpan(erasureBuffer[i])
 		if err != nil {
 			return nil, nil, err
 		}
-		s.Put(ctx, chunk)
+		err = s.Put(ctx, chunk)
+		if err != nil {
+			return nil, nil, err
+		}
 		pAddresses = append(pAddresses, chunk.Address())
 	}