feat: add peer count to logs (#4648)

2024-01-30 12:42:26 -04:00 · 2024-01-30 12:42:26 -04:00 · e2341248b3
parent 1f0fc2935c
commit e2341248b3
1 changed files with 2 additions and 1 deletions
--- 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
 				}