feat: Lazy share writers

.golangci.yml

@@ -25,6 +25,7 @@ linters:
     - lll
     - misspell
     # - maligned
+    - misspell
     - nakedret
     - prealloc
     # - scopelint

blockchain/msgs_test.go

@@ -97,7 +97,7 @@ func TestBlockchainMessageVectors(t *testing.T) {
 			BlockRequest: &bcproto.BlockRequest{Height: math.MaxInt64}}},
 			"0a0a08ffffffffffffffff7f"},
 		{"BlockResponseMessage", &bcproto.Message{Sum: &bcproto.Message_BlockResponse{
-			BlockResponse: &bcproto.BlockResponse{Block: bpb}}}, "1a740a720a5b0a02080b1803220b088092b8c398feffffff012a0212003a20269ece38583f42aaf53fdd3abe1f570ab9b0d08284d080900966040a29df504c6a20e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b85512130a0b48656c6c6f20576f726c641a0022002801"},
+			BlockResponse: &bcproto.BlockResponse{Block: bpb}}}, "1a97010a94010a5b0a02080b1803220b088092b8c398feffffff012a0212003a20269ece38583f42aaf53fdd3abe1f570ab9b0d08284d080900966040a29df504c6a20e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b85512350a0b48656c6c6f20576f726c641a00220028013220269ece38583f42aaf53fdd3abe1f570ab9b0d08284d080900966040a29df504c"},
 		{"NoBlockResponseMessage", &bcproto.Message{Sum: &bcproto.Message_NoBlockResponse{
 			NoBlockResponse: &bcproto.NoBlockResponse{Height: 1}}}, "12020801"},
 		{"NoBlockResponseMessage", &bcproto.Message{Sum: &bcproto.Message_NoBlockResponse{

libs/protoio/io_test.go

@@ -97,10 +97,7 @@ func iotest(writer protoio.WriteCloser, reader protoio.ReadCloser) error {
 	if i != size {
 		panic("not enough messages read")
 	}
-	if err := reader.Close(); err != nil {
-		return err
-	}
-	return nil
+	return reader.Close()
 }
 
 type buffer struct {

node/node.go

@@ -1046,11 +1046,8 @@ func (n *Node) ConfigureRPC() error {
 
 		Config: *n.config.RPC,
 	})
-	if err := rpccore.InitGenesisChunks(); err != nil {
-		return err
-	}
 
-	return nil
+	return rpccore.InitGenesisChunks()
 }
 
 func (n *Node) startRPC() ([]net.Listener, error) {
@@ -1395,11 +1392,8 @@ func saveGenesisDoc(db dbm.DB, genDoc *types.GenesisDoc) error {
 	if err != nil {
 		return fmt.Errorf("failed to save genesis doc due to marshaling error: %w", err)
 	}
-	if err := db.SetSync(genesisDocKey, b); err != nil {
-		return err
-	}
 
-	return nil
+	return db.SetSync(genesisDocKey, b)
 }
 
 func createAndStartPrivValidatorSocketClient(

pkg/prove/proof_test.go

@@ -24,7 +24,8 @@ func TestTxInclusion(t *testing.T) {
 	}
 
 	// compute the data availability header
-	shares, _ := typicalBlockData.ComputeShares()
+	shares, _, err := typicalBlockData.ComputeShares(0)
+	require.NoError(t, err)
 
 	squareSize := uint(math.Sqrt(float64(len(shares))))
 
@@ -101,7 +102,9 @@ func Test_genRowShares(t *testing.T) {
 		Messages: generateRandomlySizedMessages(10, 1000),
 	}
 
-	allShares, _ := typicalBlockData.ComputeShares()
+	// compute the data availability header
+	allShares, _, err := typicalBlockData.ComputeShares(0)
+	require.NoError(t, err)
 	rawShares := allShares.RawShares()
 
 	originalSquareSize := uint(math.Sqrt(float64(len(rawShares))))
@@ -137,7 +140,9 @@ func Test_genOrigRowShares(t *testing.T) {
 		Messages: generateRandomlySizedMessages(10, 1500),
 	}
 
-	allShares, _ := typicalBlockData.ComputeShares()
+	// compute the data availability header
+	allShares, _, err := typicalBlockData.ComputeShares(0)
+	require.NoError(t, err)
 	rawShares := allShares.RawShares()
 
 	genShares := genOrigRowShares(typicalBlockData, 8, 0, 7)

proto/tendermint/abci/types.proto

@@ -137,8 +137,8 @@ message RequestPrepareProposal {
 }
 
 message RequestProcessProposal {
-  tendermint.types.Header header = 1 [(gogoproto.nullable) = false];
-  tendermint.types.Data block_data = 2;
+  tendermint.types.Header header     = 1 [(gogoproto.nullable) = false];
+  tendermint.types.Data   block_data = 2;
 }
 
 //----------------------------------------
@@ -163,7 +163,7 @@ message Response {
     ResponseLoadSnapshotChunk  load_snapshot_chunk  = 15;
     ResponseApplySnapshotChunk apply_snapshot_chunk = 16;
     ResponsePrepareProposal    prepare_proposal     = 17;
-    ResponseProcessProposal     process_proposal     = 18;
+    ResponseProcessProposal    process_proposal     = 18;
   }
 }
 
@@ -299,13 +299,13 @@ message ResponsePrepareProposal {
 }
 
 message ResponseProcessProposal {
-  Result result = 1;
+  Result         result   = 1;
   repeated bytes evidence = 2;
 
   enum Result {
-    UNKNOWN       = 0;  // Unknown result, invalidate
-    ACCEPT        = 1;  // proposal verified, vote on the proposal
-    REJECT        = 2;  // proposal invalidated
+    UNKNOWN = 0;  // Unknown result, invalidate
+    ACCEPT  = 1;  // proposal verified, vote on the proposal
+    REJECT  = 2;  // proposal invalidated
   }
 }