Optimise fetching all receipts (Snowfork#1547) (#14)

* optimise fetching all receipts

* release relayer

* rollback ci

* revert space

* updates comment

Co-authored-by: Clara van Staden <[email protected]>

Author: ParthDesai

relayer/chain/ethereum/receipt.go

@@ -5,49 +5,18 @@ package ethereum
 
 import (
 	"context"
-	"sync"
 
 	etypes "github.com/ethereum/go-ethereum/core/types"
-	"golang.org/x/sync/errgroup"
+	"github.com/ethereum/go-ethereum/rpc"
+	log "github.com/sirupsen/logrus"
 )
 
-const receiptFetchBatchSize int = 10
-
-// Fetch all receipts for the given block in batches of `receiptFetchBatchSize`
+// GetAllReceipts fetches all the transaction receipts in the given block.
 func GetAllReceipts(ctx context.Context, conn *Connection, block *etypes.Block) (etypes.Receipts, error) {
-	transactions := block.Body().Transactions
-	numTransactions := len(transactions)
-	receiptsByIndex := sync.Map{}
-
-	for i := 0; i < numTransactions; i += receiptFetchBatchSize {
-		eg, ctx := errgroup.WithContext(ctx)
-		upper := i + receiptFetchBatchSize
-		if upper >= numTransactions {
-			upper = numTransactions
-		}
-		for j, tx := range transactions[i:upper] {
-			index := i + j
-			txHash := tx.Hash()
-			eg.Go(func() error {
-				receipt, err := conn.client.TransactionReceipt(ctx, txHash)
-				if err != nil {
-					return err
-				}
-				receiptsByIndex.Store(index, receipt)
-				return nil
-			})
-		}
-		err := eg.Wait()
-		if err != nil {
-			return nil, err
-		}
-	}
-
-	// Place receipts in same order as corresponding transactions
-	receipts := make([]*etypes.Receipt, numTransactions)
-	receiptsByIndex.Range(func(index interface{}, receipt interface{}) bool {
-		receipts[index.(int)] = receipt.(*etypes.Receipt)
-		return true
-	})
-	return receipts, nil
+	blockHash := block.Hash()
+	log.WithFields(log.Fields{
+		"numTransactions": len(block.Body().Transactions),
+		"blockHash":       blockHash,
+	}).Debug("Querying transaction receipts")
+	return conn.client.BlockReceipts(ctx, rpc.BlockNumberOrHashWithHash(blockHash, false))
 }