fix(events): check for sync-in-progress (#11932)

filecoin-project · Apr 29, 2024 · ae2cc67 · ae2cc67
1 parent 0a28ce4
commit ae2cc67
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/chain/events/filter/event.go b/chain/events/filter/event.go
@@ -375,6 +375,10 @@ func (m *EventFilterManager) Revert(ctx context.Context, from, to *types.TipSet)
 func (m *EventFilterManager) Install(ctx context.Context, minHeight, maxHeight abi.ChainEpoch, tipsetCid cid.Cid, addresses []address.Address,
 	keysWithCodec map[string][]types.ActorEventBlock, excludeReverted bool) (EventFilter, error) {
 	m.mu.Lock()
+	if m.currentHeight == 0 {
+		// sync in progress, we haven't had an Apply
+		m.currentHeight = m.ChainStore.GetHeaviestTipSet().Height()
+	}
 	currentHeight := m.currentHeight
 	m.mu.Unlock()