diff --git a/waku/v2/protocol/rln/group_manager/dynamic/dynamic.go b/waku/v2/protocol/rln/group_manager/dynamic/dynamic.go index 41970984..36a0807c 100644 --- a/waku/v2/protocol/rln/group_manager/dynamic/dynamic.go +++ b/waku/v2/protocol/rln/group_manager/dynamic/dynamic.go @@ -73,11 +73,13 @@ func (gm *DynamicGroupManager) handler(events []*contracts.RLNMemberRegistered, } eventsPerBlock = append(eventsPerBlock, event) toInsertTable.Set(event.Raw.BlockNumber, eventsPerBlock) - - if event.Raw.BlockNumber > lastBlockProcessed { - lastBlockProcessed = event.Raw.BlockNumber - } } + if event.Raw.BlockNumber > lastBlockProcessed { + lastBlockProcessed = event.Raw.BlockNumber + } + } + if len(events) == 0 { + lastBlockProcessed = latestProcessBlock } err := gm.RemoveMembers(toRemoveTable)