feat(evmreader): RetrieveInputs in chunks

Author: mpolitzer

internal/evmreader/inputsource_adapter.go

@@ -7,6 +7,9 @@ import (
 	"math/big"
 
 	"github.com/cartesi/rollups-node/pkg/contracts/iinputbox"
+	"github.com/cartesi/rollups-node/pkg/ethutil"
+	"github.com/ethereum/go-ethereum"
+	"github.com/ethereum/go-ethereum/accounts/abi"
 	"github.com/ethereum/go-ethereum/accounts/abi/bind"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/ethclient"
@@ -15,6 +18,8 @@ import (
 // InputBox Wrapper
 type InputSourceAdapter struct {
 	inputbox *iinputbox.IInputBox
+	client *ethclient.Client
+	inputBoxAddress common.Address
 }
 
 func NewInputSourceAdapter(
@@ -27,28 +32,76 @@ func NewInputSourceAdapter(
 	}
 	return &InputSourceAdapter{
 		inputbox: inputbox,
+		client: client,
+		inputBoxAddress: inputBoxAddress,
 	}, nil
 }
 
+func buildInputAddedFilterQuery(
+	opts *bind.FilterOpts,
+	inputBoxAddress common.Address,
+	appContract []common.Address,
+	index []*big.Int,
+) (q ethereum.FilterQuery, err error) {
+	c, err := iinputbox.IInputBoxMetaData.GetAbi()
+	if err != nil {
+		return q, err
+	}
+
+	var appContractRule []interface{}
+	for _, appContractItem := range appContract {
+		appContractRule = append(appContractRule, appContractItem)
+	}
+	var indexRule []interface{}
+	for _, indexItem := range index {
+		indexRule = append(indexRule, indexItem)
+	}
+
+	topics, err := abi.MakeTopics(
+		[]interface{}{c.Events["InputAdded"].ID},
+		appContractRule,
+		indexRule,
+	)
+	if err != nil {
+		return q, err
+	}
+
+	q = ethereum.FilterQuery{
+		Addresses: []common.Address{inputBoxAddress},
+		FromBlock: new(big.Int).SetUint64(opts.Start),
+		Topics: topics,
+	}
+	if opts.End != nil {
+		q.ToBlock = new(big.Int).SetUint64(*opts.End)
+	}
+	return q, err
+}
+
 func (i *InputSourceAdapter) RetrieveInputs(
 	opts *bind.FilterOpts,
 	appContract []common.Address,
 	index []*big.Int,
 ) ([]iinputbox.IInputBoxInputAdded, error) {
+	q, err := buildInputAddedFilterQuery(opts, i.inputBoxAddress, appContract, index)
+	if err != nil {
+		return nil, err
+	}
 
-	itr, err := i.inputbox.FilterInputAdded(opts, appContract, index)
+	itr, err := ethutil.ChunkedFilterLogs(opts.Context, i.client, q)
 	if err != nil {
 		return nil, err
 	}
-	defer itr.Close()
 
 	var events []iinputbox.IInputBoxInputAdded
-	for itr.Next() {
-		inputAddedEvent := itr.Event
-		events = append(events, *inputAddedEvent)
-	}
-	if err = itr.Error(); err != nil {
-		return nil, err
+	for log, err := range itr {
+		if err != nil {
+			return nil, err
+		}
+		ev, err := i.inputbox.ParseInputAdded(*log)
+		if err != nil {
+			return nil, err
+		}
+		events = append(events, *ev)
 	}
 	return events, nil
 }