Mark filter stale for Besu nodes

Signed-off-by: Nicko Guyer <nicko.guyer@kaleido.io>
hyperledger · Nov 7, 2023 · 64c391b · 64c391b
1 parent 5fee4d0
commit 64c391b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/internal/events/block_confirmations.go b/internal/events/block_confirmations.go
@@ -202,7 +202,7 @@ func (bcm *blockConfirmationManager) pollBlockFilter() ([]*ethbinding.Hash, erro
 	defer cancel()
 	var blockHashes []*ethbinding.Hash
 	if err := bcm.rpc.CallContext(ctx, &blockHashes, "eth_getFilterChanges", bcm.filterID); err != nil {
-		if strings.Contains(err.Error(), "filter not found") {
+		if strings.Contains(strings.ToLower(err.Error()), "filter not found") {
 			bcm.filterStale = true
 		}
 		return nil, err

diff --git a/internal/events/subscription.go b/internal/events/subscription.go
@@ -364,7 +364,7 @@ func (s *subscription) processNewEvents(ctx context.Context) error {
 		s.info.Synchronized = true
 	}
 	if err := s.rpc.CallContext(ctx, &logs, rpcMethod, s.filterID); err != nil {
-		if strings.Contains(err.Error(), "filter not found") {
+		if strings.Contains(strings.ToLower(err.Error()), "filter not found") {
 			s.markFilterStale(ctx, true)
 		}
 		return err