From 0f00fb8d96838c7876b63217718ef3ec8737d3de Mon Sep 17 00:00:00 2001 From: Prem Chaitanya Prathi Date: Fri, 26 Jan 2024 15:38:37 +0530 Subject: [PATCH] fix: update lastProcessedBlock even if no RLN membership event is present (#1013) --- waku/v2/protocol/rln/group_manager/dynamic/dynamic.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) 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)