Remove customlogs package

core/blockchain.go

@@ -47,7 +47,6 @@ import (
 	"github.com/ava-labs/coreth/core/state/snapshot"
 	"github.com/ava-labs/coreth/internal/version"
 	"github.com/ava-labs/coreth/params"
-	"github.com/ava-labs/coreth/plugin/evm/customlogs"
 	"github.com/ava-labs/coreth/plugin/evm/customrawdb"
 	"github.com/ava-labs/coreth/plugin/evm/customtypes"
 	"github.com/ava-labs/coreth/triedb/firewood"
@@ -624,7 +623,10 @@ func (bc *BlockChain) startAcceptor() {
 		bc.acceptorTipLock.Unlock()
 
 		// Update accepted feeds
-		flattenedLogs := customlogs.FlattenLogs(logs)
+		var flattenedLogs []*types.Log
+		for _, txLogs := range logs {
+			flattenedLogs = append(flattenedLogs, txLogs...)
+		}
 		bc.chainAcceptedFeed.Send(ChainEvent{Block: next, Hash: next.Hash(), Logs: flattenedLogs})
 		if len(flattenedLogs) > 0 {
 			bc.logsAcceptedFeed.Send(flattenedLogs)
@@ -1478,7 +1480,11 @@ func (bc *BlockChain) collectUnflattenedLogs(b *types.Block, removed bool) [][]*
 // the processing of a block. These logs are later announced as deleted or reborn.
 func (bc *BlockChain) collectLogs(b *types.Block, removed bool) []*types.Log {
 	unflattenedLogs := bc.collectUnflattenedLogs(b, removed)
-	return customlogs.FlattenLogs(unflattenedLogs)
+	var logs []*types.Log
+	for _, txLogs := range unflattenedLogs {
+		logs = append(logs, txLogs...)
+	}
+	return logs
 }
 
 // reorg takes two blocks, an old chain and a new chain and will reconstruct the

eth/filters/filter.go

@@ -34,7 +34,6 @@ import (
 	"math/big"
 
 	"github.com/ava-labs/coreth/core/bloombits"
-	"github.com/ava-labs/coreth/plugin/evm/customlogs"
 	"github.com/ava-labs/coreth/rpc"
 	"github.com/ava-labs/libevm/common"
 	"github.com/ava-labs/libevm/core/types"
@@ -343,8 +342,10 @@ func (f *Filter) checkMatches(ctx context.Context, header *types.Header) ([]*typ
 		return nil, err
 	}
 
-	unfiltered := customlogs.FlattenLogs(logsList)
-	logs := filterLogs(unfiltered, nil, nil, f.addresses, f.topics)
+	var logs []*types.Log
+	for _, txLogs := range logsList {
+		logs = append(logs, filterLogs(txLogs, nil, nil, f.addresses, f.topics)...)
+	}
 	if len(logs) == 0 {
 		return nil, nil
 	}
@@ -357,11 +358,11 @@ func (f *Filter) checkMatches(ctx context.Context, header *types.Header) ([]*typ
 	if err != nil {
 		return nil, err
 	}
-	unfiltered = unfiltered[:0]
-	for _, receipt := range receipts {
-		unfiltered = append(unfiltered, receipt.Logs...)
+	// Replace the incomplete logs with complete logs from receipts
+	logs = logs[:0]
+	for _, r := range receipts {
+		logs = append(logs, filterLogs(r.Logs, nil, nil, f.addresses, f.topics)...)
 	}
-	logs = filterLogs(unfiltered, nil, nil, f.addresses, f.topics)
 
 	return logs, nil
 }