feat: eth_getLogs (#120)

Adds the two functions required in the backend to implement
`eth_getLogs`, and adds some basic tests.

---------

Signed-off-by: Jonathan Oppenheimer <147infiniti@gmail.com>
Co-authored-by: Arran Schlosberg <me@arranschlosberg.com>
Co-authored-by: Jonathan Oppenheimer <jonathan.oppenheimer@avalabs.org>
Co-authored-by: Jonathan Oppenheimer <147infiniti@gmail.com>
Co-authored-by: Stephen Buttolph <stephen@avalabs.org>

Author: 4 people

go.mod

@@ -6,7 +6,7 @@ tool github.com/go-task/task/v3/cmd/task
 
 require (
 	github.com/ava-labs/avalanchego v1.14.2-0.20260123184805-18c4dbe2714e
-	github.com/ava-labs/libevm v1.13.15-0.20260128160829-e673c7097059
+	github.com/ava-labs/libevm v1.13.15-0.20260212133604-62502c671227
 	github.com/google/go-cmp v0.7.0
 	github.com/holiman/uint256 v1.2.4
 	github.com/stretchr/testify v1.11.1

go.sum

@@ -40,8 +40,8 @@ github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5 h1:0CwZNZbxp69SHPd
 github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5/go.mod h1:wHh0iHkYZB8zMSxRWpUBQtwG5a7fFgvEO+odwuTv2gs=
 github.com/ava-labs/avalanchego v1.14.2-0.20260123184805-18c4dbe2714e h1:vmO2RL0wG6QuMxZqSzY13BtR77XsSCcCmiwPKCJkAXI=
 github.com/ava-labs/avalanchego v1.14.2-0.20260123184805-18c4dbe2714e/go.mod h1:aE2RZUWfJwiK+tyVu+fnE5DWOZ0W1TEg5BL3n1rkq7s=
-github.com/ava-labs/libevm v1.13.15-0.20260128160829-e673c7097059 h1:3l75HBUnvVeSjs1ikoA8LUu8eo/A7NTgacuy1qUvQuk=
-github.com/ava-labs/libevm v1.13.15-0.20260128160829-e673c7097059/go.mod h1:oyJdZfpQTc9fVzAbDry+QRYeiCbw8s/kGaDUsEMpb4I=
+github.com/ava-labs/libevm v1.13.15-0.20260212133604-62502c671227 h1:G/fQiyPj+0dXaLRUu1ntbfcIww233nqbofis8deBar0=
+github.com/ava-labs/libevm v1.13.15-0.20260212133604-62502c671227/go.mod h1:oyJdZfpQTc9fVzAbDry+QRYeiCbw8s/kGaDUsEMpb4I=
 github.com/aymerick/raymond v2.0.3-0.20180322193309-b565731e1464+incompatible/go.mod h1:osfaiScAUVup+UC9Nfq76eWqDhXlp+4UYaA8uhTBO6g=
 github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
 github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=

sae/bloom.go

@@ -0,0 +1,78 @@
+// Copyright (C) 2026, Ava Labs, Inc. All rights reserved.
+// See the file LICENSE for licensing terms.
+
+package sae
+
+import (
+	"context"
+	"math"
+
+	"github.com/ava-labs/libevm/core"
+	"github.com/ava-labs/libevm/core/bloombits"
+	"github.com/ava-labs/libevm/core/rawdb"
+	"github.com/ava-labs/libevm/core/types"
+	"github.com/ava-labs/libevm/eth"
+	"github.com/ava-labs/libevm/eth/filters"
+	"github.com/ava-labs/libevm/ethdb"
+	"github.com/ava-labs/libevm/params"
+)
+
+// bloomIndexer provides the [bloomIndexer.BloomStatus] and
+// [bloomIndexer.ServiceFilter] methods of an [ethapi.Backend] implementation.
+type bloomIndexer struct {
+	indexer  *core.ChainIndexer
+	size     uint64
+	handlers *eth.BloomHandlers
+}
+
+// newBloomIndexer creates a [bloomIndexer] and starts the indexer to run with
+// events from `chain`.
+//
+// The consumer must call [bloomIndexer.Close] to release allocated resources.
+func newBloomIndexer(db ethdb.Database, chain core.ChainIndexerChain, override filters.BloomOverrider, size uint64) *bloomIndexer {
+	if size == 0 || size > math.MaxInt32 {
+		size = params.BloomBitsBlocks
+	}
+
+	backend := &bloomBackend{
+		BloomIndexer:   core.NewBloomIndexerBackend(db, size),
+		BloomOverrider: override,
+	}
+	table := rawdb.NewTable(db, string(rawdb.BloomBitsIndexPrefix))
+	b := &bloomIndexer{
+		indexer:  core.NewChainIndexer(db, table, backend, size, 0, core.BloomThrottling, "bloombits"),
+		size:     size,
+		handlers: eth.StartBloomHandlers(db, size),
+	}
+	b.indexer.Start(chain)
+	return b
+}
+
+func (b *bloomIndexer) BloomStatus() (size uint64, sections uint64) {
+	sections, _, _ = b.indexer.Sections()
+	return b.size, sections
+}
+
+func (b *bloomIndexer) ServiceFilter(ctx context.Context, session *bloombits.MatcherSession) {
+	for range eth.BloomFilterThreads {
+		go session.Multiplex(eth.BloomRetrievalBatch, eth.BloomRetrievalWait, b.handlers.Requests)
+	}
+}
+
+func (b *bloomIndexer) Close() error {
+	b.handlers.Close()
+	return b.indexer.Close()
+}
+
+var _ core.ChainIndexerBackend = (*bloomBackend)(nil)
+
+// bloomBackend is a wrapper around a [core.BloomIndexer] that overrides
+// Process() to allow for custom bloom-filter generation.
+type bloomBackend struct {
+	*core.BloomIndexer
+	filters.BloomOverrider
+}
+
+func (b *bloomBackend) Process(ctx context.Context, hdr *types.Header) error {
+	return b.ProcessWithBloomOverride(hdr, b.OverrideHeaderBloom(hdr))
+}

sae/rpc.go

@@ -30,20 +30,24 @@ import (
 	"github.com/ava-labs/libevm/params"
 	"github.com/ava-labs/libevm/rpc"
 
+	"github.com/ava-labs/strevm/saexec"
 	"github.com/ava-labs/strevm/txgossip"
 )
 
-// APIBackend returns an API backend backed by the VM.
-func (vm *VM) APIBackend() ethapi.Backend {
+// APIBackend is the union of all interfaces required to implement the SAE APIs.
+type APIBackend interface {
+	ethapi.Backend
+	filters.BloomOverrider
+}
+
+// APIBackend returns an API backend backed by the [VM].
+func (vm *VM) APIBackend() APIBackend {
 	return vm.apiBackend
 }
 
 func (vm *VM) ethRPCServer() (*rpc.Server, error) {
 	b := vm.APIBackend()
-	s := rpc.NewServer()
 
-	// Even if this function errors, we should close API to prevent a goroutine
-	// from leaking.
 	filterSystem := filters.NewFilterSystem(b, filters.Config{})
 	filterAPI := filters.NewFilterAPI(filterSystem, false /*isLightClient*/)
 	vm.toClose = append(vm.toClose, func() error {
@@ -108,6 +112,9 @@ func (vm *VM) ethRPCServer() (*rpc.Server, error) {
 		// - eth_getRawTransactionByHash
 		// - eth_pendingTransactions
 		{"eth", ethapi.NewTransactionAPI(b, new(ethapi.AddrLocker))},
+		// Standard Ethereum node APIS:
+		// - eth_getLogs
+		//
 		// Geth-specific APIs:
 		// - eth_subscribe
 		//  - newHeads
@@ -143,6 +150,7 @@ func (vm *VM) ethRPCServer() (*rpc.Server, error) {
 		})
 	}
 
+	s := rpc.NewServer()
 	for _, api := range apis {
 		if err := s.RegisterName(api.namespace, api.api); err != nil {
 			return nil, fmt.Errorf("%T.RegisterName(%q, %T): %v", s, api.namespace, api.api, err)
@@ -200,12 +208,51 @@ func (s *netAPI) Version() string {
 	return s.chainID
 }
 
+// chainIndexer implements the subset of [ethapi.Backend] required to back a
+// [core.ChainIndexer].
+type chainIndexer struct {
+	exec *saexec.Executor
+}
+
+var _ core.ChainIndexerChain = chainIndexer{}
+
+func (c chainIndexer) CurrentHeader() *types.Header {
+	return types.CopyHeader(c.exec.LastExecuted().Header())
+}
+
+func (c chainIndexer) SubscribeChainHeadEvent(ch chan<- core.ChainHeadEvent) event.Subscription {
+	return c.exec.SubscribeChainHeadEvent(ch)
+}
+
+// A bloomOverrider constructs Bloom filters from persisted receipts instead of
+// relying on the [types.Header] field.
+type bloomOverrider struct {
+	db ethdb.Database
+}
+
+var _ filters.BloomOverrider = bloomOverrider{}
+
+// OverrideHeaderBloom returns the Bloom filter of the receipts generated when
+// executing the respective block, whereas the [types.Header] carries those
+// settled by the block.
+func (b bloomOverrider) OverrideHeaderBloom(header *types.Header) types.Bloom {
+	return types.CreateBloom(rawdb.ReadRawReceipts(
+		b.db,
+		header.Hash(),
+		header.Number.Uint64(),
+	))
+}
+
 type ethAPIBackend struct {
-	*txgossip.Set
 	vm             *VM
 	accountManager *accounts.Manager
 
-	ethapi.Backend // TODO(arr4n) remove in favour of `var _ ethapi.Backend = (*ethAPIBackend)(nil)`
+	*txgossip.Set
+	chainIndexer
+	bloomOverrider
+	*bloomIndexer
+
+	ethapi.Backend // TODO(arr4n) remove once all methods are implemented
 }
 
 func (b *ethAPIBackend) ChainConfig() *params.ChainConfig {
@@ -224,10 +271,6 @@ func (b *ethAPIBackend) AccountManager() *accounts.Manager {
 	return b.accountManager
 }
 
-func (b *ethAPIBackend) CurrentHeader() *types.Header {
-	return types.CopyHeader(b.vm.exec.LastExecuted().Header())
-}
-
 func (b *ethAPIBackend) CurrentBlock() *types.Header {
 	return b.CurrentHeader()
 }
@@ -275,6 +318,29 @@ func (b *ethAPIBackend) GetPoolTransaction(txHash common.Hash) *types.Transactio
 	return b.Set.Pool.Get(txHash)
 }
 
+func (b *ethAPIBackend) GetBody(ctx context.Context, hash common.Hash, number rpc.BlockNumber) (*types.Body, error) {
+	if hash == (common.Hash{}) {
+		return nil, errors.New("empty block hash")
+	}
+	n, err := b.resolveBlockNumber(number)
+	if err != nil {
+		return nil, err
+	}
+
+	if block, ok := b.vm.blocks.Load(hash); ok {
+		if block.NumberU64() != n {
+			return nil, fmt.Errorf("found block number %d for hash %#x, expected %d", block.NumberU64(), hash, number)
+		}
+		return block.EthBlock().Body(), nil
+	}
+
+	return rawdb.ReadBody(b.vm.db, hash, n), nil
+}
+
+func (b *ethAPIBackend) GetLogs(ctx context.Context, blockHash common.Hash, number uint64) ([][]*types.Log, error) {
+	return rawdb.ReadLogs(b.vm.db, blockHash, number), nil
+}
+
 func (b *ethAPIBackend) GetPoolTransactions() (types.Transactions, error) {
 	pending := b.Pool.Pending(txpool.PendingFilter{})
 
@@ -355,10 +421,6 @@ func (b *ethAPIBackend) SubscribeChainEvent(ch chan<- core.ChainEvent) event.Sub
 	return b.vm.exec.SubscribeChainEvent(ch)
 }
 
-func (b *ethAPIBackend) SubscribeChainHeadEvent(ch chan<- core.ChainHeadEvent) event.Subscription {
-	return b.vm.exec.SubscribeChainHeadEvent(ch)
-}
-
 func (b *ethAPIBackend) SubscribeChainSideEvent(chan<- core.ChainSideEvent) event.Subscription {
 	// SAE never reorgs, so there are no side events.
 	return newNoopSubscription()