diff --git a/waku/waku_rln_relay/group_manager/on_chain/group_manager.nim b/waku/waku_rln_relay/group_manager/on_chain/group_manager.nim index 107e02dcd..f44ef7556 100644 --- a/waku/waku_rln_relay/group_manager/on_chain/group_manager.nim +++ b/waku/waku_rln_relay/group_manager/on_chain/group_manager.nim @@ -199,6 +199,11 @@ proc trackRootChanges*(g: OnchainGroupManager) {.async.} = if proofResult.isErr(): error "Failed to fetch Merkle proof", error = proofResult.error g.merkleProofCache = proofResult.get() + + # also need update registerd membership + let memberCount = cast[float64](await wakuRlnContract.commitmentIndex().call()) + waku_rln_number_registered_memberships.set(memberCount) + await sleepAsync(rpcDelay) method atomicBatch*( @@ -581,9 +586,6 @@ method init*(g: OnchainGroupManager): Future[GroupManagerResult[void]] {.async.} ethRpc.ondisconnect = proc() = asyncSpawn onDisconnect() - let memberCount = cast[float64](await wakuRlnContract.commitmentIndex().call()) - waku_rln_number_registered_memberships.set(memberCount) - g.initialized = true return ok() diff --git a/waku/waku_rln_relay/protocol_metrics.nim b/waku/waku_rln_relay/protocol_metrics.nim index 52a107772..54958f3e3 100644 --- a/waku/waku_rln_relay/protocol_metrics.nim +++ b/waku/waku_rln_relay/protocol_metrics.nim @@ -120,5 +120,6 @@ proc getRlnMetricsLogger*(): RLNMetricsLogger = info "Total proofs verified", count = freshProofsVerifiedCount info "Total proofs generated", count = freshProofsGeneratedCount info "Total proofs remaining", count = freshProofsRemainingCount + info "Total registered member", count = freshRegisteredMemberCount return logMetrics