From e2341248b3e0837e2e2afac59869472be220fab7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?rich=CE=9Brd?= Date: Tue, 30 Jan 2024 12:42:26 -0400 Subject: [PATCH] feat: add peer count to logs (#4648) --- wakuv2/waku.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/wakuv2/waku.go b/wakuv2/waku.go index bc28228cc..f99e10222 100644 --- a/wakuv2/waku.go +++ b/wakuv2/waku.go @@ -1020,7 +1020,8 @@ func (w *Waku) broadcast() { } } else { fn = func(env *protocol.Envelope, logger *zap.Logger) error { - logger.Info("publishing message via relay") + peerCnt := len(w.node.Relay().PubSub().ListPeers(env.PubsubTopic())) + logger.Info("publishing message via relay", zap.Int("peerCnt", peerCnt)) _, err := w.node.Relay().Publish(w.ctx, env.Message(), relay.WithPubSubTopic(env.PubsubTopic())) return err }