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 d1b94093e..107e02dcd 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 @@ -581,7 +581,9 @@ method init*(g: OnchainGroupManager): Future[GroupManagerResult[void]] {.async.} ethRpc.ondisconnect = proc() = asyncSpawn onDisconnect() - waku_rln_number_registered_memberships.set(int64(g.rlnInstance.leavesSet())) + 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 121727809..52a107772 100644 --- a/waku/waku_rln_relay/protocol_metrics.nim +++ b/waku/waku_rln_relay/protocol_metrics.nim @@ -85,6 +85,7 @@ proc getRlnMetricsLogger*(): RLNMetricsLogger = var cumulativeProofsVerified = 0.float64 var cumulativeProofsGenerated = 0.float64 var cumulativeProofsRemaining = 100.float64 + var cumulativeRegisteredMember = 0.float64 when defined(metrics): logMetrics = proc() = @@ -107,6 +108,9 @@ proc getRlnMetricsLogger*(): RLNMetricsLogger = let freshProofsRemainingCount = parseAndAccumulate( waku_rln_remaining_proofs_per_epoch, cumulativeProofsRemaining ) + let freshRegisteredMemberCount = parseAndAccumulate( + waku_rln_number_registered_memberships, cumulativeRegisteredMember + ) info "Total messages", count = freshMsgCount info "Total spam messages", count = freshSpamCount