Return EventFilterer from Events() on Blockchain

NethermindEth · Nov 22, 2024 · 9b033c5 · 9b033c5
1 parent 1519d46
commit 9b033c5
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/blockchain/blockchain.go b/blockchain/blockchain.go
@@ -44,7 +44,7 @@ type Reader interface {
 
 	BlockCommitmentsByNumber(blockNumber uint64) (*core.BlockCommitments, error)
 
-	EventFilter(from *felt.Felt, keys [][]felt.Felt) (*EventFilter, error)
+	EventFilter(from *felt.Felt, keys [][]felt.Felt) (EventFilterer, error)
 
 	Pending() (Pending, error)
 
@@ -844,7 +844,7 @@ func (b *Blockchain) StateAtBlockHash(blockHash *felt.Felt) (core.StateReader, S
 }
 
 // EventFilter returns an EventFilter object that is tied to a snapshot of the blockchain
-func (b *Blockchain) EventFilter(from *felt.Felt, keys [][]felt.Felt) (*EventFilter, error) {
+func (b *Blockchain) EventFilter(from *felt.Felt, keys [][]felt.Felt) (EventFilterer, error) {
 	b.listener.OnRead("EventFilter")
 	txn, err := b.database.NewTransaction(false)
 	if err != nil {

diff --git a/mocks/mock_blockchain.go b/mocks/mock_blockchain.go
diff --git a/rpc/events.go b/rpc/events.go
@@ -191,7 +191,7 @@ func (h *Handler) unsubscribe(sub *subscription, id uint64) {
 	h.mu.Unlock()
 }
 
-func setEventFilterRange(filter *blockchain.EventFilter, fromID, toID *BlockID, latestHeight uint64) error {
+func setEventFilterRange(filter blockchain.EventFilterer, fromID, toID *BlockID, latestHeight uint64) error {
 	set := func(filterRange blockchain.EventFilterRange, id *BlockID) error {
 		if id == nil {
 			return nil