From c8ce26de6de53140c3bad5bb769c374094fe1cbf Mon Sep 17 00:00:00 2001 From: Roy Crihfield Date: Wed, 10 Jul 2024 19:03:26 +0800 Subject: [PATCH] Export IPLD encoders --- indexer/ipld/encode.go | 14 +++++++------- indexer/ipld/eth_parser.go | 8 ++++---- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/indexer/ipld/encode.go b/indexer/ipld/encode.go index 8108f8e..68979be 100644 --- a/indexer/ipld/encode.go +++ b/indexer/ipld/encode.go @@ -38,8 +38,8 @@ func EncodeHeader(header *types.Header) (IPLD, error) { }, nil } -// encodeTx converts a *types.Transaction to an IPLD node -func encodeTx(tx *types.Transaction) (IPLD, error) { +// EncodeTx converts a *types.Transaction to an IPLD node +func EncodeTx(tx *types.Transaction) (IPLD, error) { txRaw, err := tx.MarshalBinary() if err != nil { return nil, err @@ -54,8 +54,8 @@ func encodeTx(tx *types.Transaction) (IPLD, error) { }, nil } -// encodeReceipt converts a types.Receipt to an IPLD node -func encodeReceipt(receipt *types.Receipt) (IPLD, error) { +// EncodeReceipt converts a types.Receipt to an IPLD node +func EncodeReceipt(receipt *types.Receipt) (IPLD, error) { rctRaw, err := receipt.MarshalBinary() if err != nil { return nil, err @@ -70,8 +70,8 @@ func encodeReceipt(receipt *types.Receipt) (IPLD, error) { }, nil } -// encodeLog converts a Log to an IPLD node -func encodeLog(log *types.Log) (IPLD, error) { +// EncodeLog converts a Log to an IPLD node +func EncodeLog(log *types.Log) (IPLD, error) { logRaw, err := rlp.EncodeToBytes(log) if err != nil { return nil, err @@ -86,7 +86,7 @@ func encodeLog(log *types.Log) (IPLD, error) { }, nil } -func encodeWithdrawal(w *types.Withdrawal) (IPLD, error) { +func EncodeWithdrawal(w *types.Withdrawal) (IPLD, error) { wRaw, err := rlp.EncodeToBytes(w) if err != nil { return nil, err diff --git a/indexer/ipld/eth_parser.go b/indexer/ipld/eth_parser.go index c247df6..fa5c118 100644 --- a/indexer/ipld/eth_parser.go +++ b/indexer/ipld/eth_parser.go @@ -44,7 +44,7 @@ func FromBlockAndReceipts(block *types.Block, receipts []*types.Receipt) ([]IPLD func processTransactions(txs []*types.Transaction) ([]IPLD, error) { var ethTxNodes []IPLD for _, tx := range txs { - ethTx, err := encodeTx(tx) + ethTx, err := EncodeTx(tx) if err != nil { return nil, err } @@ -57,7 +57,7 @@ func processTransactions(txs []*types.Transaction) ([]IPLD, error) { func processWithdrawals(withdrawals []*types.Withdrawal) ([]IPLD, error) { var withdrawalNodes []IPLD for _, withdrawal := range withdrawals { - ethW, err := encodeWithdrawal(withdrawal) + ethW, err := EncodeWithdrawal(withdrawal) if err != nil { return nil, err } @@ -80,7 +80,7 @@ func processReceiptsAndLogs(rcts []*types.Receipt) ([]IPLD, [][]IPLD, error) { return nil, nil, err } - ethRct, err := encodeReceipt(rct) + ethRct, err := EncodeReceipt(rct) if err != nil { return nil, nil, err } @@ -95,7 +95,7 @@ func processReceiptsAndLogs(rcts []*types.Receipt) ([]IPLD, [][]IPLD, error) { func processLogs(logs []*types.Log) ([]IPLD, error) { logNodes := make([]IPLD, len(logs)) for idx, log := range logs { - logNode, err := encodeLog(log) + logNode, err := EncodeLog(log) if err != nil { return nil, err }