feat: check eth events indexed in range

CHANGELOG.md

@@ -16,7 +16,8 @@
 
 - Make `EthTraceFilter` / `trace_filter` skip null rounds instead of erroring. ([filecoin-project/lotus#12702](https://github.com/filecoin-project/lotus/pull/12702))
 - Event APIs (`GetActorEventsRaw`, `SubscribeActorEventsRaw`, `eth_getLogs`, `eth_newFilter`, etc.) will now return an error when a request matches more than `MaxFilterResults` (default: 10,000) rather than silently truncating the results. Also apply an internal event matcher for `eth_getLogs` (etc.) to avoid builtin actor events on database query so as not to include them in `MaxFilterResults` calculation. ([filecoin-project/lotus#12671](https://github.com/filecoin-project/lotus/pull/12671))
-- `ChainIndexer#GetMsgInfo` returns an `ErrNotFound` when there are no rows. ([filecoin-project/lotus#12680](https://github.com/filecoin-project/lotus/pull/12680))
+- `ChainIndexer#GetMsgInfo` returns an `ErrNotFound` when there are no rows. ([filecoin-project/lotus#12680](https://github.com/filecoin-project/lotus/pull/12680))\
+- Return error if logs or events within range are not indexed. ([filecoin-project/lotus#12728](https://github.com/filecoin-project/lotus/pull/12728))
 
 ## New Features
 

chain/index/events.go

@@ -256,6 +256,8 @@ func (si *SqliteIndexer) checkTipsetIndexedStatus(ctx context.Context, f *EventF
 
 			return xerrors.Errorf("failed to get tipset key cid by height: %w", err)
 		}
+	case f.MinHeight >= 0 && f.MaxHeight >= 0 && f.MinHeight != f.MaxHeight:
+		return si.checkRangeIndexedStatus(ctx, f)
 	default:
 		// This function distinguishes between two scenarios:
 		// 1. Missing events: The requested tipset is not present in the Index (an error condition).
@@ -280,6 +282,39 @@ func (si *SqliteIndexer) checkTipsetIndexedStatus(ctx context.Context, f *EventF
 	return ErrNotFound // Tipset is not indexed
 }
 
+func (si *SqliteIndexer) checkRangeIndexedStatus(ctx context.Context, f *EventFilter) error {
+	startCid, err := si.getTipsetKeyCidByHeight(ctx, f.MinHeight)
+	if err != nil {
+		if errors.Is(err, ErrNotFound) {
+			// Null round for the start of the range is acceptable
+			return nil
+		}
+		return xerrors.Errorf("failed to get tipset key cid for start height: %w", err)
+	}
+
+	endCid, err := si.getTipsetKeyCidByHeight(ctx, f.MaxHeight)
+	if err != nil {
+		if errors.Is(err, ErrNotFound) {
+			// Check if the range ends in the future
+			head := si.cs.GetHeaviestTipSet()
+			if head == nil || f.MaxHeight > head.Height() {
+				return xerrors.Errorf("range end is in the future: %w", err)
+			}
+			return ErrNotFound // End is unindexed
+		}
+		return xerrors.Errorf("failed to get tipset key cid for end height: %w", err)
+	}
+
+	if exists, err := si.isTipsetIndexed(ctx, startCid); err != nil || !exists {
+		return xerrors.Errorf("start tipset not indexed: %w", err)
+	}
+	if exists, err := si.isTipsetIndexed(ctx, endCid); err != nil || !exists {
+		return xerrors.Errorf("end tipset not indexed: %w", err)
+	}
+
+	return nil
+}
+
 // getTipsetKeyCidByHeight retrieves the tipset key CID for a given height.
 func (si *SqliteIndexer) getTipsetKeyCidByHeight(ctx context.Context, height abi.ChainEpoch) ([]byte, error) {
 	ts, err := si.cs.GetTipsetByHeight(ctx, height, nil, false)