diff --git a/waku/discovery/waku_discv5.nim b/waku/discovery/waku_discv5.nim index 75e15b9d7..5841b5685 100644 --- a/waku/discovery/waku_discv5.nim +++ b/waku/discovery/waku_discv5.nim @@ -211,6 +211,8 @@ proc findRandomPeers*( elif wd.predicate.isSome(): discoveredRecords = discoveredRecords.filter(wd.predicate.get()) + waku_discv5_discovered.inc(discoveredRecords.len) + return discoveredRecords proc searchLoop(wd: WakuDiscoveryV5) {.async.} = @@ -233,6 +235,7 @@ proc searchLoop(wd: WakuDiscoveryV5) {.async.} = let peerInfo = record.toRemotePeerInfo().valueOr: ## in case of error, we keep track of it for debugging purposes wrongRecordsReasons.add(($record, $error)) + waku_discv5_errors.inc(labelValues = [$error]) continue discoveredPeers.add(peerInfo) diff --git a/waku/node/peer_manager/peer_manager.nim b/waku/node/peer_manager/peer_manager.nim index f4ef5e1bb..9c5c31df1 100644 --- a/waku/node/peer_manager/peer_manager.nim +++ b/waku/node/peer_manager/peer_manager.nim @@ -36,6 +36,7 @@ declarePublicGauge waku_streams_peers, declarePublicGauge waku_peer_store_size, "Number of peers managed by the peer store" declarePublicGauge waku_service_peers, "Service peer protocol and multiaddress ", labels = ["protocol", "peerId"] +declarePublicGauge waku_total_unique_peers, "total number of unique peers" logScope: topics = "waku node peer_manager" @@ -141,6 +142,8 @@ proc addPeer*( trace "Adding peer to manager", peerId = remotePeerInfo.peerId, addresses = remotePeerInfo.addrs + waku_total_unique_peers.inc() + pm.peerStore[AddressBook][remotePeerInfo.peerId] = remotePeerInfo.addrs pm.peerStore[KeyBook][remotePeerInfo.peerId] = remotePeerInfo.publicKey pm.peerStore[SourceBook][remotePeerInfo.peerId] = origin